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
  • func (b *Broker) EnqueueScheduled(ctx context.Context, msg []byte, queue string, ts time.Time) error
  • func (r *Broker) GetPending(ctx context.Context, queue string) ([]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

func (*Broker) EnqueueScheduled

func (b *Broker) EnqueueScheduled(ctx context.Context, msg []byte, queue string, ts time.Time) error

func (*Broker) GetPending

func (r *Broker) GetPending(ctx context.Context, queue string) ([]string, error)

type Options

type Options struct {
	Addrs        []string
	Password     string
	DB           int
	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	IdleTimeout  time.Duration
	MinIdleConns int
	PollPeriod   time.Duration
}