Documentation ¶
Overview ¶
Package queue is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) GetPredefinedQueue ¶
func (m *MockProvider) GetPredefinedQueue(arg0 string) (provider.Queue, error)
GetPredefinedQueue mocks base method.
type MockProviderMockRecorder ¶
type MockProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockProviderMockRecorder is the mock recorder for MockProvider.
func (*MockProviderMockRecorder) GetPredefinedQueue ¶
func (mr *MockProviderMockRecorder) GetPredefinedQueue(arg0 interface{}) *gomock.Call
GetPredefinedQueue indicates an expected call of GetPredefinedQueue.
func (*MockProviderMockRecorder) GetQueue ¶
func (mr *MockProviderMockRecorder) GetQueue(arg0, arg1 interface{}) *gomock.Call
GetQueue indicates an expected call of GetQueue.
type Provider ¶
type Provider interface { GetPredefinedQueue(string) (provider.Queue, error) GetQueue(string, *types.DataBlob) (provider.Queue, error) }
Provider is used to get a queue
func NewAsyncQueueProvider ¶
func NewAsyncQueueProvider(cfg map[string]config.AsyncWorkflowQueueProvider) (Provider, error)
NewAsyncQueueProvider returns a new async queue provider
Click to show internal directories.
Click to hide internal directories.