mock

Documentation

Index

• type EventsBackend
  • func NewEventsBackend(ownAddr string) *EventsBackend
  • func (mb *EventsBackend) PublishEvent(topic string, data []byte) error
  • func (mb *EventsBackend) Subscribe(ctx context.Context, topic string) (eventsBackend.Subscription, error)

Types

type EventsBackend

type EventsBackend struct {
	// contains filtered or unexported fields
}

EventsBackend fakes the event backend by setting up a very basic message broker in memory and tunneling all messages over it.

func NewEventsBackend

func NewEventsBackend(ownAddr string) *EventsBackend

NewEventsBackend returns a new EventsBackend

func (*EventsBackend) PublishEvent

func (mb *EventsBackend) PublishEvent(topic string, data []byte) error

PublishEvent is a mock implementation meant for testing.

func (*EventsBackend) Subscribe

func (mb *EventsBackend) Subscribe(ctx context.Context, topic string) (eventsBackend.Subscription, error)

Subscribe is a mock implementation meant for testing.