tendermint

Documentation

Index

• func BroadcastTxAsyncFunc(validator *Node, txEncoder txs.Encoder) func(tx txs.Tx, callback func(res *abci_types.Response)) error
• func DeriveGenesisDoc(burrowGenesisDoc *genesis.GenesisDoc) *tm_types.GenesisDoc
• func EventBusAsSubscribable(eventBus tm_types.EventBusSubscriber) event.Subscribable
• func NewLogger(logger *logging.Logger) *tendermintLogger
• func PublishAllEvents(ctx context.Context, fromSubscribable event.Subscribable, subscriber string, ...) error
• func PublishEvent(ctx context.Context, fromSubscribable event.Subscribable, subscriber string, ...) error
• func SubscribableAsEventBus(subscribable event.Subscribable) tm_types.EventBusSubscriber
• func SubscribeNewBlock(ctx context.Context, subscribable event.Subscribable, subscriber string, ...) error
• type BurrowTendermintConfig
  • func DefaultBurrowTendermintConfig() *BurrowTendermintConfig
  • func (btc *BurrowTendermintConfig) TendermintConfig() *tm_config.Config
• type Node
  • func NewNode(conf *config.Config, privValidator tm_types.PrivValidator, ...) (*Node, error)
  • func (n *Node) Close()
  • func (n *Node) DBProvider(ctx *node.DBContext) (dbm.DB, error)

Functions

func BroadcastTxAsyncFunc

func BroadcastTxAsyncFunc(validator *Node, txEncoder txs.Encoder) func(tx txs.Tx,
	callback func(res *abci_types.Response)) error

func DeriveGenesisDoc

func DeriveGenesisDoc(burrowGenesisDoc *genesis.GenesisDoc) *tm_types.GenesisDoc

func EventBusAsSubscribable

func EventBusAsSubscribable(eventBus tm_types.EventBusSubscriber) event.Subscribable

func NewLogger

func NewLogger(logger *logging.Logger) *tendermintLogger

func PublishAllEvents

func PublishAllEvents(ctx context.Context, fromSubscribable event.Subscribable, subscriber string,
	toPublisher event.Publisher) error

Publishes all tendermint events available on subscribable to publisher

func PublishEvent

func PublishEvent(ctx context.Context, fromSubscribable event.Subscribable, subscriber string, eventType string,
	toPublisher event.Publisher) error

func SubscribableAsEventBus

func SubscribableAsEventBus(subscribable event.Subscribable) tm_types.EventBusSubscriber

func SubscribeNewBlock

func SubscribeNewBlock(ctx context.Context, subscribable event.Subscribable, subscriber string,
	ch chan<- *tm_types.EventDataNewBlock) error

Types

type BurrowTendermintConfig

type BurrowTendermintConfig struct {
	Seeds          string
	ListenAddress  string
	Moniker        string
	TendermintRoot string
}

Burrow's view on Tendermint's config. Since we operate as a Tendermint harness not all configuration values are applicable, we may not allow some values to specified, or we may not allow some to be set independently. So this serves as a layer of indirection over Tendermint's real config that we derive from ours.

func DefaultBurrowTendermintConfig

func DefaultBurrowTendermintConfig() *BurrowTendermintConfig

func (*BurrowTendermintConfig) TendermintConfig

func (btc *BurrowTendermintConfig) TendermintConfig() *tm_config.Config

type Node

type Node struct {
	*node.Node
	// contains filtered or unexported fields
}

Serves as a wrapper around the Tendermint node's closeable resources (database connections)

func NewNode

func NewNode(
	conf *config.Config,
	privValidator tm_types.PrivValidator,
	genesisDoc *tm_types.GenesisDoc,
	blockchain bcm.MutableBlockchain,
	checker execution.BatchExecutor,
	committer execution.BatchCommitter,
	logger *logging.Logger) (*Node, error)

func (*Node) Close

func (n *Node) Close()

func (*Node) DBProvider

func (n *Node) DBProvider(ctx *node.DBContext) (dbm.DB, error)

Since Tendermint doesn't close its DB connections