driver

Documentation

Index

• type Driver
  • func New(hcsClient HCSClient, tarStreamer TarStreamer, ...) *Driver
  • func (d *Driver) Bundle(logger lager.Logger, bundleID string, layerIDs []string, diskLimit int64) (specs.Spec, error)
  • func (d *Driver) Delete(logger lager.Logger, bundleID string) error
  • func (d *Driver) LayerStore() string
  • func (d *Driver) Stats(logger lager.Logger, bundleID string) (groot.VolumeStats, error)
  • func (d *Driver) Unpack(logger lager.Logger, layerID string, parentIDs []string, layerTar io.Reader) (int64, error)
  • func (d *Driver) VolumeStore() string
  • func (d *Driver) WriteMetadata(logger lager.Logger, bundleID string, volumeData groot.ImageMetadata) error
• type EmptyDriverStoreError
  • func (e *EmptyDriverStoreError) Error() string
• type HCSClient
• type LayerExistsError
  • func (e *LayerExistsError) Error() string
• type Limiter
• type MissingVolumePathError
  • func (e *MissingVolumePathError) Error() string
• type PrivilegeElevator
• type TarStreamer

Types

type Driver

type Driver struct {
	Store string
	// contains filtered or unexported fields
}

func New

func New(hcsClient HCSClient, tarStreamer TarStreamer, privilegeElevator PrivilegeElevator, limiter Limiter) *Driver

func (*Driver) Bundle

func (d *Driver) Bundle(logger lager.Logger, bundleID string, layerIDs []string, diskLimit int64) (specs.Spec, error)

func (*Driver) Delete

func (d *Driver) Delete(logger lager.Logger, bundleID string) error

func (*Driver) LayerStore

func (d *Driver) LayerStore() string

func (*Driver) Stats

func (d *Driver) Stats(logger lager.Logger, bundleID string) (groot.VolumeStats, error)

func (*Driver) Unpack

func (d *Driver) Unpack(logger lager.Logger, layerID string, parentIDs []string, layerTar io.Reader) (int64, error)

func (*Driver) VolumeStore

func (d *Driver) VolumeStore() string

func (*Driver) WriteMetadata

func (d *Driver) WriteMetadata(logger lager.Logger, bundleID string, volumeData groot.ImageMetadata) error

type EmptyDriverStoreError

type EmptyDriverStoreError struct{}

func (*EmptyDriverStoreError) Error

func (e *EmptyDriverStoreError) Error() string

type HCSClient

type HCSClient interface {
	NewLayerWriter(hcsshim.DriverInfo, string, []string) (hcs.LayerWriter, error)
	CreateLayer(hcsshim.DriverInfo, string, []string) error
	LayerExists(hcsshim.DriverInfo, string) (bool, error)
	GetLayerMountPath(hcsshim.DriverInfo, string) (string, error)
	DestroyLayer(hcsshim.DriverInfo, string) error
}

type LayerExistsError

type LayerExistsError struct {
	Id string
}

func (*LayerExistsError) Error

func (e *LayerExistsError) Error() string

type Limiter

type Limiter interface {
	SetQuota(string, uint64) error
	GetQuotaUsed(string) (uint64, error)
}

type MissingVolumePathError

type MissingVolumePathError struct {
	Id string
}

func (*MissingVolumePathError) Error

func (e *MissingVolumePathError) Error() string

type PrivilegeElevator

type PrivilegeElevator interface {
	EnableProcessPrivileges([]string) error
	DisableProcessPrivileges([]string) error
}

type TarStreamer

type TarStreamer interface {
	SetReader(io.Reader)
	Next() (*tar.Header, error)
	FileInfoFromHeader(*tar.Header) (string, int64, *winio.FileBasicInfo, error)
	WriteBackupStreamFromTarFile(io.Writer, *tar.Header) (*tar.Header, error)
}