burrow: github.com/hyperledger/burrow/consensus/tendermint Index | Files | Directories

package tendermint

import "github.com/hyperledger/burrow/consensus/tendermint"

Index

Package Files

amino.go config.go logger.go node_view.go priv_validator_memory.go sign_info.go tendermint.go tendermint.pb.go

Constants

const (
    NeverCreateEmptyBlocks  = "never"
    AlwaysCreateEmptyBlocks = "always"
)

func DBProvider Uses

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

func DeriveGenesisDoc Uses

func DeriveGenesisDoc(burrowGenesisDoc *genesis.GenesisDoc, appHash []byte) *tmTypes.GenesisDoc

func EnsureNodeKey Uses

func EnsureNodeKey(nodeKeyFile string) (*p2p.NodeKey, error)

func NewLogger Uses

func NewLogger(logger *logging.Logger) log.Logger

func NewNodeKey Uses

func NewNodeKey() *p2p.NodeKey

func NewPrivValidatorMemory Uses

func NewPrivValidatorMemory(addressable crypto.Addressable, signer crypto.Signer) *privValidatorMemory

Create a PrivValidator with in-memory state that takes an addressable representing the validator identity and a signer providing private signing for that identity.

func WriteNodeKey Uses

func WriteNodeKey(nodeKeyFile string, key json.RawMessage) error

type BurrowTendermintConfig Uses

type BurrowTendermintConfig struct {
    Enabled bool
    // Initial peers we connect to for peer exchange
    Seeds string
    // Whether this node should crawl the network looking for new peers - disconnecting to peers after it has shared addresses
    SeedMode bool
    // Peers to which we automatically connect
    PersistentPeers string
    ListenHost      string
    ListenPort      string
    // Optional external that nodes may provide with their NodeInfo
    ExternalAddress string
    // Set true for strict address routability rules
    // Set false for private or local networks
    AddrBookStrict bool
    Moniker        string
    // Only accept connections from registered peers
    IdentifyPeers bool
    // Peers ID or address this node is authorize to sync with
    AuthorizedPeers string
    // EmptyBlocks mode and possible interval between empty blocks in seconds, one of:
    // "", "never" (to never create unnecessary blocks)
    // "always" (to create empty blocks each consensus round)
    CreateEmptyBlocks 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 Uses

func DefaultBurrowTendermintConfig() *BurrowTendermintConfig

func (*BurrowTendermintConfig) Config Uses

func (btc *BurrowTendermintConfig) Config(rootDir string, timeoutFactor float64) (*tmConfig.Config, error)

func (*BurrowTendermintConfig) DefaultAuthorizedPeersProvider Uses

func (btc *BurrowTendermintConfig) DefaultAuthorizedPeersProvider() abci.AuthorizedPeers

func (*BurrowTendermintConfig) ListenAddress Uses

func (btc *BurrowTendermintConfig) ListenAddress() string

type LastSignedInfo Uses

type LastSignedInfo struct {
    sync.Mutex
    Height    int64           `json:"height"`
    Round     int             `json:"round"`
    Step      int8            `json:"step"`
    Signature []byte          `json:"signature,omitempty"` // so we don't lose signatures
    SignBytes binary.HexBytes `json:"signbytes,omitempty"` // so we don't lose signatures
}

LastSignedInfo contains information about the latest data signed by a validator to help prevent double signing.

func NewLastSignedInfo Uses

func NewLastSignedInfo() *LastSignedInfo

func (*LastSignedInfo) SignProposal Uses

func (lsi *LastSignedInfo) SignProposal(sign tmCryptoSigner, chainID string, proposal *types.Proposal) error

SignProposal signs a canonical representation of the proposal, along with the chainID. Implements PrivValidator.

func (*LastSignedInfo) SignVote Uses

func (lsi *LastSignedInfo) SignVote(sign tmCryptoSigner, chainID string, vote *types.Vote) error

SignVote signs a canonical representation of the vote, along with the chainID. Implements PrivValidator.

func (*LastSignedInfo) String Uses

func (lsi *LastSignedInfo) String() string

String returns a string representation of the LastSignedInfo.

type Node Uses

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 Uses

func NewNode(conf *config.Config, privValidator tmTypes.PrivValidator, genesisDoc *tmTypes.GenesisDoc,
    app *abci.App, metricsProvider node.MetricsProvider, logger *logging.Logger) (*Node, error)

func (*Node) Close Uses

func (n *Node) Close()

func (*Node) DBProvider Uses

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

Since Tendermint doesn't close its DB connections

type NodeInfo Uses

type NodeInfo struct {
    ID                   github_com_hyperledger_burrow_crypto.Address  `protobuf:"bytes,1,opt,name=ID,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"ID"`
    ListenAddress        string                                        `protobuf:"bytes,2,opt,name=ListenAddress,proto3" json:"ListenAddress,omitempty"`
    Network              string                                        `protobuf:"bytes,3,opt,name=Network,proto3" json:"Network,omitempty"`
    Version              string                                        `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`
    Channels             github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,5,opt,name=Channels,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"Channels"`
    Moniker              string                                        `protobuf:"bytes,6,opt,name=Moniker,proto3" json:"Moniker,omitempty"`
    RPCAddress           string                                        `protobuf:"bytes,7,opt,name=RPCAddress,proto3" json:"RPCAddress,omitempty"`
    TxIndex              string                                        `protobuf:"bytes,8,opt,name=TxIndex,proto3" json:"TxIndex,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
    XXX_unrecognized     []byte                                        `json:"-"`
    XXX_sizecache        int32                                         `json:"-"`
}

func NewNodeInfo Uses

func NewNodeInfo(ni p2p.DefaultNodeInfo) *NodeInfo

func (*NodeInfo) Descriptor Uses

func (*NodeInfo) Descriptor() ([]byte, []int)

func (*NodeInfo) GetListenAddress Uses

func (m *NodeInfo) GetListenAddress() string

func (*NodeInfo) GetMoniker Uses

func (m *NodeInfo) GetMoniker() string

func (*NodeInfo) GetNetwork Uses

func (m *NodeInfo) GetNetwork() string

func (*NodeInfo) GetRPCAddress Uses

func (m *NodeInfo) GetRPCAddress() string

func (*NodeInfo) GetTxIndex Uses

func (m *NodeInfo) GetTxIndex() string

func (*NodeInfo) GetVersion Uses

func (m *NodeInfo) GetVersion() string

func (*NodeInfo) ProtoMessage Uses

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset Uses

func (m *NodeInfo) Reset()

func (*NodeInfo) Size Uses

func (m *NodeInfo) Size() (n int)

func (*NodeInfo) String Uses

func (m *NodeInfo) String() string

func (*NodeInfo) XXX_DiscardUnknown Uses

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal Uses

func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeInfo) XXX_Merge Uses

func (m *NodeInfo) XXX_Merge(src proto.Message)

func (*NodeInfo) XXX_MessageName Uses

func (*NodeInfo) XXX_MessageName() string

func (*NodeInfo) XXX_Size Uses

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal Uses

func (m *NodeInfo) XXX_Unmarshal(b []byte) error

type NodeView Uses

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

func NewNodeView Uses

func NewNodeView(tmNode *Node, txDecoder txs.Decoder, runID simpleuuid.UUID) (*NodeView, error)

func (*NodeView) BlockStore Uses

func (nv *NodeView) BlockStore() state.BlockStoreRPC

func (*NodeView) IsFastSyncing Uses

func (nv *NodeView) IsFastSyncing() bool

func (*NodeView) MempoolTransactions Uses

func (nv *NodeView) MempoolTransactions(maxTxs int) ([]*txs.Envelope, error)

Pass -1 to get all available transactions

func (*NodeView) NodeInfo Uses

func (nv *NodeView) NodeInfo() *NodeInfo

func (*NodeView) PeerRoundStates Uses

func (nv *NodeView) PeerRoundStates() ([]*ctypes.PeerRoundState, error)

func (*NodeView) Peers Uses

func (nv *NodeView) Peers() p2p.IPeerSet

func (*NodeView) RoundState Uses

func (nv *NodeView) RoundState() *ctypes.RoundState

func (*NodeView) RoundStateJSON Uses

func (nv *NodeView) RoundStateJSON() ([]byte, error)

func (*NodeView) RunID Uses

func (nv *NodeView) RunID() simpleuuid.UUID

func (*NodeView) ValidatorAddress Uses

func (nv *NodeView) ValidatorAddress() crypto.Address

func (*NodeView) ValidatorPublicKey Uses

func (nv *NodeView) ValidatorPublicKey() crypto.PublicKey

Directories

PathSynopsis
codes

Package tendermint imports 40 packages (graph) and is imported by 37 packages. Updated 2020-03-02. Refresh now. Tools for package owners.