engine

package

Go to main page

Versions in this module

v1

v1.4.0

Aug 12, 2015

v1.3.1

Jul 30, 2015

v1.3.0

Jul 6, 2015

v1.2.1

Jun 19, 2015

v1.2.0

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

v1.1.0

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

v1.0.0

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)

v0

v0.0.3

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL