messagerouter

Documentation

Overview

Package messagerouter routes messages (contract calls & responses) and delivers'em to relevant modules.

Usage:

TODO:

Index

• func DeserializeResponse(data []byte) (res core.Response, err error)
• func Serialize(value interface{}) ([]byte, error)
• type MessageRouter
  • func New(cfg configuration.Configuration) (*MessageRouter, error)
  • func (mr *MessageRouter) Route(msg core.Message) (response core.Response, err error)
  • func (mr *MessageRouter) Start(c core.Components) error
  • func (mr *MessageRouter) Stop() error

Functions

func DeserializeResponse

func DeserializeResponse(data []byte) (res core.Response, err error)

DeserializeResponse reads response from byte slice.

func Serialize

func Serialize(value interface{}) ([]byte, error)

Serialize converts Message or Response to byte slice.

Types

type MessageRouter

type MessageRouter struct {
	LogicRunner core.LogicRunner
	// contains filtered or unexported fields
}

MessageRouter is component that routes application logic requests, e.g. glue between network and logic runner

func New

func New(cfg configuration.Configuration) (*MessageRouter, error)

New is a `MessageRouter` constructor, takes an executor object that satisfies `LogicRunner` interface

func (*MessageRouter) Route

func (mr *MessageRouter) Route(msg core.Message) (response core.Response, err error)

Route a `Message` and get a `Response` or error from remote host

func (*MessageRouter) Start

func (mr *MessageRouter) Start(c core.Components) error

func (*MessageRouter) Stop

func (mr *MessageRouter) Stop() error