message

Documentation

Index

• type Decoder
• type DecoderFunc
  • func (f DecoderFunc) Decode(message interface{}) error
• type Dispatcher
• type DispatcherFunc
  • func (f DispatcherFunc) Dispatch(message interface{}) error
• type Encoder
• type EncoderFunc
  • func (f EncoderFunc) Encode(message interface{}) error
• type ErrorHandler
• type ErrorHandlerFunc
  • func (f ErrorHandlerFunc) OnError(err error)
• type HandlerMap
  • func NewHandlerMap() HandlerMap
  • func (handlerMap HandlerMap) Handle(contex interface{}, message interface{}) error
  • func (handlerMap HandlerMap) Register(contex interface{})
  • func (handlerMap HandlerMap) RegisterWithoutLog(contex interface{})
• type Sendable
• type SimpleDispatcher
  • func NewSimpleDispatcher(contex interface{}, printLog bool) *SimpleDispatcher
  • func (dispatcher *SimpleDispatcher) Dispatch(message interface{}) error
• type Transporter
  • func NewTransporter(encoder Encoder, decoder Decoder, dispatcher Dispatcher, ...) Transporter
• type TypeMap
  • func NewTypeMap() TypeMap
  • func (typeMap TypeMap) Instantiate(name string) interface{}
  • func (typeMap TypeMap) Register(value interface{}) error
  • func (typeMap TypeMap) RegisterName(name string, value interface{}) error

Types

type Decoder

type Decoder interface {
	Decode(message interface{}) error
}

type DecoderFunc

type DecoderFunc func(message interface{}) error

func (DecoderFunc) Decode

func (f DecoderFunc) Decode(message interface{}) error

type Dispatcher

type Dispatcher interface {
	Dispatch(message interface{}) error
}

type DispatcherFunc

type DispatcherFunc func(message interface{}) error

func (DispatcherFunc) Dispatch

func (f DispatcherFunc) Dispatch(message interface{}) error

type Encoder

type Encoder interface {
	Encode(message interface{}) error
}

type EncoderFunc

type EncoderFunc func(message interface{}) error

func (EncoderFunc) Encode

func (f EncoderFunc) Encode(message interface{}) error

type ErrorHandler

type ErrorHandler interface {
	OnError(error)
}

type ErrorHandlerFunc

type ErrorHandlerFunc func(error)

func (ErrorHandlerFunc) OnError

func (f ErrorHandlerFunc) OnError(err error)

type HandlerMap

type HandlerMap map[reflect.Type]*reflect.Method

func NewHandlerMap

func NewHandlerMap() HandlerMap

func (HandlerMap) Handle

func (handlerMap HandlerMap) Handle(contex interface{}, message interface{}) error

func (HandlerMap) Register

func (handlerMap HandlerMap) Register(contex interface{})

func (HandlerMap) RegisterWithoutLog

func (handlerMap HandlerMap) RegisterWithoutLog(contex interface{})

type Sendable

type Sendable interface {
	Send(interface{})
}

type SimpleDispatcher

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

func NewSimpleDispatcher

func NewSimpleDispatcher(contex interface{}, printLog bool) *SimpleDispatcher

func (*SimpleDispatcher) Dispatch

func (dispatcher *SimpleDispatcher) Dispatch(message interface{}) error

type Transporter

type Transporter interface {
	Start() error
	Stop() error
	Send(message interface{})
	WaitForDone()
}

func NewTransporter

func NewTransporter(encoder Encoder,
	decoder Decoder,
	dispatcher Dispatcher,
	errorHandler ErrorHandler) Transporter

type TypeMap

type TypeMap map[string]reflect.Type

func NewTypeMap

func NewTypeMap() TypeMap

func (TypeMap) Instantiate

func (typeMap TypeMap) Instantiate(name string) interface{}

func (TypeMap) Register

func (typeMap TypeMap) Register(value interface{}) error

func (TypeMap) RegisterName

func (typeMap TypeMap) RegisterName(name string, value interface{}) error