manager

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

type Aggregation struct {
	Roots []datamodel.Link
}

type BufferStore interface {
	// Aggregation retrieves the pending pieces aggregation.
	Aggregation(context.Context) (Aggregation, error)
	// AppendRoots adds roots to the pending aggregation
	AppendRoots(context.Context, []datamodel.Link) error
	// ClearRoots removes all roots from the current aggregation.
	ClearRoots(context.Context) error
}

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

type ManagerOption func(*Manager)

type ManagerParams struct {
	fx.In

	Queue       jobqueue.Service[[]datamodel.Link]
	TaskHandler jobqueue.TaskHandler[[]datamodel.Link]
	Buffer      BufferStore
	Options     []ManagerOption `optional:"true"`
}

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

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

type SubmissionWorkspaceParams struct {
	fx.In
	Datastore datastore.Datastore `name:"aggregator_datastore"`
}