dependency

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 OCICollection struct {
	Targets []OCIPullTarget
	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) (*OCICollection, error)
}

type OCIPullTarget struct {
	Type       OCIType
	Reference  string
	Digest     string
	PullPolicy v1beta1.ImagePullPolicy
	PullSecret *client.PullSecret
}

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) 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
}