persistence

Documentation

Index

• func SourceDriver() (source.Driver, error)
• func WithTelemetry(wrapped Storage, tracer trace.Tracer) *wrapper
• type Storage

Functions

func SourceDriver

func SourceDriver() (source.Driver, error)

func WithTelemetry

func WithTelemetry(wrapped Storage, tracer trace.Tracer) *wrapper

WithTelemetry enriches Storage by adding instrumentation and context.

Types

type Storage

type Storage interface {
	// Package.
	CreatePackage(ctx context.Context, pkg *goastorage.Package) (*goastorage.Package, error)
	ListPackages(ctx context.Context) (goastorage.PackageCollection, error)
	ReadPackage(ctx context.Context, aipID uuid.UUID) (*goastorage.Package, error)
	UpdatePackageStatus(ctx context.Context, aipID uuid.UUID, status types.PackageStatus) error
	UpdatePackageLocationID(ctx context.Context, aipID, locationID uuid.UUID) error

	// Location.
	CreateLocation(
		ctx context.Context,
		location *goastorage.Location,
		config *types.LocationConfig,
	) (*goastorage.Location, error)
	ListLocations(ctx context.Context) (goastorage.LocationCollection, error)
	ReadLocation(ctx context.Context, locationID uuid.UUID) (*goastorage.Location, error)
	LocationPackages(ctx context.Context, locationID uuid.UUID) (goastorage.PackageCollection, error)
}