pipeline

Documentation

Index

• Constants
• func ConfigurePipeline(obj *unstructured.Unstructured, pipelines []platformv1alpha1.Pipeline, ...) (*batchv1.Job, error)
• func LabelsForAllPromiseWorkflows(promiseID string) map[string]string
• func LabelsForAllResourceWorkflows(rrID, promiseID string) map[string]string
• func LabelsForConfigurePromise(promiseID string, requestSHA ...string) map[string]string
• func LabelsForConfigureResource(rrID, promiseID string, requestSHA ...string) map[string]string
• func LabelsForDeleteResource(rrID, promiseID string, requestSHA ...string) map[string]string
• func NewConfigurePromise(unstructedPromise *unstructured.Unstructured, ...) ([]client.Object, error)
• func NewConfigureResource(rr *unstructured.Unstructured, crdPlural string, ...) ([]client.Object, error)
• func NewDeletePipeline(rr *unstructured.Unstructured, pipelines []platformv1alpha1.Pipeline, ...) batchv1.Job
• func PromiseLabels(promiseID string) pipelineLabels
• func ResourceLabels(rrID, promiseID string) pipelineLabels
• type PipelineArgs
  • func NewPipelineArgs(promiseIdentifier, resourceRequestIdentifier, namespace string) PipelineArgs
  • func (p PipelineArgs) ConfigMapName() string
  • func (p PipelineArgs) ConfigurePipelineName() string
  • func (p PipelineArgs) ConfigurePipelinePodLabels(objHash string) pipelineLabels
  • func (p PipelineArgs) DeletePipelineName() string
  • func (p PipelineArgs) DeletePipelinePodLabels() pipelineLabels
  • func (p PipelineArgs) Labels() pipelineLabels
  • func (p PipelineArgs) Namespace() string
  • func (p PipelineArgs) PromiseID() string
  • func (p PipelineArgs) RoleBindingName() string
  • func (p PipelineArgs) RoleName() string
  • func (p PipelineArgs) ServiceAccountName() string

Constants

const (
	KratixResourceHashLabel = "kratix-resource-hash"
)

Functions

func ConfigurePipeline

func ConfigurePipeline(obj *unstructured.Unstructured, pipelines []platformv1alpha1.Pipeline, pipelineArgs PipelineArgs, promiseName string, promiseWorkflow bool, logger logr.Logger) (*batchv1.Job, error)

func LabelsForAllPromiseWorkflows

func LabelsForAllPromiseWorkflows(promiseID string) map[string]string

func LabelsForAllResourceWorkflows

func LabelsForAllResourceWorkflows(rrID, promiseID string) map[string]string

func LabelsForConfigurePromise

func LabelsForConfigurePromise(promiseID string, requestSHA ...string) map[string]string

func LabelsForConfigureResource

func LabelsForConfigureResource(rrID, promiseID string, requestSHA ...string) map[string]string

func LabelsForDeleteResource

func LabelsForDeleteResource(rrID, promiseID string, requestSHA ...string) map[string]string

func NewConfigurePromise

func NewConfigurePromise(
	unstructedPromise *unstructured.Unstructured,
	pipelines []platformv1alpha1.Pipeline,
	promiseIdentifier string,
	promiseDestinationSelectors []platformv1alpha1.PromiseScheduling,
	logger logr.Logger,
) ([]client.Object, error)

func NewConfigureResource

func NewConfigureResource(
	rr *unstructured.Unstructured,
	crdPlural string,
	pipelines []platformv1alpha1.Pipeline,
	resourceRequestIdentifier,
	promiseIdentifier string,
	promiseDestinationSelectors []platformv1alpha1.PromiseScheduling,
	promiseWorkflowSelectors *platformv1alpha1.WorkloadGroupScheduling,
	logger logr.Logger,
) ([]client.Object, error)

func NewDeletePipeline

func NewDeletePipeline(rr *unstructured.Unstructured, pipelines []platformv1alpha1.Pipeline, resourceRequestIdentifier, promiseIdentifier string) batchv1.Job

func PromiseLabels

func PromiseLabels(promiseID string) pipelineLabels

func ResourceLabels

func ResourceLabels(rrID, promiseID string) pipelineLabels

Types

type PipelineArgs

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

func NewPipelineArgs

func NewPipelineArgs(promiseIdentifier, resourceRequestIdentifier, namespace string) PipelineArgs

func (PipelineArgs) ConfigMapName

func (p PipelineArgs) ConfigMapName() string

func (PipelineArgs) ConfigurePipelineName

func (p PipelineArgs) ConfigurePipelineName() string

func (PipelineArgs) ConfigurePipelinePodLabels

func (p PipelineArgs) ConfigurePipelinePodLabels(objHash string) pipelineLabels

func (PipelineArgs) DeletePipelineName

func (p PipelineArgs) DeletePipelineName() string

func (PipelineArgs) DeletePipelinePodLabels

func (p PipelineArgs) DeletePipelinePodLabels() pipelineLabels

func (PipelineArgs) Labels

func (p PipelineArgs) Labels() pipelineLabels

func (PipelineArgs) Namespace

func (p PipelineArgs) Namespace() string

func (PipelineArgs) PromiseID

func (p PipelineArgs) PromiseID() string

func (PipelineArgs) RoleBindingName

func (p PipelineArgs) RoleBindingName() string

func (PipelineArgs) RoleName

func (p PipelineArgs) RoleName() string

func (PipelineArgs) ServiceAccountName

func (p PipelineArgs) ServiceAccountName() string