diff options
| author | kadisi <iamkadisi@163.com> | 2020-04-17 20:18:44 +0800 |
|---|---|---|
| committer | kadisi <iamkadisi@163.com> | 2020-04-30 18:41:47 +0800 |
| commit | e6ebaebc1ef2b59de19b8251d8a0b6914a915f26 (patch) | |
| tree | 6d09154c580555d77a1c58169b4d9223ac6bdef9 /edge/cmd | |
| parent | set stream server (diff) | |
| download | kubeedge-e6ebaebc1ef2b59de19b8251d8a0b6914a915f26.tar.gz | |
add edgestream
Signed-off-by: kadisi <iamkadisi@163.com>
Diffstat (limited to 'edge/cmd')
| -rw-r--r-- | edge/cmd/edgecore/app/server.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/edge/cmd/edgecore/app/server.go b/edge/cmd/edgecore/app/server.go index 6a26be05b..001d1372c 100644 --- a/edge/cmd/edgecore/app/server.go +++ b/edge/cmd/edgecore/app/server.go @@ -5,6 +5,8 @@ import ( "fmt" "os" + "github.com/kubeedge/kubeedge/edge/pkg/edgestream" + "github.com/mitchellh/go-ps" "github.com/spf13/cobra" "k8s.io/apiserver/pkg/util/term" @@ -152,6 +154,7 @@ func registerModules(c *v1alpha1.EdgeCoreConfig) { edgemesh.Register(c.Modules.EdgeMesh) metamanager.Register(c.Modules.MetaManager) servicebus.Register(c.Modules.ServiceBus) + edgestream.Register(c.Modules.EdgeStream, c.Modules.Edged.HostnameOverride) test.Register(c.Modules.DBTest) // Nodte: Need to put it to the end, and wait for all models to register before executing dbm.InitDBConfig(c.DataBase.DriverName, c.DataBase.AliasName, c.DataBase.DataSource) |