agent

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

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

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

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

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

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

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

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

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

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