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) Attributes() []attribute.KeyValue
  • func (g GapFillTipSetPayload) HasTraceCarrier() bool
  • func (g GapFillTipSetPayload) MarshalLogObject(enc zapcore.ObjectEncoder) error
• type IndexTipSetPayload
  • func (i IndexTipSetPayload) Attributes() []attribute.KeyValue
  • func (i IndexTipSetPayload) HasTraceCarrier() bool
  • func (i IndexTipSetPayload) MarshalLogObject(enc zapcore.ObjectEncoder) error

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
	Tasks        []string
	TraceCarrier *tracing.TraceCarrier `json:",omitempty"`
}

func (GapFillTipSetPayload) Attributes

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

Attributes returns a slice of attributes for populating tracing span attributes.

func (GapFillTipSetPayload) HasTraceCarrier

func (g GapFillTipSetPayload) HasTraceCarrier() bool

HasTraceCarrier returns true iff payload contains a trace.

func (GapFillTipSetPayload) MarshalLogObject

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

MarshalLogObject implement ObjectMarshaler and allows user-defined types to efficiently add themselves to the logging context, and to selectively omit information which shouldn't be included in logs (e.g., passwords).

type IndexTipSetPayload

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

func (IndexTipSetPayload) Attributes

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

Attributes returns a slice of attributes for populating tracing span attributes.

func (IndexTipSetPayload) HasTraceCarrier

func (i IndexTipSetPayload) HasTraceCarrier() bool

HasTraceCarrier returns true iff payload contains a trace.

func (IndexTipSetPayload) MarshalLogObject

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

MarshalLogObject implement ObjectMarshaler and allows user-defined types to efficiently add themselves to the logging context, and to selectively omit information which shouldn't be included in logs (e.g., passwords).