worker

Aug 29, 2022

Changes in this version

+ type ContainerManager interface

+ CreateContainer func(ctx context.Context, cmd []string, wfID string, action *pb.WorkflowAction, ...) (string, error)

+ PullImage func(ctx context.Context, image string) error

+ RemoveContainer func(ctx context.Context, id string) error

+ StartContainer func(ctx context.Context, id string) error

+ WaitForContainer func(ctx context.Context, id string) (pb.State, error)

+ WaitForFailedContainer func(ctx context.Context, id string, failedActionStatus chan pb.State)

+ func NewContainerManager(logger log.Logger, cli DockerClient, registryDetails RegistryConnDetails) ContainerManager

+ type DockerClient interface

+ type DockerLogCapturer struct

+ func NewDockerLogCapturer(cli client.ContainerAPIClient, logger log.Logger, writer io.Writer) *DockerLogCapturer

+ func (l *DockerLogCapturer) CaptureLogs(ctx context.Context, id string)

+ type ImagePullStatus struct

+ Error string

+ Progress string

+ ProgressDetail struct{ ... }

+ Status string

+ type LogCapturer interface

+ CaptureLogs func(ctx context.Context, containerID string)

+ type Option func(*Worker)

+ func WithDataDir(dir string) Option

+ func WithLogCapture(capture bool) Option

+ func WithMaxFileSize(maxSize int64) Option

+ func WithPrivileged(privileged bool) Option

+ func WithRetries(interval time.Duration, retries int) Option

+ type RegistryConnDetails struct

+ Password string

+ Registry string

+ Username string

+ type Worker struct

+ func NewWorker(workerID string, tinkClient pb.WorkflowServiceClient, ...) *Worker

+ func (w *Worker) ProcessWorkflowActions(ctx context.Context) error

+ type WorkflowMetadata struct

+ Action string

+ SHA string

+ Task string

+ UpdatedAt time.Time

+ WorkerID string