inmem

Documentation

Index

• type InmemBroker
  • func NewInmemBroker() *InmemBroker
  • func (i *InmemBroker) Close() error
  • func (i *InmemBroker) Consumer(q string) (broker.Consumer, error)
  • func (i *InmemBroker) Publisher(q string) (broker.Publisher, error)
• type InmemConsumer
  • func (i *InmemConsumer) Ack() error
  • func (i *InmemConsumer) Close() error
  • func (i *InmemConsumer) Consume(out interface{}) error
  • func (i *InmemConsumer) ConsumeAck(out interface{}) error
  • func (i *InmemConsumer) ConsumeTimeout(out interface{}, timeout time.Duration) error
  • func (i *InmemConsumer) Nack() error
• type InmemPublisher
  • func (i *InmemPublisher) Close() error
  • func (i *InmemPublisher) Publish(in interface{}) error

Types

type InmemBroker

type InmemBroker struct {
	Closed bool
	Queues map[string][]interface{}
	// contains filtered or unexported fields
}

InmemBroker implements the Broker interface in-memory

func NewInmemBroker

func NewInmemBroker() *InmemBroker

func (*InmemBroker) Close

func (i *InmemBroker) Close() error

func (*InmemBroker) Consumer

func (i *InmemBroker) Consumer(q string) (broker.Consumer, error)

func (*InmemBroker) Publisher

func (i *InmemBroker) Publisher(q string) (broker.Publisher, error)

type InmemConsumer

type InmemConsumer struct {
	Broker      *InmemBroker
	Queue       string
	Closed      bool
	NeedAck     bool
	LastDequeue interface{}
}

InmemConsumer implements the Consumer interface

func (*InmemConsumer) Ack

func (i *InmemConsumer) Ack() error

func (*InmemConsumer) Close

func (i *InmemConsumer) Close() error

func (*InmemConsumer) Consume

func (i *InmemConsumer) Consume(out interface{}) error

func (*InmemConsumer) ConsumeAck

func (i *InmemConsumer) ConsumeAck(out interface{}) error

func (*InmemConsumer) ConsumeTimeout

func (i *InmemConsumer) ConsumeTimeout(out interface{}, timeout time.Duration) error

func (*InmemConsumer) Nack

func (i *InmemConsumer) Nack() error

type InmemPublisher

type InmemPublisher struct {
	Broker *InmemBroker
	Queue  string
	Closed bool
}

InmemConsumer implements the Publisher interface

func (*InmemPublisher) Close

func (i *InmemPublisher) Close() error

func (*InmemPublisher) Publish

func (i *InmemPublisher) Publish(in interface{}) error