docker

package

v0.1.3 Latest Latest Go to latest Published: Feb 27, 2026 License: MIT Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kbukum/gokit

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
- func (c *Config) ApplyDefaults()
- func (c *Config) Validate() error
type Manager
- func NewManager(cfg *Config, defaultLabels map[string]string, log *logger.Logger) (*Manager, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Host       string              `mapstructure:"host" json:"host"`
	APIVersion string              `mapstructure:"api_version" json:"api_version"`
	TLS        *security.TLSConfig `mapstructure:"tls" json:"tls"`
	Network    string              `mapstructure:"network" json:"network"`
	Registry   string              `mapstructure:"registry" json:"registry"`
	Platform   string              `mapstructure:"platform" json:"platform"`
}

Config holds Docker-specific workload configuration.

func (*Config) ApplyDefaults ¶

func (c *Config) ApplyDefaults()

ApplyDefaults fills in zero-valued fields.

func (*Config) Validate ¶

func (c *Config) Validate() error

Validate checks the Docker configuration.

type Manager ¶

type Manager struct {
	// contains filtered or unexported fields
}

Manager implements workload.Manager using the Docker Engine SDK.

func NewManager ¶

func NewManager(cfg *Config, defaultLabels map[string]string, log *logger.Logger) (*Manager, error)

NewManager creates a new Docker workload manager.

func (*Manager) Deploy ¶

func (m *Manager) Deploy(ctx context.Context, req workload.DeployRequest) (*workload.DeployResult, error)

Deploy creates and starts a Docker container.

func (*Manager) Exec ¶

func (m *Manager) Exec(ctx context.Context, id string, cmd []string) (*workload.ExecResult, error)

Exec executes a command inside a running container.

func (*Manager) HealthCheck ¶

func (m *Manager) HealthCheck(ctx context.Context) error

HealthCheck verifies Docker is available.

func (*Manager) List ¶

func (m *Manager) List(ctx context.Context, filter workload.ListFilter) ([]workload.WorkloadInfo, error)

List returns containers matching the filter.

func (*Manager) Logs ¶

func (m *Manager) Logs(ctx context.Context, id string, opts workload.LogOptions) ([]string, error)

Logs retrieves log output from a Docker container.

func (*Manager) Remove ¶

func (m *Manager) Remove(ctx context.Context, id string) error

Remove removes a Docker container.

func (*Manager) Restart ¶

func (m *Manager) Restart(ctx context.Context, id string) error

Restart restarts a Docker container.

func (*Manager) Stats ¶

func (m *Manager) Stats(ctx context.Context, id string) (*workload.WorkloadStats, error)

Stats returns resource usage statistics for a container.

func (*Manager) Status ¶

func (m *Manager) Status(ctx context.Context, id string) (*workload.WorkloadStatus, error)

Status returns the current status of a Docker container.

func (*Manager) Stop ¶

func (m *Manager) Stop(ctx context.Context, id string) error

Stop gracefully stops a Docker container.

func (*Manager) StreamLogs ¶

func (m *Manager) StreamLogs(ctx context.Context, id string, opts workload.LogOptions) (io.ReadCloser, error)

StreamLogs implements LogStreamer for real-time log streaming.

func (*Manager) Wait ¶

func (m *Manager) Wait(ctx context.Context, id string) (*workload.WaitResult, error)

Wait blocks until the container exits and returns the exit status.

func (*Manager) WatchEvents ¶

func (m *Manager) WatchEvents(ctx context.Context, filter workload.ListFilter) (<-chan workload.WorkloadEvent, error)

WatchEvents watches Docker container lifecycle events and emits WorkloadEvents.

Source Files ¶

View all Source files

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