tortoise

Documentation

Index

• func RecoverLayer(ctx context.Context, trtl *Tortoise, db *datastore.CachedDB, ...) error
• type Config
  • func DefaultConfig() Config
• type DecodedBallot
• type EncodeVotesOpts
  • func EncodeVotesWithCurrent(current types.LayerID) EncodeVotesOpts
• type Opt
  • func WithConfig(cfg Config) Opt
  • func WithContext(ctx context.Context) Opt
  • func WithLogger(logger log.Log) Opt
• type Tortoise
  • func New(opts ...Opt) (*Tortoise, error)
  • func Recover(db *datastore.CachedDB, beacon system.BeaconGetter, opts ...Opt) (*Tortoise, error)
  • func (t *Tortoise) DecodeBallot(ballot *types.Ballot) (*DecodedBallot, error)
  • func (t *Tortoise) EncodeVotes(ctx context.Context, opts ...EncodeVotesOpts) (*types.Opinion, error)
  • func (t *Tortoise) GetMissingActiveSet(epoch types.EpochID, atxs []types.ATXID) []types.ATXID
  • func (t *Tortoise) LatestComplete() types.LayerID
  • func (t *Tortoise) OnAtx(atx *types.ActivationTxHeader)
  • func (t *Tortoise) OnBallot(ballot *types.Ballot)
  • func (t *Tortoise) OnBeacon(eid types.EpochID, beacon types.Beacon)
  • func (t *Tortoise) OnBlock(header types.BlockHeader)
  • func (t *Tortoise) OnHareOutput(lid types.LayerID, bid types.BlockID)
  • func (t *Tortoise) OnValidBlock(header types.BlockHeader)
  • func (t *Tortoise) OnWeakCoin(lid types.LayerID, coin bool)
  • func (t *Tortoise) Results(from, to types.LayerID) ([]result.Layer, error)
  • func (t *Tortoise) StoreBallot(decoded *DecodedBallot) error
  • func (t *Tortoise) TallyVotes(ctx context.Context, lid types.LayerID)
  • func (t *Tortoise) Updates() map[types.LayerID]map[types.BlockID]bool

Functions

func RecoverLayer

func RecoverLayer(ctx context.Context, trtl *Tortoise, db *datastore.CachedDB, beacon system.BeaconGetter, lid types.LayerID) error

Types

type Config

type Config struct {
	Hdist uint32 `mapstructure:"tortoise-hdist"` // hare output lookback distance
	Zdist uint32 `mapstructure:"tortoise-zdist"` // hare result wait distance
	// how long we are waiting for a switch from verifying to full. relevant during rerun.
	WindowSize    uint32 `mapstructure:"tortoise-window-size"`    // size of the tortoise sliding window (in layers)
	MaxExceptions int    `mapstructure:"tortoise-max-exceptions"` // if candidate for base ballot has more than max exceptions it will be ignored
	// number of layers to delay votes for blocks with bad beacon values during self-healing. ideally a full epoch.
	BadBeaconVoteDelayLayers uint32 `mapstructure:"tortoise-delay-layers"`

	LayerSize uint32
}

Config for protocol parameters.

func DefaultConfig

func DefaultConfig() Config

DefaultConfig for Tortoise.

type DecodedBallot

type DecodedBallot struct {
	*types.Ballot
	// contains filtered or unexported fields
}

DecodedBallot created after unwrapping exceptions list and computing internal opinion.

type EncodeVotesOpts

type EncodeVotesOpts func(*encodeConf)

EncodeVotesOpts is for configuring EncodeVotes options.

func EncodeVotesWithCurrent

func EncodeVotesWithCurrent(current types.LayerID) EncodeVotesOpts

EncodeVotesWithCurrent changes last known layer that will be used for encoding votes.

NOTE(dshulyak) why do we need this? tortoise computes threshold from last non-verified till the last known layer, since we dont download atxs before starting tortoise we won't be able to compute threshold based on the last clock layer (see https://github.com/spacemeshos/go-spacemesh/issues/3003)

type Opt

type Opt func(t *Tortoise)

Opt for configuring tortoise.

func WithConfig

func WithConfig(cfg Config) Opt

WithConfig defines protocol parameters.

func WithContext

func WithContext(ctx context.Context) Opt

WithContext defines context for tortoise.

func WithLogger

func WithLogger(logger log.Log) Opt

WithLogger defines logger for tortoise.

type Tortoise

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

Tortoise is a thread safe verifying tortoise wrapper, it just locks all actions.

func New

func New(opts ...Opt) (*Tortoise, error)

New creates Tortoise instance.

func Recover

func Recover(db *datastore.CachedDB, beacon system.BeaconGetter, opts ...Opt) (*Tortoise, error)

Recover tortoise state from database.

func (*Tortoise) DecodeBallot

func (t *Tortoise) DecodeBallot(ballot *types.Ballot) (*DecodedBallot, error)

DecodeBallot decodes ballot if it wasn't processed earlier.

func (*Tortoise) EncodeVotes

func (t *Tortoise) EncodeVotes(ctx context.Context, opts ...EncodeVotesOpts) (*types.Opinion, error)

EncodeVotes chooses a base ballot and creates a differences list. needs the hare results for latest layers.

func (*Tortoise) GetMissingActiveSet

func (t *Tortoise) GetMissingActiveSet(epoch types.EpochID, atxs []types.ATXID) []types.ATXID

GetMissingActiveSet returns unknown atxs from the original list. It is done for a specific epoch as active set atxs never cross epoch boundary.

func (*Tortoise) LatestComplete

func (t *Tortoise) LatestComplete() types.LayerID

LatestComplete returns the latest verified layer.

func (*Tortoise) OnAtx

func (t *Tortoise) OnAtx(atx *types.ActivationTxHeader)

OnAtx is expected to be called before ballots that use this atx.

func (*Tortoise) OnBallot

func (t *Tortoise) OnBallot(ballot *types.Ballot)

OnBallot should be called every time new ballot is received. Dependencies (base ballot, ref ballot, active set and its own atx) must be processed before ballot.

func (*Tortoise) OnBeacon

func (t *Tortoise) OnBeacon(eid types.EpochID, beacon types.Beacon)

func (*Tortoise) OnBlock

func (t *Tortoise) OnBlock(header types.BlockHeader)

OnBlock updates tortoise with information that data is available locally.

func (*Tortoise) OnHareOutput

func (t *Tortoise) OnHareOutput(lid types.LayerID, bid types.BlockID)

OnHareOutput should be called when hare terminated or certificate for a block was synced from a peer. This method is expected to be called any number of times, with layers in any order.

This method should be called with EmptyBlockID if node received proof of malicious behavior, such as signing same block id by members of the same committee.

func (*Tortoise) OnValidBlock

func (t *Tortoise) OnValidBlock(header types.BlockHeader)

OnValidBlock inserts block, updates that data is stored locally and that block was previously considered valid by tortoise.

func (*Tortoise) OnWeakCoin

func (t *Tortoise) OnWeakCoin(lid types.LayerID, coin bool)

func (*Tortoise) Results

func (t *Tortoise) Results(from, to types.LayerID) ([]result.Layer, error)

Results returns layers that crossed threshold in range [from, to].

func (*Tortoise) StoreBallot

func (t *Tortoise) StoreBallot(decoded *DecodedBallot) error

StoreBallot stores previously decoded ballot.

func (*Tortoise) TallyVotes

func (t *Tortoise) TallyVotes(ctx context.Context, lid types.LayerID)

TallyVotes up to the specified layer.

func (*Tortoise) Updates

func (t *Tortoise) Updates() map[types.LayerID]map[types.BlockID]bool