queue

Documentation

Overview

Package queue provides queueing semantics.

Index

• type Consumer
• type Mock
  • func (m *Mock) Consume(ctx context.Context) (<-chan amqp.Delivery, error)
  • func (m *Mock) Publish(ctx context.Context, pub interface{}, priority uint8) error
• type MockFactory
  • func (f *MockFactory) NewPublisher(ctx context.Context) (Publisher, error)
• type Publisher
• type PublisherFactory
• type Queue

Types

type Consumer

type Consumer interface {
	Consume(context.Context) (<-chan amqp.Delivery, error)
}

Consumer allows consuming of published items.

type Mock

type Mock struct {
	mock.Mock
}

Mock mocks the Queue interface.

func (*Mock) Consume

func (m *Mock) Consume(ctx context.Context) (<-chan amqp.Delivery, error)

Consume mocks the corresponding method on the Queue interface.

func (*Mock) Publish

func (m *Mock) Publish(ctx context.Context, pub interface{}, priority uint8) error

Publish mocks the corresponding method on the Queue interface.

type MockFactory

type MockFactory struct {
	mock.Mock
}

MockFactory mocks the Factory interface.

func (*MockFactory) NewPublisher

func (f *MockFactory) NewPublisher(ctx context.Context) (Publisher, error)

NewPublisher mocks the corresponding method on the Factory interface.

type Publisher

type Publisher interface {
	Publish(context.Context, interface{}, uint8) error
}

Publisher allows publishing of sniffed items.

type PublisherFactory

type PublisherFactory interface {
	NewPublisher(context.Context) (Publisher, error)
}

PublisherFactory creates Publishers.

type Queue

type Queue interface {
	Publisher
	Consumer
}

Queue allows both publishing as well as consuming.