eventbus

Documentation

Overview

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

Usage:

TODO:

Index

• type EventBus
  • func New(cfg configuration.Configuration) (*EventBus, error)
  • func (eb *EventBus) Dispatch(event core.Event) (core.Reaction, error)
  • func (eb *EventBus) DispatchAsync(event core.Event)
  • func (eb *EventBus) Start(c core.Components) error
  • func (eb *EventBus) Stop() error

Types

type EventBus

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

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

func New

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

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

func (*EventBus) Dispatch

func (eb *EventBus) Dispatch(event core.Event) (core.Reaction, error)

Dispatch an `Event` and get a `Reaction` or error from remote host.

func (*EventBus) DispatchAsync

func (eb *EventBus) DispatchAsync(event core.Event)

DispatchAsync dispatches a `Event` to remote host.

func (*EventBus) Start

func (eb *EventBus) Start(c core.Components) error

func (*EventBus) Stop

func (eb *EventBus) Stop() error