serv

Documentation

Index

• Constants
• func CheckGCStats() func()
• func CreateInitialToken() string
• func GetCurrentToken() string
• func MonitorApi() *monitorApi
• func SetSoftMemoryCap()
• func ShowMonitor(ctx context.Context)
• func StartDumpTrafficLog(ctx context.Context)
• func StopDumpTrafficLog()
• func StopMonitor()
• func TerminalAPI() *terminalCmd
• func TrafficInfoToMonitorClient(t TrafficInfo)
• type BaseServer
  • func (bs *BaseServer) Start() error
  • func (bs *BaseServer) Stop()
• type CmdResult
• type CpuInfo
  • func NewCpuInfo(cpuInfos []SingleCpuInfo, cpuUsedPercent float64) CpuInfo
• type DiskUsage
• type HdInfo
  • func NewHdInfo(hdTotal uint64, hdFree uint64, hdUsed uint64, hdUsedPercent float64) HdInfo
• type MemInfo
  • func NewMemInfo(memTotal uint64, memFree uint64, memUsed uint64, memUsedPercent float64) MemInfo
• type MonitorNotificationResult
• type MonitorResult
• type NodeDetails
• type OnlineState
• type ParamMonitor
• type ParamTrafficInfo
• type SingleCpuInfo
  • func NewSingleCpuInfo(cpuModelName string, cpuCores int32) SingleCpuInfo
• type TrafficDumpInfo
  • func NewTrafficDumpInfo(memInfo MemInfo, cpuInfo CpuInfo, hdInfo HdInfo, trafficInfo TrafficInfo) TrafficDumpInfo
• type TrafficInfo
  • func NewTrafficInfo(trafficInbound uint64, trafficOutbound uint64) TrafficInfo

Constants

const (
	MSG_GET_TRAFFIC_DATA_RESPONSE = "monitor_getTrafficData"
	MSG_GET_DIST_USAGE_RESPONSE   = "monitor_getDiskUsage"
	MSG_GET_ONLINE_STATE          = "monitor_getOnlineState"
	MSG_GET_NODE_DETAILS          = "monitor_getNodeDetails"
)

const (
	INVALID_MEM_LIMIT_FOR_READING  = -1
	CHECK_GCSTATS_INTERVAL         = 30 * time.Second
	THRESHOLD_GC_OVER_TRIGGERED    = 30
	THRESHOLD_NUM_CONSEC_STAY_HIGH = 3
)

const (
	DefaultMsg               = "Request Accepted"
	DefaultDesiredUploadTier = 2
)

Functions

func CheckGCStats

func CheckGCStats() func()

func CreateInitialToken

func CreateInitialToken() string

CreateInitialToken the initial token is used to generate all following tokens

func GetCurrentToken

func GetCurrentToken() string

GetCurrentToken

func MonitorApi

func MonitorApi() *monitorApi

func SetSoftMemoryCap

func SetSoftMemoryCap()

func ShowMonitor

func ShowMonitor(ctx context.Context)

ShowMonitor

func StartDumpTrafficLog

func StartDumpTrafficLog(ctx context.Context)

func StopDumpTrafficLog

func StopDumpTrafficLog()

func StopMonitor

func StopMonitor()

StopMonitor

func TerminalAPI

func TerminalAPI() *terminalCmd

func TrafficInfoToMonitorClient

func TrafficInfoToMonitorClient(t TrafficInfo)

TrafficInfoToMonitorClient traffic info generator calls this to feed the notifiers to the subscribed clients

Types

type BaseServer

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

BaseServer base pp server

func (*BaseServer) Start

func (bs *BaseServer) Start() error

func (*BaseServer) Stop

func (bs *BaseServer) Stop()

type CmdResult

type CmdResult struct {
	Msg string
}

type CpuInfo

type CpuInfo struct {
	CpuInfos       []SingleCpuInfo `json:"cpu_infos"`
	CpuUsedPercent float64         `json:"cpu_used_percent"`
}

func NewCpuInfo

func NewCpuInfo(cpuInfos []SingleCpuInfo, cpuUsedPercent float64) CpuInfo

type DiskUsage

type DiskUsage struct {
	DataHost int64 `json:"data_host"`
}

type HdInfo

type HdInfo struct {
	HdTotal       uint64  `json:"hd_total"`
	HdFree        uint64  `json:"hd_free"`
	HdUsed        uint64  `json:"hd_used"`
	HdUsedPercent float64 `json:"hd_used_percent"`
}

func NewHdInfo

func NewHdInfo(hdTotal uint64, hdFree uint64, hdUsed uint64, hdUsedPercent float64) HdInfo

type MemInfo

type MemInfo struct {
	MemTotal       uint64  `json:"mem_total"`
	MemFree        uint64  `json:"mem_free"`
	MemUsed        uint64  `json:"mem_used"`
	MemUsedPercent float64 `json:"mem_used_percent"`
}

func NewMemInfo

func NewMemInfo(memTotal uint64, memFree uint64, memUsed uint64, memUsedPercent float64) MemInfo

type MonitorNotificationResult

type MonitorNotificationResult struct {
	TrafficInfo *TrafficInfo `json:"traffic_info"`
	OnlineState *OnlineState `json:"online_state,omitempty"`
	DiskUsage   *DiskUsage   `json:"disk_usage,omitempty"`
}

type MonitorResult

type MonitorResult struct {
	Return      string         `json:"return"`
	MessageType string         `json:"message_type"`
	TrafficInfo *[]TrafficInfo `json:"traffic_info,omitempty"`
	OnlineState *OnlineState   `json:"online_state,omitempty"`
	DiskUsage   *DiskUsage     `json:"disk_usage,omitempty"`
	NodeDetails *NodeDetails   `json:"node_details,omitempty"`
}

type NodeDetails

type NodeDetails struct {
	Id              string `json:"id"`
	Address         string `json:"address"`
	AdvancedDetails *[]struct {
		Id      string `json:"id"`
		Title   string `json:"title"`
		Details string `json:"details"`
	} `json:"advanced_details,omitempty"`
}

type OnlineState

type OnlineState struct {
	Online bool  `json:"online"`
	Since  int64 `json:"since"`
}

type ParamMonitor

type ParamMonitor struct {
	SubId string `json:"subid"`
}

type ParamTrafficInfo

type ParamTrafficInfo struct {
	SubId string `json:"subid"`
	Lines uint64 `json:"lines"`
}

type SingleCpuInfo

type SingleCpuInfo struct {
	CpuModelName string `json:"cpu_model_name"`
	CpuCores     int32  `json:"cpu_cores"`
}

func NewSingleCpuInfo

func NewSingleCpuInfo(cpuModelName string, cpuCores int32) SingleCpuInfo

type TrafficDumpInfo

type TrafficDumpInfo struct {
	MemInfo     MemInfo     `json:"mem_info"`
	CpuInfo     CpuInfo     `json:"cpu_info"`
	HdInfo      HdInfo      `json:"hd_info"`
	TrafficInfo TrafficInfo `json:"traffic_info"`
}

func NewTrafficDumpInfo

func NewTrafficDumpInfo(memInfo MemInfo, cpuInfo CpuInfo, hdInfo HdInfo, trafficInfo TrafficInfo) TrafficDumpInfo

type TrafficInfo

type TrafficInfo struct {
	TrafficInbound  uint64 `json:"traffic_inbound"`
	TrafficOutbound uint64 `json:"traffic_outbound"`
	TimeStamp       string `json:"time_stamp,omitempty"`
}

func NewTrafficInfo

func NewTrafficInfo(trafficInbound uint64, trafficOutbound uint64) TrafficInfo