Documentation ¶
Index ¶
Constants ¶
View Source
const ( // MessageChannelCacheSize is size of worker message channel cache MessageChannelCacheSize = 100 // ReadyStatus is the ready status about worker ReadyStatus = "ready" // CompletedStatus is the completed status about worker CompletedStatus = "completed" // FailedStatus is the failed status about worker FailedStatus = "failed" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageContent ¶
type MessageContent struct { // Name is worker name Name string `json:"name"` Namespace string `json:"namespace"` // OwnerName is job name OwnerName string `json:"ownerName"` // OwnerKind is kind of job OwnerKind string `json:"ownerKind"` // OwnerInfo is info about job OwnerInfo map[string]interface{} `json:"ownerInfo"` // Kind is worker phase, include train/eval/deploy Kind string `json:"kind"` // Status is worker status, include running/completed/failed Status string `json:"status"` // Results is the output of worker when it was completed Results []map[string]interface{} `json:"results"` }
MessageContent defines the body content of message that comes from workers.
Click to show internal directories.
Click to hide internal directories.