redis

Documentation

Index

• type Config
• type RedisQueue
  • func NewRedisQueue(config Config, key string) *RedisQueue
  • func (redisQueue *RedisQueue) Start()
• type RedisServer
  • func (redisServer *RedisServer) Init(config yaml.MapSlice, sender buffer.Sender) error
  • func (redisServer *RedisServer) Start() error
  • func (s *RedisServer) Stop() error
  • func (redisServer *RedisServer) ValidateConfig(config *Config) error

Types

type Config

type Config struct {
	Host       string   `yaml:"host"`
	Port       int      `yaml:"port"`
	Db         int64    `yaml:"db"`
	Password   string   `yaml:"password"`
	CopyQueues []string `yaml:"copy_queues"`
}

type RedisQueue

type RedisQueue struct {
	// contains filtered or unexported fields
}

func NewRedisQueue

func NewRedisQueue(config Config, key string) *RedisQueue

func (*RedisQueue) Start

func (redisQueue *RedisQueue) Start()

type RedisServer

type RedisServer struct {
	// contains filtered or unexported fields
}

func (*RedisServer) Init

func (redisServer *RedisServer) Init(config yaml.MapSlice, sender buffer.Sender) error

func (*RedisServer) Start

func (redisServer *RedisServer) Start() error

func (*RedisServer) Stop

func (s *RedisServer) Stop() error

func (*RedisServer) ValidateConfig

func (redisServer *RedisServer) ValidateConfig(config *Config) error