Versions in this module Expand all Collapse all v0 v0.5.0 Mar 31, 2015 Changes in this version + const RotatorMaxFiles + func LoadGeoIPData() + func PrintPublishEvent(event common.MapStr) + type ElasticsearchOutputType struct + Index string + TopologyExpire int + TopologyMap map[string]string + func (out *ElasticsearchOutputType) EnableTTL() error + func (out *ElasticsearchOutputType) GetNameByIP(ip string) string + func (out *ElasticsearchOutputType) Init(config config.MothershipConfig, topology_expire int) error + func (out *ElasticsearchOutputType) PublishEvent(ts time.Time, event common.MapStr) error + func (out *ElasticsearchOutputType) PublishIPs(name string, localAddrs []string) error + func (out *ElasticsearchOutputType) UpdateLocalTopologyMap() + type FileOutputType struct + func (out *FileOutputType) Init(config config.MothershipConfig) error + func (out *FileOutputType) PublishEvent(ts time.Time, event common.MapStr) error + func (out *FileOutputType) PublishIPs(name string, localAddrs []string) error + func (out *FileOutputType) UpdateLocalTopologyMap() + type FileRotator struct + KeepFiles int + Name string + Path string + RotateEveryBytes uint64 + func (rotator *FileRotator) CheckIfConfigSane() error + func (rotator *FileRotator) CreateDirectory() error + func (rotator *FileRotator) FileExists(file_no int) bool + func (rotator *FileRotator) FilePath(file_no int) string + func (rotator *FileRotator) Rotate() error + func (rotator *FileRotator) WriteLine(line []byte) error + type OutputInterface interface + GetNameByIP func(ip string) string + PublishEvent func(ts time.Time, event common.MapStr) error + PublishIPs func(name string, localAddrs []string) error + type PublishedTopology struct + IPs string + Name string + type PublisherType struct + ElasticsearchOutput ElasticsearchOutputType + FileOutput FileOutputType + Index string + Output []OutputInterface + Queue chan common.MapStr + RedisOutput RedisOutputType + RefreshTopologyTimer <-chan time.Time + TopologyOutput OutputInterface + var Publisher PublisherType + func (publisher *PublisherType) GetServerName(ip string) string + func (publisher *PublisherType) Init(publishDisabled bool) error + func (publisher *PublisherType) PublishTopology(params ...string) error + func (publisher *PublisherType) UpdateTopologyPeriodically() + type RedisDataType uint16 + const RedisChannelType + const RedisListType + type RedisOutputType struct + Conn redis.Conn + DataType RedisDataType + Db int + DbTopology int + FlushInterval time.Duration + Hostname string + Index string + Password string + ReconnectInterval time.Duration + Timeout time.Duration + TopologyExpire time.Duration + TopologyMap map[string]string + func (out *RedisOutputType) Close() + func (out *RedisOutputType) Connect() error + func (out *RedisOutputType) GetNameByIP(ip string) string + func (out *RedisOutputType) Init(config config.MothershipConfig, topology_expire int) error + func (out *RedisOutputType) PublishEvent(ts time.Time, event common.MapStr) error + func (out *RedisOutputType) PublishIPs(name string, localAddrs []string) error + func (out *RedisOutputType) Reconnect() + func (out *RedisOutputType) RedisConnect(db int) (redis.Conn, error) + func (out *RedisOutputType) SendMessagesGoroutine() + func (out *RedisOutputType) UpdateLocalTopologyMap(conn redis.Conn) + type RedisQueueMsg struct + type Topology struct + Ip string + Name string
Go to main page