manager

package

v1.2.4 Latest Latest Go to latest Published: Dec 24, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/werf/werf

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ShouldResetStagesStorageCache(err error) bool
type ForEachDeleteStageOptions
type StagesStorageManager
type StorageManager
- func NewStorageManager(projectName string, stagesStorage storage.StagesStorage, ...) *StorageManager
- func (m StorageManager) EnableParallel(parallelTasksLimit int)
- func (m StorageManager) MaxNumberOfWorkers() int

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

func ShouldResetStagesStorageCache ¶

func ShouldResetStagesStorageCache(err error) bool

Types ¶

type ForEachDeleteStageOptions ¶

type ForEachDeleteStageOptions struct {
	storage.DeleteImageOptions
	storage.FilterStagesAndProcessRelatedDataOptions
}

type StagesStorageManager ¶

type StagesStorageManager struct {
	ProjectName string

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

	SecondaryStagesStorageList []storage.StagesStorage
	// contains filtered or unexported fields
}

func (*StagesStorageManager) AtomicStoreStagesByDigestToCache ¶ added in v1.2.0

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

func (*StagesStorageManager) CopySuitableByDigestStage ¶ added in v1.2.0

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

func (*StagesStorageManager) EnableParallel ¶

func (m *StagesStorageManager) EnableParallel(parallelTasksLimit int)

func (*StagesStorageManager) FetchStage ¶

func (m *StagesStorageManager) FetchStage(ctx context.Context, stg stage.Interface) error

func (*StagesStorageManager) ForEachDeleteStage ¶

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

func (*StagesStorageManager) ForEachGetImportMetadata ¶ added in v1.2.0

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

func (*StagesStorageManager) ForEachRmImageMetadata ¶ added in v1.2.0

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

func (*StagesStorageManager) ForEachRmImportMetadata ¶ added in v1.2.0

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

func (*StagesStorageManager) ForEachRmManagedImage ¶ added in v1.2.0

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

func (*StagesStorageManager) GenerateStageUniqueID ¶

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

func (*StagesStorageManager) GetStageDescriptionList ¶ added in v1.2.0

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

func (*StagesStorageManager) GetStagesByDigest ¶ added in v1.2.0

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

func (*StagesStorageManager) GetStagesByDigestFromStagesStorage ¶ added in v1.2.0

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

func (*StagesStorageManager) MaxNumberOfWorkers ¶

func (m *StagesStorageManager) MaxNumberOfWorkers() int

func (*StagesStorageManager) ResetStagesStorageCache ¶

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

func (*StagesStorageManager) SelectSuitableStage ¶

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

type StorageManager ¶

type StorageManager struct {
	*StagesStorageManager
}

func NewStorageManager ¶

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

func (StorageManager) EnableParallel ¶ added in v1.2.0

func (m StorageManager) EnableParallel(parallelTasksLimit int)

func (StorageManager) MaxNumberOfWorkers ¶ added in v1.2.0

func (m StorageManager) MaxNumberOfWorkers() int

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL