Documentation ¶
Index ¶
- type Handler
- type Handler_Expecter
- type Handler_Handle_Call
- func (_c *Handler_Handle_Call) Return(_a0 azbus.Disposition, _a1 context.Context, _a2 error) *Handler_Handle_Call
- func (_c *Handler_Handle_Call) Run(run func(_a0 context.Context, _a1 *azservicebus.ReceivedMessage)) *Handler_Handle_Call
- func (_c *Handler_Handle_Call) RunAndReturn(...) *Handler_Handle_Call
- type MsgReceiver
- func (_m *MsgReceiver) Close(_a0 context.Context)
- func (_m *MsgReceiver) EXPECT() *MsgReceiver_Expecter
- func (_m *MsgReceiver) GetAZClient() azbus.AZClient
- func (_m *MsgReceiver) Listen() error
- func (_m *MsgReceiver) Open() error
- func (_m *MsgReceiver) Shutdown(_a0 context.Context) error
- func (_m *MsgReceiver) String() string
- type MsgReceiver_Close_Call
- type MsgReceiver_Expecter
- func (_e *MsgReceiver_Expecter) Close(_a0 interface{}) *MsgReceiver_Close_Call
- func (_e *MsgReceiver_Expecter) GetAZClient() *MsgReceiver_GetAZClient_Call
- func (_e *MsgReceiver_Expecter) Listen() *MsgReceiver_Listen_Call
- func (_e *MsgReceiver_Expecter) Open() *MsgReceiver_Open_Call
- func (_e *MsgReceiver_Expecter) Shutdown(_a0 interface{}) *MsgReceiver_Shutdown_Call
- func (_e *MsgReceiver_Expecter) String() *MsgReceiver_String_Call
- type MsgReceiver_GetAZClient_Call
- type MsgReceiver_Listen_Call
- type MsgReceiver_Open_Call
- type MsgReceiver_Shutdown_Call
- type MsgReceiver_String_Call
- type MsgSender
- func (_m *MsgSender) Close(_a0 context.Context)
- func (_m *MsgSender) EXPECT() *MsgSender_Expecter
- func (_m *MsgSender) GetAZClient() azbus.AZClient
- func (_m *MsgSender) Open() error
- func (_m *MsgSender) Send(_a0 context.Context, _a1 []byte, _a2 ...azbus.OutMessageOption) error
- func (_m *MsgSender) SendMsg(_a0 context.Context, _a1 azservicebus.Message, _a2 ...azbus.OutMessageOption) error
- func (_m *MsgSender) String() string
- type MsgSender_Close_Call
- type MsgSender_Expecter
- func (_e *MsgSender_Expecter) Close(_a0 interface{}) *MsgSender_Close_Call
- func (_e *MsgSender_Expecter) GetAZClient() *MsgSender_GetAZClient_Call
- func (_e *MsgSender_Expecter) Open() *MsgSender_Open_Call
- func (_e *MsgSender_Expecter) Send(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MsgSender_Send_Call
- func (_e *MsgSender_Expecter) SendMsg(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MsgSender_SendMsg_Call
- func (_e *MsgSender_Expecter) String() *MsgSender_String_Call
- type MsgSender_GetAZClient_Call
- type MsgSender_Open_Call
- type MsgSender_SendMsg_Call
- type MsgSender_Send_Call
- func (_c *MsgSender_Send_Call) Return(_a0 error) *MsgSender_Send_Call
- func (_c *MsgSender_Send_Call) Run(run func(_a0 context.Context, _a1 []byte, _a2 ...azbus.OutMessageOption)) *MsgSender_Send_Call
- func (_c *MsgSender_Send_Call) RunAndReturn(run func(context.Context, []byte, ...azbus.OutMessageOption) error) *MsgSender_Send_Call
- type MsgSender_String_Call
- type OutMessageOption
- type OutMessageOption_Execute_Call
- func (_c *OutMessageOption_Execute_Call) Return() *OutMessageOption_Execute_Call
- func (_c *OutMessageOption_Execute_Call) Run(run func(_a0 *azservicebus.Message)) *OutMessageOption_Execute_Call
- func (_c *OutMessageOption_Execute_Call) RunAndReturn(run func(*azservicebus.Message)) *OutMessageOption_Execute_Call
- type OutMessageOption_Expecter
- type ReceiverOption
- type ReceiverOption_Execute_Call
- type ReceiverOption_Expecter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
Handler is an autogenerated mock type for the Handler type
func NewHandler ¶
NewHandler creates a new instance of Handler. 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 (*Handler) EXPECT ¶
func (_m *Handler) EXPECT() *Handler_Expecter
func (*Handler) Handle ¶
func (_m *Handler) Handle(_a0 context.Context, _a1 *azservicebus.ReceivedMessage) (azbus.Disposition, context.Context, error)
Handle provides a mock function with given fields: _a0, _a1
type Handler_Expecter ¶
type Handler_Expecter struct {
// contains filtered or unexported fields
}
func (*Handler_Expecter) Handle ¶
func (_e *Handler_Expecter) Handle(_a0 interface{}, _a1 interface{}) *Handler_Handle_Call
Handle is a helper method to define mock.On call
- _a0 context.Context
- _a1 *azservicebus.ReceivedMessage
type Handler_Handle_Call ¶
Handler_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'
func (*Handler_Handle_Call) Return ¶
func (_c *Handler_Handle_Call) Return(_a0 azbus.Disposition, _a1 context.Context, _a2 error) *Handler_Handle_Call
func (*Handler_Handle_Call) Run ¶
func (_c *Handler_Handle_Call) Run(run func(_a0 context.Context, _a1 *azservicebus.ReceivedMessage)) *Handler_Handle_Call
func (*Handler_Handle_Call) RunAndReturn ¶
func (_c *Handler_Handle_Call) RunAndReturn(run func(context.Context, *azservicebus.ReceivedMessage) (azbus.Disposition, context.Context, error)) *Handler_Handle_Call
type MsgReceiver ¶
MsgReceiver is an autogenerated mock type for the MsgReceiver type
func NewMsgReceiver ¶
func NewMsgReceiver(t interface { mock.TestingT Cleanup(func()) }) *MsgReceiver
NewMsgReceiver creates a new instance of MsgReceiver. 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 (*MsgReceiver) Close ¶
func (_m *MsgReceiver) Close(_a0 context.Context)
Close provides a mock function with given fields: _a0
func (*MsgReceiver) EXPECT ¶
func (_m *MsgReceiver) EXPECT() *MsgReceiver_Expecter
func (*MsgReceiver) GetAZClient ¶
func (_m *MsgReceiver) GetAZClient() azbus.AZClient
GetAZClient provides a mock function with given fields:
func (*MsgReceiver) Listen ¶ added in v0.10.3
func (_m *MsgReceiver) Listen() error
Listen provides a mock function with given fields:
func (*MsgReceiver) Open ¶
func (_m *MsgReceiver) Open() error
Open provides a mock function with given fields:
func (*MsgReceiver) Shutdown ¶ added in v0.10.3
func (_m *MsgReceiver) Shutdown(_a0 context.Context) error
Shutdown provides a mock function with given fields: _a0
func (*MsgReceiver) String ¶
func (_m *MsgReceiver) String() string
String provides a mock function with given fields:
type MsgReceiver_Close_Call ¶
MsgReceiver_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MsgReceiver_Close_Call) Return ¶
func (_c *MsgReceiver_Close_Call) Return() *MsgReceiver_Close_Call
func (*MsgReceiver_Close_Call) Run ¶
func (_c *MsgReceiver_Close_Call) Run(run func(_a0 context.Context)) *MsgReceiver_Close_Call
func (*MsgReceiver_Close_Call) RunAndReturn ¶
func (_c *MsgReceiver_Close_Call) RunAndReturn(run func(context.Context)) *MsgReceiver_Close_Call
type MsgReceiver_Expecter ¶
type MsgReceiver_Expecter struct {
// contains filtered or unexported fields
}
func (*MsgReceiver_Expecter) Close ¶
func (_e *MsgReceiver_Expecter) Close(_a0 interface{}) *MsgReceiver_Close_Call
Close is a helper method to define mock.On call
- _a0 context.Context
func (*MsgReceiver_Expecter) GetAZClient ¶
func (_e *MsgReceiver_Expecter) GetAZClient() *MsgReceiver_GetAZClient_Call
GetAZClient is a helper method to define mock.On call
func (*MsgReceiver_Expecter) Listen ¶ added in v0.10.3
func (_e *MsgReceiver_Expecter) Listen() *MsgReceiver_Listen_Call
Listen is a helper method to define mock.On call
func (*MsgReceiver_Expecter) Open ¶
func (_e *MsgReceiver_Expecter) Open() *MsgReceiver_Open_Call
Open is a helper method to define mock.On call
func (*MsgReceiver_Expecter) Shutdown ¶ added in v0.10.3
func (_e *MsgReceiver_Expecter) Shutdown(_a0 interface{}) *MsgReceiver_Shutdown_Call
Shutdown is a helper method to define mock.On call
- _a0 context.Context
func (*MsgReceiver_Expecter) String ¶
func (_e *MsgReceiver_Expecter) String() *MsgReceiver_String_Call
String is a helper method to define mock.On call
type MsgReceiver_GetAZClient_Call ¶
MsgReceiver_GetAZClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAZClient'
func (*MsgReceiver_GetAZClient_Call) Return ¶
func (_c *MsgReceiver_GetAZClient_Call) Return(_a0 azbus.AZClient) *MsgReceiver_GetAZClient_Call
func (*MsgReceiver_GetAZClient_Call) Run ¶
func (_c *MsgReceiver_GetAZClient_Call) Run(run func()) *MsgReceiver_GetAZClient_Call
func (*MsgReceiver_GetAZClient_Call) RunAndReturn ¶
func (_c *MsgReceiver_GetAZClient_Call) RunAndReturn(run func() azbus.AZClient) *MsgReceiver_GetAZClient_Call
type MsgReceiver_Listen_Call ¶ added in v0.10.3
MsgReceiver_Listen_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Listen'
func (*MsgReceiver_Listen_Call) Return ¶ added in v0.10.3
func (_c *MsgReceiver_Listen_Call) Return(_a0 error) *MsgReceiver_Listen_Call
func (*MsgReceiver_Listen_Call) Run ¶ added in v0.10.3
func (_c *MsgReceiver_Listen_Call) Run(run func()) *MsgReceiver_Listen_Call
func (*MsgReceiver_Listen_Call) RunAndReturn ¶ added in v0.10.3
func (_c *MsgReceiver_Listen_Call) RunAndReturn(run func() error) *MsgReceiver_Listen_Call
type MsgReceiver_Open_Call ¶
MsgReceiver_Open_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Open'
func (*MsgReceiver_Open_Call) Return ¶
func (_c *MsgReceiver_Open_Call) Return(_a0 error) *MsgReceiver_Open_Call
func (*MsgReceiver_Open_Call) Run ¶
func (_c *MsgReceiver_Open_Call) Run(run func()) *MsgReceiver_Open_Call
func (*MsgReceiver_Open_Call) RunAndReturn ¶
func (_c *MsgReceiver_Open_Call) RunAndReturn(run func() error) *MsgReceiver_Open_Call
type MsgReceiver_Shutdown_Call ¶ added in v0.10.3
MsgReceiver_Shutdown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Shutdown'
func (*MsgReceiver_Shutdown_Call) Return ¶ added in v0.10.3
func (_c *MsgReceiver_Shutdown_Call) Return(_a0 error) *MsgReceiver_Shutdown_Call
func (*MsgReceiver_Shutdown_Call) Run ¶ added in v0.10.3
func (_c *MsgReceiver_Shutdown_Call) Run(run func(_a0 context.Context)) *MsgReceiver_Shutdown_Call
func (*MsgReceiver_Shutdown_Call) RunAndReturn ¶ added in v0.10.3
func (_c *MsgReceiver_Shutdown_Call) RunAndReturn(run func(context.Context) error) *MsgReceiver_Shutdown_Call
type MsgReceiver_String_Call ¶
MsgReceiver_String_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'String'
func (*MsgReceiver_String_Call) Return ¶
func (_c *MsgReceiver_String_Call) Return(_a0 string) *MsgReceiver_String_Call
func (*MsgReceiver_String_Call) Run ¶
func (_c *MsgReceiver_String_Call) Run(run func()) *MsgReceiver_String_Call
func (*MsgReceiver_String_Call) RunAndReturn ¶
func (_c *MsgReceiver_String_Call) RunAndReturn(run func() string) *MsgReceiver_String_Call
type MsgSender ¶
MsgSender is an autogenerated mock type for the MsgSender type
func NewMsgSender ¶
NewMsgSender creates a new instance of MsgSender. 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 (*MsgSender) EXPECT ¶
func (_m *MsgSender) EXPECT() *MsgSender_Expecter
func (*MsgSender) GetAZClient ¶
GetAZClient provides a mock function with given fields:
func (*MsgSender) SendMsg ¶
func (_m *MsgSender) SendMsg(_a0 context.Context, _a1 azservicebus.Message, _a2 ...azbus.OutMessageOption) error
SendMsg provides a mock function with given fields: _a0, _a1, _a2
type MsgSender_Close_Call ¶
MsgSender_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MsgSender_Close_Call) Return ¶
func (_c *MsgSender_Close_Call) Return() *MsgSender_Close_Call
func (*MsgSender_Close_Call) Run ¶
func (_c *MsgSender_Close_Call) Run(run func(_a0 context.Context)) *MsgSender_Close_Call
func (*MsgSender_Close_Call) RunAndReturn ¶
func (_c *MsgSender_Close_Call) RunAndReturn(run func(context.Context)) *MsgSender_Close_Call
type MsgSender_Expecter ¶
type MsgSender_Expecter struct {
// contains filtered or unexported fields
}
func (*MsgSender_Expecter) Close ¶
func (_e *MsgSender_Expecter) Close(_a0 interface{}) *MsgSender_Close_Call
Close is a helper method to define mock.On call
- _a0 context.Context
func (*MsgSender_Expecter) GetAZClient ¶
func (_e *MsgSender_Expecter) GetAZClient() *MsgSender_GetAZClient_Call
GetAZClient is a helper method to define mock.On call
func (*MsgSender_Expecter) Open ¶
func (_e *MsgSender_Expecter) Open() *MsgSender_Open_Call
Open is a helper method to define mock.On call
func (*MsgSender_Expecter) Send ¶
func (_e *MsgSender_Expecter) Send(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MsgSender_Send_Call
Send is a helper method to define mock.On call
- _a0 context.Context
- _a1 []byte
- _a2 ...azbus.OutMessageOption
func (*MsgSender_Expecter) SendMsg ¶
func (_e *MsgSender_Expecter) SendMsg(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MsgSender_SendMsg_Call
SendMsg is a helper method to define mock.On call
- _a0 context.Context
- _a1 azservicebus.Message
- _a2 ...azbus.OutMessageOption
func (*MsgSender_Expecter) String ¶
func (_e *MsgSender_Expecter) String() *MsgSender_String_Call
String is a helper method to define mock.On call
type MsgSender_GetAZClient_Call ¶
MsgSender_GetAZClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAZClient'
func (*MsgSender_GetAZClient_Call) Return ¶
func (_c *MsgSender_GetAZClient_Call) Return(_a0 azbus.AZClient) *MsgSender_GetAZClient_Call
func (*MsgSender_GetAZClient_Call) Run ¶
func (_c *MsgSender_GetAZClient_Call) Run(run func()) *MsgSender_GetAZClient_Call
func (*MsgSender_GetAZClient_Call) RunAndReturn ¶
func (_c *MsgSender_GetAZClient_Call) RunAndReturn(run func() azbus.AZClient) *MsgSender_GetAZClient_Call
type MsgSender_Open_Call ¶
MsgSender_Open_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Open'
func (*MsgSender_Open_Call) Return ¶
func (_c *MsgSender_Open_Call) Return(_a0 error) *MsgSender_Open_Call
func (*MsgSender_Open_Call) Run ¶
func (_c *MsgSender_Open_Call) Run(run func()) *MsgSender_Open_Call
func (*MsgSender_Open_Call) RunAndReturn ¶
func (_c *MsgSender_Open_Call) RunAndReturn(run func() error) *MsgSender_Open_Call
type MsgSender_SendMsg_Call ¶
MsgSender_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'
func (*MsgSender_SendMsg_Call) Return ¶
func (_c *MsgSender_SendMsg_Call) Return(_a0 error) *MsgSender_SendMsg_Call
func (*MsgSender_SendMsg_Call) Run ¶
func (_c *MsgSender_SendMsg_Call) Run(run func(_a0 context.Context, _a1 azservicebus.Message, _a2 ...azbus.OutMessageOption)) *MsgSender_SendMsg_Call
func (*MsgSender_SendMsg_Call) RunAndReturn ¶
func (_c *MsgSender_SendMsg_Call) RunAndReturn(run func(context.Context, azservicebus.Message, ...azbus.OutMessageOption) error) *MsgSender_SendMsg_Call
type MsgSender_Send_Call ¶
MsgSender_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'
func (*MsgSender_Send_Call) Return ¶
func (_c *MsgSender_Send_Call) Return(_a0 error) *MsgSender_Send_Call
func (*MsgSender_Send_Call) Run ¶
func (_c *MsgSender_Send_Call) Run(run func(_a0 context.Context, _a1 []byte, _a2 ...azbus.OutMessageOption)) *MsgSender_Send_Call
func (*MsgSender_Send_Call) RunAndReturn ¶
func (_c *MsgSender_Send_Call) RunAndReturn(run func(context.Context, []byte, ...azbus.OutMessageOption) error) *MsgSender_Send_Call
type MsgSender_String_Call ¶
MsgSender_String_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'String'
func (*MsgSender_String_Call) Return ¶
func (_c *MsgSender_String_Call) Return(_a0 string) *MsgSender_String_Call
func (*MsgSender_String_Call) Run ¶
func (_c *MsgSender_String_Call) Run(run func()) *MsgSender_String_Call
func (*MsgSender_String_Call) RunAndReturn ¶
func (_c *MsgSender_String_Call) RunAndReturn(run func() string) *MsgSender_String_Call
type OutMessageOption ¶
OutMessageOption is an autogenerated mock type for the OutMessageOption type
func NewOutMessageOption ¶
func NewOutMessageOption(t interface { mock.TestingT Cleanup(func()) }) *OutMessageOption
NewOutMessageOption creates a new instance of OutMessageOption. 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 (*OutMessageOption) EXPECT ¶
func (_m *OutMessageOption) EXPECT() *OutMessageOption_Expecter
func (*OutMessageOption) Execute ¶
func (_m *OutMessageOption) Execute(_a0 *azservicebus.Message)
Execute provides a mock function with given fields: _a0
type OutMessageOption_Execute_Call ¶
OutMessageOption_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'
func (*OutMessageOption_Execute_Call) Return ¶
func (_c *OutMessageOption_Execute_Call) Return() *OutMessageOption_Execute_Call
func (*OutMessageOption_Execute_Call) Run ¶
func (_c *OutMessageOption_Execute_Call) Run(run func(_a0 *azservicebus.Message)) *OutMessageOption_Execute_Call
func (*OutMessageOption_Execute_Call) RunAndReturn ¶
func (_c *OutMessageOption_Execute_Call) RunAndReturn(run func(*azservicebus.Message)) *OutMessageOption_Execute_Call
type OutMessageOption_Expecter ¶
type OutMessageOption_Expecter struct {
// contains filtered or unexported fields
}
func (*OutMessageOption_Expecter) Execute ¶
func (_e *OutMessageOption_Expecter) Execute(_a0 interface{}) *OutMessageOption_Execute_Call
Execute is a helper method to define mock.On call
- _a0 *azservicebus.Message
type ReceiverOption ¶ added in v0.10.3
ReceiverOption is an autogenerated mock type for the ReceiverOption type
func NewReceiverOption ¶ added in v0.10.3
func NewReceiverOption(t interface { mock.TestingT Cleanup(func()) }) *ReceiverOption
NewReceiverOption creates a new instance of ReceiverOption. 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 (*ReceiverOption) EXPECT ¶ added in v0.10.3
func (_m *ReceiverOption) EXPECT() *ReceiverOption_Expecter
func (*ReceiverOption) Execute ¶ added in v0.10.3
func (_m *ReceiverOption) Execute(_a0 *azbus.Receiver)
Execute provides a mock function with given fields: _a0
type ReceiverOption_Execute_Call ¶ added in v0.10.3
ReceiverOption_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'
func (*ReceiverOption_Execute_Call) Return ¶ added in v0.10.3
func (_c *ReceiverOption_Execute_Call) Return() *ReceiverOption_Execute_Call
func (*ReceiverOption_Execute_Call) Run ¶ added in v0.10.3
func (_c *ReceiverOption_Execute_Call) Run(run func(_a0 *azbus.Receiver)) *ReceiverOption_Execute_Call
func (*ReceiverOption_Execute_Call) RunAndReturn ¶ added in v0.10.3
func (_c *ReceiverOption_Execute_Call) RunAndReturn(run func(*azbus.Receiver)) *ReceiverOption_Execute_Call
type ReceiverOption_Expecter ¶ added in v0.10.3
type ReceiverOption_Expecter struct {
// contains filtered or unexported fields
}
func (*ReceiverOption_Expecter) Execute ¶ added in v0.10.3
func (_e *ReceiverOption_Expecter) Execute(_a0 interface{}) *ReceiverOption_Execute_Call
Execute is a helper method to define mock.On call
- _a0 *azbus.Receiver