chainsched

Documentation

Index

• type CurioChainSched
  • func New(api NodeAPI) *CurioChainSched
  • func (s *CurioChainSched) AddHandler(ch UpdateFunc) error
  • func (s *CurioChainSched) Run(ctx context.Context)
• type NodeAPI
• type UpdateFunc

Types

type CurioChainSched

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

func New

func New(api NodeAPI) *CurioChainSched

func (*CurioChainSched) AddHandler

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

func (*CurioChainSched) Run

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

type NodeAPI

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

type UpdateFunc

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