alexei.dolgolyov
389ed5aff8
Phase 3: Docker Engine API wrapper — pull/inspect images, container lifecycle (create/start/stop/remove/restart), network management, label-based container tracking, deterministic naming. Phase 4: Nginx Proxy Manager API client — JWT auth with auto-refresh, CRUD for proxy hosts, domain-based host lookup.
51 lines
1.1 KiB
Go
51 lines
1.1 KiB
Go
package docker
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/docker/docker/client"
|
|
)
|
|
|
|
// Labels applied to all containers managed by docker-watcher.
|
|
const (
|
|
LabelProject = "docker-watcher.project"
|
|
LabelStage = "docker-watcher.stage"
|
|
LabelInstanceID = "docker-watcher.instance-id"
|
|
)
|
|
|
|
// Client wraps the Docker Engine API client.
|
|
type Client struct {
|
|
api client.APIClient
|
|
}
|
|
|
|
// New creates a new Docker client connected to the default Docker socket.
|
|
func New() (*Client, error) {
|
|
api, err := client.NewClientWithOpts(
|
|
client.FromEnv,
|
|
client.WithAPIVersionNegotiation(),
|
|
)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("create docker client: %w", err)
|
|
}
|
|
|
|
return &Client{api: api}, nil
|
|
}
|
|
|
|
// Close releases resources held by the Docker client.
|
|
func (c *Client) Close() error {
|
|
if err := c.api.Close(); err != nil {
|
|
return fmt.Errorf("close docker client: %w", err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Ping checks connectivity to the Docker daemon.
|
|
func (c *Client) Ping(ctx context.Context) error {
|
|
_, err := c.api.Ping(ctx)
|
|
if err != nil {
|
|
return fmt.Errorf("ping docker daemon: %w", err)
|
|
}
|
|
return nil
|
|
}
|