event

Documentation

Index

• type EventRouter
  • func NewEventRouter(t interface{ ... }) *EventRouter
  • func (_m *EventRouter) Add(topic string, _a1 event.Eventable)
• type EventRouterHandler
  • func NewEventRouterHandler(t interface{ ... }) *EventRouterHandler
  • func (_m *EventRouterHandler) Add(topic string, _a1 event.Eventable)
  • func (_m *EventRouterHandler) OnMessage(msg *kafka.Message) error
• type Eventable
  • func NewEventable(t interface{ ... }) *Eventable
  • func (_m *Eventable) OnMessage(msg *kafka.Message) error
• type KafkaHeaders
  • func NewKafkaHeaders(t interface{ ... }) *KafkaHeaders
  • func (_m *KafkaHeaders) FromEchoContext(ctx echo.Context, _a1 string) ([]kafka.Header, error)

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

type Eventable

type Eventable struct {
	mock.Mock
}

Eventable is an autogenerated mock type for the Eventable type

func NewEventable

func NewEventable(t interface {
	mock.TestingT
	Cleanup(func())
}) *Eventable

NewEventable creates a new instance of Eventable. 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 (*Eventable) OnMessage

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

OnMessage provides a mock function with given fields: msg

type KafkaHeaders

type KafkaHeaders struct {
	mock.Mock
}

KafkaHeaders is an autogenerated mock type for the KafkaHeaders type

func NewKafkaHeaders

func NewKafkaHeaders(t interface {
	mock.TestingT
	Cleanup(func())
}) *KafkaHeaders

NewKafkaHeaders creates a new instance of KafkaHeaders. 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 (*KafkaHeaders) FromEchoContext

func (_m *KafkaHeaders) FromEchoContext(ctx echo.Context, _a1 string) ([]kafka.Header, error)

FromEchoContext provides a mock function with given fields: ctx, _a1