engine

Feb 2, 2018

Changes in this version

type DockerContainerChangeEvent

+ Type api.DockerEventType

+ func (event *DockerContainerChangeEvent) String() string

type DockerContainerMetadata

+ CreatedAt time.Time

+ FinishedAt time.Time

+ Health api.HealthStatus

+ Labels map[string]string

+ StartedAt time.Time

Nov 22, 2017

Changes in this version

+ type CannotGetDockerClientVersionError struct

+ func (err CannotGetDockerClientVersionError) Error() string

+ func (err CannotGetDockerClientVersionError) ErrorName() string

type DockerClient

+ APIVersion func() (dockerclient.DockerVersion, error)

type MockDockerClient

+ func (_m *MockDockerClient) APIVersion() (dockerclient.DockerVersion, error)

Oct 31, 2017

Changes in this version

+ type InfiniteBuffer struct

+ func NewInfiniteBuffer() *InfiniteBuffer

+ func (buffer *InfiniteBuffer) Consume(in chan<- *docker.APIEvents)

+ func (buffer *InfiniteBuffer) CopyEvents(event *docker.APIEvents)

+ func (buffer *InfiniteBuffer) StartListening(events chan *docker.APIEvents)

Sep 30, 2017

Changes in this version

+ const LoadImageTimeout

type CannotPullECRContainerError

+ func (err CannotPullECRContainerError) Retry() bool

+ type ContainerNetworkingError struct

+ func (err ContainerNetworkingError) Error() string

+ func (err ContainerNetworkingError) ErrorName() string

+ type CreateEmptyVolumeError struct

+ func (err CreateEmptyVolumeError) Error() string

+ func (err CreateEmptyVolumeError) ErrorName() string

+ func (err CreateEmptyVolumeError) Retry() bool

type DockerClient

+ ImportLocalEmptyVolumeImage func() DockerContainerMetadata

+ LoadImage func(io.Reader, time.Duration) error

type MockDockerClient

+ func (_m *MockDockerClient) ImportLocalEmptyVolumeImage() DockerContainerMetadata

+ func (_m *MockDockerClient) LoadImage(_param0 io.Reader, _param1 time.Duration) error

Aug 22, 2017

Changes in this version

type CannotStopContainerError

+ func (err CannotStopContainerError) IsRetriableError() bool

type DockerClient

+ KnownVersions func() []dockerclient.DockerVersion

type MockDockerClient

+ func (_m *MockDockerClient) KnownVersions() []dockerclient.DockerVersion

May 26, 2017

Changes in this version

type DockerTaskEngine

+ func (engine *DockerTaskEngine) StateChangeEvents() <-chan statechange.Event

type MockTaskEngine

+ func (_m *MockTaskEngine) StateChangeEvents() <-chan statechange.Event

+ type TaskDependencyError struct

+ func (err TaskDependencyError) Error() string

+ func (err TaskDependencyError) ErrorName() string

type TaskEngine

+ StateChangeEvents func() <-chan statechange.Event

Mar 6, 2017

Changes in this version

+ const StatsInactivityTimeout

Jan 18, 2017

Changes in this version

+ type CannotCreateContainerError struct

+ func (err CannotCreateContainerError) Error() string

+ func (err CannotCreateContainerError) ErrorName() string

+ type CannotDescribeContainerError struct

+ func (err CannotDescribeContainerError) Error() string

+ func (err CannotDescribeContainerError) ErrorName() string

+ type CannotInspectContainerError struct

+ func (err CannotInspectContainerError) Error() string

+ func (err CannotInspectContainerError) ErrorName() string

+ type CannotListContainersError struct

+ func (err CannotListContainersError) Error() string

+ func (err CannotListContainersError) ErrorName() string

+ type CannotPullContainerError struct

+ func (err CannotPullContainerError) Error() string

+ func (err CannotPullContainerError) ErrorName() string

+ type CannotPullECRContainerError struct

+ func (err CannotPullECRContainerError) Error() string

+ func (err CannotPullECRContainerError) ErrorName() string

+ type CannotRemoveContainerError struct

+ func (err CannotRemoveContainerError) Error() string

+ func (err CannotRemoveContainerError) ErrorName() string

+ type CannotStartContainerError struct

+ func (err CannotStartContainerError) Error() string

+ func (err CannotStartContainerError) ErrorName() string

+ type CannotStopContainerError struct

+ func (err CannotStopContainerError) Error() string

+ func (err CannotStopContainerError) ErrorName() string

+ func (err CannotStopContainerError) IsUnretriableError() bool

Nov 16, 2016

Changes in this version

+ const DockerDefaultEndpoint

+ const DockerEndpointEnvVariable

+ const ListContainersTimeout

type DockerContainerMetadata

+ DockerID string

type ImageManager

+ RecordContainerReference func(container *api.Container) error

type ListContainersResponse

+ DockerIDs []string

type MockImageManager

+ func (_m *MockImageManager) RecordContainerReference(_param0 *api.Container) error

Sep 28, 2016

Changes in this version

+ var ImagePullDeleteLock sync.Mutex

type DockerClient

+ InspectImage func(string) (*docker.Image, error)

+ RemoveImage func(string, time.Duration) error

+ type ImageManager interface

+ AddAllImageStates func(imageStates []*image.ImageState)

+ AddContainerReferenceToImageState func(container *api.Container) error

+ GetImageStateFromImageName func(containerImageName string) *image.ImageState

+ RemoveContainerReferenceFromImageState func(container *api.Container) error

+ SetSaver func(stateManager statemanager.Saver)

+ StartImageCleanupProcess func(ctx context.Context)

+ func NewImageManager(cfg *config.Config, client DockerClient, ...) ImageManager

+ type ImageStatesForDeletion []*image.ImageState

+ func (imageStates ImageStatesForDeletion) Len() int

+ func (imageStates ImageStatesForDeletion) Less(i, j int) bool

+ func (imageStates ImageStatesForDeletion) Swap(i, j int)

type MockDockerClient

+ func (_m *MockDockerClient) InspectImage(_param0 string) (*go_dockerclient.Image, error)

+ func (_m *MockDockerClient) RemoveImage(_param0 string, _param1 time.Duration) error

+ type MockImageManager struct

+ func NewMockImageManager(ctrl *gomock.Controller) *MockImageManager

+ func (_m *MockImageManager) AddAllImageStates(_param0 []*image.ImageState)

+ func (_m *MockImageManager) AddContainerReferenceToImageState(_param0 *api.Container) error

+ func (_m *MockImageManager) EXPECT() *_MockImageManagerRecorder

+ func (_m *MockImageManager) GetImageStateFromImageName(_param0 string) *image.ImageState

+ func (_m *MockImageManager) RemoveContainerReferenceFromImageState(_param0 *api.Container) error

+ func (_m *MockImageManager) SetSaver(_param0 statemanager.Saver)

+ func (_m *MockImageManager) StartImageCleanupProcess(_param0 context.Context)

+ type TaskStoppedBeforePullBeginError struct

+ func (TaskStoppedBeforePullBeginError) ErrorName() string

+ func (err TaskStoppedBeforePullBeginError) Error() string

May 25, 2016

Changes in this version

type DockerClient

+ Stats func(string, context.Context) (<-chan *docker.Stats, error)

type MockDockerClient

+ func (_m *MockDockerClient) Stats(_param0 string, _param1 context.Context) (<-chan *go_dockerclient.Stats, error)

Apr 1, 2016

Changes in this version

type DockerTaskEngine

+ func (engine *DockerTaskEngine) GetTaskByArn(arn string) (*api.Task, bool)

type MockTaskEngine

+ func (_m *MockTaskEngine) GetTaskByArn(_param0 string) (*api.Task, bool)

type TaskEngine

+ GetTaskByArn func(string) (*api.Task, bool)

Dec 9, 2015

Changes in this version

+ type MockDockerClient struct

+ func NewMockDockerClient(ctrl *gomock.Controller) *MockDockerClient

+ func (_m *MockDockerClient) ContainerEvents(_param0 context.Context) (<-chan DockerContainerChangeEvent, error)

+ func (_m *MockDockerClient) CreateContainer(_param0 *go_dockerclient.Config, _param1 *go_dockerclient.HostConfig, ...) DockerContainerMetadata

+ func (_m *MockDockerClient) DescribeContainer(_param0 string) (api.ContainerStatus, DockerContainerMetadata)

+ func (_m *MockDockerClient) EXPECT() *_MockDockerClientRecorder

+ func (_m *MockDockerClient) GetContainerName(_param0 string) (string, error)

+ func (_m *MockDockerClient) InspectContainer(_param0 string) (*go_dockerclient.Container, error)

+ func (_m *MockDockerClient) ListContainers(_param0 bool) ListContainersResponse

+ func (_m *MockDockerClient) PullImage(_param0 string, _param1 *api.RegistryAuthenticationData) DockerContainerMetadata

+ func (_m *MockDockerClient) RemoveContainer(_param0 string) error

+ func (_m *MockDockerClient) StartContainer(_param0 string) DockerContainerMetadata

+ func (_m *MockDockerClient) StopContainer(_param0 string) DockerContainerMetadata

+ func (_m *MockDockerClient) SupportedVersions() []dockerclient.DockerVersion

+ func (_m *MockDockerClient) Version() (string, error)

+ func (_m *MockDockerClient) WithVersion(_param0 dockerclient.DockerVersion) DockerClient

+ type MockTaskEngine struct

+ func NewMockTaskEngine(ctrl *gomock.Controller) *MockTaskEngine

+ func (_m *MockTaskEngine) AddTask(_param0 *api.Task) error

+ func (_m *MockTaskEngine) Capabilities() []string

+ func (_m *MockTaskEngine) Disable()

+ func (_m *MockTaskEngine) EXPECT() *_MockTaskEngineRecorder

+ func (_m *MockTaskEngine) Init() error

+ func (_m *MockTaskEngine) ListTasks() ([]*api.Task, error)

+ func (_m *MockTaskEngine) MarshalJSON() ([]byte, error)

+ func (_m *MockTaskEngine) MustInit()

+ func (_m *MockTaskEngine) SetSaver(_param0 statemanager.Saver)

+ func (_m *MockTaskEngine) TaskEvents() (<-chan api.TaskStateChange, <-chan api.ContainerStateChange)

+ func (_m *MockTaskEngine) UnmarshalJSON(_param0 []byte) error

+ func (_m *MockTaskEngine) Version() (string, error)

Sep 29, 2015

Changes in this version

+ type CannotGetDockerClientError struct

+ func (CannotGetDockerClientError) ErrorName() string

+ func (c CannotGetDockerClientError) Error() string

type DockerClient

+ SupportedVersions func() []dockerclient.DockerVersion

+ WithVersion func(dockerclient.DockerVersion) DockerClient

type DockerGoClient

+ func (dg *DockerGoClient) SupportedVersions() []dockerclient.DockerVersion

+ func (dg *DockerGoClient) WithVersion(version dockerclient.DockerVersion) DockerClient

type DockerTaskEngine

+ func (engine *DockerTaskEngine) Capabilities() []string

type TaskEngine

+ Capabilities func() []string

Jun 9, 2015

Changes in this version

type DockerClient

+ ListContainers func(bool) ListContainersResponse

type DockerGoClient

+ func (dg *DockerGoClient) ListContainers(all bool) ListContainersResponse

+ type ListContainersResponse struct

+ DockerIds []string

+ Error error

May 6, 2015

Changes in this version

+ type CannotXContainerError struct

+ func (err CannotXContainerError) Error() string

+ func (err CannotXContainerError) ErrorName() string

+ type ContainerVanishedError struct

+ func (err ContainerVanishedError) Error() string

+ func (err ContainerVanishedError) ErrorName() string

+ type DockerContainerMetadata struct

+ DockerId string

+ Error error

+ ExitCode *int

+ PortBindings []api.PortBinding

+ Volumes map[string]string

type DockerGoClient

+ func (dg *DockerGoClient) SetGoDockerClient(to dockerclient.Client)

+ type DockerStateError struct

+ func NewDockerStateError(err string) DockerStateError

+ func (err DockerStateError) Error() string

+ func (err DockerStateError) ErrorName() string

type DockerTaskEngine

+ func (engine *DockerTaskEngine) CheckTaskState(task *api.Task)

+ func (engine *DockerTaskEngine) SetDockerClient(client DockerClient)

+ func (engine *DockerTaskEngine) Shutdown()

+ type DockerTimeoutError struct

+ func (err *DockerTimeoutError) Error() string

+ func (err *DockerTimeoutError) ErrorName() string

+ type OutOfMemoryError struct

+ func (err OutOfMemoryError) Error() string

+ func (err OutOfMemoryError) ErrorName() string

Apr 3, 2015

Changes in this version

type DockerClient

+ Version func() (string, error)

type DockerGoClient

+ func (dg *DockerGoClient) Version() (string, error)

type DockerTaskEngine

+ func (engine *DockerTaskEngine) Disable()

+ func (engine *DockerTaskEngine) Version() (string, error)

type TaskEngine

+ Disable func()

+ Version func() (string, error)

Feb 19, 2015

Changes in this version

+ const DEFAULT_TIMEOUT_SECONDS

+ const DOCKER_DEFAULT_ENDPOINT

+ const DOCKER_ENDPOINT_ENV_VARIABLE

+ func TaskCompleted(task *api.Task) bool

+ type ContainerNotFound struct

+ ContainerName string

+ TaskArn string

+ func (cnferror ContainerNotFound) Error() string

+ type DockerClient interface

+ ContainerEvents func() (<-chan DockerContainerChangeEvent, error)

+ CreateContainer func(*docker.Config, string) (string, error)

+ DescribeContainer func(string) (api.ContainerStatus, error)

+ GetContainerName func(string) (string, error)

+ InspectContainer func(string) (*docker.Container, error)

+ PullImage func(image string) error

+ RemoveContainer func(string) error

+ StartContainer func(string, *docker.HostConfig) error

+ StopContainer func(string) error

+ type DockerContainerChangeEvent struct

+ DockerId string

+ Image string

+ Status api.ContainerStatus

+ type DockerGoClient struct

+ func NewDockerGoClient() (*DockerGoClient, error)

+ func (dg *DockerGoClient) ContainerEvents() (<-chan DockerContainerChangeEvent, error)

+ func (dg *DockerGoClient) CreateContainer(config *docker.Config, name string) (string, error)

+ func (dg *DockerGoClient) DescribeContainer(dockerId string) (api.ContainerStatus, error)

+ func (dg *DockerGoClient) DescribeDockerImages() (string, error)

+ func (dg *DockerGoClient) GetContainerName(id string) (string, error)

+ func (dg *DockerGoClient) InspectContainer(dockerId string) (*docker.Container, error)

+ func (dg *DockerGoClient) PullImage(image string) error

+ func (dg *DockerGoClient) RemoveContainer(dockerId string) error

+ func (dg *DockerGoClient) StartContainer(id string, hostConfig *docker.HostConfig) error

+ func (dg *DockerGoClient) StopContainer(dockerId string) error

+ func (dg *DockerGoClient) StopContainerById(id string) error

+ type DockerImageResponse struct

+ Images []docker.APIImages

+ type DockerTaskEngine struct

+ func NewDockerTaskEngine(cfg *config.Config) *DockerTaskEngine

+ func (engine *DockerTaskEngine) AddTask(task *api.Task)

+ func (engine *DockerTaskEngine) ApplyContainerState(task *api.Task, container *api.Container)

+ func (engine *DockerTaskEngine) ApplyTaskState(task *api.Task)

+ func (engine *DockerTaskEngine) CreateContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) Init() error

+ func (engine *DockerTaskEngine) ListTasks() ([]*api.Task, error)

+ func (engine *DockerTaskEngine) MarshalJSON() ([]byte, error)

+ func (engine *DockerTaskEngine) MustInit()

+ func (engine *DockerTaskEngine) PullContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) RemoveContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) SetSaver(saver statemanager.Saver)

+ func (engine *DockerTaskEngine) StartContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) State() *dockerstate.DockerTaskEngineState

+ func (engine *DockerTaskEngine) StopContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) TaskEvents() <-chan api.ContainerStateChange

+ func (engine *DockerTaskEngine) UnmarshalJSON(data []byte) error

+ type TaskEngine interface

+ AddTask func(*api.Task)

+ Init func() error

+ ListTasks func() ([]*api.Task, error)

+ MarshalJSON func() ([]byte, error)

+ MustInit func()

+ SetSaver func(statemanager.Saver)

+ TaskEvents func() <-chan api.ContainerStateChange

+ UnmarshalJSON func([]byte) error

+ func NewTaskEngine(cfg *config.Config) TaskEngine