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 DeployRequest
  • func (d DeployRequest) GetCorrelation() string
  • func (d DeployRequest) GetJob() string
  • func (d DeployRequest) GetService() string
  • func (d DeployRequest) GetType() string
• type DestroyRequest
  • func (d DestroyRequest) GetCorrelation() string
  • func (d DestroyRequest) GetJob() string
  • func (d DestroyRequest) GetService() string
  • func (d DestroyRequest) GetType() string
• type Message
• type ServicePayload
• type Workers
  • func NewWorkers() *Workers
  • func (w *Workers) DeployRequest(c *gin.Context, rawBody []byte)
  • func (w *Workers) DestroyRequest(c *gin.Context, rawBody []byte)
  • 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()

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 DeployRequest

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

DeployRequest type

func (DeployRequest) GetCorrelation

func (d DeployRequest) GetCorrelation() string

GetCorrelation gets the correlation id

func (DeployRequest) GetJob

func (d DeployRequest) GetJob() string

GetJob gets the job id

func (DeployRequest) GetService

func (d DeployRequest) GetService() string

GetService gets the service id

func (DeployRequest) GetType

func (d DeployRequest) GetType() string

GetType gets the job type

type DestroyRequest

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

DestroyRequest type

func (DestroyRequest) GetCorrelation

func (d DestroyRequest) GetCorrelation() string

GetCorrelation gets the correlation id

func (DestroyRequest) GetJob

func (d DestroyRequest) GetJob() string

GetJob gets the job id

func (DestroyRequest) GetService

func (d DestroyRequest) GetService() string

GetService gets the service id

func (DestroyRequest) GetType

func (d DestroyRequest) GetType() string

GetType gets the job type

type Message

type Message interface {
	GetCorrelation() string
	GetService() string
	GetJob() string
	GetType() string
}

Message interface

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) DeployRequest

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

DeployRequest sends a deploy request to workers

func (*Workers) DestroyRequest

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

DestroyRequest sends a destroy request to workers

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

func (*Workers) ProcessRequest

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

ProcessRequest process incoming request

func (*Workers) Watch

func (w *Workers) Watch()

Watch watches for a pending jobs