fetch

type CachedImageStore ¶

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

CachedImageStore caches complete OCI images (not individual layers), and does so only for fully qualified image references. A fully qualified image reference has either a digest or a tag with major.minor.patch (and optionally release) components. Image refs with only major, major.minor, or `latest` tags are not cached. Note: there is no cache expiration/eviction yet.

func NewCachedImageStore(remote ImageStore, storePath string, logger *slog.Logger) *CachedImageStore

func (cis *CachedImageStore) Fetch(ctx context.Context, ref name.Reference) (string, error)

type Client ¶

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

func NewClient(imageStore ImageStore, versionLookup VersionLookup) *Client

func (c *Client) Pull(ctx context.Context, ref name.Reference) (string, error)

type DiskLayerWriter ¶

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

func NewDiskLayerWriter(logger *slog.Logger) *DiskLayerWriter

func (w *DiskLayerWriter) Write(layers []v1.Layer, outputDir string) error

type ImageStore ¶

type ImageStore interface {
	Fetch(context.Context, name.Reference) (string, error)
}

type Inputs ¶

type Inputs struct {
	RemoteImageRef name.Reference
	StepPath       string
	LogLevel       slog.Level
	OutputFile     string
}

type LayerWriter ¶

type LayerWriter interface {
	Write(layers []v1.Layer, dir string) error
}

type OutputValue ¶

type OutputValue struct {
	Name  string `json:"name"`
	Value any    `json:"value"`
}

type Outputs ¶

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

func NewOutputs(outputFile string) *Outputs

func (o *Outputs) Write(downloadDir string, imgRef name.Reference, stepPath string) error

type RemoteImageStore ¶

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

RemoteImageStore downloads and extract OCI images. The path is composed from the image reference and is rooted at `storePath`. There's no caching or cleanup.

func NewRemoteImageStore(storePath string, logger *slog.Logger, options ...func(*RemoteImageStore)) *RemoteImageStore

func (ris *RemoteImageStore) Fetch(ctx context.Context, ref name.Reference) (string, error)

func (ris *RemoteImageStore) Version(ctx context.Context, ref name.Reference) (*internal.Version, error)

type VersionLookup ¶

type VersionLookup interface {
	Version(context.Context, name.Reference) (*internal.Version, error)
}