sync

Documentation

Index

• func BufferedTipsetChannel(ctx context.Context, api BufferedTipsetChannelApi, lastHeight abi.ChainEpoch, ...) (<-chan *types.TipSet, error)
• func SyncWait(ctx context.Context, napi SyncWaitApi) error
• type BufferedTipsetChannelApi
• type SyncWaitApi

Functions

func BufferedTipsetChannel

func BufferedTipsetChannel(ctx context.Context, api BufferedTipsetChannelApi, lastHeight abi.ChainEpoch, size int) (<-chan *types.TipSet, error)

BufferedTipsetChannel returns an unbuffered channel of tipsets. Buffering occurs internally to handle revert ChainNotify changes. The returned channel can output tipsets at the same height twice if a reorg larger the provided `size` occurs.

func SyncWait

func SyncWait(ctx context.Context, napi SyncWaitApi) error

SyncWait returns when ChainHead is within 20 epochs of the expected height

Types

type BufferedTipsetChannelApi

type BufferedTipsetChannelApi interface {
	ChainNotify(context.Context) (<-chan []*api.HeadChange, error)
	Version(context.Context) (api.APIVersion, error)
	ChainGetTipSet(context.Context, types.TipSetKey) (*types.TipSet, error)
}

type SyncWaitApi

type SyncWaitApi interface {
	SyncState(context.Context) (*api.SyncState, error)
	ChainHead(context.Context) (*types.TipSet, error)
}