tower

Documentation

Index

• func AgentBootstrap(c *gin.Context)
• func AgentHeartbeat(c *gin.Context)
• func AgentPostback(c *gin.Context)
• func Auth(c *gin.Context)
• func CreateHostCron(c *gin.Context)
• func DeleteHost(c *gin.Context)
• func DeleteHostCron(c *gin.Context)
• func DeleteHostJob(c *gin.Context)
• func GetHost(c *gin.Context)
• func GetHostCron(c *gin.Context)
• func GetHostCrons(c *gin.Context)
• func GetHostJob(c *gin.Context)
• func GetHostJobs(c *gin.Context)
• func GetHosts(c *gin.Context)
• func GetSettings(c *gin.Context)
• func Health(c *gin.Context)
• func Heartbeat()
• func Home(c *gin.Context)
• func Info(c *gin.Context)
• func Metrics() http.Handler
• func Ready(c *gin.Context)
• func Setup(c *gin.Context)
• func UpdateHostCron(c *gin.Context)
• func UpdateHostJob(c *gin.Context)
• func UpdateSettings(c *gin.Context)
• type Host
• type HostCron
• type Workers
  • func NewWorkers() *Workers
  • func (w *Workers) BroadcastRequests()
  • 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 AgentBootstrap

func AgentBootstrap(c *gin.Context)

AgentBootstrap controller

func AgentHeartbeat

func AgentHeartbeat(c *gin.Context)

AgentHeartbeat controller

func AgentPostback

func AgentPostback(c *gin.Context)

AgentPostback controller

func Auth

func Auth(c *gin.Context)

Auth controller

func CreateHostCron

func CreateHostCron(c *gin.Context)

CreateHostCron controller

func DeleteHost

func DeleteHost(c *gin.Context)

DeleteHost controller

func DeleteHostCron

func DeleteHostCron(c *gin.Context)

DeleteHostCron controller

func DeleteHostJob

func DeleteHostJob(c *gin.Context)

DeleteHostJob controller

func GetHost

func GetHost(c *gin.Context)

GetHost controller

func GetHostCron

func GetHostCron(c *gin.Context)

GetHostCron controller

func GetHostCrons

func GetHostCrons(c *gin.Context)

GetHostCrons controller

func GetHostJob

func GetHostJob(c *gin.Context)

GetHostJob controller

func GetHostJobs

func GetHostJobs(c *gin.Context)

GetHostJobs controller

func GetHosts

func GetHosts(c *gin.Context)

GetHosts controller

func GetSettings

func GetSettings(c *gin.Context)

GetSettings controller

func Health

func Health(c *gin.Context)

Health controller

func Heartbeat

func Heartbeat()

Heartbeat node heartbeat

func Home

func Home(c *gin.Context)

Home controller

func Info

func Info(c *gin.Context)

Info controller

func Metrics

func Metrics() http.Handler

Metrics controller

func Ready

func Ready(c *gin.Context)

Ready controller

func Setup

func Setup(c *gin.Context)

Setup controller

func UpdateHostCron

func UpdateHostCron(c *gin.Context)

UpdateHostCron controller

func UpdateHostJob

func UpdateHostJob(c *gin.Context)

UpdateHostJob controller

func UpdateSettings

func UpdateSettings(c *gin.Context)

UpdateSettings controller

Types

type Host

type Host struct {
	ID           string    `json:"id"`
	Hostname     string    `json:"hostname"`
	CreatedAt    time.Time `json:"createdAt"`
	UpdatedAt    time.Time `json:"updatedAt"`
	OnlineAgents int       `json:"onlineAgents"`
}

Host type

type HostCron

type HostCron struct {
	ID           string        `json:"id"`
	Name         string        `json:"name"`
	Request      model.Request `json:"request"`
	Interval     int           `json:"interval"`
	IntervalType string        `json:"intervalType"`
	LastRun      time.Time     `json:"lastRun"`
	SuccessJobs  int           `json:"successJobs"`
	FailedJobs   int           `json:"failedJobs"`
	PendingJobs  int           `json:"pendingJobs"`
	CreatedAt    time.Time     `json:"createdAt"`
	UpdatedAt    time.Time     `json:"updatedAt"`
}

HostCron 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) BroadcastRequests

func (w *Workers) BroadcastRequests()

BroadcastRequests 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