consensus

Sep 30, 2024

Changes in this version

+ func EqualMessage(a, b Message) bool

+ type AbciApp abci.Accumulator

+ func (a *AbciApp) Check(req *CheckRequest) (*CheckResponse, error)

+ func (a *AbciApp) Commit(req *CommitRequest) (*CommitResponse, error)

+ func (a *AbciApp) Execute(req *ExecuteRequest) (*ExecuteResponse, error)

+ func (a *AbciApp) Info(*InfoRequest) (*InfoResponse, error)

+ func (a *AbciApp) Init(req *InitRequest) (*InitResponse, error)

type App

+ Commit func(*CommitRequest) (*CommitResponse, error)

+ Execute func(*ExecuteRequest) (*ExecuteResponse, error)

+ type BlockProposal struct

+ Envelopes []*messaging.Envelope

+ Index uint64

+ Time time.Time

+ func (v *BlockProposal) Copy() *BlockProposal

+ func (v *BlockProposal) CopyAsInterface() interface{}

+ func (v *BlockProposal) Equal(u *BlockProposal) bool

+ func (v *BlockProposal) IsValid() error

+ func (v *BlockProposal) MarshalBinary() ([]byte, error)

+ func (v *BlockProposal) MarshalJSON() ([]byte, error)

+ func (v *BlockProposal) UnmarshalBinary(data []byte) error

+ func (v *BlockProposal) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *BlockProposal) UnmarshalJSON(data []byte) error

+ type BlockResults struct

+ MessageResults []*protocol.TransactionStatus

+ ValidatorUpdates []*ValidatorUpdate

+ func (v *BlockResults) Copy() *BlockResults

+ func (v *BlockResults) CopyAsInterface() interface{}

+ func (v *BlockResults) Equal(u *BlockResults) bool

+ func (v *BlockResults) IsValid() error

+ func (v *BlockResults) MarshalBinary() ([]byte, error)

+ func (v *BlockResults) MarshalJSON() ([]byte, error)

+ func (v *BlockResults) UnmarshalBinary(data []byte) error

+ func (v *BlockResults) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *BlockResults) UnmarshalJSON(data []byte) error

+ type Capture []V

+ func (r *Capture[V]) Receive(messages ...Message) ([]Message, error)

+ type CommitRequest struct

+ Block any

+ type CommitResponse struct

+ Hash [32]byte

+ type CommitResult struct

+ Hash [32]byte

+ func (v *CommitResult) Copy() *CommitResult

+ func (v *CommitResult) CopyAsInterface() interface{}

+ func (v *CommitResult) Equal(u *CommitResult) bool

+ func (v *CommitResult) IsValid() error

+ func (v *CommitResult) MarshalBinary() ([]byte, error)

+ func (v *CommitResult) MarshalJSON() ([]byte, error)

+ func (v *CommitResult) UnmarshalBinary(data []byte) error

+ func (v *CommitResult) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *CommitResult) UnmarshalJSON(data []byte) error

+ type ConsensusError struct

+ Message string

+ Mine V

+ Theirs V

+ func (e *ConsensusError[V]) Error() string

+ type Dispatcher struct

+ func NewDispatcher(router routing.Router) *Dispatcher

+ func (d *Dispatcher) Receive(messages ...Message) ([]Message, error)

+ func (d *Dispatcher) Send(context.Context) <-chan error

+ func (d *Dispatcher) Submit(ctx context.Context, dest *url.URL, envelope *messaging.Envelope) error

+ type EnvelopeSubmitted struct

+ Results []*protocol.TransactionStatus

+ func (*EnvelopeSubmitted) Type() messageType

+ func (v *EnvelopeSubmitted) Copy() *EnvelopeSubmitted

+ func (v *EnvelopeSubmitted) CopyAsInterface() interface{}

+ func (v *EnvelopeSubmitted) Equal(u *EnvelopeSubmitted) bool

+ func (v *EnvelopeSubmitted) IsValid() error

+ func (v *EnvelopeSubmitted) MarshalBinary() ([]byte, error)

+ func (v *EnvelopeSubmitted) MarshalJSON() ([]byte, error)

+ func (v *EnvelopeSubmitted) UnmarshalBinary(data []byte) error

+ func (v *EnvelopeSubmitted) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *EnvelopeSubmitted) UnmarshalFieldsFrom(reader *encoding.Reader) error

+ func (v *EnvelopeSubmitted) UnmarshalJSON(data []byte) error

type ExecuteRequest

+ Envelopes []*messaging.Envelope

+ Params execute.BlockParams

type ExecuteResponse

+ Block any

+ Results []*protocol.TransactionStatus

+ Updates []*execute.ValidatorUpdate

+ type ExecutedBlock struct

+ Network string

+ Node [32]byte

+ func (*ExecutedBlock) Type() messageType

+ func (v *ExecutedBlock) Copy() *ExecutedBlock

+ func (v *ExecutedBlock) CopyAsInterface() interface{}

+ func (v *ExecutedBlock) Equal(u *ExecutedBlock) bool

+ func (v *ExecutedBlock) IsValid() error

+ func (v *ExecutedBlock) MarshalBinary() ([]byte, error)

+ func (v *ExecutedBlock) MarshalJSON() ([]byte, error)

+ func (v *ExecutedBlock) UnmarshalBinary(data []byte) error

+ func (v *ExecutedBlock) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *ExecutedBlock) UnmarshalFieldsFrom(reader *encoding.Reader) error

+ func (v *ExecutedBlock) UnmarshalJSON(data []byte) error

type ExecutorApp

+ Record Recorder

+ func (a *ExecutorApp) Commit(req *CommitRequest) (*CommitResponse, error)

+ func (a *ExecutorApp) Execute(req *ExecuteRequest) (*ExecuteResponse, error)

+ func (a *ExecutorApp) SetRecorder(rec Recorder)

+ type Hub interface

+ Register func(module Module)

+ Send func(...Message) error

+ With func(modules ...Module) Hub

+ type LeaderProposal struct

+ Leader [32]byte

+ func (v *LeaderProposal) Copy() *LeaderProposal

+ func (v *LeaderProposal) CopyAsInterface() interface{}

+ func (v *LeaderProposal) Equal(u *LeaderProposal) bool

+ func (v *LeaderProposal) IsValid() error

+ func (v *LeaderProposal) MarshalBinary() ([]byte, error)

+ func (v *LeaderProposal) MarshalJSON() ([]byte, error)

+ func (v *LeaderProposal) UnmarshalBinary(data []byte) error

+ func (v *LeaderProposal) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *LeaderProposal) UnmarshalJSON(data []byte) error

+ type Message interface

+ Type func() messageType

+ func CopyMessage(v Message) Message

+ func NewMessage(typ messageType) (Message, error)

+ func UnmarshalMessage(data []byte) (Message, error)

+ func UnmarshalMessageFrom(rd io.Reader) (Message, error)

+ func UnmarshalMessageJSON(data []byte) (Message, error)

+ type Module interface

+ Receive func(...Message) ([]Message, error)

+ type NetworkMessage interface

+ PartitionID func() string

type Node

+ func (n *Node) Receive(messages ...Message) ([]Message, error)

+ type NodeMessage interface

+ SenderID func() [32]byte

type Recorder

+ DidCommitBlock func(state execute.BlockState) error

+ DidReceiveMessages func([]Message) error

+ type SimpleHub struct

+ func NewSimpleHub(ctx context.Context) *SimpleHub

+ func (s *SimpleHub) Register(module Module)

+ func (s *SimpleHub) Send(messages ...Message) error

+ func (s *SimpleHub) With(modules ...Module) Hub

+ type StartBlock struct

+ func (*StartBlock) Type() messageType

+ func (v *StartBlock) Copy() *StartBlock

+ func (v *StartBlock) CopyAsInterface() interface{}

+ func (v *StartBlock) Equal(u *StartBlock) bool

+ func (v *StartBlock) IsValid() error

+ func (v *StartBlock) MarshalBinary() ([]byte, error)

+ func (v *StartBlock) MarshalJSON() ([]byte, error)

+ func (v *StartBlock) UnmarshalBinary(data []byte) error

+ func (v *StartBlock) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *StartBlock) UnmarshalFieldsFrom(reader *encoding.Reader) error

+ func (v *StartBlock) UnmarshalJSON(data []byte) error

+ type SubmitEnvelope struct

+ Envelope *messaging.Envelope

+ Network string

+ Pretend bool

+ func (*SubmitEnvelope) Type() messageType

+ func (s *SubmitEnvelope) PartitionID() string

+ func (v *SubmitEnvelope) Copy() *SubmitEnvelope

+ func (v *SubmitEnvelope) CopyAsInterface() interface{}

+ func (v *SubmitEnvelope) Equal(u *SubmitEnvelope) bool

+ func (v *SubmitEnvelope) IsValid() error

+ func (v *SubmitEnvelope) MarshalBinary() ([]byte, error)

+ func (v *SubmitEnvelope) MarshalJSON() ([]byte, error)

+ func (v *SubmitEnvelope) UnmarshalBinary(data []byte) error

+ func (v *SubmitEnvelope) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *SubmitEnvelope) UnmarshalFieldsFrom(reader *encoding.Reader) error

+ func (v *SubmitEnvelope) UnmarshalJSON(data []byte) error

+ type ValidatorUpdate struct

+ Power int64

+ PublicKey []byte

+ Type protocol.SignatureType

+ func (v *ValidatorUpdate) Copy() *ValidatorUpdate

+ func (v *ValidatorUpdate) CopyAsInterface() interface{}

+ func (v *ValidatorUpdate) Equal(u *ValidatorUpdate) bool

+ func (v *ValidatorUpdate) IsValid() error

+ func (v *ValidatorUpdate) MarshalBinary() ([]byte, error)

+ func (v *ValidatorUpdate) MarshalJSON() ([]byte, error)

+ func (v *ValidatorUpdate) UnmarshalBinary(data []byte) error

+ func (v *ValidatorUpdate) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *ValidatorUpdate) UnmarshalJSON(data []byte) error

Dec 6, 2023

Changes in this version

type CheckRequest

+ Context context.Context

+ Pretend bool

+ type CommitConsensusError [][]byte

+ func (CommitConsensusError) Error() string

+ type ExecuteHookFunc = func(*Node, execute.BlockParams, []*messaging.Envelope) (_ []*messaging.Envelope, keepHook bool)

+ type ExecuteRequest struct

+ Context context.Context

+ type ExecuteResponse struct

type ExecutorApp

+ Restore RestoreFunc

+ type Gossip struct

type InitRequest

+ Validators []*execute.ValidatorUpdate

type InitResponse

+ Validators []*execute.ValidatorUpdate

type Node

+ IgnoreCommitResults bool

+ IgnoreDeliverResults bool

+ SkipProposalCheck bool

+ func (n *Node) Execute(req *ExecuteRequest) (*ExecuteResponse, error)

+ func (n *Node) SetExecuteHook(hook ExecuteHookFunc)

+ func (n *Node) SetRecorder(rec Recorder)

+ func (n *Node) Status(*StatusRequest) (*StatusResponse, error)

+ type RestoreFunc func(ioutil.SectionReader) error

+ type StatusRequest struct

+ type StatusResponse struct

+ BlockIndex uint64

+ BlockTime time.Time

Aug 4, 2023

Changes in this version

+ type App interface

+ Begin func(*BeginRequest) (*BeginResponse, error)

+ Check func(*CheckRequest) (*CheckResponse, error)

+ Info func(*InfoRequest) (*InfoResponse, error)

+ Init func(*InitRequest) (*InitResponse, error)

+ type BeginRequest struct

+ Params execute.BlockParams

+ type BeginResponse struct

+ Block execute.Block

+ type CheckRequest struct

+ Envelope *messaging.Envelope

+ New bool

+ type CheckResponse struct

+ Results []*protocol.TransactionStatus

+ type ExecutorApp struct

+ Database database.Beginner

+ Describe *config.Describe

+ EventBus *events.Bus

+ Executor execute.Executor

+ func (a *ExecutorApp) Begin(req *BeginRequest) (*BeginResponse, error)

+ func (a *ExecutorApp) Check(req *CheckRequest) (*CheckResponse, error)

+ func (a *ExecutorApp) Info(*InfoRequest) (*InfoResponse, error)

+ func (a *ExecutorApp) Init(req *InitRequest) (*InitResponse, error)

+ type ExecutorBlock struct

+ func (b *ExecutorBlock) Close() (execute.BlockState, error)

+ func (b *ExecutorBlock) Process(envelope *messaging.Envelope) ([]*protocol.TransactionStatus, error)

+ type ExecutorBlockState struct

+ func (s *ExecutorBlockState) Commit() error

+ type InfoRequest struct

+ type InfoResponse struct

+ LastBlock *execute.BlockParams

+ LastHash [32]byte

+ type InitRequest struct

+ Snapshot ioutil2.SectionReader

+ type InitResponse struct

+ Hash []byte

+ type Node struct

+ func NewNode(app App, recorder Recorder) *Node

+ func (n *Node) Begin(req *BeginRequest) (*BeginResponse, error)

+ func (n *Node) Check(req *CheckRequest) (*CheckResponse, error)

+ func (n *Node) Commit(state execute.BlockState) ([]byte, error)

+ func (n *Node) Deliver(block execute.Block, envelopes []*messaging.Envelope) ([]*protocol.TransactionStatus, error)

+ func (n *Node) EndBlock(block execute.Block) (execute.BlockState, error)

+ func (n *Node) Info(req *InfoRequest) (*InfoResponse, error)

+ func (n *Node) Init(req *InitRequest) (*InitResponse, error)

+ type Recorder interface

+ DidExecuteBlock func(state execute.BlockState, submissions []*messaging.Envelope) error

+ DidInit func(snapshot ioutil.SectionReader) error