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 json.RawMessage, sender buffer.Sender) error
  • func (redisServer *RedisServer) Start() error
  • func (s *RedisServer) Stop() error

Types

type Config

type Config struct {
	Host     string   `json:"host"`
	Port     int      `json:"port"`
	Db       int64    `json:"db"`
	Password string   `json:"password"`
	Keys     []string `json:"keys"`
}

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 json.RawMessage, sender buffer.Sender) error

func (*RedisServer) Start

func (redisServer *RedisServer) Start() error

func (*RedisServer) Stop

func (s *RedisServer) Stop() error