propagator

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 6, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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{}) (*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) TxSwitchOutPutFunc

func (tp *TxPropagator) TxSwitchOutPutFunc() port.OutPutFunc

TxSwitchOutPutFunc get a OutPutFunc that can be bound to gossip switch

Jump to

Keyboard shortcuts

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