tower

package

v1.2.6 Latest Latest Go to latest Published: Jan 31, 2024 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/clivern/walrus

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL