commp

package

v0.2.2 Latest Latest Go to latest Published: Feb 5, 2026 License: Apache-2.0, MIT Imports: 20 Imported by: 0

Details

View Source

const (
	QueueName = "commp"
	TaskName  = "compute_commp"
)

View Source

var Module = fx.Module("aggregation/commp",
	fx.Provide(
		NewQueue,
		NewHandler,
		NewQueuingCommpCalculator,
	),
)

func NewHandler(api types.PieceAPI, a *aggregator.Aggregator) jobqueue.TaskHandler[multihash.Multihash]

func NewQueue(params CommpQueueParams) (jobqueue.Service[multihash.Multihash], error)

type Calculator interface {
	Enqueue(ctx context.Context, blob multihash.Multihash) error
}

func NewQueuingCommpCalculator(lc fx.Lifecycle, params ComperParams) (Calculator, error)

type CommpQueueParams struct {
	fx.In
	DB *sql.DB `name:"aggregator_db"`
}

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

func (c *Comper) Enqueue(ctx context.Context, blob multihash.Multihash) error

type ComperParams struct {
	fx.In

	Queue   jobqueue.Service[multihash.Multihash]
	Handler jobqueue.TaskHandler[multihash.Multihash]
}

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

func (h *ComperTaskHandler) Handle(ctx context.Context, blob multihash.Multihash) error

func (h *ComperTaskHandler) Name() string