ArchiveTgz takes a map of files with name as key and content as value and tar and gzip it to a tgz content string.

BooleanPointer converts a bool to a bool pointer.

Getter of the executionType.

ExtractTgz extracts a list of files from a tgz content.

FormatTimeForLogging formats an epoch for logging purposes.

GetKubernetesConfig will first try an in-cluster configuration but fallback to using a kubeconfig.

GetMetricValue get metric value from registered Collector.

IsNotFound returns whether an error indicates that a Kubernetes resource was "not found".

IsUserErrorCodeMatch returns whether the error is a user error with specified code.

Converts an object into []byte array.

Marshal parameters to JSON encoded string.

Marshal parameters to JSON encoded string.

Metav1TimePointer converts a metav1.Time to a pointer.

Create an ExecutionClient for the specified ExecutionType.

Create an ExecutionInformer for the specified Executiontype.

Convert YAML in bytes into ExecutionSpec instance.

Construct a ExecutionSpec based on the data struct.

Convert JSON in bytes into ExecutionSpec instance If the data contains the TypeMeta info, then there is no need to specify the ExecutionType.

NewFakeUUIDGeneratorOrFatal creates a UUIDGenerator that always returns the UUID and error provided as parameters.

NewWorkflow creates a Workflow.

NewRunParameterFormatter returns a new ParameterFormatter to substitute run macros.

NewScheduledWorkflow creates an instance of ScheduledWorkflow.

NewSWFParameterFormatter returns a new ParameterFormatter to substitute recurring run macros.

NewWorkflow creates a Workflow.

RetrieveInt64FromLabel converts a string label value into an epoch.

Derives the Pod name from a given workflowapi.Workflow and workflowapi.NodeStatus This is a workaround for an upstream breaking change with node.ID and node.Name mismatches, see https://github.com/argoproj/argo-workflows/issues/10107#issuecomment-1536113642.

Unmarshal Spec from ScheduleWorkflow to ExecutionSpec.

Setter of the executionType.

TerminateIfError Check if error is nil.

Converts google.rpc.Status to an error.

Converts an error to google.rpc.Status.

Truncate the provided string up to provided size.

Converts a []byte array into an interface.

Unmarshal parameters from JSON encoded string and convert it to SpecParameters.

UnmarshalString unmarshals a JSON object from s into m.

LabelKeyWorkflowEpoch is a Workflow annotation key.

LabelKeyCacheEnabled is a workflow label key.

LabelKeyScheduledWorkflowEnabled is a label on a ScheduledWorkflow.

LabelKeyScheduledWorkflowStatus is a label on a ScheduledWorkflow.

LabelKeyWorkflowEpoch is a label on a Workflow.

LabelKeyWorkflowIndex is a label on a Workflow.

LabelKeyWorkflowIsOwnedByScheduledWorkflow is a label on a Workflow.

LabelKeyWorkflowScheduledWorkflowName is a label on a Workflow.

The maximum byte sizes of the parameter column in package/pipeline DB.

ClientParameters contains parameters needed when creating a client.

FakeUUIDGenerator is a fake implementation of the UUIDGeneratorInterface used for testing.

Data struct to represent Node status.

ParameterFormatter is an object that substitutes specific strings in workflow parameters by information about the workflow execution (time at which the workflow was started, time at which the workflow was scheduled, etc.).

PipelineRun is a type to help manipulate PipelineRun objects.

implementation of ExecutionClientInterface.

ScheduledWorkflow is a type to help manipulate ScheduledWorkflow objects.

Represent the value of a Parameter containing Name, Default and Value.

UUIDGenerator is the concrete implementation of the UUIDGeneratorInterface used to generate UUIDs in production deployments.

Workflow is a type to help manipulate Workflow objects.

implementation of ExecutionClientInterface.

ExecutionClient is used to get a ExecutionInterface in specific namespace scope.

Mini version of ExecutionSpec informer only contains functions that are needed in current code base ExecutionInformerEventHandler only has AddEventHandler function ExecutionInformer has all functions we need in current code base.

ExecutionInterface has methods to work with Execution resources.

Abastract interface to encapsulate the resource needed by the underlying execution runtime i.e Workflow is for Argo, PipelineRun is for Tekton and etc.

Abstract interface to encapsulate the resources of the execution runtime specifically for status information.

Represent the Parameter which is a list of SpecParameters.