stages_manager

Documentation

Index

• func SyncStages(projectName string, fromStagesStorage storage.StagesStorage, ...) error
• type StagesManager
  • func NewStagesManager(projectName string, storageLockManager storage.LockManager, ...) *StagesManager
  • func (m *StagesManager) AtomicStoreStagesBySignatureToCache(stageName, stageSig string, stageIDs []image.StageID) error
  • func (m *StagesManager) DeleteStages(options storage.DeleteImageOptions, stages ...*image.StageDescription) error
  • func (m *StagesManager) FetchStage(stg stage.Interface) error
  • func (m *StagesManager) GenerateStageUniqueID(signature string, stages []*image.StageDescription) (string, string)
  • func (m *StagesManager) GetAllStages() ([]*image.StageDescription, error)
  • func (m *StagesManager) GetStagesBySignature(stageName, stageSig string) ([]*image.StageDescription, error)
  • func (m *StagesManager) SelectSuitableStage(stg stage.Interface, stages []*image.StageDescription) (*image.StageDescription, error)
  • func (m *StagesManager) SwitchStagesStorage(newStagesStorage storage.StagesStorage) error
  • func (m *StagesManager) UseStagesStorage(stagesStorage storage.StagesStorage) error
• type SyncStagesOptions

Functions

func SyncStages

func SyncStages(projectName string, fromStagesStorage storage.StagesStorage, toStagesStorage storage.StagesStorage, storageManager storage.LockManager, containerRuntime container_runtime.ContainerRuntime, opts SyncStagesOptions) error

SyncStages will make sure, that destination stages storage contains all stages from source stages storage. Repeatedly calling SyncStages will copy stages from source stages storage to destination, that already exists in the destination. SyncStages will not delete excess stages from destination storage, that does not exists in the source.

Types

type StagesManager

type StagesManager struct {
	StagesStorageByProjectDir string
	ProjectName               string

	StorageLockManager storage.LockManager
	StagesStorage      storage.StagesStorage
	StagesStorageCache storage.StagesStorageCache
}

func NewStagesManager

func NewStagesManager(projectName string, storageLockManager storage.LockManager, stagesStorageCache storage.StagesStorageCache) *StagesManager

func (*StagesManager) AtomicStoreStagesBySignatureToCache

func (m *StagesManager) AtomicStoreStagesBySignatureToCache(stageName, stageSig string, stageIDs []image.StageID) error

func (*StagesManager) DeleteStages

func (m *StagesManager) DeleteStages(options storage.DeleteImageOptions, stages ...*image.StageDescription) error

func (*StagesManager) FetchStage

func (m *StagesManager) FetchStage(stg stage.Interface) error

func (*StagesManager) GenerateStageUniqueID

func (m *StagesManager) GenerateStageUniqueID(signature string, stages []*image.StageDescription) (string, string)

func (*StagesManager) GetAllStages

func (m *StagesManager) GetAllStages() ([]*image.StageDescription, error)

func (*StagesManager) GetStagesBySignature

func (m *StagesManager) GetStagesBySignature(stageName, stageSig string) ([]*image.StageDescription, error)

func (*StagesManager) SelectSuitableStage

func (m *StagesManager) SelectSuitableStage(stg stage.Interface, stages []*image.StageDescription) (*image.StageDescription, error)

func (*StagesManager) SwitchStagesStorage

func (m *StagesManager) SwitchStagesStorage(newStagesStorage storage.StagesStorage) error

func (*StagesManager) UseStagesStorage

func (m *StagesManager) UseStagesStorage(stagesStorage storage.StagesStorage) error

type SyncStagesOptions

type SyncStagesOptions struct {
	RemoveSource      bool
	CleanupLocalCache bool
}