tasks

Documentation

Index

• Constants
• 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
  • func NewGapFillHandler(indexer indexer.Indexer, db *storage.Database) *AsynqGapFillTipSetTaskHandler
  • func (gh *AsynqGapFillTipSetTaskHandler) HandleGapFillTipSetTask(ctx context.Context, t *asynq.Task) error
• type AsynqTipSetTaskHandler
  • func NewIndexHandler(i indexer.Indexer) *AsynqTipSetTaskHandler
  • func (ih *AsynqTipSetTaskHandler) HandleIndexTipSetTask(ctx context.Context, t *asynq.Task) error
• type GapFillTipSetPayload
  • func (g *GapFillTipSetPayload) HasTraceCarrier() bool
• type IndexTipSetPayload
  • func (i *IndexTipSetPayload) HasTraceCarrier() bool

Constants

const (
	TypeGapFillTipSet = "tipset:gapfill"
)

const (
	TypeIndexTipSet = "tipset:index"
)

Functions

func NewGapFillTipSetTask

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

func NewIndexTipSetTask

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

Types

type AsynqGapFillTipSetTaskHandler

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

func NewGapFillHandler

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

func (*AsynqGapFillTipSetTaskHandler) HandleGapFillTipSetTask

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

type AsynqTipSetTaskHandler

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

func NewIndexHandler

func NewIndexHandler(i indexer.Indexer) *AsynqTipSetTaskHandler

func (*AsynqTipSetTaskHandler) HandleIndexTipSetTask

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

type GapFillTipSetPayload

type GapFillTipSetPayload struct {
	TipSet *types.TipSet
	// TODO include the height of the tipset here to correctly mark the epoch as gap filled cuz Null rounds
	Tasks        []string
	TraceCarrier *tracing.TraceCarrier `json:",omitempty"`
}

func (*GapFillTipSetPayload) HasTraceCarrier

func (g *GapFillTipSetPayload) HasTraceCarrier() bool

HasTraceCarrier returns true iff payload contains a trace.

type IndexTipSetPayload

type IndexTipSetPayload struct {
	TipSet       *types.TipSet
	Tasks        []string
	TraceCarrier *tracing.TraceCarrier `json:",omitempty"`
}

func (*IndexTipSetPayload) HasTraceCarrier

func (i *IndexTipSetPayload) HasTraceCarrier() bool

HasTraceCarrier returns true iff payload contains a trace.