redis

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

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 (out *RedisOutput) PublishEvent(ts time.Time, event common.MapStr) error

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
}