vote

Documentation

Index

• type Blacklist
  • func (bl *Blacklist) Deserialize(buf []byte) error
  • func (bl *Blacklist) LoadProto(blackListpb *iotextypes.ProbationCandidateList) error
  • func (bl *Blacklist) Proto() *iotextypes.ProbationCandidateList
  • func (bl *Blacklist) Serialize() ([]byte, error)
• type UnproductiveDelegate
  • func NewUnproductiveDelegate(kickoutPeriod uint64, cacheSize uint64) (*UnproductiveDelegate, error)
  • func (upd *UnproductiveDelegate) AddRecentUPD(new []string) error
  • func (upd *UnproductiveDelegate) DelegateList() [][]string
  • func (upd *UnproductiveDelegate) Deserialize(buf []byte) error
  • func (upd *UnproductiveDelegate) Equal(upd2 *UnproductiveDelegate) bool
  • func (upd *UnproductiveDelegate) LoadProto(updPb *updpb.UnproductiveDelegate) error
  • func (upd *UnproductiveDelegate) Proto() *updpb.UnproductiveDelegate
  • func (upd *UnproductiveDelegate) ReadOldestUPD() []string
  • func (upd *UnproductiveDelegate) Serialize() ([]byte, error)

Types

type Blacklist

type Blacklist struct {
	BlacklistInfos map[string]uint32
	IntensityRate  uint32
}

Blacklist defines a map where key is candidate's name and value is the counter which counts the unproductivity during kick-out epoch.

func (*Blacklist) Deserialize

func (bl *Blacklist) Deserialize(buf []byte) error

Deserialize deserializes bytes to delegate blacklist

func (*Blacklist) LoadProto

func (bl *Blacklist) LoadProto(blackListpb *iotextypes.ProbationCandidateList) error

LoadProto loads blacklist from proto

func (*Blacklist) Proto

func (bl *Blacklist) Proto() *iotextypes.ProbationCandidateList

Proto converts the blacklist to a protobuf message

func (*Blacklist) Serialize

func (bl *Blacklist) Serialize() ([]byte, error)

Serialize serializes map of blacklist to bytes

type UnproductiveDelegate

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

UnproductiveDelegate defines unproductive delegates information within kickout period

func NewUnproductiveDelegate

func NewUnproductiveDelegate(kickoutPeriod uint64, cacheSize uint64) (*UnproductiveDelegate, error)

NewUnproductiveDelegate creates new UnproductiveDelegate with kickoutperiod and cacheSize

func (*UnproductiveDelegate) AddRecentUPD

func (upd *UnproductiveDelegate) AddRecentUPD(new []string) error

AddRecentUPD adds new epoch upd-list at the leftmost and shift existing lists to the right

func (*UnproductiveDelegate) DelegateList

func (upd *UnproductiveDelegate) DelegateList() [][]string

DelegateList returns delegate list 2D array

func (*UnproductiveDelegate) Deserialize

func (upd *UnproductiveDelegate) Deserialize(buf []byte) error

Deserialize deserializes bytes to UnproductiveDelegate struct

func (*UnproductiveDelegate) Equal

func (upd *UnproductiveDelegate) Equal(upd2 *UnproductiveDelegate) bool

Equal compares with other upd struct and returns true if it's equal

func (*UnproductiveDelegate) LoadProto

func (upd *UnproductiveDelegate) LoadProto(updPb *updpb.UnproductiveDelegate) error

LoadProto converts protobuf message to unproductvieDelegate struct

func (*UnproductiveDelegate) Proto

func (upd *UnproductiveDelegate) Proto() *updpb.UnproductiveDelegate

Proto converts the unproductvieDelegate struct to a protobuf message

func (*UnproductiveDelegate) ReadOldestUPD

func (upd *UnproductiveDelegate) ReadOldestUPD() []string

ReadOldestUPD returns the last upd-list

func (*UnproductiveDelegate) Serialize

func (upd *UnproductiveDelegate) Serialize() ([]byte, error)

Serialize serializes unproductvieDelegate struct to bytes