mockbus

Documentation

Index

• type MockBus
  • func (m *MockBus) Err() <-chan error
  • func (m *MockBus) Name() string
  • func (m *MockBus) Publish(topic string, message interface{}) error
  • func (m *MockBus) PublishDirect(ctx context.Context, topic string, message interface{}) error
  • func (m *MockBus) Start() error
  • func (m *MockBus) Status() error
  • func (m *MockBus) Stop() error
  • func (m *MockBus) Subscribe(topic string, consumer string, subscriber messaging.Subscriber) (messaging.Subscription, error)

Types

type MockBus

type MockBus struct {
	mock.Mock
}

MockBus ...

func (*MockBus) Err

func (m *MockBus) Err() <-chan error

Err ...

func (*MockBus) Name

func (m *MockBus) Name() string

Name ...

func (*MockBus) Publish

func (m *MockBus) Publish(topic string, message interface{}) error

Publish ...

func (*MockBus) PublishDirect

func (m *MockBus) PublishDirect(ctx context.Context, topic string, message interface{}) error

PublishDirect ...

func (*MockBus) Start

func (m *MockBus) Start() error

Start ...

func (*MockBus) Status

func (m *MockBus) Status() error

Status ...

func (*MockBus) Stop

func (m *MockBus) Stop() error

Stop ...

func (*MockBus) Subscribe

func (m *MockBus) Subscribe(topic string, consumer string, subscriber messaging.Subscriber) (messaging.Subscription, error)

Subscribe ...