Documentation
¶
Index ¶
- type MockPubSub
- func (_mock *MockPubSub) Disconnect(ctx context.Context) error
- func (_m *MockPubSub) EXPECT() *MockPubSub_Expecter
- func (_mock *MockPubSub) Publish(ctx context.Context, topic string, msg any) error
- func (_mock *MockPubSub) Subscribe(ctx context.Context, topic string, handler mqtt.Handler) error
- func (_mock *MockPubSub) Unsubscribe(ctx context.Context, topic string) error
- type MockPubSub_Disconnect_Call
- func (_c *MockPubSub_Disconnect_Call) Return(err error) *MockPubSub_Disconnect_Call
- func (_c *MockPubSub_Disconnect_Call) Run(run func(ctx context.Context)) *MockPubSub_Disconnect_Call
- func (_c *MockPubSub_Disconnect_Call) RunAndReturn(run func(ctx context.Context) error) *MockPubSub_Disconnect_Call
- type MockPubSub_Expecter
- func (_e *MockPubSub_Expecter) Disconnect(ctx interface{}) *MockPubSub_Disconnect_Call
- func (_e *MockPubSub_Expecter) Publish(ctx interface{}, topic interface{}, msg interface{}) *MockPubSub_Publish_Call
- func (_e *MockPubSub_Expecter) Subscribe(ctx interface{}, topic interface{}, handler interface{}) *MockPubSub_Subscribe_Call
- func (_e *MockPubSub_Expecter) Unsubscribe(ctx interface{}, topic interface{}) *MockPubSub_Unsubscribe_Call
- type MockPubSub_Publish_Call
- func (_c *MockPubSub_Publish_Call) Return(err error) *MockPubSub_Publish_Call
- func (_c *MockPubSub_Publish_Call) Run(run func(ctx context.Context, topic string, msg any)) *MockPubSub_Publish_Call
- func (_c *MockPubSub_Publish_Call) RunAndReturn(run func(ctx context.Context, topic string, msg any) error) *MockPubSub_Publish_Call
- type MockPubSub_Subscribe_Call
- func (_c *MockPubSub_Subscribe_Call) Return(err error) *MockPubSub_Subscribe_Call
- func (_c *MockPubSub_Subscribe_Call) Run(run func(ctx context.Context, topic string, handler mqtt.Handler)) *MockPubSub_Subscribe_Call
- func (_c *MockPubSub_Subscribe_Call) RunAndReturn(run func(ctx context.Context, topic string, handler mqtt.Handler) error) *MockPubSub_Subscribe_Call
- type MockPubSub_Unsubscribe_Call
- func (_c *MockPubSub_Unsubscribe_Call) Return(err error) *MockPubSub_Unsubscribe_Call
- func (_c *MockPubSub_Unsubscribe_Call) Run(run func(ctx context.Context, topic string)) *MockPubSub_Unsubscribe_Call
- func (_c *MockPubSub_Unsubscribe_Call) RunAndReturn(run func(ctx context.Context, topic string) error) *MockPubSub_Unsubscribe_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockPubSub ¶
MockPubSub is an autogenerated mock type for the PubSub type
func NewMockPubSub ¶
func NewMockPubSub(t interface {
mock.TestingT
Cleanup(func())
}) *MockPubSub
NewMockPubSub creates a new instance of MockPubSub. 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 (*MockPubSub) Disconnect ¶
func (_mock *MockPubSub) Disconnect(ctx context.Context) error
Disconnect provides a mock function for the type MockPubSub
func (*MockPubSub) EXPECT ¶
func (_m *MockPubSub) EXPECT() *MockPubSub_Expecter
func (*MockPubSub) Unsubscribe ¶
func (_mock *MockPubSub) Unsubscribe(ctx context.Context, topic string) error
Unsubscribe provides a mock function for the type MockPubSub
type MockPubSub_Disconnect_Call ¶
MockPubSub_Disconnect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Disconnect'
func (*MockPubSub_Disconnect_Call) Return ¶
func (_c *MockPubSub_Disconnect_Call) Return(err error) *MockPubSub_Disconnect_Call
func (*MockPubSub_Disconnect_Call) Run ¶
func (_c *MockPubSub_Disconnect_Call) Run(run func(ctx context.Context)) *MockPubSub_Disconnect_Call
func (*MockPubSub_Disconnect_Call) RunAndReturn ¶
func (_c *MockPubSub_Disconnect_Call) RunAndReturn(run func(ctx context.Context) error) *MockPubSub_Disconnect_Call
type MockPubSub_Expecter ¶
type MockPubSub_Expecter struct {
// contains filtered or unexported fields
}
func (*MockPubSub_Expecter) Disconnect ¶
func (_e *MockPubSub_Expecter) Disconnect(ctx interface{}) *MockPubSub_Disconnect_Call
Disconnect is a helper method to define mock.On call
- ctx context.Context
func (*MockPubSub_Expecter) Publish ¶
func (_e *MockPubSub_Expecter) Publish(ctx interface{}, topic interface{}, msg interface{}) *MockPubSub_Publish_Call
Publish is a helper method to define mock.On call
- ctx context.Context
- topic string
- msg any
func (*MockPubSub_Expecter) Subscribe ¶
func (_e *MockPubSub_Expecter) Subscribe(ctx interface{}, topic interface{}, handler interface{}) *MockPubSub_Subscribe_Call
Subscribe is a helper method to define mock.On call
- ctx context.Context
- topic string
- handler mqtt.Handler
func (*MockPubSub_Expecter) Unsubscribe ¶
func (_e *MockPubSub_Expecter) Unsubscribe(ctx interface{}, topic interface{}) *MockPubSub_Unsubscribe_Call
Unsubscribe is a helper method to define mock.On call
- ctx context.Context
- topic string
type MockPubSub_Publish_Call ¶
MockPubSub_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'
func (*MockPubSub_Publish_Call) Return ¶
func (_c *MockPubSub_Publish_Call) Return(err error) *MockPubSub_Publish_Call
func (*MockPubSub_Publish_Call) Run ¶
func (_c *MockPubSub_Publish_Call) Run(run func(ctx context.Context, topic string, msg any)) *MockPubSub_Publish_Call
func (*MockPubSub_Publish_Call) RunAndReturn ¶
func (_c *MockPubSub_Publish_Call) RunAndReturn(run func(ctx context.Context, topic string, msg any) error) *MockPubSub_Publish_Call
type MockPubSub_Subscribe_Call ¶
MockPubSub_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'
func (*MockPubSub_Subscribe_Call) Return ¶
func (_c *MockPubSub_Subscribe_Call) Return(err error) *MockPubSub_Subscribe_Call
func (*MockPubSub_Subscribe_Call) Run ¶
func (_c *MockPubSub_Subscribe_Call) Run(run func(ctx context.Context, topic string, handler mqtt.Handler)) *MockPubSub_Subscribe_Call
func (*MockPubSub_Subscribe_Call) RunAndReturn ¶
func (_c *MockPubSub_Subscribe_Call) RunAndReturn(run func(ctx context.Context, topic string, handler mqtt.Handler) error) *MockPubSub_Subscribe_Call
type MockPubSub_Unsubscribe_Call ¶
MockPubSub_Unsubscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unsubscribe'
func (*MockPubSub_Unsubscribe_Call) Return ¶
func (_c *MockPubSub_Unsubscribe_Call) Return(err error) *MockPubSub_Unsubscribe_Call
func (*MockPubSub_Unsubscribe_Call) Run ¶
func (_c *MockPubSub_Unsubscribe_Call) Run(run func(ctx context.Context, topic string)) *MockPubSub_Unsubscribe_Call
func (*MockPubSub_Unsubscribe_Call) RunAndReturn ¶
func (_c *MockPubSub_Unsubscribe_Call) RunAndReturn(run func(ctx context.Context, topic string) error) *MockPubSub_Unsubscribe_Call