replica

Oct 4, 2021

Changes in this version

+ type ResetHeightMessage struct

Jun 15, 2021

Changes in this version

type Options

+ StartingHeight process.Height

+ func (opts Options) WithStartingHeight(height process.Height) Options

Mar 25, 2020

Changes in this version

type Broadcaster

+ Cast func(id.Signatory, Message)

type Message

+ func (message *Message) Unmarshal(r io.Reader, m int) (int, error)

+ func (message Message) Marshal(w io.Writer, m int) (int, error)

+ func (message Message) SizeHint() int

type ProcessStorage

+ RestoreState func(state *process.State, shard Shard)

+ SaveState func(state *process.State, shard Shard)

type Shard

+ func (shard *Shard) Unmarshal(r io.Reader, m int) (int, error)

+ func (shard Shard) Marshal(w io.Writer, m int) (int, error)

+ func (shard Shard) SizeHint() int

Dec 10, 2020

Changes in this version

+ type DidHandleMessage func()

type Options

+ func (opts Options) WithLogger(logger *zap.Logger) Options

+ func (opts Options) WithMqOptions(mqOpts mq.Options) Options

type Replica

+ func (replica *Replica) ResetHeight(newHeight process.Height)

+ func (replica *Replica) TimeoutPrecommit(ctx context.Context, timeout timer.Timeout)

+ func (replica *Replica) TimeoutPrevote(ctx context.Context, timeout timer.Timeout)

+ func (replica *Replica) TimeoutPropose(ctx context.Context, timeout timer.Timeout)

+ func (replica Replica) CurrentHeight() process.Height

+ func (replica Replica) State() (process.Height, process.Round, process.Step)

Jul 1, 2020

Changes in this version

type Options

+ MessageQueueOpts mq.Options

+ TimerOpts timer.Options

+ func DefaultOptions() Options

+ func (opts Options) WithLogLevel(level logrus.Level) Options

+ func (opts Options) WithLogOutput(output io.Writer) Options

+ func (opts Options) WithTimerOptions(timerOpts timer.Options) Options

type Replica

+ func (replica *Replica) Precommit(ctx context.Context, precommit process.Precommit)

+ func (replica *Replica) Prevote(ctx context.Context, prevote process.Prevote)

+ func (replica *Replica) Propose(ctx context.Context, propose process.Propose)

+ func (replica *Replica) Run(ctx context.Context)

Oct 23, 2019

Changes in this version

type Observer

+ DidReceiveSufficientNilPrevotes func(messages process.Messages, f int)

Oct 1, 2019

Changes in this version

+ type BlockIterator interface

+ NextBlock func(block.Kind, block.Height, Shard) (block.Data, block.State)

+ type BlockStorage interface

+ Blockchain func(shard Shard) process.Blockchain

+ LatestBaseBlock func(shard Shard) block.Block

+ LatestBlock func(shard Shard) block.Block

+ type Broadcaster interface

+ Broadcast func(Message)

+ type Message struct

+ Message process.Message

+ Shard Shard

+ func (m *Message) UnmarshalBinary(data []byte) error

+ func (m *Message) UnmarshalJSON(data []byte) error

+ func (m Message) MarshalBinary() ([]byte, error)

+ func (m Message) MarshalJSON() ([]byte, error)

+ type Messages []Message

+ type Observer interface

+ DidCommitBlock func(block.Height, Shard)

+ IsSignatory func(Shard) bool

+ type Options struct

+ BackOffBase time.Duration

+ BackOffExp float64

+ BackOffMax time.Duration

+ Logger logrus.FieldLogger

+ type ProcessStorage interface

+ RestoreProcess func(p *process.Process, shard Shard)

+ SaveProcess func(p *process.Process, shard Shard)

type Replica

+ func (replica *Replica) HandleMessage(m Message)

+ func (replica *Replica) Rebase(sigs id.Signatories)

+ func (replica *Replica) Start()

+ type Replicas []Replica

+ type Shard [32]byte

+ func (shard Shard) Equal(other Shard) bool

+ func (shard Shard) String() string

+ type Shards []Shard

type Validator

+ IsBlockValid func(block block.Block, checkHistory bool, shard Shard) error

Aug 12, 2019

Changes in this version

+ type Dispatcher interface

+ Dispatch func(shardHash sig.Hash, action state.Action)

+ type Replica interface

+ Init func()

+ Sync func(commit block.Commit) bool

+ Transition func(transition state.Transition)

+ func New(dispatcher Dispatcher, signer sig.SignerVerifier, stateMachine state.Machine, ...) Replica

+ type Validator interface

+ ValidateCommit func(commit block.Commit) bool

+ ValidatePolka func(polka block.Polka) bool

+ ValidatePreCommit func(preCommit block.SignedPreCommit) bool

+ ValidatePreVote func(preVote block.SignedPreVote) bool

+ ValidatePropose func(propose block.SignedPropose) bool

+ func NewValidator(signer sig.Verifier, shard shard.Shard) Validator