stages_manager

Jun 22, 2020

Changes in this version

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

+ func ShouldResetStagesStorageCache(err error) bool

+ func SyncStages(projectName string, fromStagesStorage storage.StagesStorage, ...) error

+ type StagesManager struct

+ ProjectName string

+ StagesStorage storage.StagesStorage

+ StagesStorageCache storage.StagesStorageCache

+ StagesSwitchFromLocalBlockDir string

+ StorageLockManager storage.LockManager

+ 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, int64)

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

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

+ func (m *StagesManager) ResetStagesStorageCache() error

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

+ func (m *StagesManager) SetStagesSwitchFromLocalBlock(newStagesStorage storage.StagesStorage) error

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

+ type SyncStagesOptions struct

+ CleanupLocalCache bool

+ RemoveSource bool

+ WithoutLock bool