engine

package

Go to main page

Versions in this module

v1

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