worker

Documentation

Index

• Constants
• func Main(c *cli.Context) error
• type DeploymentMap
• type Worker
  • func (w *Worker) Delete(ctx context.Context, deploy *deployment.Deployment) error
  • func (w *Worker) Deploy(ctx context.Context, deploy *deployment.Deployment, imagePath string, ...) ([]containerd.Container, error)
  • func (w *Worker) SyncLocalContainerInfos(ctx context.Context)

Constants

const (
	ContainerdAddr  = "/run/containerd/containerd.sock"
	HuangNS         = "huang"
	DeploymentLabel = "deploy"
	SyncDuration    = 3
)

Functions

func Main

func Main(c *cli.Context) error

Types

type DeploymentMap

type DeploymentMap map[string][]containerd.Container

type Worker

type Worker struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Worker) Delete

func (w *Worker) Delete(ctx context.Context, deploy *deployment.Deployment) error

func (*Worker) Deploy

func (w *Worker) Deploy(ctx context.Context, deploy *deployment.Deployment, imagePath string, replica int) ([]containerd.Container, error)

Deploy deploy a deployment

func (*Worker) SyncLocalContainerInfos

func (w *Worker) SyncLocalContainerInfos(ctx context.Context)

SyncLocalContainerInfos sync local container infomation