testutil

type Provider struct {
	content.InfoReaderProvider
	Reads      atomic.Int64
	BeforeRead func(context.Context, ocispecs.Descriptor) error
}

type Store struct {
	Manager   bkcache.SnapshotManager
	Content   *containerdsnapshot.Store
	Snapshots bkcache.Snapshotter
	Leases    leases.Manager
	DB        *metadata.DB
	Applies   atomic.Int64
	// ContentRead counts the bytes read from the content store.
	ContentRead atomic.Int64
	Diffs       atomic.Int64
	BeforeWrite func([]byte) error
	BeforeApply func(context.Context, ocispecs.Descriptor) error
	BeforeDiff  func(context.Context) error
	// BeforeSnapshotUpdate runs before each snapshot label update.
	BeforeSnapshotUpdate func(context.Context, ctdsnapshots.Info) error
	// BeforeStat runs before each snapshot Stat the manager makes.
	BeforeStat func(ctx context.Context, key string)
	// LeaseCommitErr, when set, rolls back each transaction the manager
	// makes through SnapshotManagerOpt.MetadataDB and returns it.
	LeaseCommitErr error
	// Builtin, when set before the manager is (re)opened, plays the engine's
	// builtin image store for chain imports.
	Builtin     content.InfoReaderProvider
	BeforeAdd   func(context.Context, leases.Lease, leases.Resource) error
	AfterAdd    func(context.Context, leases.Lease, leases.Resource)
	AfterCreate func(leases.Lease)

	// SharedMountLinger and MaxIdleSharedMounts, when set before the manager
	// is (re)opened, bound its idle shared read-only mounts.
	SharedMountLinger   time.Duration
	MaxIdleSharedMounts int
	// LocalMounts and LocalUnmounts count the shared read-only mounts made
	// and unmounted; they are made in place, without privileges.
	LocalMounts   atomic.Int64
	LocalUnmounts atomic.Int64
	// BeforeLocalUnmount runs before each of those unmounts.
	BeforeLocalUnmount func()
	// contains filtered or unexported fields
}