redis

Documentation

Index

• type Config
• type RedisInputServer
  • func (redisServer *RedisInputServer) Init(config yaml.MapSlice, receiver input.Receiver) error
  • func (redisServer *RedisInputServer) Start() error
  • func (redisServer *RedisInputServer) Stop() error
  • func (redisServer *RedisInputServer) 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"`
	InputQueue   string `yaml:"input_queue"`
	WorkingQueue string `yaml:"working_queue"`
	JsonDecode   bool   `yaml:"json_decode"`
}

type RedisInputServer

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

func (*RedisInputServer) Init

func (redisServer *RedisInputServer) Init(config yaml.MapSlice, receiver input.Receiver) error

func (*RedisInputServer) Start

func (redisServer *RedisInputServer) Start() error

func (*RedisInputServer) Stop

func (redisServer *RedisInputServer) Stop() error

func (*RedisInputServer) ValidateConfig

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