storagereconcile

package

v1.1.2 Latest Latest Go to latest Published: Aug 14, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var ErrPending = errors.New("storage size reconciliation is waiting for concurrent lifecycle work")

func Run(ctx context.Context, options Options, ready chan<- struct{})

type Options struct {
	DB        *ent.Client
	Storage   storage.Adapter
	Lifecycle *storagelifecycle.Service
	Logger    *zerolog.Logger
}

type Result struct {
	Candidates int
	Updated    int
	Purged     int
	Deferred   int
}

func Reconcile(ctx context.Context, options Options) (Result, error)