model

Documentation

Index

• type AgentHeartbeatRequest
• type AgentHeartbeatResponse
• type MetricValue
  • func (t *MetricValue) PK() string
  • func (this *MetricValue) String() string
• type NullRpcRequest
• type PluginParam
• type SimpleRpcResponse
  • func (this *SimpleRpcResponse) String() string
• type TransferResponse
  • func (this *TransferResponse) String() string

Types

type AgentHeartbeatRequest

type AgentHeartbeatRequest struct {
	Hostname      string
	IP            string
	AgentVersion  string
	PluginVersion string
	ConfigVersion int64
}

type AgentHeartbeatResponse

type AgentHeartbeatResponse struct {
	ConfigModified bool
	ConfigVersion  int64
	PluginVersion  string
	PluginDirs     []string
	Plugins        []PluginParam // [{"_metric": "net.port.listen", "_step": 60, "port": 6379}, ...]
}

type MetricValue

type MetricValue struct {
	Endpoint  string            `json:"endpoint"`
	Metric    string            `json:"metric"`
	Value     float64           `json:"value"`
	Tags      map[string]string `json:"tags"`
	Desc      string            `json:"description"`
	Timestamp int64             `json:"timestamp"`
}

func (*MetricValue) PK

func (t *MetricValue) PK() string

func (*MetricValue) String

func (this *MetricValue) String() string

type NullRpcRequest

type NullRpcRequest struct {
}

type PluginParam

type PluginParam map[string]interface{}

type SimpleRpcResponse

type SimpleRpcResponse struct {
	Code int `json:"code"`
}

code == 0 => success code == 1 => bad request

func (*SimpleRpcResponse) String

func (this *SimpleRpcResponse) String() string

type TransferResponse

type TransferResponse struct {
	Message string
	Total   int
	Invalid int
	Latency int64
}

func (*TransferResponse) String

func (this *TransferResponse) String() string