hare4

Oct 4, 2024

Changes in this version

type MalfeasanceHandler

+ func (mh *MalfeasanceHandler) Info(data wire.ProofData) (map[string]string, error)

Sep 25, 2024

Changes in this version

+ const MAX_EXCHANGE_SIZE

+ const PROTOCOL_NAME

+ type Body struct

+ Eligibility types.HareEligibility

+ Layer types.LayerID

+ Value Value

+ func (t *Body) DecodeScale(dec *scale.Decoder) (total int, err error)

+ func (t *Body) EncodeScale(enc *scale.Encoder) (total int, err error)

+ type CommitteeUpgrade struct

+ Layer types.LayerID

+ Size uint16

+ type CompactIdRequest struct

+ MsgId types.Hash32

+ func (t *CompactIdRequest) DecodeScale(dec *scale.Decoder) (total int, err error)

+ func (t *CompactIdRequest) EncodeScale(enc *scale.Encoder) (total int, err error)

+ type CompactIdResponse struct

+ Ids []types.ProposalID

+ func (t *CompactIdResponse) DecodeScale(dec *scale.Decoder) (total int, err error)

+ func (t *CompactIdResponse) EncodeScale(enc *scale.Encoder) (total int, err error)

+ type Config struct

+ Committee uint16

+ CommitteeUpgrade *CommitteeUpgrade

+ DisableLayer types.LayerID

+ Enable bool

+ EnableLayer types.LayerID

+ IterationsLimit uint8

+ Leaders uint16

+ LogStats bool

+ PreroundDelay time.Duration

+ ProtocolName string

+ RoundDuration time.Duration

+ func DefaultConfig() Config

+ func (cfg *Config) CommitteeFor(layer types.LayerID) uint16

+ func (cfg *Config) MarshalLogObject(encoder zapcore.ObjectEncoder) error

+ func (cfg *Config) Validate(zdist time.Duration) error

+ type ConsensusOutput struct

+ Layer types.LayerID

+ Proposals []types.ProposalID

+ type Hare struct

+ func New(nodeClock nodeClock, pubsub pubsub.PublishSubscriber, db sql.StateDatabase, ...) *Hare

+ func (h *Hare) Coins() <-chan WeakCoinOutput

+ func (h *Hare) Handler(ctx context.Context, peer p2p.Peer, buf []byte) error

+ func (h *Hare) IsKnown(layer types.LayerID, proposal types.ProposalID) bool

+ func (h *Hare) OnProposal(p *types.Proposal) error

+ func (h *Hare) Register(sig *signing.EdSigner)

+ func (h *Hare) Results() <-chan ConsensusOutput

+ func (h *Hare) Running() int

+ func (h *Hare) Start()

+ func (h *Hare) Stop()

+ type IterRound struct

+ Iter uint8

+ Round Round

+ func (ir IterRound) Absolute() uint32

+ func (ir IterRound) Delay(since IterRound) uint32

+ func (ir IterRound) Grade(since IterRound) grade

+ func (ir IterRound) IsMessageRound() bool

+ func (t *IterRound) DecodeScale(dec *scale.Decoder) (total int, err error)

+ func (t *IterRound) EncodeScale(enc *scale.Encoder) (total int, err error)

+ type MalfeasanceHandler struct

+ func NewMalfeasanceHandler(db sql.Executor, edVerifier *signing.EdVerifier, opt ...MalfeasanceOpt) *MalfeasanceHandler

+ func (mh *MalfeasanceHandler) ReportInvalidProof(numInvalidProofs *prometheus.CounterVec)

+ func (mh *MalfeasanceHandler) ReportProof(numProofs *prometheus.CounterVec)

+ func (mh *MalfeasanceHandler) Validate(ctx context.Context, data wire.ProofData) (types.NodeID, error)

+ type MalfeasanceOpt func(*MalfeasanceHandler)

+ func WithMalfeasanceLogger(logger *zap.Logger) MalfeasanceOpt

+ type Message struct

+ Sender types.NodeID

+ Signature types.EdSignature

+ func (m *Message) MarshalLogObject(encoder zapcore.ObjectEncoder) error

+ func (m *Message) ToBytes() []byte

+ func (m *Message) ToHash() types.Hash32

+ func (m *Message) ToMalfeasanceProof() wire.HareProofMsg

+ func (m *Message) ToMetadata() wire.HareMetadata

+ func (m *Message) Validate() error

+ func (t *Message) DecodeScale(dec *scale.Decoder) (total int, err error)

+ func (t *Message) EncodeScale(enc *scale.Encoder) (total int, err error)

+ type Opt func(*Hare)

+ func WithConfig(cfg Config) Opt

+ func WithLogger(logger *zap.Logger) Opt

+ func WithResultsChan(c chan ConsensusOutput) Opt

+ func WithServer(s streamRequester) Opt

+ func WithTracer(tracer Tracer) Opt

+ func WithWallClock(clock clockwork.Clock) Opt

+ type Round uint8

+ func (r Round) String() string

+ type Tracer interface

+ OnActive func([]*types.HareEligibility)

+ OnCompactIdRequest func(*CompactIdRequest)

+ OnCompactIdResponse func(*CompactIdResponse)

+ OnMessageReceived func(*Message)

+ OnMessageSent func(*Message)

+ OnStart func(types.LayerID)

+ OnStop func(types.LayerID)

+ type Value struct

+ CompactProposals []types.CompactProposalID

+ Proposals []types.ProposalID

+ Reference *types.Hash32

+ func (t *Value) DecodeScale(dec *scale.Decoder) (total int, err error)

+ func (t *Value) EncodeScale(enc *scale.Encoder) (total int, err error)

+ type WeakCoinOutput struct

+ Coin bool

+ Layer types.LayerID