Documentation ¶
Index ¶
- type EventBroadcaster
- func (_m *EventBroadcaster) Close() error
- func (_m *EventBroadcaster) HealthReport() map[string]error
- func (_m *EventBroadcaster) Name() string
- func (_m *EventBroadcaster) Notify(channel string, payload string) error
- func (_m *EventBroadcaster) Ready() error
- func (_m *EventBroadcaster) Start(_a0 context.Context) error
- func (_m *EventBroadcaster) Subscribe(channel string, payloadFilter string) (pg.Subscription, error)
- type Subscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBroadcaster ¶
EventBroadcaster is an autogenerated mock type for the EventBroadcaster type
func NewEventBroadcaster ¶
func NewEventBroadcaster(t mockConstructorTestingTNewEventBroadcaster) *EventBroadcaster
NewEventBroadcaster creates a new instance of EventBroadcaster. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*EventBroadcaster) Close ¶
func (_m *EventBroadcaster) Close() error
Close provides a mock function with given fields:
func (*EventBroadcaster) HealthReport ¶
func (_m *EventBroadcaster) HealthReport() map[string]error
HealthReport provides a mock function with given fields:
func (*EventBroadcaster) Name ¶
func (_m *EventBroadcaster) Name() string
Name provides a mock function with given fields:
func (*EventBroadcaster) Notify ¶
func (_m *EventBroadcaster) Notify(channel string, payload string) error
Notify provides a mock function with given fields: channel, payload
func (*EventBroadcaster) Ready ¶
func (_m *EventBroadcaster) Ready() error
Ready provides a mock function with given fields:
func (*EventBroadcaster) Start ¶
func (_m *EventBroadcaster) Start(_a0 context.Context) error
Start provides a mock function with given fields: _a0
func (*EventBroadcaster) Subscribe ¶
func (_m *EventBroadcaster) Subscribe(channel string, payloadFilter string) (pg.Subscription, error)
Subscribe provides a mock function with given fields: channel, payloadFilter
type Subscription ¶
Subscription is an autogenerated mock type for the Subscription type
func NewSubscription ¶
func NewSubscription(t mockConstructorTestingTNewSubscription) *Subscription
NewSubscription creates a new instance of Subscription. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Subscription) ChannelName ¶
func (_m *Subscription) ChannelName() string
ChannelName provides a mock function with given fields:
func (*Subscription) Close ¶
func (_m *Subscription) Close()
Close provides a mock function with given fields:
func (*Subscription) Events ¶
func (_m *Subscription) Events() <-chan pg.Event
Events provides a mock function with given fields:
func (*Subscription) InterestedIn ¶
func (_m *Subscription) InterestedIn(event pg.Event) bool
InterestedIn provides a mock function with given fields: event
func (*Subscription) Send ¶
func (_m *Subscription) Send(event pg.Event)
Send provides a mock function with given fields: event