dispatch

Documentation

Index

• func NewDispatcher(cfg *config.Config, ap actpool.ActPool, bs blocksync.BlockSync, ...) (dispatcher.Dispatcher, error)
• type IotxDispatcher
  • func (d *IotxDispatcher) EventAudit() map[uint32]int
  • func (d *IotxDispatcher) EventChan() *chan interface{}
  • func (d *IotxDispatcher) HandleBroadcast(message proto.Message, done chan bool)
  • func (d *IotxDispatcher) HandleTell(sender net.Addr, message proto.Message, done chan bool)
  • func (d *IotxDispatcher) Start(ctx context.Context) error
  • func (d *IotxDispatcher) Stop(ctx context.Context) error

Functions

func NewDispatcher

func NewDispatcher(
	cfg *config.Config,
	ap actpool.ActPool,
	bs blocksync.BlockSync,
	cs consensus.Consensus,
) (dispatcher.Dispatcher, error)

NewDispatcher creates a new Dispatcher

Types

type IotxDispatcher

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

IotxDispatcher is the request and event dispatcher for iotx node.

func (*IotxDispatcher) EventAudit

func (d *IotxDispatcher) EventAudit() map[uint32]int

EventAudit returns the event audit map

func (*IotxDispatcher) EventChan

func (d *IotxDispatcher) EventChan() *chan interface{}

EventChan returns the event chan

func (*IotxDispatcher) HandleBroadcast

func (d *IotxDispatcher) HandleBroadcast(message proto.Message, done chan bool)

HandleBroadcast handles incoming broadcast message

func (*IotxDispatcher) HandleTell

func (d *IotxDispatcher) HandleTell(sender net.Addr, message proto.Message, done chan bool)

HandleTell handles incoming unicast message

func (*IotxDispatcher) Start

func (d *IotxDispatcher) Start(ctx context.Context) error

Start starts the dispatcher.

func (*IotxDispatcher) Stop

func (d *IotxDispatcher) Stop(ctx context.Context) error

Stop gracefully shuts down the dispatcher by stopping all handlers and waiting for them to finish.