| package swarm |
| |
| import "time" |
| |
| // TaskState represents the state of a task. |
| type TaskState string |
| |
| const ( |
| // TaskStateNew NEW |
| TaskStateNew TaskState = "new" |
| // TaskStateAllocated ALLOCATED |
| TaskStateAllocated TaskState = "allocated" |
| // TaskStatePending PENDING |
| TaskStatePending TaskState = "pending" |
| // TaskStateAssigned ASSIGNED |
| TaskStateAssigned TaskState = "assigned" |
| // TaskStateAccepted ACCEPTED |
| TaskStateAccepted TaskState = "accepted" |
| // TaskStatePreparing PREPARING |
| TaskStatePreparing TaskState = "preparing" |
| // TaskStateReady READY |
| TaskStateReady TaskState = "ready" |
| // TaskStateStarting STARTING |
| TaskStateStarting TaskState = "starting" |
| // TaskStateRunning RUNNING |
| TaskStateRunning TaskState = "running" |
| // TaskStateComplete COMPLETE |
| TaskStateComplete TaskState = "complete" |
| // TaskStateShutdown SHUTDOWN |
| TaskStateShutdown TaskState = "shutdown" |
| // TaskStateFailed FAILED |
| TaskStateFailed TaskState = "failed" |
| // TaskStateRejected REJECTED |
| TaskStateRejected TaskState = "rejected" |
| ) |
| |
| // Task represents a task. |
| type Task struct { |
| ID string |
| Meta |
| Annotations |
| |
| Spec TaskSpec `json:",omitempty"` |
| ServiceID string `json:",omitempty"` |
| Slot int `json:",omitempty"` |
| NodeID string `json:",omitempty"` |
| Status TaskStatus `json:",omitempty"` |
| DesiredState TaskState `json:",omitempty"` |
| NetworksAttachments []NetworkAttachment `json:",omitempty"` |
| } |
| |
| // TaskSpec represents the spec of a task. |
| type TaskSpec struct { |
| ContainerSpec ContainerSpec `json:",omitempty"` |
| Resources *ResourceRequirements `json:",omitempty"` |
| RestartPolicy *RestartPolicy `json:",omitempty"` |
| Placement *Placement `json:",omitempty"` |
| Networks []NetworkAttachmentConfig `json:",omitempty"` |
| |
| // LogDriver specifies the LogDriver to use for tasks created from this |
| // spec. If not present, the one on cluster default on swarm.Spec will be |
| // used, finally falling back to the engine default if not specified. |
| LogDriver *Driver `json:",omitempty"` |
| |
| // ForceUpdate is a counter that triggers an update even if no relevant |
| // parameters have been changed. |
| ForceUpdate uint64 |
| } |
| |
| // Resources represents resources (CPU/Memory). |
| type Resources struct { |
| NanoCPUs int64 `json:",omitempty"` |
| MemoryBytes int64 `json:",omitempty"` |
| } |
| |
| // ResourceRequirements represents resources requirements. |
| type ResourceRequirements struct { |
| Limits *Resources `json:",omitempty"` |
| Reservations *Resources `json:",omitempty"` |
| } |
| |
| // Placement represents orchestration parameters. |
| type Placement struct { |
| Constraints []string `json:",omitempty"` |
| } |
| |
| // RestartPolicy represents the restart policy. |
| type RestartPolicy struct { |
| Condition RestartPolicyCondition `json:",omitempty"` |
| Delay *time.Duration `json:",omitempty"` |
| MaxAttempts *uint64 `json:",omitempty"` |
| Window *time.Duration `json:",omitempty"` |
| } |
| |
| // RestartPolicyCondition represents when to restart. |
| type RestartPolicyCondition string |
| |
| const ( |
| // RestartPolicyConditionNone NONE |
| RestartPolicyConditionNone RestartPolicyCondition = "none" |
| // RestartPolicyConditionOnFailure ON_FAILURE |
| RestartPolicyConditionOnFailure RestartPolicyCondition = "on-failure" |
| // RestartPolicyConditionAny ANY |
| RestartPolicyConditionAny RestartPolicyCondition = "any" |
| ) |
| |
| // TaskStatus represents the status of a task. |
| type TaskStatus struct { |
| Timestamp time.Time `json:",omitempty"` |
| State TaskState `json:",omitempty"` |
| Message string `json:",omitempty"` |
| Err string `json:",omitempty"` |
| ContainerStatus ContainerStatus `json:",omitempty"` |
| PortStatus PortStatus `json:",omitempty"` |
| } |
| |
| // ContainerStatus represents the status of a container. |
| type ContainerStatus struct { |
| ContainerID string `json:",omitempty"` |
| PID int `json:",omitempty"` |
| ExitCode int `json:",omitempty"` |
| } |
| |
| // PortStatus represents the port status of a task's host ports whose |
| // service has published host ports |
| type PortStatus struct { |
| Ports []PortConfig `json:",omitempty"` |
| } |