Documentation ¶
Index ¶
- type Notifier
- func (_m *Notifier) EXPECT() *Notifier_Expecter
- func (_m *Notifier) GetSystemDefaultTemplate() string
- func (_m *Notifier) PostHookQueueTransformConfigs(ctx context.Context, notificationConfigMap map[string]interface{}) (map[string]interface{}, error)
- func (_m *Notifier) PreHookQueueTransformConfigs(ctx context.Context, notificationConfigMap map[string]interface{}) (map[string]interface{}, error)
- func (_m *Notifier) Send(ctx context.Context, message notification.Message) (bool, error)
- type Notifier_Expecter
- func (_e *Notifier_Expecter) GetSystemDefaultTemplate() *Notifier_GetSystemDefaultTemplate_Call
- func (_e *Notifier_Expecter) PostHookQueueTransformConfigs(ctx interface{}, notificationConfigMap interface{}) *Notifier_PostHookQueueTransformConfigs_Call
- func (_e *Notifier_Expecter) PreHookQueueTransformConfigs(ctx interface{}, notificationConfigMap interface{}) *Notifier_PreHookQueueTransformConfigs_Call
- func (_e *Notifier_Expecter) Send(ctx interface{}, message interface{}) *Notifier_Send_Call
- type Notifier_GetSystemDefaultTemplate_Call
- type Notifier_PostHookQueueTransformConfigs_Call
- func (_c *Notifier_PostHookQueueTransformConfigs_Call) Return(_a0 map[string]interface{}, _a1 error) *Notifier_PostHookQueueTransformConfigs_Call
- func (_c *Notifier_PostHookQueueTransformConfigs_Call) Run(run func(ctx context.Context, notificationConfigMap map[string]interface{})) *Notifier_PostHookQueueTransformConfigs_Call
- type Notifier_PreHookQueueTransformConfigs_Call
- func (_c *Notifier_PreHookQueueTransformConfigs_Call) Return(_a0 map[string]interface{}, _a1 error) *Notifier_PreHookQueueTransformConfigs_Call
- func (_c *Notifier_PreHookQueueTransformConfigs_Call) Run(run func(ctx context.Context, notificationConfigMap map[string]interface{})) *Notifier_PreHookQueueTransformConfigs_Call
- type Notifier_Send_Call
- type Queuer
- func (_m *Queuer) Cleanup(ctx context.Context, filter queues.FilterCleanup) error
- func (_m *Queuer) Dequeue(ctx context.Context, receiverTypes []string, batchSize int, ...) error
- func (_m *Queuer) EXPECT() *Queuer_Expecter
- func (_m *Queuer) Enqueue(ctx context.Context, ms ...notification.Message) error
- func (_m *Queuer) ErrorCallback(ctx context.Context, ms notification.Message) error
- func (_m *Queuer) Stop(ctx context.Context) error
- func (_m *Queuer) SuccessCallback(ctx context.Context, ms notification.Message) error
- func (_m *Queuer) Type() string
- type Queuer_Cleanup_Call
- type Queuer_Dequeue_Call
- type Queuer_Enqueue_Call
- type Queuer_ErrorCallback_Call
- type Queuer_Expecter
- func (_e *Queuer_Expecter) Cleanup(ctx interface{}, filter interface{}) *Queuer_Cleanup_Call
- func (_e *Queuer_Expecter) Dequeue(ctx interface{}, receiverTypes interface{}, batchSize interface{}, ...) *Queuer_Dequeue_Call
- func (_e *Queuer_Expecter) Enqueue(ctx interface{}, ms ...interface{}) *Queuer_Enqueue_Call
- func (_e *Queuer_Expecter) ErrorCallback(ctx interface{}, ms interface{}) *Queuer_ErrorCallback_Call
- func (_e *Queuer_Expecter) Stop(ctx interface{}) *Queuer_Stop_Call
- func (_e *Queuer_Expecter) SuccessCallback(ctx interface{}, ms interface{}) *Queuer_SuccessCallback_Call
- func (_e *Queuer_Expecter) Type() *Queuer_Type_Call
- type Queuer_Stop_Call
- type Queuer_SuccessCallback_Call
- type Queuer_Type_Call
- type ReceiverService
- type ReceiverService_Expecter
- type ReceiverService_Get_Call
- type SubscriptionService
- type SubscriptionService_Expecter
- type SubscriptionService_MatchByLabels_Call
- func (_c *SubscriptionService_MatchByLabels_Call) Return(_a0 []subscription.Subscription, _a1 error) *SubscriptionService_MatchByLabels_Call
- func (_c *SubscriptionService_MatchByLabels_Call) Run(run func(ctx context.Context, namespaceID uint64, labels map[string]string)) *SubscriptionService_MatchByLabels_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Notifier ¶
Notifier is an autogenerated mock type for the Notifier type
func NewNotifier ¶
func NewNotifier(t mockConstructorTestingTNewNotifier) *Notifier
NewNotifier creates a new instance of Notifier. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Notifier) EXPECT ¶
func (_m *Notifier) EXPECT() *Notifier_Expecter
func (*Notifier) GetSystemDefaultTemplate ¶
GetSystemDefaultTemplate provides a mock function with given fields:
func (*Notifier) PostHookQueueTransformConfigs ¶
func (_m *Notifier) PostHookQueueTransformConfigs(ctx context.Context, notificationConfigMap map[string]interface{}) (map[string]interface{}, error)
PostHookQueueTransformConfigs provides a mock function with given fields: ctx, notificationConfigMap
type Notifier_Expecter ¶
type Notifier_Expecter struct {
// contains filtered or unexported fields
}
func (*Notifier_Expecter) GetSystemDefaultTemplate ¶
func (_e *Notifier_Expecter) GetSystemDefaultTemplate() *Notifier_GetSystemDefaultTemplate_Call
GetSystemDefaultTemplate is a helper method to define mock.On call
func (*Notifier_Expecter) PostHookQueueTransformConfigs ¶
func (_e *Notifier_Expecter) PostHookQueueTransformConfigs(ctx interface{}, notificationConfigMap interface{}) *Notifier_PostHookQueueTransformConfigs_Call
PostHookQueueTransformConfigs is a helper method to define mock.On call
- ctx context.Context
- notificationConfigMap map[string]interface{}
func (*Notifier_Expecter) PreHookQueueTransformConfigs ¶
func (_e *Notifier_Expecter) PreHookQueueTransformConfigs(ctx interface{}, notificationConfigMap interface{}) *Notifier_PreHookQueueTransformConfigs_Call
PreHookQueueTransformConfigs is a helper method to define mock.On call
- ctx context.Context
- notificationConfigMap map[string]interface{}
func (*Notifier_Expecter) Send ¶
func (_e *Notifier_Expecter) Send(ctx interface{}, message interface{}) *Notifier_Send_Call
Send is a helper method to define mock.On call
- ctx context.Context
- message notification.Message
type Notifier_GetSystemDefaultTemplate_Call ¶
Notifier_GetSystemDefaultTemplate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSystemDefaultTemplate'
func (*Notifier_GetSystemDefaultTemplate_Call) Return ¶
func (_c *Notifier_GetSystemDefaultTemplate_Call) Return(_a0 string) *Notifier_GetSystemDefaultTemplate_Call
func (*Notifier_GetSystemDefaultTemplate_Call) Run ¶
func (_c *Notifier_GetSystemDefaultTemplate_Call) Run(run func()) *Notifier_GetSystemDefaultTemplate_Call
type Notifier_PostHookQueueTransformConfigs_Call ¶
Notifier_PostHookQueueTransformConfigs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PostHookQueueTransformConfigs'
func (*Notifier_PostHookQueueTransformConfigs_Call) Return ¶
func (_c *Notifier_PostHookQueueTransformConfigs_Call) Return(_a0 map[string]interface{}, _a1 error) *Notifier_PostHookQueueTransformConfigs_Call
func (*Notifier_PostHookQueueTransformConfigs_Call) Run ¶
func (_c *Notifier_PostHookQueueTransformConfigs_Call) Run(run func(ctx context.Context, notificationConfigMap map[string]interface{})) *Notifier_PostHookQueueTransformConfigs_Call
type Notifier_PreHookQueueTransformConfigs_Call ¶
Notifier_PreHookQueueTransformConfigs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PreHookQueueTransformConfigs'
func (*Notifier_PreHookQueueTransformConfigs_Call) Return ¶
func (_c *Notifier_PreHookQueueTransformConfigs_Call) Return(_a0 map[string]interface{}, _a1 error) *Notifier_PreHookQueueTransformConfigs_Call
func (*Notifier_PreHookQueueTransformConfigs_Call) Run ¶
func (_c *Notifier_PreHookQueueTransformConfigs_Call) Run(run func(ctx context.Context, notificationConfigMap map[string]interface{})) *Notifier_PreHookQueueTransformConfigs_Call
type Notifier_Send_Call ¶
Notifier_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'
func (*Notifier_Send_Call) Return ¶
func (_c *Notifier_Send_Call) Return(_a0 bool, _a1 error) *Notifier_Send_Call
func (*Notifier_Send_Call) Run ¶
func (_c *Notifier_Send_Call) Run(run func(ctx context.Context, message notification.Message)) *Notifier_Send_Call
type Queuer ¶
Queuer is an autogenerated mock type for the Queuer type
func NewQueuer ¶
func NewQueuer(t mockConstructorTestingTNewQueuer) *Queuer
NewQueuer creates a new instance of Queuer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Queuer) Dequeue ¶
func (_m *Queuer) Dequeue(ctx context.Context, receiverTypes []string, batchSize int, handlerFn func(context.Context, []notification.Message) error) error
Dequeue provides a mock function with given fields: ctx, receiverTypes, batchSize, handlerFn
func (*Queuer) EXPECT ¶
func (_m *Queuer) EXPECT() *Queuer_Expecter
func (*Queuer) ErrorCallback ¶
ErrorCallback provides a mock function with given fields: ctx, ms
func (*Queuer) SuccessCallback ¶
SuccessCallback provides a mock function with given fields: ctx, ms
type Queuer_Cleanup_Call ¶
Queuer_Cleanup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Cleanup'
func (*Queuer_Cleanup_Call) Return ¶
func (_c *Queuer_Cleanup_Call) Return(_a0 error) *Queuer_Cleanup_Call
func (*Queuer_Cleanup_Call) Run ¶
func (_c *Queuer_Cleanup_Call) Run(run func(ctx context.Context, filter queues.FilterCleanup)) *Queuer_Cleanup_Call
type Queuer_Dequeue_Call ¶
Queuer_Dequeue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Dequeue'
func (*Queuer_Dequeue_Call) Return ¶
func (_c *Queuer_Dequeue_Call) Return(_a0 error) *Queuer_Dequeue_Call
func (*Queuer_Dequeue_Call) Run ¶
func (_c *Queuer_Dequeue_Call) Run(run func(ctx context.Context, receiverTypes []string, batchSize int, handlerFn func(context.Context, []notification.Message) error)) *Queuer_Dequeue_Call
type Queuer_Enqueue_Call ¶
Queuer_Enqueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Enqueue'
func (*Queuer_Enqueue_Call) Return ¶
func (_c *Queuer_Enqueue_Call) Return(_a0 error) *Queuer_Enqueue_Call
func (*Queuer_Enqueue_Call) Run ¶
func (_c *Queuer_Enqueue_Call) Run(run func(ctx context.Context, ms ...notification.Message)) *Queuer_Enqueue_Call
type Queuer_ErrorCallback_Call ¶
Queuer_ErrorCallback_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ErrorCallback'
func (*Queuer_ErrorCallback_Call) Return ¶
func (_c *Queuer_ErrorCallback_Call) Return(_a0 error) *Queuer_ErrorCallback_Call
func (*Queuer_ErrorCallback_Call) Run ¶
func (_c *Queuer_ErrorCallback_Call) Run(run func(ctx context.Context, ms notification.Message)) *Queuer_ErrorCallback_Call
type Queuer_Expecter ¶
type Queuer_Expecter struct {
// contains filtered or unexported fields
}
func (*Queuer_Expecter) Cleanup ¶
func (_e *Queuer_Expecter) Cleanup(ctx interface{}, filter interface{}) *Queuer_Cleanup_Call
Cleanup is a helper method to define mock.On call
- ctx context.Context
- filter queues.FilterCleanup
func (*Queuer_Expecter) Dequeue ¶
func (_e *Queuer_Expecter) Dequeue(ctx interface{}, receiverTypes interface{}, batchSize interface{}, handlerFn interface{}) *Queuer_Dequeue_Call
Dequeue is a helper method to define mock.On call
- ctx context.Context
- receiverTypes []string
- batchSize int
- handlerFn func(context.Context , []notification.Message) error
func (*Queuer_Expecter) Enqueue ¶
func (_e *Queuer_Expecter) Enqueue(ctx interface{}, ms ...interface{}) *Queuer_Enqueue_Call
Enqueue is a helper method to define mock.On call
- ctx context.Context
- ms ...notification.Message
func (*Queuer_Expecter) ErrorCallback ¶
func (_e *Queuer_Expecter) ErrorCallback(ctx interface{}, ms interface{}) *Queuer_ErrorCallback_Call
ErrorCallback is a helper method to define mock.On call
- ctx context.Context
- ms notification.Message
func (*Queuer_Expecter) Stop ¶
func (_e *Queuer_Expecter) Stop(ctx interface{}) *Queuer_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
func (*Queuer_Expecter) SuccessCallback ¶
func (_e *Queuer_Expecter) SuccessCallback(ctx interface{}, ms interface{}) *Queuer_SuccessCallback_Call
SuccessCallback is a helper method to define mock.On call
- ctx context.Context
- ms notification.Message
func (*Queuer_Expecter) Type ¶ added in v0.5.2
func (_e *Queuer_Expecter) Type() *Queuer_Type_Call
Type is a helper method to define mock.On call
type Queuer_Stop_Call ¶
Queuer_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Queuer_Stop_Call) Return ¶
func (_c *Queuer_Stop_Call) Return(_a0 error) *Queuer_Stop_Call
func (*Queuer_Stop_Call) Run ¶
func (_c *Queuer_Stop_Call) Run(run func(ctx context.Context)) *Queuer_Stop_Call
type Queuer_SuccessCallback_Call ¶
Queuer_SuccessCallback_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SuccessCallback'
func (*Queuer_SuccessCallback_Call) Return ¶
func (_c *Queuer_SuccessCallback_Call) Return(_a0 error) *Queuer_SuccessCallback_Call
func (*Queuer_SuccessCallback_Call) Run ¶
func (_c *Queuer_SuccessCallback_Call) Run(run func(ctx context.Context, ms notification.Message)) *Queuer_SuccessCallback_Call
type Queuer_Type_Call ¶ added in v0.5.2
Queuer_Type_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Type'
func (*Queuer_Type_Call) Return ¶ added in v0.5.2
func (_c *Queuer_Type_Call) Return(_a0 string) *Queuer_Type_Call
func (*Queuer_Type_Call) Run ¶ added in v0.5.2
func (_c *Queuer_Type_Call) Run(run func()) *Queuer_Type_Call
type ReceiverService ¶
ReceiverService is an autogenerated mock type for the ReceiverService type
func NewReceiverService ¶
func NewReceiverService(t mockConstructorTestingTNewReceiverService) *ReceiverService
NewReceiverService creates a new instance of ReceiverService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ReceiverService) EXPECT ¶
func (_m *ReceiverService) EXPECT() *ReceiverService_Expecter
type ReceiverService_Expecter ¶
type ReceiverService_Expecter struct {
// contains filtered or unexported fields
}
func (*ReceiverService_Expecter) Get ¶
func (_e *ReceiverService_Expecter) Get(ctx interface{}, id interface{}, gopts ...interface{}) *ReceiverService_Get_Call
Get is a helper method to define mock.On call
- ctx context.Context
- id uint64
- gopts ...receiver.GetOption
type ReceiverService_Get_Call ¶
ReceiverService_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*ReceiverService_Get_Call) Return ¶
func (_c *ReceiverService_Get_Call) Return(_a0 *receiver.Receiver, _a1 error) *ReceiverService_Get_Call
func (*ReceiverService_Get_Call) Run ¶
func (_c *ReceiverService_Get_Call) Run(run func(ctx context.Context, id uint64, gopts ...receiver.GetOption)) *ReceiverService_Get_Call
type SubscriptionService ¶
SubscriptionService is an autogenerated mock type for the SubscriptionService type
func NewSubscriptionService ¶
func NewSubscriptionService(t mockConstructorTestingTNewSubscriptionService) *SubscriptionService
NewSubscriptionService creates a new instance of SubscriptionService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*SubscriptionService) EXPECT ¶
func (_m *SubscriptionService) EXPECT() *SubscriptionService_Expecter
func (*SubscriptionService) MatchByLabels ¶
func (_m *SubscriptionService) MatchByLabels(ctx context.Context, namespaceID uint64, labels map[string]string) ([]subscription.Subscription, error)
MatchByLabels provides a mock function with given fields: ctx, namespaceID, labels
type SubscriptionService_Expecter ¶
type SubscriptionService_Expecter struct {
// contains filtered or unexported fields
}
func (*SubscriptionService_Expecter) MatchByLabels ¶
func (_e *SubscriptionService_Expecter) MatchByLabels(ctx interface{}, namespaceID interface{}, labels interface{}) *SubscriptionService_MatchByLabels_Call
MatchByLabels is a helper method to define mock.On call
- ctx context.Context
- namespaceID uint64
- labels map[string]string
type SubscriptionService_MatchByLabels_Call ¶
SubscriptionService_MatchByLabels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MatchByLabels'
func (*SubscriptionService_MatchByLabels_Call) Return ¶
func (_c *SubscriptionService_MatchByLabels_Call) Return(_a0 []subscription.Subscription, _a1 error) *SubscriptionService_MatchByLabels_Call
func (*SubscriptionService_MatchByLabels_Call) Run ¶
func (_c *SubscriptionService_MatchByLabels_Call) Run(run func(ctx context.Context, namespaceID uint64, labels map[string]string)) *SubscriptionService_MatchByLabels_Call