Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLength = errors.New("invalid length") ErrAlreadyAppliedMessage = errors.New("already applied message") ErrNotAppliedMessage = errors.New("not applied message") ErrUnhandledMessage = errors.New("unhandled message") ErrInvalidMessage = errors.New("invalid message") ErrUnknownMessage = errors.New("unknown message") )
message error list
Functions ¶
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager is a structure that stores data for message processing.
func (*Manager) DeleteMessage ¶
DeleteMessage deletes registered messageMap.
func (*Manager) ParseMessage ¶
ParseMessage receives the data stream as a Reader and processes them through the creator and returns the message.
type Message ¶
type Message interface { io.WriterTo io.ReaderFrom Type() Type }
Message is a message for communicating between services
Click to show internal directories.
Click to hide internal directories.