redis

Documentation

Index

• Variables
• 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
• type RedisStream
  • func (d *RedisStream) Cleanup() error
  • func (d *RedisStream) ClearWork() error
  • func (d *RedisStream) GetWork() (io.Reader, error)
  • func (d *RedisStream) HandleFailure() error
  • func (d *RedisStream) Init() error
  • func (d *RedisStream) LoadEnv(prefix string) error
  • func (d *RedisStream) LoadFlags() error
• type StreamOp

Variables

var (
	StreamOpAck = StreamOp("ack")
	StreamOpDel = StreamOp("del")
)

Types

type RedisList

type RedisList struct {
	Client   *redis.Client
	Host     string
	Port     string
	Password string
	Key      string
	// TLS
	EnableTLS   *bool
	TLSInsecure *bool
	TLSCert     *string
	TLSKey      *string
	TLSCA       *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
	// TLS
	EnableTLS   *bool
	TLSInsecure *bool
	TLSCert     *string
	TLSKey      *string
	TLSCA       *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

type RedisStream

type RedisStream struct {
	Client        *redis.Client
	Host          string
	Port          string
	Password      string
	ConsumerName  *string
	ConsumerGroup *string
	Key           string
	ValueKeys     []string
	MessageID     *string
	ClearOp       *StreamOp
	FailOp        *StreamOp
	// TLS
	EnableTLS   *bool
	TLSInsecure *bool
	TLSCert     *string
	TLSKey      *string
	TLSCA       *string
}

func (*RedisStream) Cleanup

func (d *RedisStream) Cleanup() error

func (*RedisStream) ClearWork

func (d *RedisStream) ClearWork() error

func (*RedisStream) GetWork

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

func (*RedisStream) HandleFailure

func (d *RedisStream) HandleFailure() error

func (*RedisStream) Init

func (d *RedisStream) Init() error

func (*RedisStream) LoadEnv

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

func (*RedisStream) LoadFlags

func (d *RedisStream) LoadFlags() error

type StreamOp

type StreamOp string