Documentation
¶
Index ¶
- type RedisDataType
- type RedisOutput
- func (out *RedisOutput) Close()
- func (out *RedisOutput) Connect() error
- func (out *RedisOutput) GetNameByIP(ip string) string
- func (out *RedisOutput) Init(beat string, config outputs.MothershipConfig, topology_expire int) error
- func (out *RedisOutput) PublishEvent(ts time.Time, event common.MapStr) error
- func (out *RedisOutput) PublishIPs(name string, localAddrs []string) error
- func (out *RedisOutput) Reconnect()
- func (out *RedisOutput) RedisConnect(db int) (redis.Conn, error)
- func (out *RedisOutput) SendMessagesGoroutine()
- func (out *RedisOutput) UpdateLocalTopologyMap(conn redis.Conn)
- type RedisQueueMsg
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisDataType ¶
type RedisDataType uint16
const ( RedisListType RedisDataType = iota RedisChannelType )
type RedisOutput ¶
type RedisOutput struct {
Index string
Conn redis.Conn
TopologyExpire time.Duration
ReconnectInterval time.Duration
Hostname string
Password string
Db int
DbTopology int
Timeout time.Duration
DataType RedisDataType
FlushInterval time.Duration
TopologyMap map[string]string
// contains filtered or unexported fields
}
func (*RedisOutput) Close ¶
func (out *RedisOutput) Close()
func (*RedisOutput) Connect ¶
func (out *RedisOutput) Connect() error
func (*RedisOutput) GetNameByIP ¶
func (out *RedisOutput) GetNameByIP(ip string) string
func (*RedisOutput) Init ¶
func (out *RedisOutput) Init(beat string, config outputs.MothershipConfig, topology_expire int) error
func (*RedisOutput) PublishEvent ¶
func (*RedisOutput) PublishIPs ¶
func (out *RedisOutput) PublishIPs(name string, localAddrs []string) error
func (*RedisOutput) Reconnect ¶
func (out *RedisOutput) Reconnect()
func (*RedisOutput) RedisConnect ¶
func (out *RedisOutput) RedisConnect(db int) (redis.Conn, error)
func (*RedisOutput) SendMessagesGoroutine ¶
func (out *RedisOutput) SendMessagesGoroutine()
func (*RedisOutput) UpdateLocalTopologyMap ¶
func (out *RedisOutput) UpdateLocalTopologyMap(conn redis.Conn)
type RedisQueueMsg ¶
type RedisQueueMsg struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.