plnbuilder

Documentation

Index

• Constants
• Variables
• func CurrentReleaseExistingResourcesUIDs(standaloneCRDsInfos []*resrcinfo.DeployableStandaloneCRDInfo, ...) (existingUIDs []types.UID, present bool)
• type DeployFailurePlanBuilder
  • func NewDeployFailurePlanBuilder(releaseNamespace string, deployType common.DeployType, deployPlan *pln.Plan, ...) *DeployFailurePlanBuilder
  • func (b *DeployFailurePlanBuilder) Build(ctx context.Context) (*pln.Plan, error)
• type DeployFailurePlanBuilderOptions
• type DeployPlanBuilder
  • func NewDeployPlanBuilder(releaseNamespace string, deployType common.DeployType, ...) *DeployPlanBuilder
  • func (b *DeployPlanBuilder) Build(ctx context.Context) (*pln.Plan, error)
• type DeployPlanBuilderOptions
• type StageOpNamePrefix

Constants

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"
)

const StageOpNameSuffixEnd = "end"

const StageOpNameSuffixStart = "start"

Variables

var StageOpNamesOrdered = []string{
	StageOpNamePrefixInit,
	StageOpNamePrefixStandaloneCRDs,
	StageOpNamePrefixHookCRDs,
	StageOpNamePrefixHookResources,
	StageOpNamePrefixGeneralCRDs,
	StageOpNamePrefixGeneralResources,
	StageOpNamePrefixPostHookCRDs,
	StageOpNamePrefixPostHookResources,
	StageOpNamePrefixFinal,
}

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(
	releaseNamespace string,
	deployType common.DeployType,
	deployPlan *pln.Plan,
	taskStore *statestore.TaskStore,
	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

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

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(
	releaseNamespace string,
	deployType common.DeployType,
	taskStore *statestore.TaskStore,
	logStore *util.Concurrent[*logstore.LogStore],
	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