Documentation ¶
Overview ¶
Util around parsing request filters
Shared method implementations.
Index ¶
- func AddRequestFilters(requestFilters string, primaryEntity common.Entity, ...) ([]common.InlineFilter, error)
- func CreateOrGetLaunchPlan(ctx context.Context, db repositoryInterfaces.Repository, ...) (*admin.LaunchPlan, error)
- func CreateOrGetWorkflowModel(ctx context.Context, request admin.ExecutionCreateRequest, ...) (*models.Workflow, error)
- func FetchAndGetWorkflowClosure(ctx context.Context, store *storage.DataStore, remoteLocationIdentifier string) (*admin.WorkflowClosure, error)
- func GetActiveLaunchPlanVersionFilters(project, domain, name string) ([]common.InlineFilter, error)
- func GetDbFilters(spec FilterSpec, primaryEntity common.Entity) ([]common.InlineFilter, error)
- func GetExecutionModel(ctx context.Context, repo repoInterfaces.Repository, ...) (*models.Execution, error)
- func GetExecutionName(request admin.ExecutionCreateRequest) string
- func GetInputs(ctx context.Context, urlData dataInterfaces.RemoteURLInterface, ...) (*core.LiteralMap, *admin.UrlBlob, error)
- func GetLaunchPlan(ctx context.Context, repo repoInterfaces.Repository, ...) (*admin.LaunchPlan, error)
- func GetLaunchPlanDigest(ctx context.Context, launchPlan *admin.LaunchPlan) ([]byte, error)
- func GetLaunchPlanModel(ctx context.Context, repo repoInterfaces.Repository, ...) (models.LaunchPlan, error)
- func GetNamedEntity(ctx context.Context, repo repoInterfaces.Repository, ...) (*admin.NamedEntity, error)
- func GetNamedEntityModel(ctx context.Context, repo repoInterfaces.Repository, ...) (models.NamedEntity, error)
- func GetNodeExecutionIdentifierFilters(ctx context.Context, nodeExecutionIdentifier core.NodeExecutionIdentifier) ([]common.InlineFilter, error)
- func GetNodeExecutionModel(ctx context.Context, repo repoInterfaces.Repository, ...) (*models.NodeExecution, error)
- func GetOutputs(ctx context.Context, urlData dataInterfaces.RemoteURLInterface, ...) (*core.LiteralMap, *admin.UrlBlob, error)
- func GetSingleValueEqualityFilter(entity common.Entity, field, value string) (common.InlineFilter, error)
- func GetTask(ctx context.Context, repo repoInterfaces.Repository, ...) (*admin.Task, error)
- func GetTaskDigest(ctx context.Context, task *core.CompiledTask) ([]byte, error)
- func GetTaskExecutionModel(ctx context.Context, repo repoInterfaces.Repository, ...) (*models.TaskExecution, error)
- func GetTaskModel(ctx context.Context, repo repoInterfaces.Repository, ...) (*models.Task, error)
- func GetWorkflow(ctx context.Context, repo repoInterfaces.Repository, store *storage.DataStore, ...) (*admin.Workflow, error)
- func GetWorkflowDigest(ctx context.Context, workflowClosure *core.CompiledWorkflowClosure) ([]byte, error)
- func GetWorkflowExecutionIdentifierFilters(ctx context.Context, ...) ([]common.InlineFilter, error)
- func GetWorkflowModel(ctx context.Context, repo repoInterfaces.Repository, ...) (models.Workflow, error)
- func ListActiveLaunchPlanVersionsFilters(project, domain string) ([]common.InlineFilter, error)
- func ParseFilters(filterParams string, primaryEntity common.Entity) ([]common.InlineFilter, error)
- type ExecutionClosure
- type FilterSpec
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddRequestFilters ¶
func AddRequestFilters(requestFilters string, primaryEntity common.Entity, existingFilters []common.InlineFilter) ( []common.InlineFilter, error)
func CreateOrGetLaunchPlan ¶ added in v0.3.38
func CreateOrGetLaunchPlan(ctx context.Context, db repositoryInterfaces.Repository, config runtimeInterfaces.Configuration, taskIdentifier *core.Identifier, workflowInterface *core.TypedInterface, workflowID uint, spec *admin.ExecutionSpec) (*admin.LaunchPlan, error)
func CreateOrGetWorkflowModel ¶ added in v0.3.38
func CreateOrGetWorkflowModel( ctx context.Context, request admin.ExecutionCreateRequest, db repositoryInterfaces.Repository, workflowManager interfaces.WorkflowInterface, namedEntityManager interfaces.NamedEntityInterface, taskIdentifier *core.Identifier, task *admin.Task) (*models.Workflow, error)
func GetActiveLaunchPlanVersionFilters ¶
func GetActiveLaunchPlanVersionFilters(project, domain, name string) ([]common.InlineFilter, error)
Returns the set of filters necessary to query launch plan models to find the active version of a launch plan
func GetDbFilters ¶
func GetDbFilters(spec FilterSpec, primaryEntity common.Entity) ([]common.InlineFilter, error)
Consolidates request params and filters to a single list of filters. This consolidation is necessary since the db is agnostic to required request parameters and additional filter arguments.
func GetExecutionModel ¶
func GetExecutionModel( ctx context.Context, repo repoInterfaces.Repository, identifier core.WorkflowExecutionIdentifier) ( *models.Execution, error)
func GetExecutionName ¶
func GetExecutionName(request admin.ExecutionCreateRequest) string
func GetInputs ¶ added in v0.6.43
func GetInputs(ctx context.Context, urlData dataInterfaces.RemoteURLInterface, remoteDataConfig *runtimeInterfaces.RemoteDataConfig, storageClient *storage.DataStore, inputURI string) ( *core.LiteralMap, *admin.UrlBlob, error)
GetInputs returns an inputs URL blob and if config settings permit, inline inputs data for an execution.
func GetLaunchPlan ¶
func GetLaunchPlan( ctx context.Context, repo repoInterfaces.Repository, identifier core.Identifier) (*admin.LaunchPlan, error)
func GetLaunchPlanDigest ¶
Returns a unique digest for functionally equivalent launch plans
func GetLaunchPlanModel ¶
func GetLaunchPlanModel( ctx context.Context, repo repoInterfaces.Repository, identifier core.Identifier) (models.LaunchPlan, error)
func GetNamedEntity ¶ added in v0.1.5
func GetNamedEntity( ctx context.Context, repo repoInterfaces.Repository, resourceType core.ResourceType, identifier admin.NamedEntityIdentifier) (*admin.NamedEntity, error)
func GetNamedEntityModel ¶ added in v0.1.5
func GetNamedEntityModel( ctx context.Context, repo repoInterfaces.Repository, resourceType core.ResourceType, identifier admin.NamedEntityIdentifier) (models.NamedEntity, error)
func GetNodeExecutionIdentifierFilters ¶
func GetNodeExecutionIdentifierFilters( ctx context.Context, nodeExecutionIdentifier core.NodeExecutionIdentifier) ([]common.InlineFilter, error)
All inputs to this function must be validated.
func GetNodeExecutionModel ¶
func GetNodeExecutionModel(ctx context.Context, repo repoInterfaces.Repository, nodeExecutionIdentifier *core.NodeExecutionIdentifier) ( *models.NodeExecution, error)
func GetOutputs ¶ added in v0.6.43
func GetOutputs(ctx context.Context, urlData dataInterfaces.RemoteURLInterface, remoteDataConfig *runtimeInterfaces.RemoteDataConfig, storageClient *storage.DataStore, closure ExecutionClosure) ( *core.LiteralMap, *admin.UrlBlob, error)
GetOutputs returns an outputs URL blob and if config settings permit, inline outputs data for an execution.
func GetTask ¶
func GetTask(ctx context.Context, repo repoInterfaces.Repository, identifier core.Identifier) ( *admin.Task, error)
func GetTaskDigest ¶
Returns a unique digest for functionally equivalent compiled tasks
func GetTaskExecutionModel ¶
func GetTaskExecutionModel( ctx context.Context, repo repoInterfaces.Repository, taskExecutionID *core.TaskExecutionIdentifier) (*models.TaskExecution, error)
func GetTaskModel ¶
func GetTaskModel(ctx context.Context, repo repoInterfaces.Repository, taskIdentifier *core.Identifier) ( *models.Task, error)
func GetWorkflow ¶
func GetWorkflow( ctx context.Context, repo repoInterfaces.Repository, store *storage.DataStore, identifier core.Identifier) (*admin.Workflow, error)
func GetWorkflowDigest ¶
func GetWorkflowDigest(ctx context.Context, workflowClosure *core.CompiledWorkflowClosure) ([]byte, error)
Returns a unique digest for functionally equivalent compiled workflows
func GetWorkflowExecutionIdentifierFilters ¶
func GetWorkflowExecutionIdentifierFilters( ctx context.Context, workflowExecutionIdentifier core.WorkflowExecutionIdentifier) ([]common.InlineFilter, error)
func GetWorkflowModel ¶
func GetWorkflowModel( ctx context.Context, repo repoInterfaces.Repository, identifier core.Identifier) (models.Workflow, error)
func ListActiveLaunchPlanVersionsFilters ¶
func ListActiveLaunchPlanVersionsFilters(project, domain string) ([]common.InlineFilter, error)
Returns the set of filters necessary to query launch plan models to find the active version of a launch plan
func ParseFilters ¶
Types ¶
type ExecutionClosure ¶ added in v0.6.43
type ExecutionClosure interface { GetOutputUri() string //nolint GetOutputData() *core.LiteralMap }
ExecutionClosure defines common methods in NodeExecutionClosure and TaskExecutionClosure used to return output data.
func ToExecutionClosureInterface ¶ added in v0.6.43
func ToExecutionClosureInterface(closure *admin.ExecutionClosure) ExecutionClosure
ToExecutionClosureInterface converts a workflow execution closure to an implementation of the ExecutionClosure interface for use in producing execution output data.