queue

Documentation

Overview

Package queue is a generated GoMock package.

Index

• type MockProvider
  • func NewMockProvider(ctrl *gomock.Controller) *MockProvider
  • func (m *MockProvider) EXPECT() *MockProviderMockRecorder
  • func (m *MockProvider) GetAsyncQueueConsumer(domain string) (messaging.Consumer, error)
  • func (m *MockProvider) GetAsyncQueueProducer(domain string) (messaging.Producer, error)
• type MockProviderMockRecorder
  • func (mr *MockProviderMockRecorder) GetAsyncQueueConsumer(domain interface{}) *gomock.Call
  • func (mr *MockProviderMockRecorder) GetAsyncQueueProducer(domain interface{}) *gomock.Call
• type Provider
  • func NewAsyncQueueProvider(cfg map[string]config.AsyncWorkflowQueueProvider, params *provider.Params) (Provider, error)

Types

type MockProvider

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

MockProvider is a mock of Provider interface.

func NewMockProvider

func NewMockProvider(ctrl *gomock.Controller) *MockProvider

NewMockProvider creates a new mock instance.

func (*MockProvider) EXPECT

func (m *MockProvider) EXPECT() *MockProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProvider) GetAsyncQueueConsumer

func (m *MockProvider) GetAsyncQueueConsumer(domain string) (messaging.Consumer, error)

GetAsyncQueueConsumer mocks base method.

func (*MockProvider) GetAsyncQueueProducer

func (m *MockProvider) GetAsyncQueueProducer(domain string) (messaging.Producer, error)

GetAsyncQueueProducer mocks base method.

type MockProviderMockRecorder

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

MockProviderMockRecorder is the mock recorder for MockProvider.

func (*MockProviderMockRecorder) GetAsyncQueueConsumer

func (mr *MockProviderMockRecorder) GetAsyncQueueConsumer(domain interface{}) *gomock.Call

GetAsyncQueueConsumer indicates an expected call of GetAsyncQueueConsumer.

func (*MockProviderMockRecorder) GetAsyncQueueProducer

func (mr *MockProviderMockRecorder) GetAsyncQueueProducer(domain interface{}) *gomock.Call

GetAsyncQueueProducer indicates an expected call of GetAsyncQueueProducer.

type Provider

type Provider interface {
	GetAsyncQueueProducer(domain string) (messaging.Producer, error)
	GetAsyncQueueConsumer(domain string) (messaging.Consumer, error)
}

Provider is used to get a queue for a given domain

func NewAsyncQueueProvider

func NewAsyncQueueProvider(cfg map[string]config.AsyncWorkflowQueueProvider, params *provider.Params) (Provider, error)

NewAsyncQueueProvider returns a new async queue provider