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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.