events

type CheckFunc ¶

type CheckFunc func(ts *types.TipSet) (done bool, more bool, err error)

CheckFunc is used for atomicity guarantees. If the condition the callbacks wait for has already happened in tipset `ts`

If `done` is true, timeout won't be triggered If `more` is false, no messages will be sent to EventHandler (RevertHandler

may still be called)

type EventHandler ¶

type EventHandler func(data eventData, prevTs, ts *types.TipSet, curH abi.ChainEpoch) (more bool, err error)

EventHandler arguments: `prevTs` is the previous tipset, eg the "from" tipset for a state change. `ts` is the event tipset, eg the tipset in which the `msg` is included. `curH`-`ts.Height` = `confidence`

type Events ¶

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

func NewEvents(ctx context.Context, api eventAPI) *Events

func (e *Events) ChainAt(hnd HeightHandler, rev RevertHandler, confidence int, h abi.ChainEpoch) error

type HeightHandler ¶

type HeightHandler func(ctx context.Context, ts *types.TipSet, curH abi.ChainEpoch) error

HeightHandler `curH`-`ts.Height` = `confidence`

type MsgHandler ¶

type MsgHandler func(msg *types.Message, rec *types.MessageReceipt, ts *types.TipSet, curH abi.ChainEpoch) (more bool, err error)

MsgHandler arguments: `ts` is the tipset, in which the `msg` is included. `curH`-`ts.Height` = `confidence`

type MsgMatchFunc ¶

type MsgMatchFunc func(msg *types.Message, ts *types.TipSet) (matched bool, err error)

type RevertHandler ¶

type RevertHandler func(ctx context.Context, ts *types.TipSet) error

HeightHandler `curH`-`ts.Height` = `confidence`

type StateChange ¶

type StateChange interface{}

StateChange represents a change in state

type StateChangeHandler ¶

type StateChangeHandler func(oldTs, newTs *types.TipSet, states StateChange, curH abi.ChainEpoch) (more bool, err error)

StateChangeHandler arguments: `oldTs` is the state "from" tipset `newTs` is the state "to" tipset `states` is the change in state `curH`-`ts.Height` = `confidence`

type StateMatchFunc ¶

type StateMatchFunc func(oldTs, newTs *types.TipSet) (bool, StateChange, error)