docker

package
v0.0.0-...-5bae4c0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 2, 2023 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Byte     = 1
	Kilobyte = 1024 * Byte
	Megabyte = 1024 * Kilobyte
)

Variables

This section is empty.

Functions

func NewClient

func NewClient(instance *types.Instance, proxyHost string) (*client.Client, error)

func NewDocker

func NewDocker(c *client.Client) *docker

func NewLocalCachedFactory

func NewLocalCachedFactory(s storage.StorageApi) *localCachedFactory

Types

type CreateContainerOpts

type CreateContainerOpts struct {
	Image          string
	SessionId      string
	ContainerName  string
	Hostname       string
	ServerCert     []byte
	ServerKey      []byte
	CACert         []byte
	Privileged     bool
	HostFQDN       string
	Labels         map[string]string
	Networks       []string
	DindVolumeSize string
	Envs           []string
}

type DockerApi

type DockerApi interface {
	GetClient() *client.Client

	NetworkCreate(id string, opts types.NetworkCreate) error
	NetworkConnect(container, network, ip string) (string, error)
	NetworkInspect(id string) (types.NetworkResource, error)
	NetworkDelete(id string) error
	NetworkDisconnect(containerId, networkId string) error

	DaemonInfo() (types.Info, error)
	DaemonHost() string

	GetSwarmPorts() ([]string, []uint16, error)
	GetPorts() ([]uint16, error)

	ContainerStats(name string) (io.ReadCloser, error)
	ContainerResize(name string, rows, cols uint) error
	ContainerRename(old, new string) error
	ContainerDelete(name string) error
	ContainerCreate(opts CreateContainerOpts) error
	ContainerIPs(id string) (map[string]string, error)
	ExecAttach(instanceName string, command []string, out io.Writer) (int, error)
	Exec(instanceName string, command []string) (int, error)

	CreateAttachConnection(name string) (net.Conn, error)
	CopyToContainer(containerName, destination, fileName string, content io.Reader) error
	CopyFromContainer(containerName, filePath string) (io.Reader, error)
	SwarmInit(advertiseAddr string) (*SwarmTokens, error)
	SwarmJoin(addr, token string) error

	ConfigCreate(name string, labels map[string]string, data []byte) error
	ConfigDelete(name string) error
}

type FactoryApi

type FactoryApi interface {
	GetForSession(session *types.Session) (DockerApi, error)
	GetForInstance(instance *types.Instance) (DockerApi, error)
}

type FactoryMock

type FactoryMock struct {
	mock.Mock
}

func (*FactoryMock) GetForInstance

func (m *FactoryMock) GetForInstance(instance *types.Instance) (DockerApi, error)

func (*FactoryMock) GetForSession

func (m *FactoryMock) GetForSession(session *types.Session) (DockerApi, error)

type Mock

type Mock struct {
	mock.Mock
}

func (*Mock) ConfigCreate

func (m *Mock) ConfigCreate(name string, labels map[string]string, data []byte) error

func (*Mock) ConfigDelete

func (m *Mock) ConfigDelete(name string) error

func (*Mock) ContainerCreate

func (m *Mock) ContainerCreate(opts CreateContainerOpts) error

func (*Mock) ContainerDelete

func (m *Mock) ContainerDelete(id string) error

func (*Mock) ContainerIPs

func (m *Mock) ContainerIPs(id string) (map[string]string, error)

func (*Mock) ContainerRename

func (m *Mock) ContainerRename(old, new string) error

func (*Mock) ContainerResize

func (m *Mock) ContainerResize(name string, rows, cols uint) error

func (*Mock) ContainerStats

func (m *Mock) ContainerStats(name string) (io.ReadCloser, error)

func (*Mock) CopyFromContainer

func (m *Mock) CopyFromContainer(containerName, filePath string) (io.Reader, error)

func (*Mock) CopyToContainer

func (m *Mock) CopyToContainer(containerName, destination, fileName string, content io.Reader) error

func (*Mock) CreateAttachConnection

func (m *Mock) CreateAttachConnection(name string) (net.Conn, error)

func (*Mock) DaemonHost

func (m *Mock) DaemonHost() string

func (*Mock) DaemonInfo

func (m *Mock) DaemonInfo() (types.Info, error)

func (*Mock) Exec

func (m *Mock) Exec(instanceName string, command []string) (int, error)

func (*Mock) ExecAttach

func (m *Mock) ExecAttach(instanceName string, command []string, out io.Writer) (int, error)

func (*Mock) GetClient

func (m *Mock) GetClient() *client.Client

func (*Mock) GetPorts

func (m *Mock) GetPorts() ([]uint16, error)

func (*Mock) GetSwarmPorts

func (m *Mock) GetSwarmPorts() ([]string, []uint16, error)

func (*Mock) NetworkConnect

func (m *Mock) NetworkConnect(container, network, ip string) (string, error)

func (*Mock) NetworkCreate

func (m *Mock) NetworkCreate(id string, opts types.NetworkCreate) error

func (*Mock) NetworkDelete

func (m *Mock) NetworkDelete(id string) error

func (*Mock) NetworkDisconnect

func (m *Mock) NetworkDisconnect(containerId, networkId string) error

func (*Mock) NetworkInspect

func (m *Mock) NetworkInspect(id string) (types.NetworkResource, error)

func (*Mock) SwarmInit

func (m *Mock) SwarmInit(advertiseAddr string) (*SwarmTokens, error)

func (*Mock) SwarmJoin

func (m *Mock) SwarmJoin(addr, token string) error

type MockConn

type MockConn struct {
}

func (*MockConn) Close

func (m *MockConn) Close() error

func (*MockConn) LocalAddr

func (m *MockConn) LocalAddr() net.Addr

func (*MockConn) Read

func (m *MockConn) Read(b []byte) (n int, err error)

func (*MockConn) RemoteAddr

func (m *MockConn) RemoteAddr() net.Addr

func (*MockConn) SetDeadline

func (m *MockConn) SetDeadline(t time.Time) error

func (*MockConn) SetReadDeadline

func (m *MockConn) SetReadDeadline(t time.Time) error

func (*MockConn) SetWriteDeadline

func (m *MockConn) SetWriteDeadline(t time.Time) error

func (*MockConn) Write

func (m *MockConn) Write(b []byte) (n int, err error)

type SwarmTokens

type SwarmTokens struct {
	Manager string
	Worker  string
}

Jump to

Keyboard shortcuts

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