Documentation ¶
Index ¶
- type PublisherManager
- func (_m *PublisherManager) Create(subscription *types.Subscription) (*types.CreateResponse, error)
- func (_m *PublisherManager) Delete(name string) (*types.DeleteResponse, error)
- func (_m *PublisherManager) EXPECT() *PublisherManager_Expecter
- func (_m *PublisherManager) Get(name string) (*types.Subscription, *types.Response, error)
- func (_m *PublisherManager) List() (*types.Subscriptions, *types.Response, error)
- func (_m *PublisherManager) Publish(cloudEvent v2.Event, qos types.Qos) (*types.PublishResponse, error)
- func (_m *PublisherManager) TriggerHandshake(name string) (*types.TriggerHandshake, error)
- func (_m *PublisherManager) Update(name string, webhookAuth *types.WebhookAuth) (*types.UpdateResponse, error)
- func (_m *PublisherManager) UpdateState(name string, state types.State) (*types.UpdateStateResponse, error)
- type PublisherManager_Create_Call
- func (_c *PublisherManager_Create_Call) Return(_a0 *types.CreateResponse, _a1 error) *PublisherManager_Create_Call
- func (_c *PublisherManager_Create_Call) Run(run func(subscription *types.Subscription)) *PublisherManager_Create_Call
- func (_c *PublisherManager_Create_Call) RunAndReturn(run func(*types.Subscription) (*types.CreateResponse, error)) *PublisherManager_Create_Call
- type PublisherManager_Delete_Call
- func (_c *PublisherManager_Delete_Call) Return(_a0 *types.DeleteResponse, _a1 error) *PublisherManager_Delete_Call
- func (_c *PublisherManager_Delete_Call) Run(run func(name string)) *PublisherManager_Delete_Call
- func (_c *PublisherManager_Delete_Call) RunAndReturn(run func(string) (*types.DeleteResponse, error)) *PublisherManager_Delete_Call
- type PublisherManager_Expecter
- func (_e *PublisherManager_Expecter) Create(subscription interface{}) *PublisherManager_Create_Call
- func (_e *PublisherManager_Expecter) Delete(name interface{}) *PublisherManager_Delete_Call
- func (_e *PublisherManager_Expecter) Get(name interface{}) *PublisherManager_Get_Call
- func (_e *PublisherManager_Expecter) List() *PublisherManager_List_Call
- func (_e *PublisherManager_Expecter) Publish(cloudEvent interface{}, qos interface{}) *PublisherManager_Publish_Call
- func (_e *PublisherManager_Expecter) TriggerHandshake(name interface{}) *PublisherManager_TriggerHandshake_Call
- func (_e *PublisherManager_Expecter) Update(name interface{}, webhookAuth interface{}) *PublisherManager_Update_Call
- func (_e *PublisherManager_Expecter) UpdateState(name interface{}, state interface{}) *PublisherManager_UpdateState_Call
- type PublisherManager_Get_Call
- func (_c *PublisherManager_Get_Call) Return(_a0 *types.Subscription, _a1 *types.Response, _a2 error) *PublisherManager_Get_Call
- func (_c *PublisherManager_Get_Call) Run(run func(name string)) *PublisherManager_Get_Call
- func (_c *PublisherManager_Get_Call) RunAndReturn(run func(string) (*types.Subscription, *types.Response, error)) *PublisherManager_Get_Call
- type PublisherManager_List_Call
- func (_c *PublisherManager_List_Call) Return(_a0 *types.Subscriptions, _a1 *types.Response, _a2 error) *PublisherManager_List_Call
- func (_c *PublisherManager_List_Call) Run(run func()) *PublisherManager_List_Call
- func (_c *PublisherManager_List_Call) RunAndReturn(run func() (*types.Subscriptions, *types.Response, error)) *PublisherManager_List_Call
- type PublisherManager_Publish_Call
- func (_c *PublisherManager_Publish_Call) Return(_a0 *types.PublishResponse, _a1 error) *PublisherManager_Publish_Call
- func (_c *PublisherManager_Publish_Call) Run(run func(cloudEvent v2.Event, qos types.Qos)) *PublisherManager_Publish_Call
- func (_c *PublisherManager_Publish_Call) RunAndReturn(run func(v2.Event, types.Qos) (*types.PublishResponse, error)) *PublisherManager_Publish_Call
- type PublisherManager_TriggerHandshake_Call
- func (_c *PublisherManager_TriggerHandshake_Call) Return(_a0 *types.TriggerHandshake, _a1 error) *PublisherManager_TriggerHandshake_Call
- func (_c *PublisherManager_TriggerHandshake_Call) Run(run func(name string)) *PublisherManager_TriggerHandshake_Call
- func (_c *PublisherManager_TriggerHandshake_Call) RunAndReturn(run func(string) (*types.TriggerHandshake, error)) *PublisherManager_TriggerHandshake_Call
- type PublisherManager_UpdateState_Call
- func (_c *PublisherManager_UpdateState_Call) Return(_a0 *types.UpdateStateResponse, _a1 error) *PublisherManager_UpdateState_Call
- func (_c *PublisherManager_UpdateState_Call) Run(run func(name string, state types.State)) *PublisherManager_UpdateState_Call
- func (_c *PublisherManager_UpdateState_Call) RunAndReturn(run func(string, types.State) (*types.UpdateStateResponse, error)) *PublisherManager_UpdateState_Call
- type PublisherManager_Update_Call
- func (_c *PublisherManager_Update_Call) Return(_a0 *types.UpdateResponse, _a1 error) *PublisherManager_Update_Call
- func (_c *PublisherManager_Update_Call) Run(run func(name string, webhookAuth *types.WebhookAuth)) *PublisherManager_Update_Call
- func (_c *PublisherManager_Update_Call) RunAndReturn(run func(string, *types.WebhookAuth) (*types.UpdateResponse, error)) *PublisherManager_Update_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PublisherManager ¶
PublisherManager is an autogenerated mock type for the PublisherManager type
func NewPublisherManager ¶
func NewPublisherManager(t interface { mock.TestingT Cleanup(func()) }) *PublisherManager
NewPublisherManager creates a new instance of PublisherManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PublisherManager) Create ¶
func (_m *PublisherManager) Create(subscription *types.Subscription) (*types.CreateResponse, error)
Create provides a mock function with given fields: subscription
func (*PublisherManager) Delete ¶
func (_m *PublisherManager) Delete(name string) (*types.DeleteResponse, error)
Delete provides a mock function with given fields: name
func (*PublisherManager) EXPECT ¶
func (_m *PublisherManager) EXPECT() *PublisherManager_Expecter
func (*PublisherManager) Get ¶
func (_m *PublisherManager) Get(name string) (*types.Subscription, *types.Response, error)
Get provides a mock function with given fields: name
func (*PublisherManager) List ¶
func (_m *PublisherManager) List() (*types.Subscriptions, *types.Response, error)
List provides a mock function with given fields:
func (*PublisherManager) Publish ¶
func (_m *PublisherManager) Publish(cloudEvent v2.Event, qos types.Qos) (*types.PublishResponse, error)
Publish provides a mock function with given fields: cloudEvent, qos
func (*PublisherManager) TriggerHandshake ¶
func (_m *PublisherManager) TriggerHandshake(name string) (*types.TriggerHandshake, error)
TriggerHandshake provides a mock function with given fields: name
func (*PublisherManager) Update ¶
func (_m *PublisherManager) Update(name string, webhookAuth *types.WebhookAuth) (*types.UpdateResponse, error)
Update provides a mock function with given fields: name, webhookAuth
func (*PublisherManager) UpdateState ¶
func (_m *PublisherManager) UpdateState(name string, state types.State) (*types.UpdateStateResponse, error)
UpdateState provides a mock function with given fields: name, state
type PublisherManager_Create_Call ¶
PublisherManager_Create_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Create'
func (*PublisherManager_Create_Call) Return ¶
func (_c *PublisherManager_Create_Call) Return(_a0 *types.CreateResponse, _a1 error) *PublisherManager_Create_Call
func (*PublisherManager_Create_Call) Run ¶
func (_c *PublisherManager_Create_Call) Run(run func(subscription *types.Subscription)) *PublisherManager_Create_Call
func (*PublisherManager_Create_Call) RunAndReturn ¶
func (_c *PublisherManager_Create_Call) RunAndReturn(run func(*types.Subscription) (*types.CreateResponse, error)) *PublisherManager_Create_Call
type PublisherManager_Delete_Call ¶
PublisherManager_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'
func (*PublisherManager_Delete_Call) Return ¶
func (_c *PublisherManager_Delete_Call) Return(_a0 *types.DeleteResponse, _a1 error) *PublisherManager_Delete_Call
func (*PublisherManager_Delete_Call) Run ¶
func (_c *PublisherManager_Delete_Call) Run(run func(name string)) *PublisherManager_Delete_Call
func (*PublisherManager_Delete_Call) RunAndReturn ¶
func (_c *PublisherManager_Delete_Call) RunAndReturn(run func(string) (*types.DeleteResponse, error)) *PublisherManager_Delete_Call
type PublisherManager_Expecter ¶
type PublisherManager_Expecter struct {
// contains filtered or unexported fields
}
func (*PublisherManager_Expecter) Create ¶
func (_e *PublisherManager_Expecter) Create(subscription interface{}) *PublisherManager_Create_Call
Create is a helper method to define mock.On call
- subscription *types.Subscription
func (*PublisherManager_Expecter) Delete ¶
func (_e *PublisherManager_Expecter) Delete(name interface{}) *PublisherManager_Delete_Call
Delete is a helper method to define mock.On call
- name string
func (*PublisherManager_Expecter) Get ¶
func (_e *PublisherManager_Expecter) Get(name interface{}) *PublisherManager_Get_Call
Get is a helper method to define mock.On call
- name string
func (*PublisherManager_Expecter) List ¶
func (_e *PublisherManager_Expecter) List() *PublisherManager_List_Call
List is a helper method to define mock.On call
func (*PublisherManager_Expecter) Publish ¶
func (_e *PublisherManager_Expecter) Publish(cloudEvent interface{}, qos interface{}) *PublisherManager_Publish_Call
Publish is a helper method to define mock.On call
- cloudEvent v2.Event
- qos types.Qos
func (*PublisherManager_Expecter) TriggerHandshake ¶
func (_e *PublisherManager_Expecter) TriggerHandshake(name interface{}) *PublisherManager_TriggerHandshake_Call
TriggerHandshake is a helper method to define mock.On call
- name string
func (*PublisherManager_Expecter) Update ¶
func (_e *PublisherManager_Expecter) Update(name interface{}, webhookAuth interface{}) *PublisherManager_Update_Call
Update is a helper method to define mock.On call
- name string
- webhookAuth *types.WebhookAuth
func (*PublisherManager_Expecter) UpdateState ¶
func (_e *PublisherManager_Expecter) UpdateState(name interface{}, state interface{}) *PublisherManager_UpdateState_Call
UpdateState is a helper method to define mock.On call
- name string
- state types.State
type PublisherManager_Get_Call ¶
PublisherManager_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*PublisherManager_Get_Call) Return ¶
func (_c *PublisherManager_Get_Call) Return(_a0 *types.Subscription, _a1 *types.Response, _a2 error) *PublisherManager_Get_Call
func (*PublisherManager_Get_Call) Run ¶
func (_c *PublisherManager_Get_Call) Run(run func(name string)) *PublisherManager_Get_Call
func (*PublisherManager_Get_Call) RunAndReturn ¶
func (_c *PublisherManager_Get_Call) RunAndReturn(run func(string) (*types.Subscription, *types.Response, error)) *PublisherManager_Get_Call
type PublisherManager_List_Call ¶
PublisherManager_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'
func (*PublisherManager_List_Call) Return ¶
func (_c *PublisherManager_List_Call) Return(_a0 *types.Subscriptions, _a1 *types.Response, _a2 error) *PublisherManager_List_Call
func (*PublisherManager_List_Call) Run ¶
func (_c *PublisherManager_List_Call) Run(run func()) *PublisherManager_List_Call
func (*PublisherManager_List_Call) RunAndReturn ¶
func (_c *PublisherManager_List_Call) RunAndReturn(run func() (*types.Subscriptions, *types.Response, error)) *PublisherManager_List_Call
type PublisherManager_Publish_Call ¶
PublisherManager_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'
func (*PublisherManager_Publish_Call) Return ¶
func (_c *PublisherManager_Publish_Call) Return(_a0 *types.PublishResponse, _a1 error) *PublisherManager_Publish_Call
func (*PublisherManager_Publish_Call) Run ¶
func (_c *PublisherManager_Publish_Call) Run(run func(cloudEvent v2.Event, qos types.Qos)) *PublisherManager_Publish_Call
func (*PublisherManager_Publish_Call) RunAndReturn ¶
func (_c *PublisherManager_Publish_Call) RunAndReturn(run func(v2.Event, types.Qos) (*types.PublishResponse, error)) *PublisherManager_Publish_Call
type PublisherManager_TriggerHandshake_Call ¶
PublisherManager_TriggerHandshake_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TriggerHandshake'
func (*PublisherManager_TriggerHandshake_Call) Return ¶
func (_c *PublisherManager_TriggerHandshake_Call) Return(_a0 *types.TriggerHandshake, _a1 error) *PublisherManager_TriggerHandshake_Call
func (*PublisherManager_TriggerHandshake_Call) Run ¶
func (_c *PublisherManager_TriggerHandshake_Call) Run(run func(name string)) *PublisherManager_TriggerHandshake_Call
func (*PublisherManager_TriggerHandshake_Call) RunAndReturn ¶
func (_c *PublisherManager_TriggerHandshake_Call) RunAndReturn(run func(string) (*types.TriggerHandshake, error)) *PublisherManager_TriggerHandshake_Call
type PublisherManager_UpdateState_Call ¶
PublisherManager_UpdateState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateState'
func (*PublisherManager_UpdateState_Call) Return ¶
func (_c *PublisherManager_UpdateState_Call) Return(_a0 *types.UpdateStateResponse, _a1 error) *PublisherManager_UpdateState_Call
func (*PublisherManager_UpdateState_Call) Run ¶
func (_c *PublisherManager_UpdateState_Call) Run(run func(name string, state types.State)) *PublisherManager_UpdateState_Call
func (*PublisherManager_UpdateState_Call) RunAndReturn ¶
func (_c *PublisherManager_UpdateState_Call) RunAndReturn(run func(string, types.State) (*types.UpdateStateResponse, error)) *PublisherManager_UpdateState_Call
type PublisherManager_Update_Call ¶
PublisherManager_Update_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Update'
func (*PublisherManager_Update_Call) Return ¶
func (_c *PublisherManager_Update_Call) Return(_a0 *types.UpdateResponse, _a1 error) *PublisherManager_Update_Call
func (*PublisherManager_Update_Call) Run ¶
func (_c *PublisherManager_Update_Call) Run(run func(name string, webhookAuth *types.WebhookAuth)) *PublisherManager_Update_Call
func (*PublisherManager_Update_Call) RunAndReturn ¶
func (_c *PublisherManager_Update_Call) RunAndReturn(run func(string, *types.WebhookAuth) (*types.UpdateResponse, error)) *PublisherManager_Update_Call