redis

Documentation

Index

• type RedisList
  • func (d *RedisList) Cleanup() error
  • func (d *RedisList) ClearWork() error
  • func (d *RedisList) GetWork() (io.Reader, error)
  • func (d *RedisList) HandleFailure() error
  • func (d *RedisList) Init() error
  • func (d *RedisList) LoadEnv(prefix string) error
  • func (d *RedisList) LoadFlags() error
• type RedisPubSub
  • func (d *RedisPubSub) Cleanup() error
  • func (d *RedisPubSub) ClearWork() error
  • func (d *RedisPubSub) GetWork() (io.Reader, error)
  • func (d *RedisPubSub) HandleFailure() error
  • func (d *RedisPubSub) Init() error
  • func (d *RedisPubSub) LoadEnv(prefix string) error
  • func (d *RedisPubSub) LoadFlags() error

Types

type RedisList

type RedisList struct {
	Client   *redis.Client
	Host     string
	Port     string
	Password string
	Key      string
}

func (*RedisList) Cleanup

func (d *RedisList) Cleanup() error

func (*RedisList) ClearWork

func (d *RedisList) ClearWork() error

func (*RedisList) GetWork

func (d *RedisList) GetWork() (io.Reader, error)

func (*RedisList) HandleFailure

func (d *RedisList) HandleFailure() error

func (*RedisList) Init

func (d *RedisList) Init() error

func (*RedisList) LoadEnv

func (d *RedisList) LoadEnv(prefix string) error

func (*RedisList) LoadFlags

func (d *RedisList) LoadFlags() error

type RedisPubSub

type RedisPubSub struct {
	Client   *redis.Client
	Host     string
	Port     string
	Password string
	Key      string
}

func (*RedisPubSub) Cleanup

func (d *RedisPubSub) Cleanup() error

func (*RedisPubSub) ClearWork

func (d *RedisPubSub) ClearWork() error

func (*RedisPubSub) GetWork

func (d *RedisPubSub) GetWork() (io.Reader, error)

func (*RedisPubSub) HandleFailure

func (d *RedisPubSub) HandleFailure() error

func (*RedisPubSub) Init

func (d *RedisPubSub) Init() error

func (*RedisPubSub) LoadEnv

func (d *RedisPubSub) LoadEnv(prefix string) error

func (*RedisPubSub) LoadFlags

func (d *RedisPubSub) LoadFlags() error