Documentation ¶
Index ¶
- Constants
- func ConfigurePipeline(obj *unstructured.Unstructured, pipelines []v1alpha1.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 LabelsForDeletePromise(promiseID string, requestSHA ...string) map[string]string
- func LabelsForDeleteResource(rrID, promiseID string, requestSHA ...string) map[string]string
- func NewConfigurePromise(unstructuredPromise *unstructured.Unstructured, pipelines []v1alpha1.Pipeline, ...) ([]client.Object, error)
- func NewConfigureResource(rr *unstructured.Unstructured, crdPlural string, pipelines []v1alpha1.Pipeline, ...) ([]client.Object, error)
- func NewDelete(obj *unstructured.Unstructured, pipelines []v1alpha1.Pipeline, ...) []client.Object
- func NewDeletePromise(promise *unstructured.Unstructured, pipelines []v1alpha1.Pipeline) []client.Object
- func NewDeleteResource(rr *unstructured.Unstructured, pipelines []v1alpha1.Pipeline, ...) []client.Object
- func PromiseLabels(promiseID string) pipelineLabels
- func ResourceLabels(rrID, promiseID string) pipelineLabels
- type 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 ¶
View Source
const (
KratixResourceHashLabel = "kratix-resource-hash"
)
Variables ¶
This section is empty.
Functions ¶
func ConfigurePipeline ¶
func ConfigurePipeline(obj *unstructured.Unstructured, pipelines []v1alpha1.Pipeline, pipelineArgs PipelineArgs, promiseName string, promiseWorkflow bool, logger logr.Logger) (*batchv1.Job, error)
func LabelsForDeletePromise ¶ added in v0.21.0
func LabelsForDeleteResource ¶
func NewConfigurePromise ¶
func NewConfigurePromise( unstructuredPromise *unstructured.Unstructured, pipelines []v1alpha1.Pipeline, promiseIdentifier string, promiseDestinationSelectors []v1alpha1.PromiseScheduling, logger logr.Logger, ) ([]client.Object, error)
func NewConfigureResource ¶
func NewConfigureResource( rr *unstructured.Unstructured, crdPlural string, pipelines []v1alpha1.Pipeline, resourceRequestIdentifier, promiseIdentifier string, promiseDestinationSelectors []v1alpha1.PromiseScheduling, promiseWorkflowSelectors *v1alpha1.WorkloadGroupScheduling, logger logr.Logger, ) ([]client.Object, error)
func NewDelete ¶ added in v0.58.0
func NewDelete(obj *unstructured.Unstructured, pipelines []v1alpha1.Pipeline, resourceRequestIdentifier, promiseIdentifier, objPlural string) []client.Object
func NewDeletePromise ¶ added in v0.21.0
func NewDeletePromise(promise *unstructured.Unstructured, pipelines []v1alpha1.Pipeline) []client.Object
func NewDeleteResource ¶ added in v0.21.0
func NewDeleteResource(rr *unstructured.Unstructured, pipelines []v1alpha1.Pipeline, resourceRequestIdentifier, promiseIdentifier, crdPlural string) []client.Object
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
Click to show internal directories.
Click to hide internal directories.