g

Documentation

Index

• Constants
• Variables
• func InitRpcClients()
• func ParseConfig(cfg string)
• func SendToTransfer(metrics []*model.MetricValue) error
• type GlobalConfig
  • func Config() *GlobalConfig
• type HttpConfig
• type SingleConnRpcClient
  • func (this *SingleConnRpcClient) Call(method string, args interface{}, reply interface{}) error
• type TransferConfig

Constants

const (
	VERSION = "0.0.1"
)

Variables

var (
	ConfigFile string
)

Functions

func InitRpcClients

func InitRpcClients()

func ParseConfig

func ParseConfig(cfg string)

func SendToTransfer

func SendToTransfer(metrics []*model.MetricValue) error

Types

type GlobalConfig

type GlobalConfig struct {
	Debug      bool            `json:"debug"`
	Transfer   *TransferConfig `json:"transfer"`
	Http       *HttpConfig     `json:"http"`
	AttachTags string          `json:"attachTags"`
}

func Config

func Config() *GlobalConfig

type HttpConfig

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

type SingleConnRpcClient

type SingleConnRpcClient struct {
	sync.Mutex

	RpcServer string
	Timeout   time.Duration
	// contains filtered or unexported fields
}

var (
	TransferClient *SingleConnRpcClient
)

func (*SingleConnRpcClient) Call

func (this *SingleConnRpcClient) Call(method string, args interface{}, reply interface{}) error

type TransferConfig

type TransferConfig struct {
	Enabled  bool   `json:"enabled"`
	Addr     string `json:"addr"`
	Interval int    `json:"interval"`
	Timeout  int    `json:"timeout"`
}