Documentation ¶
Index ¶
- Variables
- func CheckAgent(configFile string)
- func Ci2float(i interface{}) (o interface{}, err error)
- func Ci2int(i interface{}) (o interface{}, err error)
- func Ci2string(i interface{}) (o string, err error)
- func InitDefault(conf map[string]string, sender Sender) error
- func InitEnv()
- func InitKafka(conf map[string]string, sender Sender) error
- func InitLocalIps()
- func LoadRawConfig(f *flag.Flag)
- func MarshaLogLines(loglines []*LogLine) []byte
- func ProcessStdin() error
- func ReadConfig(cfgFile string) map[string]map[string]string
- func RegisterNewSender(name string, init func(map[string]string, Sender) error, get func() Sender)
- func TimerCheck()
- func WatchFiles(configFile string)
- type Configuration
- type DefaultSender
- type File
- type KafkaProducer
- type KafkaSender
- type LogLine
- type Rule
- type Sender
- type SenderRegister
- type Worker
Constants ¶
This section is empty.
Variables ¶
View Source
var Conf = &Configuration{ WatchDir: "", registeredSenders: make(map[string]*SenderRegister), }
View Source
var LocalIps []string //本地IP
View Source
var Locker sync.Mutex
View Source
var Root string //根目录路径
View Source
var WORKER_NUM = runtime.GOMAXPROCS(runtime.NumCPU())
worker的数控为最大CPU核数
监听的路径-文件映射
Functions ¶
func MarshaLogLines ¶
func RegisterNewSender ¶
func TimerCheck ¶
func TimerCheck()
Types ¶
type Configuration ¶
type Configuration struct { WatchDir string ReadWholeLog bool ReadAlway bool SenderName string IsPoll bool // contains filtered or unexported fields }
配置结构
type DefaultSender ¶
type DefaultSender struct {
// contains filtered or unexported fields
}
func (*DefaultSender) Send ¶
func (self *DefaultSender) Send(ll *LogLine)
func (*DefaultSender) Stop ¶
func (self *DefaultSender) Stop() error
type KafkaProducer ¶
type KafkaProducer struct {
// contains filtered or unexported fields
}
func NewKafkaProducer ¶
func NewKafkaProducer(brokers []string, topic string, bufferTime, bufferBytes, batchSz int) (*KafkaProducer, error)
构造生产者
type KafkaSender ¶
type KafkaSender struct {
// contains filtered or unexported fields
}
output to kafka
func (*KafkaSender) Name ¶
func (self *KafkaSender) Name() string
func (*KafkaSender) Receive ¶
func (self *KafkaSender) Receive()
func (*KafkaSender) Send ¶
func (self *KafkaSender) Send(ll *LogLine)
func (*KafkaSender) SetConfig ¶
func (self *KafkaSender) SetConfig(obj interface{}) error
func (*KafkaSender) Stop ¶
func (self *KafkaSender) Stop() error
type Rule ¶
type Rule struct {
// contains filtered or unexported fields
}
规则引擎
func LoadConfigFromFile ¶
载入自定义配置文件
type Sender ¶
type Sender interface { Send(*LogLine) Receive() SetConfig(interface{}) error Name() string Stop() error }
sender abstract
type SenderRegister ¶
type SenderRegister struct {
// contains filtered or unexported fields
}
func (*SenderRegister) InitSender ¶
func (self *SenderRegister) InitSender(val map[string]string) (sender Sender, err error)
初始化Sender
Click to show internal directories.
Click to hide internal directories.