redis

Documentation

Index

• type Config
• type RedisInputServer
  • func (redisServer *RedisInputServer) Init(config json.RawMessage, receiver input.Receiver) error
  • func (redisServer *RedisInputServer) Start() error
  • func (redisServer *RedisInputServer) Stop() error

Types

type Config

type Config struct {
	Host       string `json:"host"`
	Port       int    `json:"port"`
	Db         int64  `json:"db"`
	Password   string `json:"password"`
	KeyName    string `json:"keyName"`
	JsonDecode bool   `json:"decode"`
}

type RedisInputServer

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

func (*RedisInputServer) Init

func (redisServer *RedisInputServer) Init(config json.RawMessage, receiver input.Receiver) error

func (*RedisInputServer) Start

func (redisServer *RedisInputServer) Start() error

func (*RedisInputServer) Stop

func (redisServer *RedisInputServer) Stop() error