validator

package
v0.24.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2019 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthValidator = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowValidator   = fmt.Errorf("proto: integer overflow")
)

Functions

func Add

func Add(vs ReaderWriter, vsOther Iterable) error

Adds vsOther to vs

func AddPower

func AddPower(vs ReaderWriter, id crypto.PublicKey, power *big.Int) error

func Alter

func Alter(vs Alterer, vsOther Iterable) error

func Subtract

func Subtract(vs ReaderWriter, vsOther Iterable) error

Subtracts vsOther from vs

func SubtractPower

func SubtractPower(vs ReaderWriter, id crypto.PublicKey, power *big.Int) error

func Write added in v0.24.0

func Write(vs Writer, vsOther Iterable) error

Types

type Alterer added in v0.24.0

type Alterer interface {
	// AlterPower ensures that validator power would not change too quickly in a single block (unlike SetPower) which
	// merely checks values are sane. It returns the flow induced by the change in power.
	AlterPower(id crypto.PublicKey, power *big.Int) (flow *big.Int, err error)
}

type Bucket added in v0.24.0

type Bucket struct {
	// Delta tracks the changes to validator power made since the previous rotation
	Delta *Set
	// Previous the value for all validator powers at the point of the last rotation
	// (the sum of all the deltas over all rotations) - these are the history of the complete validator sets at each rotation
	Previous *Set
	// Tracks the current working version of the next set; Previous + Delta
	Next *Set
	// Flow tracks the absolute value of all flows (difference between previous cum bucket and current delta) towards and away from each validator (tracking each validator separately to avoid double counting flows made against the same validator
	Flow *Set
}

func NewBucket added in v0.24.0

func NewBucket(initialSets ...Iterable) *Bucket

func (*Bucket) AlterPower added in v0.24.0

func (vc *Bucket) AlterPower(id crypto.PublicKey, power *big.Int) (*big.Int, error)

Updates the current head bucket (accumulator) whilst

func (*Bucket) CurrentSet added in v0.24.0

func (vc *Bucket) CurrentSet() *Set

func (*Bucket) Equal added in v0.24.0

func (vc *Bucket) Equal(vwOther *Bucket) error

func (*Bucket) Power added in v0.24.0

func (vc *Bucket) Power(id crypto.Address) (*big.Int, error)

Implement Reader

func (*Bucket) SetPower added in v0.24.0

func (vc *Bucket) SetPower(id crypto.PublicKey, power *big.Int) error

func (*Bucket) String added in v0.24.0

func (vc *Bucket) String() string

type Cache added in v0.24.0

type Cache struct {
	*Bucket
}

Cache is just a Ring with no memory

func NewCache added in v0.24.0

func NewCache(backend Iterable) *Cache

func (*Cache) Flush added in v0.24.0

func (vc *Cache) Flush(output Writer, backend Iterable) error

func (*Cache) Reset added in v0.24.0

func (vc *Cache) Reset(backend Iterable)

type History added in v0.24.0

type History interface {
	ValidatorChanges(blocksAgo int) IterableReader
	Validators(blocksAgo int) IterableReader
}

type Iterable

type Iterable interface {
	IterateValidators(func(id crypto.Addressable, power *big.Int) error) error
}

type IterableReader

type IterableReader interface {
	Reader
	Iterable
}

type IterableReaderWriter

type IterableReaderWriter interface {
	ReaderWriter
	Iterable
}

type Reader

type Reader interface {
	Power(id crypto.Address) (*big.Int, error)
}

type ReaderWriter

type ReaderWriter interface {
	Reader
	Writer
}

type Ring

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

func NewRing

func NewRing(initialSet Iterable, windowSize int) *Ring

Provides a sliding window over the last size buckets of validator power changes

func (*Ring) AlterPower

func (vc *Ring) AlterPower(id crypto.PublicKey, power *big.Int) (*big.Int, error)

Updates the current head bucket (accumulator) whilst

func (*Ring) CumulativePower added in v0.24.0

func (vc *Ring) CumulativePower() *Set

Get the sum of all powers added in any bucket

func (*Ring) CurrentSet

func (vc *Ring) CurrentSet() *Set

func (*Ring) Equal

func (vc *Ring) Equal(vcOther *Ring) error

func (*Ring) GetPower added in v0.24.0

func (vc *Ring) GetPower(id crypto.Address) *big.Int

func (*Ring) Head

func (vc *Ring) Head() *Bucket

Get the current accumulator bucket

func (*Ring) Next

func (vc *Ring) Next() *Bucket

func (*Ring) OrderedBuckets

func (vc *Ring) OrderedBuckets() []*Bucket

Returns buckets in order head, previous, ...

func (*Ring) Power

func (vc *Ring) Power(id crypto.Address) (*big.Int, error)

Implement Reader Get power at index from the delta bucket then falling through to the cumulative

func (*Ring) PreviousDelta added in v0.24.0

func (vc *Ring) PreviousDelta(delay int) *Set

func (*Ring) PreviousSet

func (vc *Ring) PreviousSet(delay int) *Set

func (*Ring) ReIndex added in v0.24.0

func (vc *Ring) ReIndex(newHead int)

func (*Ring) Rotate

func (vc *Ring) Rotate() (totalPowerChange *big.Int, totalFlow *big.Int, err error)

Advance the current head bucket to the next bucket and returns the change in total power between the previous bucket and the current head, and the total flow which is the sum of absolute values of all changes each validator's power after rotation the next head is a copy of the current head

func (*Ring) SetPower added in v0.24.0

func (vc *Ring) SetPower(id crypto.PublicKey, power *big.Int) error

func (*Ring) Size

func (vc *Ring) Size() int

Get the number of buckets in the ring (use Current().Count() to get the current number of validators)

func (*Ring) String

func (vc *Ring) String() string

func (*Ring) ValidatorChanges added in v0.24.0

func (vc *Ring) ValidatorChanges(blocksAgo int) IterableReader

func (*Ring) Validators added in v0.24.0

func (vc *Ring) Validators(blocksAgo int) IterableReader

type Set

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

A Validator multiset - can be used to capture the global state of validators or as an accumulator each block

func Copy

func Copy(vss ...Iterable) *Set

Copy each of iterable in vss into a new Set - note any iterations errors thrown by the iterable itself will be swallowed Use Write instead if source iterables may error

func CopyTrim

func CopyTrim(vss ...Iterable) *Set

func Diff added in v0.24.0

func Diff(before, after IterableReader) (*Set, error)

Returns the asymmetric difference, diff, between two Sets such that applying diff to before results in after

func NewSet

func NewSet() *Set

Create a new Validators which can act as an accumulator for validator power changes

func NewTrimSet

func NewTrimSet() *Set

Like Set but removes entries when power is set to 0 this make Count() == CountNonZero() and prevents a set from leaking but does mean that a zero will not be iterated over when performing an update which is necessary in Ring

func UnpersistSet

func UnpersistSet(pvs []*Validator) *Set

func (*Set) ChangePower

func (vs *Set) ChangePower(id crypto.PublicKey, power *big.Int) *big.Int

Add the power of a validator and returns the flow into that validator

func (*Set) CountNonZero

func (vs *Set) CountNonZero() int

func (*Set) Equal

func (vs *Set) Equal(vsOther *Set) error

Returns an error if the Sets are not equal describing which part of their structures differ

func (*Set) Flow added in v0.24.0

func (vs *Set) Flow(id crypto.PublicKey, power *big.Int) *big.Int

Returns the flow that would be induced by a validator power change

func (*Set) Flush added in v0.24.0

func (vs *Set) Flush(output Writer, backend Reader) error

func (*Set) GetPower added in v0.24.0

func (vs *Set) GetPower(id crypto.Address) *big.Int

Error free version of Power

func (*Set) IterateValidators added in v0.24.0

func (vs *Set) IterateValidators(iter func(id crypto.Addressable, power *big.Int) error) error

Iterates over validators sorted by address

func (*Set) MaxFlow added in v0.24.0

func (vs *Set) MaxFlow() *big.Int

Returns the maximum allowable flow whilst ensuring the majority of validators are non-byzantine after the transition So need at most ceiling((Total Power)/3) - 1, in integer division we have ceiling(X*p/q) = (p(X+1)-1)/q For p = 1 just X/q so we want (Total Power)/3 - 1

func (*Set) MaybePower

func (vs *Set) MaybePower(id crypto.Address) *big.Int

Returns the power of id but only if it is set

func (*Set) Power

func (vs *Set) Power(id crypto.Address) (*big.Int, error)

Version of Power to match interface

func (*Set) SetPower added in v0.24.0

func (vs *Set) SetPower(id crypto.PublicKey, power *big.Int) error

Implements Writer, but will never error

func (*Set) Size added in v0.24.0

func (vs *Set) Size() int

func (*Set) String

func (vs *Set) String() string

func (*Set) Strings

func (vs *Set) Strings() string

func (*Set) TotalPower

func (vs *Set) TotalPower() *big.Int

func (*Set) Validators

func (vs *Set) Validators() []*Validator

type Validator

type Validator struct {
	Address              *github_com_hyperledger_burrow_crypto.Address `protobuf:"bytes,1,opt,name=Address,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Address,omitempty"`
	PublicKey            crypto.PublicKey                              `protobuf:"bytes,2,opt,name=PublicKey,proto3" json:"PublicKey"`
	Power                uint64                                        `protobuf:"varint,3,opt,name=Power,proto3" json:"Power,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func Decode added in v0.24.0

func Decode(bs []byte) (*Validator, error)

func FromAccount

func FromAccount(acc *acm.Account, power uint64) *Validator

func New added in v0.24.0

func New(publicKey crypto.PublicKey, power *big.Int) *Validator

func (*Validator) BigPower added in v0.24.0

func (v *Validator) BigPower() *big.Int

func (*Validator) Descriptor

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

func (*Validator) Encode added in v0.24.0

func (v *Validator) Encode() ([]byte, error)

func (*Validator) FillAddress

func (v *Validator) FillAddress()

func (*Validator) GetAddress added in v0.24.0

func (v *Validator) GetAddress() crypto.Address

func (*Validator) GetPower

func (m *Validator) GetPower() uint64

func (*Validator) GetPublicKey

func (m *Validator) GetPublicKey() crypto.PublicKey

func (*Validator) Marshal

func (m *Validator) Marshal() (dAtA []byte, err error)

func (*Validator) MarshalTo

func (m *Validator) MarshalTo(dAtA []byte) (int, error)

func (*Validator) ProtoMessage

func (*Validator) ProtoMessage()

func (*Validator) Reset

func (m *Validator) Reset()

func (*Validator) Size

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

func (*Validator) String

func (v *Validator) String() string

func (*Validator) Unmarshal

func (m *Validator) Unmarshal(dAtA []byte) error

func (*Validator) XXX_DiscardUnknown added in v0.23.0

func (m *Validator) XXX_DiscardUnknown()

func (*Validator) XXX_Marshal added in v0.23.0

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

func (*Validator) XXX_Merge added in v0.23.0

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

func (*Validator) XXX_MessageName

func (*Validator) XXX_MessageName() string

func (*Validator) XXX_Size added in v0.23.0

func (m *Validator) XXX_Size() int

func (*Validator) XXX_Unmarshal added in v0.23.0

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

type Writer

type Writer interface {
	SetPower(id crypto.PublicKey, power *big.Int) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL