revise container status stream API

cluster/calcium/status.go

@@ -24,7 +24,7 @@ func (c *Calcium) SetContainersStatus(ctx context.Context, status map[string][]b
 	return nil
 }
 
-// DeployStatusStream watch deploy status
-func (c *Calcium) DeployStatusStream(ctx context.Context, appname, entrypoint, nodename string) chan *types.DeployStatus {
-	return c.store.WatchDeployStatus(ctx, appname, entrypoint, nodename)
+// ContainerStatusStream stream container status
+func (c *Calcium) ContainerStatusStream(ctx context.Context, appname, entrypoint, nodename string, labels map[string]string) chan *types.ContainerStatus {
+	return c.store.ContainerStatusStream(ctx, appname, entrypoint, nodename, labels)
 }

cluster/cluster.go

@@ -74,15 +74,14 @@ type Cluster interface {
 	ListContainers(ctx context.Context, opts *types.ListContainersOptions) ([]*types.Container, error)
 	ListNodeContainers(ctx context.Context, nodename string) ([]*types.Container, error)
 	SetContainersStatus(ctx context.Context, status map[string][]byte, ttls map[string]int64) error
+	ContainerStatusStream(ctx context.Context, appname, entrypoint, nodename string, labels map[string]string) chan *types.ContainerStatus
 	// cluster methods
 	Copy(ctx context.Context, opts *types.CopyOptions) (chan *types.CopyMessage, error)
 	Send(ctx context.Context, opts *types.SendOptions) (chan *types.SendMessage, error)
 	// image methods
 	BuildImage(ctx context.Context, opts *enginetypes.BuildOptions) (chan *types.BuildImageMessage, error)
 	CacheImage(ctx context.Context, podname, nodenmae string, images []string, step int) (chan *types.CacheImageMessage, error)
 	RemoveImage(ctx context.Context, podname, nodename string, images []string, step int, prune bool) (chan *types.RemoveImageMessage, error)
-	// for watch
-	DeployStatusStream(ctx context.Context, appname, entrypoint, nodename string) chan *types.DeployStatus
 	// container methods
 	CreateContainer(ctx context.Context, opts *types.DeployOptions) (chan *types.CreateContainerMessage, error)
 	ReplaceContainer(ctx context.Context, opts *types.ReplaceOptions) (chan *types.ReplaceContainerMessage, error)