controller

Documentation

Index

• func DeleteJob(c *gin.Context)
• func DeleteService(c *gin.Context)
• func GetJob(c *gin.Context)
• func GetJobs(c *gin.Context)
• func GetService(c *gin.Context)
• func GetServices(c *gin.Context)
• func Health(c *gin.Context)
• func Home(c *gin.Context)
• func Metrics() http.Handler
• func Ready(c *gin.Context)
• type Message
• type ServicePayload
• type Workers
  • func NewWorkers() *Workers
  • func (w *Workers) BroadcastRequest(c *gin.Context, rawBody []byte)
  • func (w *Workers) DeployService(notifyChannel chan<- Message, wg *sync.WaitGroup)
  • func (w *Workers) Finalize(notifyChannel <-chan Message)
  • func (w *Workers) HandleWorkload() <-chan Message

Functions

func DeleteJob

func DeleteJob(c *gin.Context)

DeleteJob controller

func DeleteService

func DeleteService(c *gin.Context)

DeleteService controller

func GetJob

func GetJob(c *gin.Context)

GetJob controller

func GetJobs

func GetJobs(c *gin.Context)

GetJobs controller

func GetService

func GetService(c *gin.Context)

GetService controller

func GetServices

func GetServices(c *gin.Context)

GetServices controller

func Health

func Health(c *gin.Context)

Health controller

func Home

func Home(c *gin.Context)

Home controller

func Metrics

func Metrics() http.Handler

Metrics controller

func Ready

func Ready(c *gin.Context)

Ready controller

Types

type Message

type Message struct {
	JobID         string            `json:"jobId"`
	ServiceID     string            `json:"serviceId"`
	Template      string            `json:"template"`
	Configs       map[string]string `json:"configs"`
	DeleteAfter   string            `json:"deleteAfter"`
	CorrelationID string            `json:"correlationID"`
}

Message type

type ServicePayload

type ServicePayload struct {
	ID          string            `json:"id"`
	Template    string            `json:"template"`
	Configs     map[string]string `json:"configs"`
	DeleteAfter string            `json:"deleteAfter"`
	CreatedAt   time.Time         `json:"createdAt"`
	UpdatedAt   time.Time         `json:"updatedAt"`
}

ServicePayload type

type Workers

type Workers struct {
	// contains filtered or unexported fields
}

Workers type

func NewWorkers

func NewWorkers() *Workers

NewWorkers get a new workers instance

func (*Workers) BroadcastRequest

func (w *Workers) BroadcastRequest(c *gin.Context, rawBody []byte)

BroadcastRequest sends a request to workers

func (*Workers) DeployService

func (w *Workers) DeployService(notifyChannel chan<- Message, wg *sync.WaitGroup)

DeployService process incoming request

func (*Workers) Finalize

func (w *Workers) Finalize(notifyChannel <-chan Message)

Finalize finalizes a request

func (*Workers) HandleWorkload

func (w *Workers) HandleWorkload() <-chan Message

HandleWorkload handles all incoming requests