chainsched

package

v0.2.2 Latest Latest Go to latest Published: Feb 5, 2026 License: Apache-2.0, MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type NodeAPI interface {
	ChainHead(context.Context) (*types.TipSet, error)
	ChainNotify(context.Context) (<-chan []*api.HeadChange, error)
}

type Option func(*Scheduler)

func WithClock(clock clock.Clock) Option

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

func New(api NodeAPI, opts ...Option) (*Scheduler, error)

func (s *Scheduler) AddHandler(ch UpdateFunc) error

func (s *Scheduler) Run(ctx context.Context)

Run subscribes to chain notifications and processes them until the context is cancelled

type UpdateFunc func(ctx context.Context, revert, apply *types.TipSet) error