redis

Documentation

Index

• Constants
• type Broker
  • func New(o Options, lo logf.Logger) *Broker
  • func (b *Broker) Consume(ctx context.Context, work chan []byte, queue string)
  • func (b *Broker) Enqueue(ctx context.Context, msg []byte, queue string) error
• type Options

Constants

const (
	DefaultPollPeriod = time.Second
)

Types

type Broker

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

func New

func New(o Options, lo logf.Logger) *Broker

func (*Broker) Consume

func (b *Broker) Consume(ctx context.Context, work chan []byte, queue string)

func (*Broker) Enqueue

func (b *Broker) Enqueue(ctx context.Context, msg []byte, queue string) error

type Options

type Options struct {
	Addrs        []string      `yaml:"addrs"`
	Password     string        `yaml:"password"`
	DB           int           `yaml:"db"`
	DialTimeout  time.Duration `yaml:"dial_timeout"`
	ReadTimeout  time.Duration `yaml:"read_timeout"`
	WriteTimeout time.Duration `yaml:"write_timeout"`
	IdleTimeout  time.Duration `yaml:"idle_timeout"`
	MinIdleConns int           `yaml:"min_idle_conns"`
	PollPeriod   time.Duration `yaml:"poll_period"`
}