agent

Documentation

Index

• Variables
• func AddCollector(name string, collector Collector)
• func AddData(name string, data Data)
• func AddReporter(name string, reporter Reporter)
• func InitLogger(logpath, loglevel string, IsDebug bool)
• func LoadConfig(file string)
• func LogInit(lp string, lv string, isDebug bool)
• func Name() string
• func Start() error
• func Stop() error
• func Writer(name string, in interface{}) error
• type Agent
  • func New() *Agent
  • func (agent *Agent) AddCollector(name string, iTbl *ast.Table)
  • func (agent *Agent) AddData(name string, iTbl *ast.Table)
  • func (agent *Agent) AddReporter(name string, iTbl *ast.Table)
• type AgentConf
• type Collector
• type CommonConfig
• type Config
• type Data
• type DataConf
• type EtcdConf
• type Processer
  • func NewProcesser() *Processer
  • func (pro *Processer) AddReporter(name string, reporter Reporter)
  • func (pro *Processer) Close()
  • func (pro *Processer) InitChannels(name string, dataC *DataConf, data Data) error
  • func (pro *Processer) Route(name string, datas interface{}) error
  • func (pro *Processer) Start() error
• type Reporter

Variables

var Collectors map[string]Collector

Collectors ...

var Datas map[string]Data

Datas ...

var Logger *zap.Logger

Logger ....

var Reporters map[string]Reporter

Reporters ...

Functions

func AddCollector

func AddCollector(name string, collector Collector)

AddCollector ....

func AddData

func AddData(name string, data Data)

AddData ....

func AddReporter

func AddReporter(name string, reporter Reporter)

AddReporter ....

func InitLogger

func InitLogger(logpath, loglevel string, IsDebug bool)

InitLogger init log

func LoadConfig

func LoadConfig(file string)

func LogInit

func LogInit(lp string, lv string, isDebug bool)

LogInit ...

func Name

func Name() string

Name ...

func Start

func Start() error

Start start agent server

func Stop

func Stop() error

Stop stop agent server

func Writer

func Writer(name string, in interface{}) error

Writer ...

Types

type Agent

type Agent struct {
	Name       string
	Collectors map[string]Collector
	Reporters  map[string]Reporter
	Processer  *Processer
}

Agent ...

func New

func New() *Agent

New new agent

func (*Agent) AddCollector

func (agent *Agent) AddCollector(name string, iTbl *ast.Table)

AddCollector ...

func (*Agent) AddData

func (agent *Agent) AddData(name string, iTbl *ast.Table)

AddData ...

func (*Agent) AddReporter

func (agent *Agent) AddReporter(name string, iTbl *ast.Table)

AddReporter ...

type AgentConf

type AgentConf struct {
	Name   string
	UseEnv bool
	Env    string
	Size   int
}

AgentConf ...

type Collector

type Collector interface {
	Init() error
	Start() error
	Close() error
}

Collector ...

type CommonConfig

type CommonConfig struct {
	Version  string
	IsDebug  bool
	LogLevel string
	LogPath  string
	Hostname string
}

CommonConfig ...

type Config

type Config struct {
	Common           *CommonConfig
	AgentC           *AgentConf
	EtcdC            *EtcdConf
	DataC            map[string]*DataConf
	CollectorFilters map[string]struct{}
	ReporterFilters  map[string]struct{}
}

Config ...

var Conf *Config

type Data

type Data interface {
	Encoder() error
	Decoder() error
}

Data ...

type DataConf

type DataConf struct {
	ChanSize   int
	Collectors []string
	Reporters  []string
}

DataConf ...

type EtcdConf

type EtcdConf struct {
	Addrs     []string
	Dltimeout int
	Rqtimeout int
	WatchDir  string
	TTL       int64
}

type Processer

type Processer struct {
	Channels map[string]chan interface{}
	// contains filtered or unexported fields
}

Processer ...

func NewProcesser

func NewProcesser() *Processer

NewProcesser ....

func (*Processer) AddReporter

func (pro *Processer) AddReporter(name string, reporter Reporter)

AddReporter 。。。

func (*Processer) Close

func (pro *Processer) Close()

Close stop processer

func (*Processer) InitChannels

func (pro *Processer) InitChannels(name string, dataC *DataConf, data Data) error

InitChannels 。。。

func (*Processer) Route

func (pro *Processer) Route(name string, datas interface{}) error

Route 。。。

func (*Processer) Start

func (pro *Processer) Start() error

Start 。。。

type Reporter

type Reporter interface {
	Init() error
	Start() error
	Close() error
	Writer(interface{}) error
}

Reporter ...