Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

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
Redistributable license
Tagged version
Stable version
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