messaging

Documentation

Overview

Package messaging is a generated GoMock package.

Package messaging is a generated GoMock package.

Index

• type ChannelBuilderFunc
• type ErrorHandler
• type ErrorHandlerFunc
  • func (f ErrorHandlerFunc) HandleError(ctx context.Context, err error)
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) HandleMessage(ctx context.Context, h Header, message []byte) error
• type Header
• type LogErrorHandler
  • func NewLogErrorHandler(logger log.Logger) *LogErrorHandler
  • func (h *LogErrorHandler) HandleError(ctx context.Context, err error)
• type MockHandler
  • func NewMockHandler(ctrl *gomock.Controller) *MockHandler
  • func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
  • func (m *MockHandler) HandleMessage(ctx context.Context, h Header, message []byte) error
• type MockHandlerMockRecorder
  • func (mr *MockHandlerMockRecorder) HandleMessage(ctx, h, message interface{}) *gomock.Call
• type MockReceiver
  • func NewMockReceiver(ctrl *gomock.Controller) *MockReceiver
  • func (m *MockReceiver) Channels() []string
  • func (m *MockReceiver) Close() error
  • func (m *MockReceiver) EXPECT() *MockReceiverMockRecorder
  • func (m *MockReceiver) Receive(ctx context.Context, channel string, h Handler) error
  • func (m *MockReceiver) Suspend(ctx context.Context, channel string) error
• type MockReceiverMockRecorder
  • func (mr *MockReceiverMockRecorder) Channels() *gomock.Call
  • func (mr *MockReceiverMockRecorder) Close() *gomock.Call
  • func (mr *MockReceiverMockRecorder) Receive(ctx, channel, h interface{}) *gomock.Call
  • func (mr *MockReceiverMockRecorder) Suspend(ctx, channel interface{}) *gomock.Call
• type MockSender
  • func NewMockSender(ctrl *gomock.Controller) *MockSender
  • func (m *MockSender) Close() error
  • func (m *MockSender) EXPECT() *MockSenderMockRecorder
  • func (m *MockSender) Send(ctx context.Context, channel string, h Header, route string, message []byte) error
• type MockSenderMockRecorder
  • func (mr *MockSenderMockRecorder) Close() *gomock.Call
  • func (mr *MockSenderMockRecorder) Send(ctx, channel, h, route, message interface{}) *gomock.Call
• type Receiver
• type Sender

Types

type ChannelBuilderFunc

type ChannelBuilderFunc func(st stream.Type) string

type ErrorHandler

type ErrorHandler interface {
	HandleError(ctx context.Context, err error)
}

type ErrorHandlerFunc

type ErrorHandlerFunc func(ctx context.Context, err error)

func (ErrorHandlerFunc) HandleError

func (f ErrorHandlerFunc) HandleError(ctx context.Context, err error)

type Handler

type Handler interface {
	HandleMessage(ctx context.Context, h Header, message []byte) error
}

type HandlerFunc

type HandlerFunc func(ctx context.Context, h Header, message []byte) error

func (HandlerFunc) HandleMessage

func (f HandlerFunc) HandleMessage(ctx context.Context, h Header, message []byte) error

type Header

type Header map[string]string

type LogErrorHandler

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

func NewLogErrorHandler

func NewLogErrorHandler(logger log.Logger) *LogErrorHandler

func (*LogErrorHandler) HandleError

func (h *LogErrorHandler) HandleError(ctx context.Context, err error)

type MockHandler

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

MockHandler is a mock of Handler interface

func NewMockHandler

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

NewMockHandler creates a new mock instance

func (*MockHandler) EXPECT

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockHandler) HandleMessage

func (m *MockHandler) HandleMessage(ctx context.Context, h Header, message []byte) error

HandleMessage mocks base method

type MockHandlerMockRecorder

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

MockHandlerMockRecorder is the mock recorder for MockHandler

func (*MockHandlerMockRecorder) HandleMessage

func (mr *MockHandlerMockRecorder) HandleMessage(ctx, h, message interface{}) *gomock.Call

HandleMessage indicates an expected call of HandleMessage

type MockReceiver

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

MockReceiver is a mock of Receiver interface

func NewMockReceiver

func NewMockReceiver(ctrl *gomock.Controller) *MockReceiver

NewMockReceiver creates a new mock instance

func (*MockReceiver) Channels

func (m *MockReceiver) Channels() []string

Channels mocks base method

func (*MockReceiver) Close

func (m *MockReceiver) Close() error

Close mocks base method

func (*MockReceiver) EXPECT

func (m *MockReceiver) EXPECT() *MockReceiverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockReceiver) Receive

func (m *MockReceiver) Receive(ctx context.Context, channel string, h Handler) error

Receive mocks base method

func (*MockReceiver) Suspend

func (m *MockReceiver) Suspend(ctx context.Context, channel string) error

Suspend mocks base method

type MockReceiverMockRecorder

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

MockReceiverMockRecorder is the mock recorder for MockReceiver

func (*MockReceiverMockRecorder) Channels

func (mr *MockReceiverMockRecorder) Channels() *gomock.Call

Channels indicates an expected call of Channels

func (*MockReceiverMockRecorder) Close

func (mr *MockReceiverMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockReceiverMockRecorder) Receive

func (mr *MockReceiverMockRecorder) Receive(ctx, channel, h interface{}) *gomock.Call

Receive indicates an expected call of Receive

func (*MockReceiverMockRecorder) Suspend

func (mr *MockReceiverMockRecorder) Suspend(ctx, channel interface{}) *gomock.Call

Suspend indicates an expected call of Suspend

type MockSender

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

MockSender is a mock of Sender interface

func NewMockSender

func NewMockSender(ctrl *gomock.Controller) *MockSender

NewMockSender creates a new mock instance

func (*MockSender) Close

func (m *MockSender) Close() error

Close mocks base method

func (*MockSender) EXPECT

func (m *MockSender) EXPECT() *MockSenderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSender) Send

func (m *MockSender) Send(ctx context.Context, channel string, h Header, route string, message []byte) error

Send mocks base method

type MockSenderMockRecorder

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

MockSenderMockRecorder is the mock recorder for MockSender

func (*MockSenderMockRecorder) Close

func (mr *MockSenderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockSenderMockRecorder) Send

func (mr *MockSenderMockRecorder) Send(ctx, channel, h, route, message interface{}) *gomock.Call

Send indicates an expected call of Send

type Receiver

type Receiver interface {
	Channels() []string
	Receive(ctx context.Context, channel string, h Handler) error
	Suspend(ctx context.Context, channel string) error
	Close() error
}

type Sender

type Sender interface {
	Send(ctx context.Context, channel string, h Header, route string, message []byte) error
	Close() error
}