redis

package
Version: v1.0.0-beta2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 13, 2015 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

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(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
}

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL