monitor

Documentation

Index

• Constants
• func CORSMiddleware() gin.HandlerFunc
• type Agent
• type AgentsSyncMap
  • func NewAgentsSyncMap(logger *logger.Logger) *AgentsSyncMap
  • func (agentsMap *AgentsSyncMap) AgentToJson(id uint64) ([]byte, error)
  • func (agentsMap *AgentsSyncMap) GetAll() []Agent
  • func (agentsMap *AgentsSyncMap) Tick()
  • func (agentsMap *AgentsSyncMap) ToJson() ([]byte, error)
  • func (agentsMap *AgentsSyncMap) TryGet(id uint64) (Agent, error)
  • func (agentsMap *AgentsSyncMap) Update(agents ...Agent)
• type App
  • func NewApp(rpcPort string, webPort string) (*App, error)
  • func (app *App) Start()
• type AppConfig

Constants

const HeartbeatInterval = 20

const StaleInterval = 3 * HeartbeatInterval

Functions

func CORSMiddleware

func CORSMiddleware() gin.HandlerFunc

Types

type Agent

type Agent struct {
	Id     uint64 `json:"id"`
	Status string `json:"status"`
	// rpc connection address of agent
	Address string `json:"address"`
	// config is a place holder of config
	Config        string `json:"config"`
	HeartbeatTick int    `json:"alive"`
}

type AgentsSyncMap

type AgentsSyncMap struct {
	// contains filtered or unexported fields
}

func NewAgentsSyncMap

func NewAgentsSyncMap(logger *logger.Logger) *AgentsSyncMap

func (*AgentsSyncMap) AgentToJson

func (agentsMap *AgentsSyncMap) AgentToJson(id uint64) ([]byte, error)

func (*AgentsSyncMap) GetAll

func (agentsMap *AgentsSyncMap) GetAll() []Agent

func (*AgentsSyncMap) Tick

func (agentsMap *AgentsSyncMap) Tick()

func (*AgentsSyncMap) ToJson

func (agentsMap *AgentsSyncMap) ToJson() ([]byte, error)

func (*AgentsSyncMap) TryGet

func (agentsMap *AgentsSyncMap) TryGet(id uint64) (Agent, error)

func (*AgentsSyncMap) Update

func (agentsMap *AgentsSyncMap) Update(agents ...Agent)

type App

type App struct {
	// contains filtered or unexported fields
}

App instance at Run time most recent agents information is maintained in memory db updates only happens when 1) create a new agent instance 2) delete a agent instance 3) a heartbeat comes from a new agent

func NewApp

func NewApp(rpcPort string, webPort string) (*App, error)

NewApp

func (*App) Start

func (app *App) Start()

type AppConfig

type AppConfig struct {
	WebPort string `yaml: "webport"`
	RpcPort string `yaml: "rpcport"`
}