manager

Documentation

Index

• Variables
• func IsStageNotFound(err error) bool
• func ShouldResetStagesStorageCache(err error) bool
• type ForEachDeleteStageOptions
• type StorageManager
  • func NewStorageManager(projectName string, stagesStorage storage.StagesStorage, ...) *StorageManager
  • func (m *StorageManager) AtomicStoreStagesByDigestToCache(ctx context.Context, stageName, stageDigest string, stageIDs []image.StageID) error
  • func (m *StorageManager) CopyStageIntoCache(ctx context.Context, stg stage.Interface, ...) error
  • func (m *StorageManager) CopySuitableByDigestStage(ctx context.Context, stageDesc *image.StageDescription, ...) (*image.StageDescription, error)
  • func (m *StorageManager) EnableParallel(parallelTasksLimit int)
  • func (m *StorageManager) FetchStage(ctx context.Context, containerRuntime container_runtime.ContainerRuntime, ...) error
  • func (m *StorageManager) ForEachDeleteStage(ctx context.Context, options ForEachDeleteStageOptions, ...) error
  • func (m *StorageManager) ForEachGetImportMetadata(ctx context.Context, projectName string, ids []string, ...) error
  • func (m *StorageManager) ForEachRmImageMetadata(ctx context.Context, projectName, imageNameOrID string, ...) error
  • func (m *StorageManager) ForEachRmImportMetadata(ctx context.Context, projectName string, ids []string, ...) error
  • func (m *StorageManager) ForEachRmManagedImage(ctx context.Context, projectName string, managedImages []string, ...) error
  • func (m *StorageManager) GenerateStageUniqueID(digest string, stages []*image.StageDescription) (string, int64)
  • func (m *StorageManager) GetStageDescriptionList(ctx context.Context) ([]*image.StageDescription, error)
  • func (m *StorageManager) GetStagesByDigest(ctx context.Context, stageName, stageDigest string) ([]*image.StageDescription, error)
  • func (m *StorageManager) GetStagesByDigestFromStagesStorage(ctx context.Context, stageName, stageDigest string, ...) ([]*image.StageDescription, error)
  • func (m *StorageManager) LockStageImage(ctx context.Context, imageName string) error
  • func (m *StorageManager) MaxNumberOfWorkers() int
  • func (m *StorageManager) ResetStagesStorageCache(ctx context.Context) error
  • func (m *StorageManager) SelectSuitableStage(ctx context.Context, c stage.Conveyor, stg stage.Interface, ...) (*image.StageDescription, error)

Variables

var ErrShouldResetStagesStorageCache = errors.New("should reset storage cache")

var ErrStageNotFound = errors.New("stage not found")

Functions

func IsStageNotFound

func IsStageNotFound(err error) bool

func ShouldResetStagesStorageCache

func ShouldResetStagesStorageCache(err error) bool

Types

type ForEachDeleteStageOptions

type ForEachDeleteStageOptions struct {
	storage.DeleteImageOptions
	storage.FilterStagesAndProcessRelatedDataOptions
}

type StorageManager

type StorageManager struct {
	ProjectName string

	StorageLockManager storage.LockManager
	StagesStorageCache storage.StagesStorageCache

	StagesStorage              storage.StagesStorage
	CacheStagesStorageList     []storage.StagesStorage
	SecondaryStagesStorageList []storage.StagesStorage

	// These will be released automatically when current process exits
	SharedHostImagesLocks []lockgate.LockHandle
	// contains filtered or unexported fields
}

func NewStorageManager

func NewStorageManager(projectName string, stagesStorage storage.StagesStorage, secondaryStagesStorageList []storage.StagesStorage, cacheStagesStorageList []storage.StagesStorage, storageLockManager storage.LockManager, stagesStorageCache storage.StagesStorageCache) *StorageManager

func (*StorageManager) AtomicStoreStagesByDigestToCache

func (m *StorageManager) AtomicStoreStagesByDigestToCache(ctx context.Context, stageName, stageDigest string, stageIDs []image.StageID) error

func (*StorageManager) CopyStageIntoCache

func (m *StorageManager) CopyStageIntoCache(ctx context.Context, stg stage.Interface, containerRuntime container_runtime.ContainerRuntime) error

func (*StorageManager) CopySuitableByDigestStage

func (m *StorageManager) CopySuitableByDigestStage(ctx context.Context, stageDesc *image.StageDescription, sourceStagesStorage, destinationStagesStorage storage.StagesStorage, containerRuntime container_runtime.ContainerRuntime) (*image.StageDescription, error)

func (*StorageManager) EnableParallel

func (m *StorageManager) EnableParallel(parallelTasksLimit int)

func (*StorageManager) FetchStage

func (m *StorageManager) FetchStage(ctx context.Context, containerRuntime container_runtime.ContainerRuntime, stg stage.Interface) error

func (*StorageManager) ForEachDeleteStage

func (m *StorageManager) ForEachDeleteStage(ctx context.Context, options ForEachDeleteStageOptions, stagesDescriptions []*image.StageDescription, f func(ctx context.Context, stageDesc *image.StageDescription, err error) error) error

func (*StorageManager) ForEachGetImportMetadata

func (m *StorageManager) ForEachGetImportMetadata(ctx context.Context, projectName string, ids []string, f func(ctx context.Context, metadataID string, metadata *storage.ImportMetadata, err error) error) error

func (*StorageManager) ForEachRmImageMetadata

func (m *StorageManager) ForEachRmImageMetadata(ctx context.Context, projectName, imageNameOrID string, stageIDCommitList map[string][]string, f func(ctx context.Context, commit, stageID string, err error) error) error

func (*StorageManager) ForEachRmImportMetadata

func (m *StorageManager) ForEachRmImportMetadata(ctx context.Context, projectName string, ids []string, f func(ctx context.Context, id string, err error) error) error

func (*StorageManager) ForEachRmManagedImage

func (m *StorageManager) ForEachRmManagedImage(ctx context.Context, projectName string, managedImages []string, f func(ctx context.Context, managedImage string, err error) error) error

func (*StorageManager) GenerateStageUniqueID

func (m *StorageManager) GenerateStageUniqueID(digest string, stages []*image.StageDescription) (string, int64)

func (*StorageManager) GetStageDescriptionList

func (m *StorageManager) GetStageDescriptionList(ctx context.Context) ([]*image.StageDescription, error)

func (*StorageManager) GetStagesByDigest

func (m *StorageManager) GetStagesByDigest(ctx context.Context, stageName, stageDigest string) ([]*image.StageDescription, error)

func (*StorageManager) GetStagesByDigestFromStagesStorage

func (m *StorageManager) GetStagesByDigestFromStagesStorage(ctx context.Context, stageName, stageDigest string, stagesStorage storage.StagesStorage) ([]*image.StageDescription, error)

func (*StorageManager) LockStageImage

func (m *StorageManager) LockStageImage(ctx context.Context, imageName string) error

func (*StorageManager) MaxNumberOfWorkers

func (m *StorageManager) MaxNumberOfWorkers() int

func (*StorageManager) ResetStagesStorageCache

func (m *StorageManager) ResetStagesStorageCache(ctx context.Context) error

func (*StorageManager) SelectSuitableStage

func (m *StorageManager) SelectSuitableStage(ctx context.Context, c stage.Conveyor, stg stage.Interface, stages []*image.StageDescription) (*image.StageDescription, error)