propagator

Documentation

Index

• type BlockPropagator
  • func NewBlockPropagator(p2p p2p.P2PAPI, blockOut chan<- interface{}, eventCenter types.EventCenter) (*BlockPropagator, error)
  • func (bp *BlockPropagator) BlockEventFunc(event interface{})
  • func (bp *BlockPropagator) Start() error
  • func (bp *BlockPropagator) Stop()
• type TxPropagator
  • func NewTxPropagator(p2p p2p.P2PAPI, txOut chan<- interface{}, eventCenter types.EventCenter) (*TxPropagator, error)
  • func (tp *TxPropagator) Start() error
  • func (tp *TxPropagator) Stop()
  • func (tp *TxPropagator) TxEventFunc(event interface{})

Types

type BlockPropagator

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

BlockPropagator block message propagator

func NewBlockPropagator

func NewBlockPropagator(p2p p2p.P2PAPI, blockOut chan<- interface{}, eventCenter types.EventCenter) (*BlockPropagator, error)

NewBlockPropagator create a new NewBlockPropagator instance.

func (*BlockPropagator) BlockEventFunc

func (bp *BlockPropagator) BlockEventFunc(event interface{})

BlockEventFunc get a EventFunc that can be bound to event center

func (*BlockPropagator) Start

func (bp *BlockPropagator) Start() error

Start start propagator

func (*BlockPropagator) Stop

func (bp *BlockPropagator) Stop()

Stop start propagator

type TxPropagator

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

TxPropagator transaction message propagator

func NewTxPropagator

func NewTxPropagator(p2p p2p.P2PAPI, txOut chan<- interface{}, eventCenter types.EventCenter) (*TxPropagator, error)

NewBlockPropagator create a new NewBlockPropagator instance.

func (*TxPropagator) Start

func (tp *TxPropagator) Start() error

Start start propagator

func (*TxPropagator) Stop

func (tp *TxPropagator) Stop()

Stop start propagator

func (*TxPropagator) TxEventFunc

func (tp *TxPropagator) TxEventFunc(event interface{})

BlockEventFunc get a EventFunc that can be bound to event center