swarm

type DeploymentResult struct {
	UpdatedServices []ServiceUpdateResult // Services that were created or updated
	DeployID        string                // Deployment ID for this deployment
}

type DockerClient interface {
	ServiceList(ctx context.Context, options types.ServiceListOptions) ([]swarm.Service, error)
	ServiceCreate(ctx context.Context, service swarm.ServiceSpec, options types.ServiceCreateOptions) (swarm.ServiceCreateResponse, error)
	ServiceUpdate(ctx context.Context, serviceID string, version swarm.Version, service swarm.ServiceSpec, options types.ServiceUpdateOptions) (swarm.ServiceUpdateResponse, error)
	ServiceRemove(ctx context.Context, serviceID string) error
	ServiceInspectWithRaw(ctx context.Context, serviceID string, options types.ServiceInspectOptions) (swarm.Service, []byte, error)

	TaskList(ctx context.Context, options types.TaskListOptions) ([]swarm.Task, error)

	ContainerList(ctx context.Context, options container.ListOptions) ([]types.Container, error)
	ContainerInspect(ctx context.Context, containerID string) (types.ContainerJSON, error)
	ContainerRemove(ctx context.Context, containerID string, options container.RemoveOptions) error

	NetworkCreate(ctx context.Context, name string, options network.CreateOptions) (network.CreateResponse, error)
	NetworkList(ctx context.Context, options network.ListOptions) ([]network.Summary, error)
	NetworkInspect(ctx context.Context, networkID string, options network.InspectOptions) (network.Inspect, error)

	VolumeCreate(ctx context.Context, options volume.CreateOptions) (volume.Volume, error)
	VolumeList(ctx context.Context, options volume.ListOptions) (volume.ListResponse, error)
	VolumeInspect(ctx context.Context, volumeID string) (volume.Volume, error)

	NetworkRemove(ctx context.Context, networkID string) error

	ImagePull(ctx context.Context, refStr string, options image.PullOptions) (io.ReadCloser, error)

	Close() error
}

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

type ResourceSnapshot struct {
	Networks map[string]string // name -> ID
	Volumes  map[string]string // name -> ID

}

type ServiceSnapshot struct {
	Service swarm.Service
	Tasks   []swarm.Task
}

type ServiceUpdateResult struct {
	ServiceID   string        // Docker service ID
	ServiceName string        // Full service name (stack_service)
	Version     swarm.Version // Service version after update
	Warnings    []string      // Any warnings from Docker API
	Changed     bool          // Whether service was actually changed
	DeployID    string        // Deployment ID for this deployment
}

type StackDeployer struct {
	MaxFailedTaskCount int // Maximum number of failed tasks before giving up
	// contains filtered or unexported fields
}

type StackSnapshot struct {
	StackName     string
	CreatedAt     time.Time
	Services      map[string]ServiceSnapshot // key is service ID
	ExistingIDs   map[string]bool            // IDs that existed before deploy
	Resources     ResourceSnapshot
	IsFirstDeploy bool // true if stack didn't exist before
}