base_image_puller

Documentation

Index

• Constants
• type BaseImageInfo
• type BaseImagePuller
  • func NewBaseImagePuller(fetcher Fetcher, unpacker Unpacker, volumeDriver VolumeDriver, ...) *BaseImagePuller
  • func (p *BaseImagePuller) Pull(logger lager.Logger, spec groot.BaseImageSpec) (groot.BaseImage, error)
• type DependencyRegisterer
• type Fetcher
• type LayerInfo
• type UnpackOutput
• type UnpackSpec
• type Unpacker
• type VolumeDriver
• type VolumeMeta

Constants

const BaseImageReferenceFormat = "baseimage:%s"

const MetricsDownloadTimeName = "DownloadTime"

const MetricsUnpackTimeName = "UnpackTime"

Types

type BaseImageInfo

type BaseImageInfo struct {
	LayerInfos []LayerInfo
	Config     specsv1.Image
}

type BaseImagePuller

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

func NewBaseImagePuller

func NewBaseImagePuller(fetcher Fetcher, unpacker Unpacker, volumeDriver VolumeDriver, dependencyRegisterer DependencyRegisterer, metricsEmitter groot.MetricsEmitter, locksmith groot.Locksmith) *BaseImagePuller

func (*BaseImagePuller) Pull

func (p *BaseImagePuller) Pull(logger lager.Logger, spec groot.BaseImageSpec) (groot.BaseImage, error)

type DependencyRegisterer

type DependencyRegisterer interface {
	Register(id string, chainIDs []string) error
}

type Fetcher

type Fetcher interface {
	BaseImageInfo(logger lager.Logger, baseImageURL *url.URL) (BaseImageInfo, error)
	StreamBlob(logger lager.Logger, baseImageURL *url.URL, layerInfo LayerInfo) (io.ReadCloser, int64, error)
}

type LayerInfo

type LayerInfo struct {
	BlobID        string
	ChainID       string
	DiffID        string
	ParentChainID string
	Size          int64
	BaseDirectory string
	URLs          []string
	MediaType     string
}

type UnpackOutput

type UnpackOutput struct {
	BytesWritten    int64
	OpaqueWhiteouts []string
}

type UnpackSpec

type UnpackSpec struct {
	Stream        io.ReadCloser `json:"-"`
	TargetPath    string
	UIDMappings   []groot.IDMappingSpec
	GIDMappings   []groot.IDMappingSpec
	BaseDirectory string
}

type Unpacker

type Unpacker interface {
	Unpack(logger lager.Logger, spec UnpackSpec) (UnpackOutput, error)
}

type VolumeDriver

type VolumeDriver interface {
	VolumePath(logger lager.Logger, id string) (string, error)
	CreateVolume(logger lager.Logger, parentID, id string) (string, error)
	DestroyVolume(logger lager.Logger, id string) error
	Volumes(logger lager.Logger) ([]string, error)
	MoveVolume(logger lager.Logger, from, to string) error
	WriteVolumeMeta(logger lager.Logger, id string, data VolumeMeta) error
	HandleOpaqueWhiteouts(logger lager.Logger, id string, opaqueWhiteouts []string) error
}

type VolumeMeta

type VolumeMeta struct {
	Size int64
}