mockeventhub

Documentation

Index

• type MockEventHub
  • func New(adapter consumer.EventAdapter) *MockEventHub
  • func (m *MockEventHub) Disconnect(err error)
  • func (m *MockEventHub) ProduceEvent(event *pb.Event)
  • func (m *MockEventHub) Start() error

Types

type MockEventHub

type MockEventHub struct {
	Adapter          consumer.EventAdapter
	Interests        []*pb.Interest
	NumStartFailures int
}

MockEventHub mocks out the Event Hub

func New

func New(adapter consumer.EventAdapter) *MockEventHub

New returns a new MockEventHub

func (*MockEventHub) Disconnect

func (m *MockEventHub) Disconnect(err error)

Disconnect simulates a disconnect

func (*MockEventHub) ProduceEvent

func (m *MockEventHub) ProduceEvent(event *pb.Event)

ProduceEvent produces a new event, which is sent to the adapter

func (*MockEventHub) Start

func (m *MockEventHub) Start() error

Start implements the Start() method on the relay.EventHub interface