Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPRepository ¶
type AMQPRepository interface { GetChannel() (externals.AMQPChannel, error) RejectDelivery(msg externals.AMQPDelivery, requeue bool) error }
AMQPRepository represents functions for connecting to a AMQP provider
func NewAMQPRepository ¶
func NewAMQPRepository(conn externals.AMQPConnection) AMQPRepository
NewAMQPRepository creates a new AMQPRepository
type DockerRepository ¶
type DockerRepository interface { //ContainerAttach attaches to a container ContainerAttach(ctx context.Context, cli entity.Client, container string, options types.ContainerAttachOptions) (types.HijackedResponse, error) //ContainerCreate creates a new container based in the given configuration. It can be associated with a name, but it's not mandatory. ContainerCreate(ctx context.Context, cli entity.Client, config *container.Config, hostConfig *container.HostConfig, networkingConfig *network.NetworkingConfig, containerName string) (container.ContainerCreateCreatedBody, error) //ContainerList returns the list of containers in the docker host. ContainerList(ctx context.Context, cli entity.Client, options types.ContainerListOptions) ([]types.Container, error) //ContainerRemove kills and removes a container from the docker host. ContainerRemove(ctx context.Context, cli entity.Client, containerID string, options types.ContainerRemoveOptions) error //ContainerStart sends a request to the docker daemon to start a container. ContainerStart(ctx context.Context, cli entity.Client, containerID string, options types.ContainerStartOptions) error //CopyToContainer copies content into the container filesystem. Note that `content` must be a Reader for a TAR archive CopyToContainer(ctx context.Context, cli entity.Client, containerID, dstPath string, content io.Reader, options types.CopyToContainerOptions) error //ImageList returns a list of images in the docker host ImageList(ctx context.Context, cli entity.Client, options types.ImageListOptions) ([]types.ImageSummary, error) //ImageLoad is used to upload a docker image ImageLoad(ctx context.Context, cli entity.Client, input io.Reader, quiet bool) (types.ImageLoadResponse, error) //ImagePull is used to pull a docker image ImagePull(ctx context.Context, cli entity.Client, refStr string, options types.ImagePullOptions) (io.ReadCloser, error) //NetworkCreate sends a request to the docker daemon to create a network NetworkCreate(ctx context.Context, cli entity.Client, name string, options types.NetworkCreate) (types.NetworkCreateResponse, error) //NetworkConnect connects a container to an existent network in the docker host. NetworkConnect(ctx context.Context, cli entity.Client, networkID, containerID string, config *network.EndpointSettings) error //NetworkDisconnect disconnects a container from an existent network in the docker host. NetworkDisconnect(ctx context.Context, cli entity.Client, networkID, containerID string, force bool) error //NetworkRemove sends a request to the docker daemon to remove a network NetworkRemove(ctx context.Context, cli entity.Client, networkID string) error //NetworkList lists the networks known to the docker daemon NetworkList(ctx context.Context, cli entity.Client, options types.NetworkListOptions) ([]types.NetworkResource, error) //VolumeList returns the volumes configured in the docker host. VolumeList(ctx context.Context, cli entity.Client, filter filters.Args) (volume.VolumeListOKBody, error) //VolumeRemove removes a volume from the docker host. VolumeRemove(ctx context.Context, cli entity.Client, volumeID string, force bool) error //VolumeCreate creates a volume in the container VolumeCreate(ctx context.Context, cli entity.Client, options volume.VolumeCreateBody) (types.Volume, error) }
DockerRepository represents direct interacts with the docker daemon
func NewDockerRepository ¶
func NewDockerRepository() DockerRepository
NewDockerRepository creates a new DockerRepository
Click to show internal directories.
Click to hide internal directories.