message

package

v0.0.0-...-27cef4d Latest Latest Go to latest Published: Jun 11, 2019 License: LGPL-3.0 Imports: 5 Imported by: 8

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/fletaio/framework

Links

Open Source Insights

Documentation ¶

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 ¶

func NameOfType ¶

func NameOfType(t Type) string

NameOfType returns the name of the type

Types ¶

type Creator ¶

type Creator func(r io.Reader, mt Type) (Message, error)

Creator is a message creator function type

type Manager ¶

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

Manager is a structure that stores data for message processing.

func NewManager ¶

func NewManager() *Manager

NewManager returns a Manager

func (*Manager) DeleteMessage ¶

func (mm *Manager) DeleteMessage(m Type) error

DeleteMessage deletes registered messageMap.

func (*Manager) ParseMessage ¶

func (mm *Manager) ParseMessage(r io.Reader, mt Type) (Message, error)

ParseMessage receives the data stream as a Reader and processes them through the creator and returns the message.

func (*Manager) SetCreator ¶

func (mm *Manager) SetCreator(mt Type, c Creator) error

SetCreator is a function to register a message. Register author and handler by type to use when receiving messageMap.

type Message ¶

type Message interface {
	io.WriterTo
	io.ReaderFrom
	Type() Type
}

Message is a message for communicating between services

type Sender ¶

type Sender interface {
	Send(m Message) error
}

Sender is Default function of messenger

type Type ¶

type Type uint64

Type is message type

func DefineType ¶

func DefineType(Name string) Type

DefineType is return string type

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL