producers

Documentation

Index

• type Base
  • func (p *Base) Put(message queue.Message) error
  • func (p *Base) Register(m *Multiplexer, queueID string) error
• type Multiplexer
  • func NewMultiplexer(q Queue) *Multiplexer
  • func (m *Multiplexer) NewSubqueue(id string) (Queue, error)
• type Queue

Types

type Base

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

func (*Base) Put

func (p *Base) Put(message queue.Message) error

func (*Base) Register

func (p *Base) Register(m *Multiplexer, queueID string) error

type Multiplexer

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

func NewMultiplexer

func NewMultiplexer(q Queue) *Multiplexer

func (*Multiplexer) NewSubqueue

func (m *Multiplexer) NewSubqueue(id string) (Queue, error)

type Queue

type Queue interface {
	Put(message queue.Message) error
}