docker

Documentation

Overview

Package docker implements the Scheduler interface backed by the Docker API.

Index

• Constants
• type AttachedScheduler
  • func RunAttachedWithDocker(s scheduler.Scheduler, client *dockerutil.Client) *AttachedScheduler
  • func (s *AttachedScheduler) Instances(ctx context.Context, app string) ([]*scheduler.Instance, error)
  • func (s *AttachedScheduler) Run(ctx context.Context, app *scheduler.App, process *scheduler.Process, ...) error
  • func (s *AttachedScheduler) Stop(ctx context.Context, maybeContainerID string) error
• type Scheduler
  • func NewScheduler(client *dockerutil.Client) *Scheduler
  • func (s *Scheduler) Instances(ctx context.Context, app string) ([]*scheduler.Instance, error)
  • func (s *Scheduler) InstancesFromAttachedRuns(ctx context.Context, app string) ([]*scheduler.Instance, error)
  • func (s *Scheduler) Run(ctx context.Context, app *scheduler.App, p *scheduler.Process, in io.Reader, ...) error
  • func (s *Scheduler) Stop(ctx context.Context, containerID string) error

Constants

const (
	Attached = "attached"
	Detached = "detached"
)

Values for `runLabel`.

Types

type AttachedScheduler

type AttachedScheduler struct {
	// If set, attached run instances will be merged in with instances
	// returned from the wrapped scheduler. This is currently an
	// experimental feature, since it requires that multiple Empire
	// processes interact with a single Docker daemon.
	ShowAttached bool

	scheduler.Scheduler
	// contains filtered or unexported fields
}

AttachedScheduler wraps a Scheduler to run attached processes using the Docker scheduler.

func RunAttachedWithDocker

func RunAttachedWithDocker(s scheduler.Scheduler, client *dockerutil.Client) *AttachedScheduler

RunAttachedWithDocker wraps a Scheduler to run attached Run's using a Docker client.

func (*AttachedScheduler) Instances

func (s *AttachedScheduler) Instances(ctx context.Context, app string) ([]*scheduler.Instance, error)

Instances returns a combination of instances from the wrapped scheduler, as well as instances from attached runs.

func (*AttachedScheduler) Run

func (s *AttachedScheduler) Run(ctx context.Context, app *scheduler.App, process *scheduler.Process, in io.Reader, out io.Writer) error

Run runs attached processes using the docker scheduler, and detached processes using the wrapped scheduler.

func (*AttachedScheduler) Stop

func (s *AttachedScheduler) Stop(ctx context.Context, maybeContainerID string) error

Stop checks if there's an attached run matching the given id, and stops that container if there is. Otherwise, it delegates to the wrapped Scheduler.

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

Scheduler provides an implementation of the scheduler.Scheduler interface backed by Docker.

func NewScheduler

func NewScheduler(client *dockerutil.Client) *Scheduler

NewScheduler returns a new Scheduler instance that uses the given client to interact with Docker.

func (*Scheduler) Instances

func (s *Scheduler) Instances(ctx context.Context, app string) ([]*scheduler.Instance, error)

func (*Scheduler) InstancesFromAttachedRuns

func (s *Scheduler) InstancesFromAttachedRuns(ctx context.Context, app string) ([]*scheduler.Instance, error)

InstancesFromAttachedRuns returns Instances that were started from attached runs.

func (*Scheduler) Run

func (s *Scheduler) Run(ctx context.Context, app *scheduler.App, p *scheduler.Process, in io.Reader, out io.Writer) error

func (*Scheduler) Stop

func (s *Scheduler) Stop(ctx context.Context, containerID string) error

Stop stops the given container.