task

type Config struct {
	AttachStderr  bool
	AttachStdin   bool
	AttachStdout  bool
	Cmd           []string
	Disk          int64
	Env           []string
	Image         string
	Memory        int64
	Name          string
	RestartPolicy string // Accepted values: always, unless-stopped, on-failure and empty.
}

type Docker struct {
	Client      DockerApi
	Config      Config
	ContainerId string
	// contains filtered or unexported fields
}

type DockerApi interface {
	ImagePull(ctx context.Context, refStr string, options types.ImagePullOptions) (io.ReadCloser, error)
	ContainerCreate(ctx context.Context, config *container.Config, hostConfig *container.HostConfig, networkingConfig *network.NetworkingConfig, platform *specs.Platform, containerName string) (container.CreateResponse, error)
	ContainerStart(ctx context.Context, id string, opts types.ContainerStartOptions) error
	ContainerLogs(ctx context.Context, container string, options types.ContainerLogsOptions) (io.ReadCloser, error)
}

type DockerResult struct {
	Action      string
	ContainerId string
	Error       error
	Result      string
}

type State int

type Task struct {
	Disk          int
	ExposedPorts  nat.PortSet
	FinishTime    time.Time
	ID            uuid.UUID
	Image         string
	Memory        int
	Name          string
	PortBindings  map[string]string
	RestartPolicy string
	StartTime     time.Time
	State         State
}

type TaskEvent struct {
	ID        uuid.UUID
	State     State
	Timestamp time.Time
	Task      Task
}