plnbuilder

package
v0.0.0-...-3d5d804 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StageOpNamePrefixInit              = opertn.TypeStageOperation + "/initialization"
	StageOpNamePrefixStandaloneCRDs    = opertn.TypeStageOperation + "/standalone-crds"
	StageOpNamePrefixHookCRDs          = opertn.TypeStageOperation + "/pre-hook-crds"
	StageOpNamePrefixHookResources     = opertn.TypeStageOperation + "/pre-hook-resources"
	StageOpNamePrefixGeneralCRDs       = opertn.TypeStageOperation + "/general-crds"
	StageOpNamePrefixGeneralResources  = opertn.TypeStageOperation + "/general-resources"
	StageOpNamePrefixPostHookCRDs      = opertn.TypeStageOperation + "/post-hook-crds"
	StageOpNamePrefixPostHookResources = opertn.TypeStageOperation + "/post-hooks-resources"
	StageOpNamePrefixFinal             = opertn.TypeStageOperation + "/finalization"
)
View Source
const StageOpNameSuffixEnd = "end"
View Source
const StageOpNameSuffixStart = "start"

Variables

Functions

func CurrentReleaseExistingResourcesUIDs

func CurrentReleaseExistingResourcesUIDs(
	standaloneCRDsInfos []*resrcinfo.DeployableStandaloneCRDInfo,
	hookResourcesInfos []*resrcinfo.DeployableHookResourceInfo,
	generalResourcesInfos []*resrcinfo.DeployableGeneralResourceInfo,
) (existingUIDs []types.UID, present bool)

Types

type DeployFailurePlanBuilder

type DeployFailurePlanBuilder struct {
	// contains filtered or unexported fields
}

func NewDeployFailurePlanBuilder

func NewDeployFailurePlanBuilder(
	deployPlan *pln.Plan,
	taskStore *statestore.TaskStore,
	releaseNamespaceInfo *resrcinfo.DeployableReleaseNamespaceInfo,
	hookResourcesInfos []*resrcinfo.DeployableHookResourceInfo,
	generalResourceInfos []*resrcinfo.DeployableGeneralResourceInfo,
	newRelease *rls.Release,
	history rlshistor.Historier,
	kubeClient kubeclnt.KubeClienter,
	dynamicClient dynamic.Interface,
	mapper meta.ResettableRESTMapper,
	opts DeployFailurePlanBuilderOptions,
) *DeployFailurePlanBuilder

func (*DeployFailurePlanBuilder) Build

type DeployFailurePlanBuilderOptions

type DeployFailurePlanBuilderOptions struct {
	PrevRelease     *rls.Release
	DeletionTimeout time.Duration
}

type DeployPlanBuilder

type DeployPlanBuilder struct {
	// contains filtered or unexported fields
}

func NewDeployPlanBuilder

func NewDeployPlanBuilder(
	deployType common.DeployType,
	taskStore *statestore.TaskStore,
	logStore *util.Concurrent[*logstore.LogStore],
	releaseNamespaceInfo *resrcinfo.DeployableReleaseNamespaceInfo,
	standaloneCRDsInfos []*resrcinfo.DeployableStandaloneCRDInfo,
	hookResourcesInfos []*resrcinfo.DeployableHookResourceInfo,
	generalResourcesInfos []*resrcinfo.DeployableGeneralResourceInfo,
	prevReleaseGeneralResourceInfos []*resrcinfo.DeployablePrevReleaseGeneralResourceInfo,
	newRelease *rls.Release,
	history rlshistor.Historier,
	kubeClient kubeclnt.KubeClienter,
	staticClient kubernetes.Interface,
	dynamicClient dynamic.Interface,
	discoveryClient discovery.CachedDiscoveryInterface,
	mapper meta.ResettableRESTMapper,
	opts DeployPlanBuilderOptions,
) *DeployPlanBuilder

func (*DeployPlanBuilder) Build

func (b *DeployPlanBuilder) Build(ctx context.Context) (*pln.Plan, error)

type DeployPlanBuilderOptions

type DeployPlanBuilderOptions struct {
	PrevRelease         *rls.Release
	PrevDeployedRelease *rls.Release
	CreationTimeout     time.Duration
	ReadinessTimeout    time.Duration
	DeletionTimeout     time.Duration
}

type StageOpNamePrefix

type StageOpNamePrefix string

Jump to

Keyboard shortcuts

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