types

package

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

Details

View Source

const AggregatePrefix = "aggregates/"

This section is empty.

func AggregateType() schema.Type

func BufferType() schema.Type

func PieceLinkType() schema.Type

type Aggregate struct {
	Root   piece.PieceLink
	Pieces []AggregatePiece
}

func (a Aggregate) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject makes Aggregate implement the zapcore.ObjectMarshaler interface

type AggregatePiece struct {
	Link           piece.PieceLink
	InclusionProof merkletree.ProofData
}

type Buffer struct {
	TotalSize           uint64
	ReverseSortedPieces []piece.PieceLink
}

Buffer tracks in progress work building an aggregation

type Store ipldstore.KVStore[datamodel.Link, Aggregate]

func NewStore(params StoreParams) Store

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