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 GapFillTipSetHandler
  • func NewGapFillHandler(indexer indexer.Indexer, db *storage.Database) *GapFillTipSetHandler
  • func (gh *GapFillTipSetHandler) HandleGapFillTipSetTask(ctx context.Context, t *asynq.Task) error
  • func (gh *GapFillTipSetHandler) Handler() asynq.HandlerFunc
  • func (gh *GapFillTipSetHandler) Type() string
• 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
• type TipSetTaskHandler
  • func NewIndexHandler(i indexer.Indexer) *TipSetTaskHandler
  • func (ih *TipSetTaskHandler) HandleIndexTipSetTask(ctx context.Context, t *asynq.Task) error
  • func (ih *TipSetTaskHandler) Handler() asynq.HandlerFunc
  • func (ih *TipSetTaskHandler) Type() string

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 GapFillTipSetHandler

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

func NewGapFillHandler

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

func (*GapFillTipSetHandler) HandleGapFillTipSetTask

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

func (*GapFillTipSetHandler) Handler

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

func (*GapFillTipSetHandler) Type

func (gh *GapFillTipSetHandler) Type() string

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).

type TipSetTaskHandler

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

func NewIndexHandler

func NewIndexHandler(i indexer.Indexer) *TipSetTaskHandler

func (*TipSetTaskHandler) HandleIndexTipSetTask

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

func (*TipSetTaskHandler) Handler

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

func (*TipSetTaskHandler) Type

func (ih *TipSetTaskHandler) Type() string