allocationstore

type AllocationStore interface {
	// Get retrieves an allocation for a blob (digest) in a space (DID). It
	// returns [github.com/storacha/piri/pkg/store.ErrNotFound] if the allocation
	// does not exist.
	Get(context.Context, multihash.Multihash, did.DID) (allocation.Allocation, error)
	// GetAny retrieves any allocation for a blob (digest), regardless of space.
	// Returns [github.com/storacha/piri/pkg/store.ErrNotFound] if no allocation exists.
	GetAny(context.Context, multihash.Multihash) (allocation.Allocation, error)
	// GetAnyNonExpired retrieves any allocation for a blob that has not expired.
	// The now parameter should be the current unix timestamp in seconds.
	// Returns [github.com/storacha/piri/pkg/store.ErrNotFound] if no non-expired allocation exists.
	GetAnyNonExpired(ctx context.Context, digest multihash.Multihash, now uint64) (allocation.Allocation, error)
	// Exists checks if any allocation exists for a blob (digest).
	Exists(context.Context, multihash.Multihash) (bool, error)
	// Put adds or replaces allocation data in the store.
	Put(context.Context, allocation.Allocation) error
}

type DatastoreKeyEncoder struct{}

type KeyEncoder interface {
	EncodeKey(digest multihash.Multihash, space did.DID) string
	EncodeKeyPrefix(digest multihash.Multihash) string
}

type S3KeyEncoder struct{}

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