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.