slotqueue

Jul 1, 2021

Changes in this version

type Queue

+ RegisterToNext func(pubKey []byte) (pubsub.SubjectChannel, error)

+ type SlotEvent struct

+ Duty *ethpb.DutiesResponse_Duty

+ Ok bool

+ Slot uint64

Jun 8, 2021

Changes in this version

+ type Duty struct

+ Committee map[uint64]*proto.Node

+ Duty *ethpb.DutiesResponse_Duty

+ NodeID uint64

+ ShareSK *bls.SecretKey

+ ValidatorPK *bls.PublicKey

+ type Queue interface

+ Next func(pubKey []byte) (uint64, *ethpb.DutiesResponse_Duty, bool, error)

+ Schedule func(pubKey []byte, slot uint64, duty *ethpb.DutiesResponse_Duty) error

+ func New(network core.Network) Queue