redis

Documentation

Index

• type RedisConfig
• type RedisModule
  • func (module *RedisModule) Name() string
  • func (module *RedisModule) Setup()
  • func (module *RedisModule) Start() error
  • func (module *RedisModule) Stop() error
• type RedisQueue
  • func (module *RedisQueue) Close(k string) error
  • func (module *RedisQueue) Consume(q *queue.QueueConfig, consumer *queue.ConsumerConfig, offsetStr string) (ctx *queue.Context, messages []queue.Message, timeout bool, err error)
  • func (module *RedisQueue) Depth(k string) int64
  • func (module *RedisQueue) GetQueues() []string
  • func (module *RedisQueue) Init(k string) error
  • func (module *RedisQueue) LatestOffset(string) string
  • func (module *RedisQueue) Name() string
  • func (module *RedisQueue) Pop(k string, timeoutDuration time.Duration) (data []byte, timeout bool)
  • func (module *RedisQueue) Push(k string, v []byte) error

Types

type RedisConfig

type RedisConfig struct {
	Enabled  bool   `config:"enabled"`
	Host     string `config:"host"`
	Port     int    `config:"port"`
	Username string `config:"username"`
	Password string `config:"password"`
	PoolSize int    `config:"pool_size"`
	Db       int    `config:"db"`
}

type RedisModule

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

func (*RedisModule) Name

func (module *RedisModule) Name() string

func (*RedisModule) Setup

func (module *RedisModule) Setup()

func (*RedisModule) Start

func (module *RedisModule) Start() error

func (*RedisModule) Stop

func (module *RedisModule) Stop() error

type RedisQueue

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

func (*RedisQueue) Close

func (module *RedisQueue) Close(k string) error

func (*RedisQueue) Consume

func (module *RedisQueue) Consume(q *queue.QueueConfig, consumer *queue.ConsumerConfig, offsetStr string) (ctx *queue.Context, messages []queue.Message, timeout bool, err error)

func (*RedisQueue) Depth

func (module *RedisQueue) Depth(k string) int64

func (*RedisQueue) GetQueues

func (module *RedisQueue) GetQueues() []string

func (*RedisQueue) Init

func (module *RedisQueue) Init(k string) error

func (*RedisQueue) LatestOffset

func (module *RedisQueue) LatestOffset(string) string

func (*RedisQueue) Name

func (module *RedisQueue) Name() string

func (*RedisQueue) Pop

func (module *RedisQueue) Pop(k string, timeoutDuration time.Duration) (data []byte, timeout bool)

func (*RedisQueue) Push

func (module *RedisQueue) Push(k string, v []byte) error