tendermint

Documentation

Index

• Variables
• func DBProvider(ID string, backendType dbm.DBBackendType, dbDir string) dbm.DB
• func DeriveGenesisDoc(burrowGenesisDoc *genesis.GenesisDoc) *tm_types.GenesisDoc
• func EventBusAsSubscribable(eventBus tm_types.EventBusSubscriber) event.Subscribable
• func NewBlockEvent(message interface{}) *tm_types.EventDataNewBlock
• 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) (<-chan *tm_types.EventDataNewBlock, 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)

Variables

var NewBlockQuery = query.Must(event.QueryForEventID(tm_types.EventNewBlock).Query())

Functions

func DBProvider

func DBProvider(ID string, backendType dbm.DBBackendType, dbDir string) dbm.DB

func DeriveGenesisDoc

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

func EventBusAsSubscribable

func EventBusAsSubscribable(eventBus tm_types.EventBusSubscriber) event.Subscribable

func NewBlockEvent

func NewBlockEvent(message interface{}) *tm_types.EventDataNewBlock

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) (<-chan *tm_types.EventDataNewBlock, error)

Subscribe to NewBlock event safely that ensures progress by a non-blocking receive as well as handling unsubscribe

Types

type BurrowTendermintConfig

type BurrowTendermintConfig struct {
	// Initial peers we connect to for peer exchange
	Seeds string
	// Peers to which we automatically connect
	PersistentPeers 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.Blockchain, checker execution.BatchExecutor, committer execution.BatchCommitter,
	txDecoder txs.Decoder, 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