implqueue

Documentation

Index

• func NewPubsubQueue(config PubsubConfigs) (goduck.MessagePool, error)
• type MockQueue
  • func NewDefaultQueue(nElems int) *MockQueue
  • func NewMock(items [][]byte) *MockQueue
  • func (m MockQueue) Close() error
  • func (m MockQueue) Done(ctx context.Context, msg goduck.RawMessage) error
  • func (m MockQueue) Failed(ctx context.Context, msg goduck.RawMessage) error
  • func (m MockQueue) IsEmpty() bool
  • func (m *MockQueue) Next(ctx context.Context) (goduck.RawMessage, error)
• type PubsubConfigs

Functions

func NewPubsubQueue

func NewPubsubQueue(config PubsubConfigs) (goduck.MessagePool, error)

NewPubsubQueue creates a new goduck.MessagePool that reads from pubsub. Deprecated: use pubsubqueue.New instead

Types

type MockQueue

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

func NewDefaultQueue

func NewDefaultQueue(nElems int) *MockQueue

func NewMock

func NewMock(items [][]byte) *MockQueue

func (MockQueue) Close

func (m MockQueue) Close() error

func (MockQueue) Done

func (m MockQueue) Done(ctx context.Context, msg goduck.RawMessage) error

func (MockQueue) Failed

func (m MockQueue) Failed(ctx context.Context, msg goduck.RawMessage) error

func (MockQueue) IsEmpty

func (m MockQueue) IsEmpty() bool

IsEmpty tests if all elements in the queue are consumed

func (*MockQueue) Next

func (m *MockQueue) Next(ctx context.Context) (goduck.RawMessage, error)

type PubsubConfigs

type PubsubConfigs struct {
	ProjectID    string
	Subscription string
}

PubsubConfigs contains the configs for pubsub connection