g

Documentation

Index

• Constants
• Variables
• func ParseConfig(cfg string)
• type ClusterNode
  • func NewClusterNode(addrs []string) *ClusterNode
• type GlobalConfig
  • func Config() *GlobalConfig
• type HttpConfig
• type InfluxdbConfig
• type ReceiverStatusManager
  • func NewReceiverStatusManager() *ReceiverStatusManager
  • func (r *ReceiverStatusManager) IsRun() bool
  • func (r *ReceiverStatusManager) Run()
  • func (r *ReceiverStatusManager) Stop()
• type RpcConfig

Constants

const (
	VERSION      = "1.0.0"
	GAUGE        = "GAUGE"
	COUNTER      = "COUNTER"
	DERIVE       = "DERIVE"
	DEFAULT_STEP = 60
	MIN_STEP     = 30
)

Variables

var (
	ConfigFile string
)

Functions

func ParseConfig

func ParseConfig(cfg string)

Types

type ClusterNode

type ClusterNode struct {
	Addrs []string `json:"addrs"`
}

CLUSTER NODE

func NewClusterNode

func NewClusterNode(addrs []string) *ClusterNode

type GlobalConfig

type GlobalConfig struct {
	Debug    bool        `json:"debug"`
	NodePath string      `json:"nodepatch"`
	Http     *HttpConfig `json:"http"`
	Rpc      *RpcConfig  `json:"rpc"`

	Influxdb *InfluxdbConfig `json:"influxdb"`
}

func Config

func Config() *GlobalConfig

type HttpConfig

type HttpConfig struct {
	Enabled bool   `json:"enabled"`
	Listen  string `json:"listen"`
}

type InfluxdbConfig

type InfluxdbConfig struct {
	Enabled       bool                    `json:"enabled"`
	Batch         int                     `json:"batch"`
	Username      string                  `json:"username"`
	Password      string                  `json:"password"`
	Database      string                  `json:"database"`
	ConnTimeout   int                     `json:"connTimeout"`
	CallTimeout   int                     `json:"callTimeout"`
	MaxConns      int                     `json:"maxConns"`
	MaxIdle       int                     `json:"maxIdle"`
	MaxRetry      int                     `json:"retry"`
	Cluster       map[string]string       `json:"cluster"`
	RemoveMetrics map[string]bool         `json:"remove"`
	Cluster2      map[string]*ClusterNode `json:"cluster2"`
}

type ReceiverStatusManager

type ReceiverStatusManager struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func NewReceiverStatusManager

func NewReceiverStatusManager() *ReceiverStatusManager

func (*ReceiverStatusManager) IsRun

func (r *ReceiverStatusManager) IsRun() bool

func (*ReceiverStatusManager) Run

func (r *ReceiverStatusManager) Run()

func (*ReceiverStatusManager) Stop

func (r *ReceiverStatusManager) Stop()

type RpcConfig

type RpcConfig struct {
	Enabled bool   `json:"enabled"`
	Listen  string `json:"listen"`
}