dependency

package
v1.1.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 29, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package dependency is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPrefetchManager 

func NewPrefetchManager(
	log *log.PrefixLogger,
	podmanFactory client.PodmanFactory,
	skopeoFactory client.SkopeoFactory,
	cliClients client.CLIClients,
	readWriter fileio.ReadWriter,
	pullTimeout util.Duration,
	resourceManager resource.Manager,
	pollConfig poll.Config,
) *prefetchManager

NewPrefetchManager creates a new prefetch manager instance TODO: Consider extending cliClients to include podman and skopeo in the future

Types

type MockOCICollector 

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

MockOCICollector is a mock of OCICollector interface.

func NewMockOCICollector 

func NewMockOCICollector(ctrl *gomock.Controller) *MockOCICollector

NewMockOCICollector creates a new mock instance.

func (*MockOCICollector) CollectOCITargets 

func (m *MockOCICollector) CollectOCITargets(ctx context.Context, current, desired *v1beta1.DeviceSpec) (*OCICollection, error)

CollectOCITargets mocks base method.

func (*MockOCICollector) EXPECT 

func (m *MockOCICollector) EXPECT() *MockOCICollectorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockOCICollectorMockRecorder 

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

MockOCICollectorMockRecorder is the mock recorder for MockOCICollector.

func (*MockOCICollectorMockRecorder) CollectOCITargets 

func (mr *MockOCICollectorMockRecorder) CollectOCITargets(ctx, current, desired any) *gomock.Call

CollectOCITargets indicates an expected call of CollectOCITargets.

type MockPrefetchManager 

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

MockPrefetchManager is a mock of PrefetchManager interface.

func NewMockPrefetchManager 

func NewMockPrefetchManager(ctrl *gomock.Controller) *MockPrefetchManager

NewMockPrefetchManager creates a new mock instance.

func (*MockPrefetchManager) BeforeUpdate 

func (m *MockPrefetchManager) BeforeUpdate(ctx context.Context, current, desired *v1beta1.DeviceSpec) error

BeforeUpdate mocks base method.

func (*MockPrefetchManager) Cleanup 

func (m *MockPrefetchManager) Cleanup()

Cleanup mocks base method.

func (*MockPrefetchManager) EXPECT 

func (m *MockPrefetchManager) EXPECT() *MockPrefetchManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPrefetchManager) RegisterOCICollector 

func (m *MockPrefetchManager) RegisterOCICollector(collector OCICollector)

RegisterOCICollector mocks base method.

func (*MockPrefetchManager) StatusMessage 

func (m *MockPrefetchManager) StatusMessage(ctx context.Context) string

StatusMessage mocks base method.

type MockPrefetchManagerMockRecorder 

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

MockPrefetchManagerMockRecorder is the mock recorder for MockPrefetchManager.

func (*MockPrefetchManagerMockRecorder) BeforeUpdate 

func (mr *MockPrefetchManagerMockRecorder) BeforeUpdate(ctx, current, desired any) *gomock.Call

BeforeUpdate indicates an expected call of BeforeUpdate.

func (*MockPrefetchManagerMockRecorder) Cleanup 

func (mr *MockPrefetchManagerMockRecorder) Cleanup() *gomock.Call

Cleanup indicates an expected call of Cleanup.

func (*MockPrefetchManagerMockRecorder) RegisterOCICollector 

func (mr *MockPrefetchManagerMockRecorder) RegisterOCICollector(collector any) *gomock.Call

RegisterOCICollector indicates an expected call of RegisterOCICollector.

func (*MockPrefetchManagerMockRecorder) StatusMessage 

func (mr *MockPrefetchManagerMockRecorder) StatusMessage(ctx any) *gomock.Call

StatusMessage indicates an expected call of StatusMessage.

type OCICollection added in v1.0.0 

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

OCICollection represents the result of collecting OCI targets

type OCICollector 

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

OCICollector interface for components that can collect OCI targets

type OCIPullTarget 

type OCIPullTarget struct {
	Type       OCIType
	Reference  string
	Digest     string
	PullPolicy v1beta1.ImagePullPolicy
	Configs    client.PullConfigProvider
}

OCIPullTarget represents an OCI target to be prefetched

type OCIPullTargetsByUser added in v1.1.0 

type OCIPullTargetsByUser map[v1beta1.Username][]OCIPullTarget

A set of OCIPullTargets grouped by the user that will use the targets (blank Username is root).

func (OCIPullTargetsByUser) Add added in v1.1.0 

func (o OCIPullTargetsByUser) Add(user v1beta1.Username, targets ...OCIPullTarget) OCIPullTargetsByUser

func (OCIPullTargetsByUser) Iter added in v1.1.0 

func (o OCIPullTargetsByUser) Iter() iter.Seq2[v1beta1.Username, OCIPullTarget]

func (OCIPullTargetsByUser) MergeWith added in v1.1.0 

func (o OCIPullTargetsByUser) MergeWith(o2 OCIPullTargetsByUser) OCIPullTargetsByUser

MergeWith o2 in-place.

type OCIType 

type OCIType string

OCIType represents the type of OCI target for prefetching 

const (
	OCITypePodmanImage    OCIType = "PodmanImage"
	OCITypeCRIImage       OCIType = "CRIImage"
	OCITypePodmanArtifact OCIType = "PodmanArtifact"
	OCITypeAuto           OCIType = "Auto"
	OCITypeHelmChart      OCIType = "HelmChart"
)

type PrefetchManager 

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

PrefetchManager orchestrates OCI target collection and prefetching

type PrefetchStatus 

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

PrefetchStatus provides the current status of prefetch operations

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.