Documentation ¶
Index ¶
- type BasePhase
- func (phase *BasePhase) AfterImageStages(ctx context.Context, img *image.Image) error
- func (phase *BasePhase) AfterImages(_ context.Context) error
- func (phase *BasePhase) BeforeImageStages(ctx context.Context, img *image.Image) (deferFn func(), err error)
- func (phase *BasePhase) BeforeImages(_ context.Context) error
- func (phase *BasePhase) ImageProcessingShouldBeStopped(_ context.Context, _ *image.Image) bool
- func (phase *BasePhase) OnImageStage(_ context.Context, _ *image.Image, _ stage.Interface) error
- type BuildOptions
- type BuildPhase
- func (phase *BuildPhase) AfterImageStages(ctx context.Context, img *image.Image) error
- func (phase *BuildPhase) AfterImages(ctx context.Context) error
- func (phase *BuildPhase) BeforeImageStages(ctx context.Context, img *image.Image) (deferFn func(), err error)
- func (phase *BuildPhase) BeforeImages(ctx context.Context) error
- func (phase *BuildPhase) Clone() Phase
- func (phase *BuildPhase) ImageProcessingShouldBeStopped(_ context.Context, _ *image.Image) bool
- func (phase *BuildPhase) Name() string
- func (phase *BuildPhase) OnImageStage(ctx context.Context, img *image.Image, stg stage.Interface) error
- type BuildPhaseOptions
- type Conveyor
- func (c *Conveyor) AppendOnTerminateFunc(f func() error)
- func (c *Conveyor) Build(ctx context.Context, opts BuildOptions) error
- func (c *Conveyor) Export(ctx context.Context, opts ExportOptions) error
- func (c *Conveyor) FetchImageStage(ctx context.Context, imageName, stageName string) error
- func (c *Conveyor) FetchLastImageStage(ctx context.Context, imageName string) error
- func (c *Conveyor) FetchLastNonEmptyImageStage(ctx context.Context, imageName string) error
- func (c *Conveyor) GetBaseImagesRepoErrCache(key string) error
- func (c *Conveyor) GetBaseImagesRepoIdsCache(key string) string
- func (c *Conveyor) GetExportedImagesNames() []string
- func (c *Conveyor) GetImage(name string) *image.Image
- func (c *Conveyor) GetImageContentDigest(imageName string) string
- func (c *Conveyor) GetImageIDForImageStage(imageName, stageName string) string
- func (c *Conveyor) GetImageIDForLastImageStage(imageName string) string
- func (c *Conveyor) GetImageInfoGetters(opts imagePkg.InfoGetterOptions) (images []*imagePkg.InfoGetter)
- func (c *Conveyor) GetImageNameForImageStage(imageName, stageName string) string
- func (c *Conveyor) GetImageNameForLastImageStage(imageName string) string
- func (c *Conveyor) GetImageStageContentDigest(imageName, stageName string) string
- func (c *Conveyor) GetImagesEnvArray() []string
- func (c *Conveyor) GetImportMetadata(ctx context.Context, projectName, id string) (*storage.ImportMetadata, error)
- func (c *Conveyor) GetImportServer(ctx context.Context, imageName, stageName string) (import_server.ImportServer, error)
- func (c *Conveyor) GetLocalGitRepoVirtualMergeOptions() stage.VirtualMergeOptions
- func (c *Conveyor) GetOrCreateStageImage(name string, prevStageImage *stage.StageImage, stg stage.Interface, ...) *stage.StageImage
- func (c *Conveyor) GetRemoteGitRepo(key string) *git_repo.Remote
- func (c *Conveyor) GetServiceRWMutex(service string) *sync.RWMutex
- func (c *Conveyor) GetStageDigestMutex(stage string) *sync.Mutex
- func (c *Conveyor) GetStageID(imageName string) string
- func (c *Conveyor) GetStageImage(name string) *stage.StageImage
- func (c *Conveyor) GiterminismManager() giterminism_manager.Interface
- func (c *Conveyor) IsBaseImagesRepoErrCacheExist(key string) bool
- func (c *Conveyor) IsBaseImagesRepoIdsCacheExist(key string) bool
- func (c *Conveyor) ProjectName() string
- func (c *Conveyor) PutImportMetadata(ctx context.Context, projectName string, metadata *storage.ImportMetadata) error
- func (c *Conveyor) RmImportMetadata(ctx context.Context, projectName, id string) error
- func (c *Conveyor) SetBaseImagesRepoErrCache(key string, err error)
- func (c *Conveyor) SetBaseImagesRepoIdsCache(key, value string)
- func (c *Conveyor) SetRemoteGitRepo(key string, repo *git_repo.Remote)
- func (c *Conveyor) SetStageImage(stageImage *stage.StageImage)
- func (c *Conveyor) ShouldBeBuilt(ctx context.Context, opts ShouldBeBuiltOptions) error
- func (c *Conveyor) Terminate(ctx context.Context) error
- func (c *Conveyor) UnsetStageImage(name string)
- func (c *Conveyor) UseLegacyStapelBuilder(cr container_backend.ContainerBackend) bool
- type ConveyorOptions
- type ConveyorWithRetryWrapper
- type ExportOptions
- type ExportPhase
- type ExportPhaseOptions
- type ImagesReport
- type ImagesToProcess
- type IntrospectOptions
- type IntrospectTarget
- type Phase
- type ReportFormat
- type ReportImageRecord
- type ShouldBeBuiltOptions
- type StagesIterator
- func (iterator *StagesIterator) GetPrevBuiltImage(img *build_image.Image, stg stage.Interface) *stage.StageImage
- func (iterator *StagesIterator) GetPrevImage(img *build_image.Image, stg stage.Interface) *stage.StageImage
- func (iterator *StagesIterator) OnImageStage(ctx context.Context, img *build_image.Image, stg stage.Interface, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasePhase ¶
type BasePhase struct {
Conveyor *Conveyor
}
func (*BasePhase) AfterImageStages ¶ added in v1.2.16
func (*BasePhase) AfterImages ¶ added in v1.2.15
func (*BasePhase) BeforeImageStages ¶ added in v1.2.15
func (*BasePhase) BeforeImages ¶ added in v1.2.15
func (*BasePhase) ImageProcessingShouldBeStopped ¶ added in v1.2.15
type BuildOptions ¶ added in v1.2.0
type BuildOptions struct { ImageBuildOptions container_backend.BuildOptions IntrospectOptions ReportPath string ReportFormat ReportFormat SkipImageMetadataPublication bool CustomTagFuncList []imagePkg.CustomTagFunc }
type BuildPhase ¶
type BuildPhase struct { BasePhase BuildPhaseOptions StagesIterator *StagesIterator ShouldAddManagedImageRecord bool ImagesReport *ImagesReport // contains filtered or unexported fields }
func NewBuildPhase ¶
func NewBuildPhase(c *Conveyor, opts BuildPhaseOptions) *BuildPhase
func (*BuildPhase) AfterImageStages ¶
func (*BuildPhase) AfterImages ¶
func (phase *BuildPhase) AfterImages(ctx context.Context) error
func (*BuildPhase) BeforeImageStages ¶
func (*BuildPhase) BeforeImages ¶
func (phase *BuildPhase) BeforeImages(ctx context.Context) error
func (*BuildPhase) Clone ¶ added in v1.1.23
func (phase *BuildPhase) Clone() Phase
func (*BuildPhase) ImageProcessingShouldBeStopped ¶
func (*BuildPhase) Name ¶
func (phase *BuildPhase) Name() string
func (*BuildPhase) OnImageStage ¶
type BuildPhaseOptions ¶
type BuildPhaseOptions struct { BuildOptions ShouldBeBuiltMode bool }
type Conveyor ¶
type Conveyor struct { ContainerBackend container_backend.ContainerBackend StorageLockManager storage.LockManager StorageManager manager.StorageManagerInterface ConveyorOptions // contains filtered or unexported fields }
func NewConveyor ¶
func NewConveyor(werfConfig *config.WerfConfig, giterminismManager giterminism_manager.Interface, projectDir, baseTmpDir, sshAuthSock string, containerBackend container_backend.ContainerBackend, storageManager manager.StorageManagerInterface, storageLockManager storage.LockManager, opts ConveyorOptions) *Conveyor
func (*Conveyor) AppendOnTerminateFunc ¶
func (*Conveyor) Build ¶ added in v1.2.0
func (c *Conveyor) Build(ctx context.Context, opts BuildOptions) error
func (*Conveyor) Export ¶ added in v1.2.15
func (c *Conveyor) Export(ctx context.Context, opts ExportOptions) error
func (*Conveyor) FetchImageStage ¶ added in v1.2.68
func (*Conveyor) FetchLastImageStage ¶ added in v1.2.0
func (*Conveyor) FetchLastNonEmptyImageStage ¶ added in v1.2.68
func (*Conveyor) GetBaseImagesRepoErrCache ¶ added in v1.1.23
func (*Conveyor) GetBaseImagesRepoIdsCache ¶ added in v1.1.23
func (*Conveyor) GetExportedImagesNames ¶ added in v1.2.10
func (*Conveyor) GetImageContentDigest ¶ added in v1.2.0
func (*Conveyor) GetImageIDForImageStage ¶
func (*Conveyor) GetImageIDForLastImageStage ¶
func (*Conveyor) GetImageInfoGetters ¶
func (c *Conveyor) GetImageInfoGetters(opts imagePkg.InfoGetterOptions) (images []*imagePkg.InfoGetter)
func (*Conveyor) GetImageNameForImageStage ¶
func (*Conveyor) GetImageNameForLastImageStage ¶
func (*Conveyor) GetImageStageContentDigest ¶ added in v1.2.0
func (*Conveyor) GetImagesEnvArray ¶ added in v1.2.1
func (*Conveyor) GetImportMetadata ¶ added in v1.2.0
func (*Conveyor) GetImportServer ¶
func (c *Conveyor) GetImportServer(ctx context.Context, imageName, stageName string) (import_server.ImportServer, error)
func (*Conveyor) GetLocalGitRepoVirtualMergeOptions ¶
func (c *Conveyor) GetLocalGitRepoVirtualMergeOptions() stage.VirtualMergeOptions
func (*Conveyor) GetOrCreateStageImage ¶
func (c *Conveyor) GetOrCreateStageImage(name string, prevStageImage *stage.StageImage, stg stage.Interface, img *image.Image) *stage.StageImage
func (*Conveyor) GetRemoteGitRepo ¶ added in v1.1.23
func (*Conveyor) GetServiceRWMutex ¶ added in v1.2.177
func (*Conveyor) GetStageDigestMutex ¶ added in v1.2.0
func (*Conveyor) GetStageID ¶ added in v1.2.0
func (*Conveyor) GetStageImage ¶
func (c *Conveyor) GetStageImage(name string) *stage.StageImage
func (*Conveyor) GiterminismManager ¶ added in v1.2.5
func (c *Conveyor) GiterminismManager() giterminism_manager.Interface
func (*Conveyor) IsBaseImagesRepoErrCacheExist ¶ added in v1.1.23
func (*Conveyor) IsBaseImagesRepoIdsCacheExist ¶ added in v1.1.23
func (*Conveyor) ProjectName ¶ added in v1.2.177
func (*Conveyor) PutImportMetadata ¶ added in v1.2.0
func (*Conveyor) RmImportMetadata ¶ added in v1.2.0
func (*Conveyor) SetBaseImagesRepoErrCache ¶ added in v1.1.23
func (*Conveyor) SetBaseImagesRepoIdsCache ¶ added in v1.1.23
func (*Conveyor) SetRemoteGitRepo ¶ added in v1.1.23
func (*Conveyor) SetStageImage ¶
func (c *Conveyor) SetStageImage(stageImage *stage.StageImage)
func (*Conveyor) ShouldBeBuilt ¶
func (c *Conveyor) ShouldBeBuilt(ctx context.Context, opts ShouldBeBuiltOptions) error
func (*Conveyor) UnsetStageImage ¶
func (*Conveyor) UseLegacyStapelBuilder ¶ added in v1.2.80
func (c *Conveyor) UseLegacyStapelBuilder(cr container_backend.ContainerBackend) bool
type ConveyorOptions ¶
type ConveyorOptions struct { Parallel bool ParallelTasksLimit int64 LocalGitRepoVirtualMergeOptions stage.VirtualMergeOptions ImagesToProcess }
type ConveyorWithRetryWrapper ¶
type ConveyorWithRetryWrapper struct { WerfConfig *config.WerfConfig GiterminismManager giterminism_manager.Interface ProjectDir string BaseTmpDir string SshAuthSock string ContainerBackend container_backend.ContainerBackend StorageManager *manager.StorageManager StorageLockManager storage.LockManager ConveyorOptions ConveyorOptions }
func NewConveyorWithRetryWrapper ¶
func NewConveyorWithRetryWrapper(werfConfig *config.WerfConfig, giterminismManager giterminism_manager.Interface, projectDir, baseTmpDir, sshAuthSock string, containerBackend container_backend.ContainerBackend, storageManager *manager.StorageManager, storageLockManager storage.LockManager, opts ConveyorOptions) *ConveyorWithRetryWrapper
func (*ConveyorWithRetryWrapper) Terminate ¶
func (wrapper *ConveyorWithRetryWrapper) Terminate() error
func (*ConveyorWithRetryWrapper) WithRetryBlock ¶
type ExportOptions ¶ added in v1.2.15
type ExportOptions struct { BuildPhaseOptions BuildPhaseOptions ExportPhaseOptions ExportPhaseOptions }
type ExportPhase ¶ added in v1.2.15
type ExportPhase struct { BasePhase ExportPhaseOptions }
func NewExportPhase ¶ added in v1.2.15
func NewExportPhase(c *Conveyor, opts ExportPhaseOptions) *ExportPhase
func (*ExportPhase) AfterImageStages ¶ added in v1.2.15
func (phase *ExportPhase) AfterImageStages(ctx context.Context, img *build_image.Image) error
func (*ExportPhase) Clone ¶ added in v1.2.15
func (phase *ExportPhase) Clone() Phase
func (*ExportPhase) Name ¶ added in v1.2.15
func (phase *ExportPhase) Name() string
type ExportPhaseOptions ¶ added in v1.2.15
type ExportPhaseOptions struct {
ExportTagFuncList []image.ExportTagFunc
}
type ImagesReport ¶ added in v1.2.0
type ImagesReport struct { Images map[string]ReportImageRecord // contains filtered or unexported fields }
func (*ImagesReport) SetImageRecord ¶ added in v1.2.0
func (report *ImagesReport) SetImageRecord(name string, imageRecord ReportImageRecord)
func (*ImagesReport) ToEnvFileData ¶ added in v1.2.1
func (report *ImagesReport) ToEnvFileData() []byte
func (*ImagesReport) ToJsonData ¶ added in v1.2.1
func (report *ImagesReport) ToJsonData() ([]byte, error)
type ImagesToProcess ¶ added in v1.2.175
func NewImagesToProcess ¶ added in v1.2.175
func NewImagesToProcess(onlyImages []string, withoutImages bool) ImagesToProcess
type IntrospectOptions ¶
type IntrospectOptions struct {
Targets []IntrospectTarget
}
func (*IntrospectOptions) ImageStageShouldBeIntrospected ¶
func (opts *IntrospectOptions) ImageStageShouldBeIntrospected(imageName, stageName string) bool
type IntrospectTarget ¶
type Phase ¶
type Phase interface { Name() string BeforeImages(ctx context.Context) error AfterImages(ctx context.Context) error BeforeImageStages(ctx context.Context, img *image.Image) (deferFn func(), err error) OnImageStage(ctx context.Context, img *image.Image, stg stage.Interface) error AfterImageStages(ctx context.Context, img *image.Image) error ImageProcessingShouldBeStopped(ctx context.Context, img *image.Image) bool Clone() Phase }
type ReportFormat ¶ added in v1.2.0
type ReportFormat string
const ( ReportJSON ReportFormat = "json" ReportEnvFile ReportFormat = "envfile" )
type ReportImageRecord ¶ added in v1.2.0
type ShouldBeBuiltOptions ¶
type ShouldBeBuiltOptions struct {
CustomTagFuncList []imagePkg.CustomTagFunc
}
type StagesIterator ¶
type StagesIterator struct { Conveyor *Conveyor PrevStage stage.Interface PrevNonEmptyStage stage.Interface PrevBuiltStage stage.Interface PrevNonEmptyStageImageSize int64 }
func NewStagesIterator ¶
func NewStagesIterator(conveyor *Conveyor) *StagesIterator
func (*StagesIterator) GetPrevBuiltImage ¶
func (iterator *StagesIterator) GetPrevBuiltImage(img *build_image.Image, stg stage.Interface) *stage.StageImage
func (*StagesIterator) GetPrevImage ¶
func (iterator *StagesIterator) GetPrevImage(img *build_image.Image, stg stage.Interface) *stage.StageImage
func (*StagesIterator) OnImageStage ¶
func (iterator *StagesIterator) OnImageStage(ctx context.Context, img *build_image.Image, stg stage.Interface, onImageStageFunc func(img *build_image.Image, stg stage.Interface, isEmpty bool) error) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.