slotqueue

Documentation

Index

• type Queue
  • func New(network core.Network, logger *zap.Logger) Queue
• type SlotEvent

Types

type Queue

type Queue interface {
	// Next returns the next slot with its duties at its time
	RegisterToNext(pubKey []byte) (pubsub.SubjectChannel, error)

	// Schedule schedules execution of the given slot and puts it into the queue
	Schedule(pubKey []byte, slot uint64, duty *beacon.Duty) error
	// contains filtered or unexported methods
}

Queue represents the behavior of the slot queue

func New

func New(network core.Network, logger *zap.Logger) Queue

New is the constructor of queue

type SlotEvent

type SlotEvent struct {
	Slot uint64
	Duty *beacon.Duty
	Ok   bool
}

SlotEvent represents the notify event fire for each pubkey subject with the proper duty