Versions in this module Expand all Collapse all v0 v0.3.0 May 10, 2026 Changes in this version + const EventArtifactDeleted + const EventBlobPhysicallyDeleted + const EventCapacityWarning + const EventKEKRotated + const EventManifestSaved + const EventOrphanScanCompleted + const EventPackCompacted + const EventScrubFailed + const EventStaleLeaseTakeover + const EventStoreDegraded + func NewHashRegistry() domain.HashRegistry + type AdminStore interface + Capabilities func() driver.CapabilityMask + Close func() error + Config func() domain.StoreConfig + ConfigHistory func(ctx context.Context) ([]domain.StoreConfig, error) + ExportRecoveryKit func(ctx context.Context) ([]byte, error) + RotateKEK func(ctx context.Context) error + SetMaintenanceMode func(ctx context.Context, mode domain.MaintenanceMode) error + SetPassphrase func(ctx context.Context) error + State func() domain.StoreState + Unlock func(ctx context.Context) error + UpdateConfig func(ctx context.Context, cfg domain.StoreConfig) error + type AgentResult struct + AgentType string + CompletedAt time.Time + Partial bool + StartedAt time.Time + Stats map[string]int64 + StoreID string + type ArtifactDeletedPayload struct + ArtifactID domain.ArtifactID + type BlobPhysicallyDeletedPayload struct + BlobRef string + type CapacityWarningPayload struct + UsedPct float64 + type DataStore interface + Capacity func(ctx context.Context) (domain.StorageInfo, error) + Delete func(ctx context.Context, id domain.ArtifactID) error + Get func(ctx context.Context, id domain.ArtifactID, opts domain.GetOptions) (ReadHandle, error) + Put func(ctx context.Context, a domain.Artifact, opts domain.PutOptions) (domain.ArtifactID, error) + PutBlob func(ctx context.Context, r io.Reader, blobType domain.BlobType) (domain.ContentHash, error) + RollbackSession func(ctx context.Context, sessionID string) error + Verify func(ctx context.Context, id domain.ArtifactID) error + Walk func(ctx context.Context, namespace string, cb func(domain.Manifest) error) error + WalkSystem func(ctx context.Context, namespace string, cb func(domain.Manifest) error) error + type Decoder interface + Transform func(r io.Reader) io.Reader + type DescriptorCache struct + Blob []byte + Checksum []byte + Sequence uint64 + type Encoder interface + Result func() TransformResult + Transform func(r io.Reader) io.Reader + type KeyResolver interface + DefaultKeyID func() string + GetKeys func(keyID string) ([][]byte, error) + func NewStaticKeyResolver(dek []byte) KeyResolver + type LeaseTakeoverPayload struct + ExpiredAt time.Time + LeaseKey string + PreviousHolder string + TakenBy string + type MaintenanceAgent interface + Run func(ctx context.Context) (*AgentResult, error) + Validate func(ctx context.Context) error + type ManifestSavedPayload struct + IsTransit bool + Manifest domain.Manifest + type OrphanReport struct + BlobsRemoved int + Duration time.Duration + Errors []error + ManifestsRemoved int + StagingRemoved int + type OrphanScanCompletedPayload struct + BlobsRemoved int + Duration time.Duration + ManifestsRemoved int + NonFatalErrors int + StagingRemoved int + type PackCompactedPayload struct + DeadEntries int + Duration time.Duration + FreedBytes int64 + LiveEntries int + NewPackRef string + NewSize int64 + OldPackRef string + OldSize int64 + type PassphraseHint struct + Reason string + StoreID string + type PassphraseProvider func(ctx context.Context, hint PassphraseHint) ([]byte, error) + type Publisher interface + Publish func(e event.Event) + type ReadHandle interface + Manifest func() domain.Manifest + ReadAtCtx func(ctx context.Context, p []byte, off int64) (n int, err error) + SupportsRandomAccess func() bool + type ScrubFailedPayload struct + ArtifactID domain.ArtifactID + Err error + type Store interface + func InitStore(ctx context.Context, drv driver.Driver, opts ...StoreOption) (Store, []byte, error) + func OpenStore(ctx context.Context, drv driver.Driver, opts ...StoreOption) (Store, error) + type StoreDegradedPayload struct + Reason string + type StoreIndex interface + Close func() error + DeleteManifest func(ctx context.Context, artifactID domain.ArtifactID, blobRefs []string) error + DeletePacked func(ctx context.Context, packBlobRef string) error + ExistsByContent func(ctx context.Context, hash domain.ContentHash, originalSize int64) (blobRef string, exists bool, err error) + ExistsByHash func(ctx context.Context, hash domain.ContentHash) (domain.BlobExistStatus, error) + GetBySession func(ctx context.Context, sessionID string) ([]domain.ArtifactID, error) + GetMeta func(ctx context.Context, key string) (string, error) + GetRefCount func(ctx context.Context, blobRef string) (int, error) + IndexManifest func(ctx context.Context, m domain.Manifest, addr domain.PhysicalAddress, ...) error + ListByNamespace func(ctx context.Context, ns string, cb func(domain.Manifest) error) error + ListOrphanBlobs func(ctx context.Context, cb func(blobRef string) error) error + ListUnverified func(ctx context.Context, before time.Time, cb func(blobRef string) error) error + LookupPacked func(ctx context.Context, artifactID domain.ArtifactID) (domain.PackedBlobInfo, bool, error) + ManifestExists func(ctx context.Context, id domain.ArtifactID) (bool, error) + MarkVerified func(ctx context.Context, blobRef string, timestamp time.Time) error + RebindBlob func(ctx context.Context, blobRef string, newAddr domain.PhysicalAddress) error + Resolve func(ctx context.Context, blobRef string) (domain.PhysicalAddress, error) + SetMeta func(ctx context.Context, key, value string) error + VacuumInto func(ctx context.Context, destPath string) error + type StoreOption func(*storeOptions) + func WithAutoUnlock() StoreOption + func WithCapabilityToken(token []byte) StoreOption + func WithConfig(cfg domain.StoreConfig) StoreOption + func WithForceReinit() StoreOption + func WithHashRegistry(r domain.HashRegistry) StoreOption + func WithKeyResolver(r KeyResolver) StoreOption + func WithPassphrase(provider PassphraseProvider) StoreOption + func WithPublisher(p Publisher) StoreOption + func WithPurgeOnReinit() StoreOption + func WithReadRegistry(r TransformerRegistry) StoreOption + func WithStoreIndex(idx StoreIndex) StoreOption + type TransformResult struct + Entropy float64 + IV []byte + OutputSize int64 + type TransformerFactory interface + NewDecoder func(stage domain.PipelineStage) Decoder + NewEncoder func() Encoder + type TransformerRegistry interface + Get func(id string) (TransformerFactory, error) + Register func(id string, f TransformerFactory) TransformerRegistry + func NewTransformerRegistry() TransformerRegistry v0.2.0 May 9, 2026
Go to main page