Documentation
¶
Overview ¶
Miscellaneous functions to validate that required proto and spec fields are non empty when required for execution.
Index ¶
- func CheckAndFetchInputsForExecution(userInputs *core.LiteralMap, fixedInputs *core.LiteralMap, ...) (*core.LiteralMap, error)
- func CheckValidExecutionID(executionID, fieldName string) error
- func ValidateActiveLaunchPlanListRequest(request admin.ActiveLaunchPlanListRequest) error
- func ValidateActiveLaunchPlanRequest(request admin.ActiveLaunchPlanRequest) error
- func ValidateCluster(ctx context.Context, clusterInDB, clusterInEvent string) error
- func ValidateClusterForExecutionID(ctx context.Context, db repositories.RepositoryInterface, ...) error
- func ValidateCompiledWorkflow(identifier core.Identifier, workflow admin.WorkflowClosure, ...) error
- func ValidateCreateWorkflowEventRequest(request admin.WorkflowExecutionEventRequest, maxOutputSizeInBytes int64) error
- func ValidateDatetime(literal *core.Literal) error
- func ValidateEmptyStringField(field, fieldName string) error
- func ValidateExecutionRequest(ctx context.Context, request admin.ExecutionCreateRequest, ...) error
- func ValidateIdentifier(id *core.Identifier, expectedType common.Entity) error
- func ValidateIdentifierFieldsSet(id *core.Identifier) error
- func ValidateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest, ...) error
- func ValidateLimit(limit uint32) error
- func ValidateListAllMatchableAttributesRequest(request admin.ListMatchableAttributesRequest) error
- func ValidateMaxLengthStringField(field string, fieldName string, limit int) error
- func ValidateMaxMapLengthField(m map[string]string, fieldName string, limit int) error
- func ValidateNamedEntityGetRequest(request admin.NamedEntityGetRequest) error
- func ValidateNamedEntityIdentifier(id *admin.NamedEntityIdentifier) error
- func ValidateNamedEntityIdentifierListRequest(request admin.NamedEntityIdentifierListRequest) error
- func ValidateNamedEntityListRequest(request admin.NamedEntityListRequest) error
- func ValidateNamedEntityUpdateRequest(request admin.NamedEntityUpdateRequest) error
- func ValidateNodeExecutionEventRequest(request *admin.NodeExecutionEventRequest, maxOutputSizeInBytes int64) error
- func ValidateNodeExecutionForTaskListRequest(request admin.NodeExecutionForTaskListRequest) error
- func ValidateNodeExecutionIdentifier(identifier *core.NodeExecutionIdentifier) error
- func ValidateNodeExecutionListRequest(request admin.NodeExecutionListRequest) error
- func ValidateOutputData(outputData *core.LiteralMap, maxSizeInBytes int64) error
- func ValidateProject(project admin.Project) error
- func ValidateProjectAndDomain(ctx context.Context, db repositories.RepositoryInterface, ...) error
- func ValidateProjectDomainAttributesDeleteRequest(ctx context.Context, db repositories.RepositoryInterface, ...) error
- func ValidateProjectDomainAttributesGetRequest(ctx context.Context, db repositories.RepositoryInterface, ...) error
- func ValidateProjectDomainAttributesUpdateRequest(ctx context.Context, db repositories.RepositoryInterface, ...) (admin.MatchableResource, error)
- func ValidateProjectRegisterRequest(request admin.ProjectRegisterRequest) error
- func ValidateResourceListRequest(request admin.ResourceListRequest) error
- func ValidateResourceType(resourceType core.ResourceType) error
- func ValidateTask(ctx context.Context, request admin.TaskCreateRequest, ...) error
- func ValidateTaskExecutionIdentifier(identifier *core.TaskExecutionIdentifier) error
- func ValidateTaskExecutionListRequest(request admin.TaskExecutionListRequest) error
- func ValidateTaskExecutionRequest(request admin.TaskExecutionEventRequest, maxOutputSizeInBytes int64) error
- func ValidateToken(token string) (int, error)
- func ValidateVersion(version string) error
- func ValidateWorkflow(ctx context.Context, request admin.WorkflowCreateRequest, ...) error
- func ValidateWorkflowAttributesDeleteRequest(ctx context.Context, db repositories.RepositoryInterface, ...) error
- func ValidateWorkflowAttributesGetRequest(ctx context.Context, db repositories.RepositoryInterface, ...) error
- func ValidateWorkflowAttributesUpdateRequest(ctx context.Context, db repositories.RepositoryInterface, ...) (admin.MatchableResource, error)
- func ValidateWorkflowExecutionIdentifier(identifier *core.WorkflowExecutionIdentifier) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckAndFetchInputsForExecution ¶
func CheckAndFetchInputsForExecution( userInputs *core.LiteralMap, fixedInputs *core.LiteralMap, expectedInputs *core.ParameterMap) (*core.LiteralMap, error)
func CheckValidExecutionID ¶
func ValidateActiveLaunchPlanListRequest ¶
func ValidateActiveLaunchPlanListRequest(request admin.ActiveLaunchPlanListRequest) error
func ValidateActiveLaunchPlanRequest ¶
func ValidateActiveLaunchPlanRequest(request admin.ActiveLaunchPlanRequest) error
func ValidateCluster ¶ added in v0.6.73
ValidateCluster validates that the execution is recorded as executing on `cluster`. clusterInEvent represents the cluster name, or historically, producerID sent in an execution event. clusterInDB represents the cluster recorded as running the execution in the database.
func ValidateClusterForExecutionID ¶ added in v0.6.73
func ValidateClusterForExecutionID(ctx context.Context, db repositories.RepositoryInterface, executionID *core.WorkflowExecutionIdentifier, clusterInEvent string) error
ValidateClusterForExecutionID validates that the execution denoted by executionId is recorded as executing on `cluster`.
func ValidateCompiledWorkflow ¶
func ValidateCompiledWorkflow(identifier core.Identifier, workflow admin.WorkflowClosure, config runtime.RegistrationValidationConfiguration) error
func ValidateCreateWorkflowEventRequest ¶
func ValidateCreateWorkflowEventRequest(request admin.WorkflowExecutionEventRequest, maxOutputSizeInBytes int64) error
func ValidateDatetime ¶ added in v0.6.76
func ValidateExecutionRequest ¶
func ValidateExecutionRequest(ctx context.Context, request admin.ExecutionCreateRequest, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration) error
func ValidateIdentifier ¶
func ValidateIdentifier(id *core.Identifier, expectedType common.Entity) error
ValidateIdentifier Validates that all required fields for an identifier are present.
func ValidateIdentifierFieldsSet ¶ added in v0.3.38
func ValidateIdentifierFieldsSet(id *core.Identifier) error
func ValidateLaunchPlan ¶
func ValidateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, workflowInterface *core.TypedInterface) error
func ValidateLimit ¶
func ValidateListAllMatchableAttributesRequest ¶ added in v0.3.38
func ValidateListAllMatchableAttributesRequest(request admin.ListMatchableAttributesRequest) error
func ValidateMaxLengthStringField ¶ added in v0.1.1
ValidateMaxLengthStringField Validates that a string field does not exceed a certain character count
func ValidateMaxMapLengthField ¶ added in v0.3.38
ValidateMaxMapLengthField Validates that a map field does not exceed a certain amount of entries
func ValidateNamedEntityGetRequest ¶ added in v0.1.5
func ValidateNamedEntityGetRequest(request admin.NamedEntityGetRequest) error
func ValidateNamedEntityIdentifier ¶ added in v0.1.5
func ValidateNamedEntityIdentifier(id *admin.NamedEntityIdentifier) error
ValidateNamedEntityIdentifier Validates that all required fields for an identifier are present.
func ValidateNamedEntityIdentifierListRequest ¶
func ValidateNamedEntityIdentifierListRequest(request admin.NamedEntityIdentifierListRequest) error
func ValidateNamedEntityListRequest ¶ added in v0.1.5
func ValidateNamedEntityListRequest(request admin.NamedEntityListRequest) error
func ValidateNamedEntityUpdateRequest ¶ added in v0.1.5
func ValidateNamedEntityUpdateRequest(request admin.NamedEntityUpdateRequest) error
func ValidateNodeExecutionEventRequest ¶ added in v0.4.14
func ValidateNodeExecutionEventRequest(request *admin.NodeExecutionEventRequest, maxOutputSizeInBytes int64) error
Validates that NodeExecutionEventRequests handled by admin include a valid node execution identifier. In the case the event specifies a DynamicWorkflow in the TaskNodeMetadata, this method also validates the contents of the dynamic workflow.
func ValidateNodeExecutionForTaskListRequest ¶
func ValidateNodeExecutionForTaskListRequest(request admin.NodeExecutionForTaskListRequest) error
func ValidateNodeExecutionIdentifier ¶
func ValidateNodeExecutionIdentifier(identifier *core.NodeExecutionIdentifier) error
func ValidateNodeExecutionListRequest ¶
func ValidateNodeExecutionListRequest(request admin.NodeExecutionListRequest) error
func ValidateOutputData ¶ added in v0.6.43
func ValidateOutputData(outputData *core.LiteralMap, maxSizeInBytes int64) error
func ValidateProject ¶ added in v0.3.38
func ValidateProjectAndDomain ¶
func ValidateProjectAndDomain( ctx context.Context, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, projectID, domainID string) error
Validates that a specified project and domain combination has been registered and exists in the db.
func ValidateProjectDomainAttributesDeleteRequest ¶ added in v0.3.38
func ValidateProjectDomainAttributesDeleteRequest(ctx context.Context, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, request admin.ProjectDomainAttributesDeleteRequest) error
func ValidateProjectDomainAttributesGetRequest ¶ added in v0.3.38
func ValidateProjectDomainAttributesGetRequest(ctx context.Context, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, request admin.ProjectDomainAttributesGetRequest) error
func ValidateProjectDomainAttributesUpdateRequest ¶ added in v0.1.4
func ValidateProjectDomainAttributesUpdateRequest(ctx context.Context, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, request admin.ProjectDomainAttributesUpdateRequest) ( admin.MatchableResource, error)
func ValidateProjectRegisterRequest ¶
func ValidateProjectRegisterRequest(request admin.ProjectRegisterRequest) error
func ValidateResourceListRequest ¶
func ValidateResourceListRequest(request admin.ResourceListRequest) error
func ValidateResourceType ¶ added in v0.1.5
func ValidateResourceType(resourceType core.ResourceType) error
func ValidateTask ¶
func ValidateTask( ctx context.Context, request admin.TaskCreateRequest, db repositories.RepositoryInterface, taskConfig runtime.TaskResourceConfiguration, whitelistConfig runtime.WhitelistConfiguration, applicationConfig runtime.ApplicationConfiguration) error
func ValidateTaskExecutionIdentifier ¶
func ValidateTaskExecutionIdentifier(identifier *core.TaskExecutionIdentifier) error
func ValidateTaskExecutionListRequest ¶
func ValidateTaskExecutionListRequest(request admin.TaskExecutionListRequest) error
func ValidateTaskExecutionRequest ¶
func ValidateTaskExecutionRequest(request admin.TaskExecutionEventRequest, maxOutputSizeInBytes int64) error
func ValidateToken ¶
ValidateToken Offsets are encoded as string tokens to enable future api pagination changes. In addition to validating that an offset is a valid integer, we assert that it is non-negative.
func ValidateVersion ¶
func ValidateWorkflow ¶
func ValidateWorkflow( ctx context.Context, request admin.WorkflowCreateRequest, db repositories.RepositoryInterface, config runtime.ApplicationConfiguration) error
func ValidateWorkflowAttributesDeleteRequest ¶ added in v0.3.38
func ValidateWorkflowAttributesDeleteRequest(ctx context.Context, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, request admin.WorkflowAttributesDeleteRequest) error
func ValidateWorkflowAttributesGetRequest ¶ added in v0.3.38
func ValidateWorkflowAttributesGetRequest(ctx context.Context, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, request admin.WorkflowAttributesGetRequest) error
func ValidateWorkflowAttributesUpdateRequest ¶ added in v0.3.38
func ValidateWorkflowAttributesUpdateRequest(ctx context.Context, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, request admin.WorkflowAttributesUpdateRequest) ( admin.MatchableResource, error)
func ValidateWorkflowExecutionIdentifier ¶
func ValidateWorkflowExecutionIdentifier(identifier *core.WorkflowExecutionIdentifier) error
Types ¶
This section is empty.