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
- type GapFillTipSetPayload
- type IndexTipSetPayload
- type TipSetTaskHandler
Constants ¶
View Source
const (
TypeGapFillTipSet = "tipset:gapfill"
)
View Source
const (
TypeIndexTipSet = "tipset:index"
)
Variables ¶
This section is empty.
Functions ¶
func NewGapFillTipSetTask ¶
Types ¶
type GapFillTipSetHandler ¶ added in v0.12.0
type GapFillTipSetHandler struct {
// contains filtered or unexported fields
}
func NewGapFillHandler ¶
func NewGapFillHandler(indexer indexer.Indexer, db *storage.Database) *GapFillTipSetHandler
func (*GapFillTipSetHandler) HandleGapFillTipSetTask ¶ added in v0.12.0
func (*GapFillTipSetHandler) Handler ¶ added in v0.12.0
func (gh *GapFillTipSetHandler) Handler() asynq.HandlerFunc
func (*GapFillTipSetHandler) Type ¶ added in v0.12.0
func (gh *GapFillTipSetHandler) Type() string
type GapFillTipSetPayload ¶
type GapFillTipSetPayload struct {
TipSet *types.TipSet
Tasks []string
TraceCarrier *tracing.TraceCarrier `json:",omitempty"`
}
func (GapFillTipSetPayload) Attributes ¶ added in v0.10.1
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 ¶ added in v0.10.1
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 ¶ added in v0.10.1
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 ¶ added in v0.10.1
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 ¶ added in v0.12.0
type TipSetTaskHandler struct {
// contains filtered or unexported fields
}
func NewIndexHandler ¶
func NewIndexHandler(i indexer.Indexer) *TipSetTaskHandler
func (*TipSetTaskHandler) HandleIndexTipSetTask ¶ added in v0.12.0
func (*TipSetTaskHandler) Handler ¶ added in v0.12.0
func (ih *TipSetTaskHandler) Handler() asynq.HandlerFunc
func (*TipSetTaskHandler) Type ¶ added in v0.12.0
func (ih *TipSetTaskHandler) Type() string
Source Files
Click to show internal directories.
Click to hide internal directories.