orchestrator

Jan 11, 2024

Changes in this version

type DockerEngine

+ ContainerExitCode func(ctx context.Context, containerName string) (int, error)

+ IsContainerHealthy func(ctx context.Context, containerName string) (bool, error)

+ Rm func(context.Context, string) error

Dec 13, 2023

Changes in this version

type ContainerDefinition

+ DependsOn map[string]string

+ IsEssential bool

type DockerEngine

+ DoesContainerExist func(context.Context, string) (bool, error)

Nov 9, 2023

Changes in this version

+ type ContainerDefinition struct

+ EnvVars map[string]string

+ ImageURI string

+ Ports map[string]string

+ Secrets map[string]string

+ type DockerEngine interface

+ Build func(ctx context.Context, args *dockerengine.BuildArguments, w io.Writer) error

+ Exec func(ctx context.Context, container string, out io.Writer, cmd string, ...) error

+ IsContainerRunning func(context.Context, string) (bool, error)

+ Run func(context.Context, *dockerengine.RunOptions) error

+ Stop func(context.Context, string) error

+ type Host struct

+ Name string

+ Port uint16

+ type Orchestrator struct

+ func New(docker DockerEngine, idPrefix string, logOptions logOptionsFunc) *Orchestrator

+ func (o *Orchestrator) RunTask(task Task, opts ...RunTaskOption)

+ func (o *Orchestrator) Start() <-chan error

+ func (o *Orchestrator) Stop()

+ type RunTaskOption func(*runTaskAction)

+ func RunTaskWithProxy(ssmTarget string, network net.IPNet, hosts ...Host) RunTaskOption

+ type Task struct

+ Containers map[string]ContainerDefinition

+ PauseSecrets map[string]string