tasks

Sep 8, 2022

Changes in this version

+ type GapFillTipSetHandler struct

+ func (gh *GapFillTipSetHandler) HandleGapFillTipSetTask(ctx context.Context, t *asynq.Task) error

+ func (gh *GapFillTipSetHandler) Handler() asynq.HandlerFunc

+ func (gh *GapFillTipSetHandler) Type() string

+ type TipSetTaskHandler struct

+ func (ih *TipSetTaskHandler) HandleIndexTipSetTask(ctx context.Context, t *asynq.Task) error

+ func (ih *TipSetTaskHandler) Handler() asynq.HandlerFunc

+ func (ih *TipSetTaskHandler) Type() string

Jun 28, 2022

Changes in this version

type GapFillTipSetPayload

+ func (g GapFillTipSetPayload) Attributes() []attribute.KeyValue

+ func (g GapFillTipSetPayload) MarshalLogObject(enc zapcore.ObjectEncoder) error

type IndexTipSetPayload

+ func (i IndexTipSetPayload) Attributes() []attribute.KeyValue

+ func (i IndexTipSetPayload) MarshalLogObject(enc zapcore.ObjectEncoder) error

May 24, 2022

Changes in this version

+ const TypeGapFillTipSet

+ const TypeIndexTipSet

+ func NewGapFillTipSetTask(ctx context.Context, ts *types.TipSet, tasks []string) (*asynq.Task, error)

+ func NewIndexTipSetTask(ctx context.Context, ts *types.TipSet, tasks []string) (*asynq.Task, error)

+ type AsynqGapFillTipSetTaskHandler struct

+ func NewGapFillHandler(indexer indexer.Indexer, db *storage.Database) *AsynqGapFillTipSetTaskHandler

+ func (gh *AsynqGapFillTipSetTaskHandler) HandleGapFillTipSetTask(ctx context.Context, t *asynq.Task) error

+ type AsynqTipSetTaskHandler struct

+ func NewIndexHandler(i indexer.Indexer) *AsynqTipSetTaskHandler

+ func (ih *AsynqTipSetTaskHandler) HandleIndexTipSetTask(ctx context.Context, t *asynq.Task) error

+ type GapFillTipSetPayload struct

+ Tasks []string

+ TipSet *types.TipSet

+ TraceCarrier *tracing.TraceCarrier

+ func (g *GapFillTipSetPayload) HasTraceCarrier() bool

+ type IndexTipSetPayload struct

+ Tasks []string

+ TipSet *types.TipSet

+ TraceCarrier *tracing.TraceCarrier

+ func (i *IndexTipSetPayload) HasTraceCarrier() bool