Documentation ¶
Index ¶
- Variables
- func ShouldResetStagesStorageCache(err error) bool
- func SyncStages(ctx context.Context, projectName string, ...) error
- type StagesManager
- func (m *StagesManager) AtomicStoreStagesBySignatureToCache(ctx context.Context, stageName, stageSig string, stageIDs []image.StageID) error
- func (m *StagesManager) DeleteStages(ctx context.Context, options storage.DeleteImageOptions, ...) error
- func (m *StagesManager) FetchStage(ctx context.Context, stg stage.Interface) error
- func (m *StagesManager) GenerateStageUniqueID(signature string, stages []*image.StageDescription) (string, int64)
- func (m *StagesManager) GetAllStages(ctx context.Context) ([]*image.StageDescription, error)
- func (m *StagesManager) GetStagesBySignature(ctx context.Context, stageName, stageSig string) ([]*image.StageDescription, error)
- func (m *StagesManager) ResetStagesStorageCache(ctx context.Context) error
- func (m *StagesManager) SelectSuitableStage(ctx context.Context, c stage.Conveyor, stg stage.Interface, ...) (*image.StageDescription, error)
- func (m *StagesManager) SetStagesSwitchFromLocalBlock(ctx context.Context, newStagesStorage storage.StagesStorage) error
- func (m *StagesManager) UseStagesStorage(ctx context.Context, stagesStorage storage.StagesStorage) error
- type SyncStagesOptions
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrShouldResetStagesStorageCache = errors.New("should reset stages storage cache")
)
Functions ¶
func SyncStages ¶
func SyncStages(ctx context.Context, projectName string, fromStagesStorage storage.StagesStorage, toStagesStorage storage.StagesStorage, storageLockManager 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 { StagesSwitchFromLocalBlockDir 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 (*StagesManager) DeleteStages ¶
func (m *StagesManager) DeleteStages(ctx context.Context, options storage.DeleteImageOptions, stages ...*image.StageDescription) error
func (*StagesManager) FetchStage ¶
func (*StagesManager) GenerateStageUniqueID ¶
func (m *StagesManager) GenerateStageUniqueID(signature string, stages []*image.StageDescription) (string, int64)
func (*StagesManager) GetAllStages ¶
func (m *StagesManager) GetAllStages(ctx context.Context) ([]*image.StageDescription, error)
func (*StagesManager) GetStagesBySignature ¶
func (m *StagesManager) GetStagesBySignature(ctx context.Context, stageName, stageSig string) ([]*image.StageDescription, error)
func (*StagesManager) ResetStagesStorageCache ¶
func (m *StagesManager) ResetStagesStorageCache(ctx context.Context) error
func (*StagesManager) SelectSuitableStage ¶
func (m *StagesManager) SelectSuitableStage(ctx context.Context, c stage.Conveyor, stg stage.Interface, stages []*image.StageDescription) (*image.StageDescription, error)
func (*StagesManager) SetStagesSwitchFromLocalBlock ¶
func (m *StagesManager) SetStagesSwitchFromLocalBlock(ctx context.Context, newStagesStorage storage.StagesStorage) error
func (*StagesManager) UseStagesStorage ¶
func (m *StagesManager) UseStagesStorage(ctx context.Context, stagesStorage storage.StagesStorage) error
type SyncStagesOptions ¶
Click to show internal directories.
Click to hide internal directories.