redis

Documentation

Index

• type RedisList
  • func (d *RedisList) Cleanup() error
  • func (d *RedisList) Init() error
  • func (d *RedisList) LoadEnv(prefix string) error
  • func (d *RedisList) LoadFlags() error
  • func (d *RedisList) Push(r io.Reader) error
• type RedisPubSub
  • func (d *RedisPubSub) Cleanup() error
  • func (d *RedisPubSub) Init() error
  • func (d *RedisPubSub) LoadEnv(prefix string) error
  • func (d *RedisPubSub) LoadFlags() error
  • func (d *RedisPubSub) Push(r io.Reader) error
• type RedisStream
  • func (d *RedisStream) Cleanup() error
  • func (d *RedisStream) Init() error
  • func (d *RedisStream) LoadEnv(prefix string) error
  • func (d *RedisStream) LoadFlags() error
  • func (d *RedisStream) Push(r io.Reader) error

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) Init

func (d *RedisList) Init() error

func (*RedisList) LoadEnv

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

func (*RedisList) LoadFlags

func (d *RedisList) LoadFlags() error

func (*RedisList) Push

func (d *RedisList) Push(r io.Reader) 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) Init

func (d *RedisPubSub) Init() error

func (*RedisPubSub) LoadEnv

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

func (*RedisPubSub) LoadFlags

func (d *RedisPubSub) LoadFlags() error

func (*RedisPubSub) Push

func (d *RedisPubSub) Push(r io.Reader) error

type RedisStream

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

func (*RedisStream) Cleanup

func (d *RedisStream) Cleanup() 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

func (*RedisStream) Push

func (d *RedisStream) Push(r io.Reader) error