agent

Documentation

Index

• func Health(c *gin.Context)
• func Heartbeat()
• type Workers
  • func NewWorkers() *Workers
  • func (w *Workers) BroadcastRequest(c *gin.Context, rawBody []byte)
  • func (w *Workers) HandleWorkload() <-chan module.BackupMessage
  • func (w *Workers) NotifyTower(notifyChannel <-chan module.BackupMessage)
  • func (w *Workers) ProcessAction(notifyChannel chan<- module.BackupMessage, wg *sync.WaitGroup)

Functions

func Health

func Health(c *gin.Context)

Health controller

func Heartbeat

func Heartbeat()

Heartbeat function

Types

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 tower request to workers

func (*Workers) HandleWorkload

func (w *Workers) HandleWorkload() <-chan module.BackupMessage

HandleWorkload handles all incoming requests from tower

func (*Workers) NotifyTower

func (w *Workers) NotifyTower(notifyChannel <-chan module.BackupMessage)

NotifyTower notifies tower

func (*Workers) ProcessAction

func (w *Workers) ProcessAction(notifyChannel chan<- module.BackupMessage, wg *sync.WaitGroup)

ProcessAction process incoming request from the tower