Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckerMock ¶
type CheckerMock struct{}
func NewCheckerMock ¶
func NewCheckerMock() *CheckerMock
func (*CheckerMock) IsAlive ¶
func (c *CheckerMock) IsAlive() bool
type EmitterMock ¶
type EmitterMock struct { Emitted bool // contains filtered or unexported fields }
func NewEmitter ¶
func NewEmitter() *EmitterMock
func (*EmitterMock) Close ¶
func (e *EmitterMock) Close()
func (*EmitterMock) Emit ¶
func (e *EmitterMock) Emit() chan *kafkabus.Message
type EventRepoMock ¶
func NewEventRepo ¶
func NewEventRepo() *EventRepoMock
Click to show internal directories.
Click to hide internal directories.