dependency

type ClientOptsFn func() []client.ClientOption

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

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

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

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

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

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

type OCICollectOpt func(*ociCollectOpts)

type OCICollection struct {
	Targets OCIPullTargetsByUser
	Requeue bool // true if collection is incomplete and should be retried
}

type OCICollector interface {
	// CollectOCITargets collects OCI targets and indicates if requeue is needed
	CollectOCITargets(ctx context.Context, current, desired *v1beta1.DeviceSpec, opts ...OCICollectOpt) (*OCICollection, error)
}

type OCIPullTarget struct {
	Type         OCIType
	Reference    string
	Digest       string
	PullPolicy   v1beta1.ImagePullPolicy
	ClientOptsFn ClientOptsFn // Called only when pulling is actually needed
}

type OCIPullTargetsByUser map[v1beta1.Username][]OCIPullTarget

type OCIType string

type PrefetchManager interface {
	// RegisterOCICollector registers a function that can collect OCI targets from a device spec
	RegisterOCICollector(collector OCICollector)
	// BeforeUpdate collects and prefetches OCI targets from all registered collectors
	BeforeUpdate(ctx context.Context, current, desired *v1beta1.DeviceSpec, opts ...OCICollectOpt) error
	// StatusMessage returns a human readable prefetch progress status message
	StatusMessage(ctx context.Context) string
	// Cleanup fires all cleanupFn cancels active pulls and drains the queue
	Cleanup()
}

type PrefetchStatus struct {
	TotalImages    int
	PendingImages  []string
	RetryingImages []string
}

type PullConfigResolver interface {
	// BeforeUpdate initializes the resolver with the desired device spec.
	// Must be called before any Options calls.
	BeforeUpdate(desired *v1beta1.DeviceSpec)

	// Options returns a lazy function that resolves configs when called.
	// For each PullConfigSpec, tries paths in order until one is found.
	// Results are cached; subsequent calls with same paths return cached values.
	Options(specs ...PullConfigSpec) ClientOptsFn

	// Cleanup cleans up all resolved configurations (temp files).
	Cleanup()
}

type PullConfigSpec struct {
	// Paths in fallback order - first found/resolved wins.
	Paths []string
	// OptionFn creates a client option from the resolved path.
	OptionFn func(string) client.ClientOption
}