handler

package
v0.0.0-...-1a88b7f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 8, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventRouter

type EventRouter struct {
	mock.Mock
}

EventRouter is an autogenerated mock type for the EventRouter type

func NewEventRouter

func NewEventRouter(t interface {
	mock.TestingT
	Cleanup(func())
}) *EventRouter

NewEventRouter creates a new instance of EventRouter. 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 (*EventRouter) Add

func (_m *EventRouter) Add(topic string, _a1 event.Eventable)

Add provides a mock function with given fields: topic, _a1

type EventRouterHandler

type EventRouterHandler struct {
	mock.Mock
}

EventRouterHandler is an autogenerated mock type for the EventRouterHandler type

func NewEventRouterHandler

func NewEventRouterHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *EventRouterHandler

NewEventRouterHandler creates a new instance of EventRouterHandler. 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 (*EventRouterHandler) Add

func (_m *EventRouterHandler) Add(topic string, _a1 event.Eventable)

Add provides a mock function with given fields: topic, _a1

func (*EventRouterHandler) OnMessage

func (_m *EventRouterHandler) OnMessage(msg *kafka.Message) error

OnMessage provides a mock function with given fields: msg

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳