containers

type AddrsMap map[ports.PortName]string

type BaseContainer struct {
	Ctx          context.Context
	Ready        ReadyFunc
	OutputStream io.Writer
	ErrorStream  io.Writer

	Name       string
	TypeID     uint8
	Image      string
	EntryPoint string

	ContainerIP string

	Cmd       []string
	Mounts    []string
	Envs      []string
	Volumes   []string
	Sysctls   map[string]string
	DebugPort ports.DebugPort
	Ports     PortBinds

	StartTimeout time.Duration
	Autoremove   bool
	NotBindPorts bool
	Background   bool

	ConfController controllers.Controller
	// contains filtered or unexported fields
}

type Client interface {
	// WithStdout устанавливает кастомный поток стандартного вывода
	WithStdout(w io.Writer) Client
	// WithStderr устанавливает кастомный поток вывода ошибок
	WithStderr(w io.Writer) Client
	// IsInContainer - возвращает признак того что процесс сам запущен
	// внутри контейнера
	IsInContainer() bool
	// NetworkList возвращает список сетей
	NetworkList(ctx context.Context) ([]*net.IPNet, error)
	// NextSubnet возвращает адрес следующей незанятой подсети
	NextSubnet() (*net.IPNet, error)
	// RemoveNetwork удаляет пользовательскую сеть
	RemoveNetwork(id string) error
	// ContainerCreate создает контейнер
	ContainerCreate(ctx context.Context, data Container) (string, error)
	// ContainerStart запускает контейнер
	ContainerStart(ctx context.Context, id, name string) (*ContainerInfo, error)
	// ContainerWait ожидает завершения работы контейнера
	ContainerWait(ctx context.Context, id string) (<-chan ContainerStatus, <-chan error)
	// ContainerStop останавливает контейнер
	ContainerStop(ctx context.Context, id string, timeout time.Duration) error
	// StreamLogs подключает вывод логов контейнера
	StreamLogs(ctx context.Context, id string, stderr, stdout io.Writer, follow bool) error
	// CheckDockerNetwork проверяет существование докер сети и создает
	// ее в случае отсутствия
	CheckDockerNetwork(nw, cidr string) (Network, error)
}

type Container interface {
	// GetID возвращает идентификатор запущенного контейнера после его создания
	GetID() string
	// GetName возвращает имя контейнера
	GetName() string
	// GetImage возвращает образ
	GetImage() string
	// GetSysctls возвращает данные системных настроек контейнера
	GetSysctls() map[string]string
	// GetContainerIP возвращает внутренний IP адрес контейнера
	GetContainerIP() string
	// ContainerPorts возвращает список внутренних портов контейнера
	ContainerPorts() []Port
	// PortMap возвращает смапленные на хост порты
	PortMap() PortMap
	// GetEnvs возвращает список переменных окружения
	GetEnvs() []string
	// GetEntryPoint возвращает точку схода процесса контейнера
	GetEntryPoint() string
	// GetCmd возвращает команду контейнера
	GetCmd() []string
	// GetVolumes возвращает список разделов
	GetVolumes() []string
	// GetMounts возвращает список подключаемых разделов
	GetMounts() []string
	// GetAutoremove признак авто удаления контейнера после завершения работы
	GetAutoremove() bool
	// GetNetwork возвращает сеть контейнера
	GetNetwork() Network
	// CreateContainer - фаза создания контейнера
	CreateContainer() error
	// StartContainer - фаза старта контейнера
	StartContainer(sigCh <-chan os.Signal, ready chan<- struct{}) error
	// Stop - останавливает контейнер
	Stop() error
	// HostAddrs - возвращает мапу адресов контейнера на хосте
	HostAddrs() AddrsMap
	// ContainerAddrs - возвращает мапу адресов контейнера
	ContainerAddrs() AddrsMap
	// LogStdout пишет сообщение во writer потока стандартного вывода контейнера
	LogStdout(format string, args ...interface{}) bool
	// LogStderr пишет сообщение во writer потока стандартного вывода ошибок контейнера
	LogStderr(format string, args ...interface{}) bool
	// LogError пишет ошибку сообщение во writer потока стандартного вывода ошибок контейнера
	LogError(err error, args ...interface{}) bool
}

type ContainerInfo struct {
	ID        string
	IPAddress string
	PortBinds PortMap
	Networks  map[string]EndpointSettings
}

type ContainerStatus struct {
	StatusCode int64
	Error      error
}

type EndpointSettings struct {
	IPAddress string
}

type ImageBuildData struct {
	Tags       []string
	Args       map[string]*string
	Root       string
	Dockerfile string
	Nocache    bool
	ClearRoot  bool
	Output     io.Writer
}

type ImageOption func(o *imageOptions)

type Images map[string]ImageOption

type Network interface {
	// ID возвращает идентификатор сети
	ID() string
	// Name возвращает имя сети
	Name() string
	// Gateway возвращает шлюз сети
	Gateway() string
	// HostIP возвращает адрес хоста
	HostIP() string
	// NextIP возвращает следующий не занятый IP-адрес сети
	NextIP() string
	// AddContainer добавляет данные контейнера
	AddContainer(info *OrchestratorInfo)
}

type OrchestratorInfo struct {
	ID                string   `json:"id"`
	TypeID            uint8    `json:"type_id"`
	ContainerEnpoints AddrsMap `json:"container_enpoints"`
	HostEnpoints      AddrsMap `json:"host_enpoints"`
}

type Port string

type PortBind struct {
	Name      ports.PortName
	Container Port
	Host      uint16
}

type PortBinding struct {
	HostIP   string
	HostPort string
}

type PortBinds []PortBind

type PortMap map[Port][]PortBinding

type ReadyFunc func(ctx context.Context) <-chan struct{}