mocks

Documentation

Index

• type EventBroadcaster
  • func NewEventBroadcaster(t mockConstructorTestingTNewEventBroadcaster) *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
  • func NewSubscription(t mockConstructorTestingTNewSubscription) *Subscription
  • func (_m *Subscription) ChannelName() string
  • func (_m *Subscription) Close()
  • func (_m *Subscription) Events() <-chan pg.Event
  • func (_m *Subscription) InterestedIn(event pg.Event) bool
  • func (_m *Subscription) Send(event pg.Event)

Types

type EventBroadcaster

type EventBroadcaster struct {
	mock.Mock
}

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

type Subscription struct {
	mock.Mock
}

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