server

Documentation

Index

• func OnUISocket(h *Hub, w http.ResponseWriter, r *http.Request)
• type Hub
  • func NewHub(hubAddr string, masterApiUrls string, daemonPublicUrl string, etcdIps string, ...) *Hub
  • func (h *Hub) AddDaemon(d *models.Daemon, c *rpc2.Client)
  • func (h *Hub) Daemons() []models.Daemon
  • func (h *Hub) RemoveDaemon(host string)
  • func (h *Hub) Serve()
  • func (h *Hub) StartChecks(msg interface{}) models.BaseModel
  • func (h *Hub) StopChecks() models.BaseModel

Functions

func OnUISocket

func OnUISocket(h *Hub, w http.ResponseWriter, r *http.Request)

Types

type Hub

type Hub struct {
	ResetStats chan bool
	// contains filtered or unexported fields
}

func NewHub

func NewHub(hubAddr string, masterApiUrls string, daemonPublicUrl string,
	etcdIps string, etcdCertPath string) *Hub

func (*Hub) AddDaemon

func (h *Hub) AddDaemon(d *models.Daemon, c *rpc2.Client)

func (*Hub) Daemons

func (h *Hub) Daemons() []models.Daemon

func (*Hub) RemoveDaemon

func (h *Hub) RemoveDaemon(host string)

func (*Hub) Serve

func (h *Hub) Serve()

func (*Hub) StartChecks

func (h *Hub) StartChecks(msg interface{}) models.BaseModel

func (*Hub) StopChecks

func (h *Hub) StopChecks() models.BaseModel