Documentation ¶
Index ¶
- func GetJob(c *gin.Context)
- func GetService(c *gin.Context)
- func GetServices(c *gin.Context)
- func GetTags(c *gin.Context)
- func Health(c *gin.Context)
- func Metrics() http.Handler
- func Ready(c *gin.Context)
- type Message
- type ServicePayload
- type Workers
- func (w *Workers) DeployRequest(c *gin.Context, rawBody []byte)
- func (w *Workers) DestroyRequest(c *gin.Context)
- func (w *Workers) Finalize(notifyChannel <-chan Message)
- func (w *Workers) HandleWorkload() <-chan Message
- func (w *Workers) ProcessRequest(notifyChannel chan<- Message, wg *sync.WaitGroup)
- func (w *Workers) Watch()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Message ¶ added in v0.1.2
type Message struct { JobID string `json:"jobId"` ServiceID string `json:"serviceId"` Service string `json:"service"` Version string `json:"version"` Configs map[string]string `json:"configs"` DeleteAfter string `json:"deleteAfter"` Type string `json:"type"` CorrelationID string `json:"correlationID"` }
Message type
type ServicePayload ¶ added in v0.1.1
type ServicePayload struct { ID string `json:"id"` Service string `json:"service"` Configs map[string]string `json:"configs"` DeleteAfter string `json:"deleteAfter"` Version string `json:"version"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` }
ServicePayload type
type Workers ¶ added in v0.1.2
type Workers struct {
// contains filtered or unexported fields
}
Workers type
func (*Workers) DeployRequest ¶ added in v0.1.6
DeployRequest sends a deploy request to workers
func (*Workers) DestroyRequest ¶ added in v0.1.6
DestroyRequest sends a destroy request to workers
func (*Workers) HandleWorkload ¶ added in v0.1.2
HandleWorkload handles all incoming requests
func (*Workers) ProcessRequest ¶ added in v0.1.6
ProcessRequest process incoming request
Source Files ¶
Click to show internal directories.
Click to hide internal directories.