Versions in this module Expand all Collapse all v0 v0.3.0 Aug 16, 2021 Changes in this version + type App struct + Consensus *consensus.Consensus + Delivered chan *AppRecord + ID uint64 + Node *Node + Setup func() + func (a *App) AssembleProposal(metadata []byte, requests [][]byte) types.Proposal + func (a *App) AuxiliaryData(msg []byte) []byte + func (a *App) ClearMutateSend(target uint64) + func (a *App) Connect() + func (a *App) ConnectTo(target uint64) + func (a *App) Deliver(proposal types.Proposal, signatures []types.Signature) types.Reconfig + func (a *App) Disconnect() + func (a *App) DisconnectFrom(target uint64) + func (a *App) MembershipChange() bool + func (a *App) MutateSend(target uint64, mutating func(uint64, *smartbftprotos.Message)) + func (a *App) Mute() + func (a *App) RequestID(req []byte) types.RequestInfo + func (a *App) RequestsFromProposal(proposal types.Proposal) []types.RequestInfo + func (a *App) Restart() + func (a *App) Sign([]byte) []byte + func (a *App) SignProposal(_ types.Proposal, aux []byte) *types.Signature + func (a *App) Submit(req Request) + func (a *App) Sync() types.SyncResponse + func (a *App) UnMute() + func (a *App) VerificationSequence() uint64 + func (a *App) VerifyConsenterSig(signature types.Signature, _ types.Proposal) ([]byte, error) + func (a *App) VerifyProposal(proposal types.Proposal) ([]types.RequestInfo, error) + func (a *App) VerifyRequest(val []byte) (types.RequestInfo, error) + func (a *App) VerifySignature(_ types.Signature) error + type AppRecord struct + Batch *batch + Metadata []byte + type Configuration struct + CollectTimeout time.Duration + DecisionsPerLeader int64 + IncomingMessageBufferSize int64 + LeaderHeartbeatCount int64 + LeaderHeartbeatTimeout time.Duration + LeaderRotation bool + NumOfTicksBehindBeforeSyncing int64 + RequestAutoRemoveTimeout time.Duration + RequestBatchMaxBytes int64 + RequestBatchMaxCount int64 + RequestBatchMaxInterval time.Duration + RequestComplainTimeout time.Duration + RequestForwardTimeout time.Duration + RequestPoolSize int64 + SpeedUpViewChange bool + SyncOnStart bool + ViewChangeResendInterval time.Duration + ViewChangeTimeout time.Duration + type FwdMessage struct + Payload []byte + Sender uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FwdMessage) Descriptor() ([]byte, []int) + func (*FwdMessage) ProtoMessage() + func (m *FwdMessage) GetPayload() []byte + func (m *FwdMessage) GetSender() uint64 + func (m *FwdMessage) Reset() + func (m *FwdMessage) String() string + func (m *FwdMessage) XXX_DiscardUnknown() + func (m *FwdMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FwdMessage) XXX_Merge(src proto.Message) + func (m *FwdMessage) XXX_Size() int + func (m *FwdMessage) XXX_Unmarshal(b []byte) error + type Network map[uint64]*Node + func (n Network) AddOrUpdateNode(id uint64, h handler, app *App) + func (n Network) Shutdown() + func (n Network) StartServe() + func (n Network) StopServe() + type Node struct + func (node *Node) Nodes() []uint64 + func (node *Node) SendConsensus(targetID uint64, m *smartbftprotos.Message) + func (node *Node) SendTransaction(targetID uint64, request []byte) + type Reconfig struct + CurrentConfig Configuration + CurrentNodes []int64 + InLatestDecision bool + type Request struct + ClientID string + ID string + Reconfig Reconfig + func (txn Request) ToBytes() []byte Incompatible versions in this module v2.3.0+incompatible Aug 16, 2021 Other modules containing this package github.com/SmartBFT-Go/consensus/v2