leaderschedule

Documentation

Index

• type Tracker
  • func (t *Tracker) FirstSlot(slotInEpoch uint64) (uint64, uint64)
  • func (t *Tracker) Get(slot uint64) solana.PublicKey
  • func (t *Tracker) Run(ctx context.Context, nodes []*envv1.RPCNode)
  • func (t *Tracker) TryGet(slot uint64) (solana.PublicKey, bool)
  • func (t *Tracker) Update(slot uint64)

Types

type Tracker

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

func (*Tracker) FirstSlot

func (t *Tracker) FirstSlot(slotInEpoch uint64) (uint64, uint64)

FirstSlot returns the epoch number and first slot of the epoch.

func (*Tracker) Get

func (t *Tracker) Get(slot uint64) solana.PublicKey

Get returns the scheduled leader for the given slot. It blocks until the leader schedule is available.

func (*Tracker) Run

func (t *Tracker) Run(ctx context.Context, nodes []*envv1.RPCNode)

Run periodically updates the leader schedule. When the current slot + prefetchSlots is greater than the highest slot in the schedule, the schedule is updated.

A random node is picked from nodes to do the request against.

func (*Tracker) TryGet

func (t *Tracker) TryGet(slot uint64) (solana.PublicKey, bool)

TryGet returns the scheduled leader for the given slot. It returns false if the leader schedule is not yet available.

func (*Tracker) Update

func (t *Tracker) Update(slot uint64)

Update updates the current highest slot. Non-blocking.