consumers

Documentation

Index

• Variables
• type Consumer
• type Multiplexer
  • func NewMultiplexer() *Multiplexer
  • func (m *Multiplexer) ConsumeMessage(ctx context.Context, message []byte) error
  • func (m *Multiplexer) RegisterConsumer(id string, consumer Consumer) error
  • func (m Multiplexer) ResultLogger() ResultLogger
  • func (m *Multiplexer) SetResultLogger(logger ResultLogger)
• type ReflectConsumer
  • func NewReflectConsumer(handler interface{}, timeout time.Duration, df *redsync.Redsync) (*ReflectConsumer, error)
  • func (c ReflectConsumer) ConsumeMessage(ctx context.Context, message []byte) error
  • func (c ReflectConsumer) ResultLogger() ResultLogger
• type ResultLogger

Variables

var ErrBadMessage = errors.New("bad message")

var ErrPermanent = errors.New("permanent error")

var ErrRetryLater = errors.New("retry later")

Types

type Consumer

type Consumer interface {
	ConsumeMessage(ctx context.Context, message []byte) error
	ResultLogger() ResultLogger
}

type Multiplexer

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

func NewMultiplexer

func NewMultiplexer() *Multiplexer

func (*Multiplexer) ConsumeMessage

func (m *Multiplexer) ConsumeMessage(ctx context.Context, message []byte) error

func (*Multiplexer) RegisterConsumer

func (m *Multiplexer) RegisterConsumer(id string, consumer Consumer) error

func (Multiplexer) ResultLogger

func (m Multiplexer) ResultLogger() ResultLogger

func (*Multiplexer) SetResultLogger

func (m *Multiplexer) SetResultLogger(logger ResultLogger)

type ReflectConsumer

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

func NewReflectConsumer

func NewReflectConsumer(handler interface{}, timeout time.Duration, df *redsync.Redsync) (*ReflectConsumer, error)

func (ReflectConsumer) ConsumeMessage

func (c ReflectConsumer) ConsumeMessage(ctx context.Context, message []byte) error

func (ReflectConsumer) ResultLogger

func (c ReflectConsumer) ResultLogger() ResultLogger

type ResultLogger

type ResultLogger func(err error)