Documentation
¶
Overview ¶
Package docker wraps the Docker API client for devrig container lifecycle management.
Index ¶
- func ExecReadyCheck(ctx context.Context, cli *dockerclient.Client, containerID, command string, ...) error
- func RunReadyCheck(ctx context.Context, cli *dockerclient.Client, containerID string, ...) error
- func StreamContainerLogs(ctx context.Context, cli *dockerclient.Client, containerID, serviceName string, ...)
- type Manager
- func (m *Manager) CleanupAll(ctx context.Context) error
- func (m *Manager) Client() *dockerclient.Client
- func (m *Manager) ConnectContainerToNetwork(ctx context.Context, containerID string, aliases []string) error
- func (m *Manager) DeleteService(ctx context.Context, st *state.DockerState) error
- func (m *Manager) EnsureNetwork(ctx context.Context) error
- func (m *Manager) NetworkName() string
- func (m *Manager) RemoveNetwork(ctx context.Context) error
- func (m *Manager) Slug() string
- func (m *Manager) StartService(ctx context.Context, name string, cfg *config.DockerConfig, ...) (state.DockerState, error)
- func (m *Manager) StopService(ctx context.Context, st *state.DockerState) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExecReadyCheck ¶
func ExecReadyCheck(ctx context.Context, cli *dockerclient.Client, containerID, command string, expect *string) error
ExecReadyCheck runs a command-based ready check via docker exec.
func RunReadyCheck ¶
func RunReadyCheck( ctx context.Context, cli *dockerclient.Client, containerID string, check *config.ReadyCheck, hostPort *uint16, name string, ) error
RunReadyCheck polls until the container passes its ready check or the configured timeout expires.
func StreamContainerLogs ¶
func StreamContainerLogs(ctx context.Context, cli *dockerclient.Client, containerID, serviceName string, b *events.Broadcaster)
StreamContainerLogs subscribes to container logs and broadcasts each line as a KindLogRecord event until ctx is cancelled or the stream ends.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages Docker containers and networks for a devrig project.
func (*Manager) CleanupAll ¶
CleanupAll removes all containers, volumes, and the network for this project.
func (*Manager) Client ¶
func (m *Manager) Client() *dockerclient.Client
func (*Manager) ConnectContainerToNetwork ¶
func (m *Manager) ConnectContainerToNetwork(ctx context.Context, containerID string, aliases []string) error
ConnectContainerToNetwork connects a container to the project network with aliases.
func (*Manager) DeleteService ¶
DeleteService stops and removes a container.
func (*Manager) EnsureNetwork ¶
EnsureNetwork creates the project bridge network if it doesn't already exist.
func (*Manager) NetworkName ¶
func (*Manager) RemoveNetwork ¶
RemoveNetwork removes the project network (ignores not-found).
func (*Manager) StartService ¶
func (m *Manager) StartService( ctx context.Context, name string, cfg *config.DockerConfig, prevState *state.DockerState, allocated map[uint16]bool, configDir string, ) (state.DockerState, error)
StartService starts a single docker service container.
func (*Manager) StopService ¶
StopService stops a container (does not remove it).
Source Files