validation

package
v1.9.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 5, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

Miscellaneous functions to validate that required proto and spec fields are non empty when required for execution.

Index

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 CheckValidExecutionID(executionID, fieldName string) error

func ValidateActiveLaunchPlanListRequest 

func ValidateActiveLaunchPlanListRequest(request admin.ActiveLaunchPlanListRequest) error

func ValidateActiveLaunchPlanRequest 

func ValidateActiveLaunchPlanRequest(request admin.ActiveLaunchPlanRequest) error

func ValidateCluster 

func ValidateCluster(ctx context.Context, clusterInDB, clusterInEvent string) error

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 

func ValidateClusterForExecutionID(ctx context.Context, db repoInterfaces.Repository, 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 

func ValidateDatetime(literal *core.Literal) error

func ValidateDescriptionEntityGetRequest 

func ValidateDescriptionEntityGetRequest(request admin.ObjectGetRequest) error

func ValidateDescriptionEntityListRequest 

func ValidateDescriptionEntityListRequest(request admin.DescriptionEntityListRequest) error

func ValidateEmptyStringField 

func ValidateEmptyStringField(field, fieldName string) error

func ValidateExecutionRequest 

func ValidateExecutionRequest(ctx context.Context, request admin.ExecutionCreateRequest,
	db repositoryInterfaces.Repository, 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 

func ValidateIdentifierFieldsSet(id *core.Identifier) error

func ValidateLaunchPlan 

func ValidateLaunchPlan(ctx context.Context,
	request admin.LaunchPlanCreateRequest, db repositoryInterfaces.Repository,
	config runtimeInterfaces.ApplicationConfiguration, workflowInterface *core.TypedInterface) error

func ValidateLimit 

func ValidateLimit(limit uint32) error

func ValidateListAllMatchableAttributesRequest 

func ValidateListAllMatchableAttributesRequest(request admin.ListMatchableAttributesRequest) error

func ValidateMaxLengthStringField 

func ValidateMaxLengthStringField(field string, fieldName string, limit int) error

ValidateMaxLengthStringField Validates that a string field does not exceed a certain character count

func ValidateMaxMapLengthField 

func ValidateMaxMapLengthField(m map[string]string, fieldName string, limit int) error

ValidateMaxMapLengthField Validates that a map field does not exceed a certain amount of entries

func ValidateNamedEntityGetRequest 

func ValidateNamedEntityGetRequest(request admin.NamedEntityGetRequest) error

func ValidateNamedEntityIdentifier 

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 

func ValidateNamedEntityListRequest(request admin.NamedEntityListRequest) error

func ValidateNamedEntityUpdateRequest 

func ValidateNamedEntityUpdateRequest(request admin.NamedEntityUpdateRequest) error

func ValidateNodeExecutionEventRequest 

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 

func ValidateOutputData(outputData *core.LiteralMap, maxSizeInBytes int64) error

func ValidateProject 

func ValidateProject(project admin.Project) error

func ValidateProjectAndDomain 

func ValidateProjectAndDomain(
	ctx context.Context, db repositoryInterfaces.Repository, config runtimeInterfaces.ApplicationConfiguration, projectID, domainID string) error

Validates that a specified project and domain combination has been registered and exists in the db.

func ValidateProjectAttributesUpdateRequest 

func ValidateProjectAttributesUpdateRequest(ctx context.Context,
	db repositoryInterfaces.Repository,
	request admin.ProjectAttributesUpdateRequest) (
	admin.MatchableResource, error)

func ValidateProjectDomainAttributesDeleteRequest 

func ValidateProjectDomainAttributesDeleteRequest(ctx context.Context, db repositoryInterfaces.Repository,
	config runtimeInterfaces.ApplicationConfiguration, request admin.ProjectDomainAttributesDeleteRequest) error

func ValidateProjectDomainAttributesGetRequest 

func ValidateProjectDomainAttributesGetRequest(ctx context.Context, db repositoryInterfaces.Repository,
	config runtimeInterfaces.ApplicationConfiguration, request admin.ProjectDomainAttributesGetRequest) error

func ValidateProjectDomainAttributesUpdateRequest 

func ValidateProjectDomainAttributesUpdateRequest(ctx context.Context,
	db repositoryInterfaces.Repository, config runtimeInterfaces.ApplicationConfiguration,
	request admin.ProjectDomainAttributesUpdateRequest) (
	admin.MatchableResource, error)

func ValidateProjectExists 

func ValidateProjectExists(
	ctx context.Context, db repositoryInterfaces.Repository, projectID string) error

ValidateProjectExists doesn't check that the project is active. This is used to get Project level attributes, which you should be able to do even for inactive projects.

func ValidateProjectForUpdate 

func ValidateProjectForUpdate(
	ctx context.Context, db repositoryInterfaces.Repository, projectID string) error

func ValidateProjectRegisterRequest 

func ValidateProjectRegisterRequest(request admin.ProjectRegisterRequest) error

func ValidateResourceListRequest 

func ValidateResourceListRequest(request admin.ResourceListRequest) error

func ValidateResourceType 

func ValidateResourceType(resourceType core.ResourceType) error

func ValidateSignalGetOrCreateRequest 

func ValidateSignalGetOrCreateRequest(ctx context.Context, request admin.SignalGetOrCreateRequest) error

func ValidateSignalIdentifier 

func ValidateSignalIdentifier(identifier core.SignalIdentifier) error

func ValidateSignalListRequest 

func ValidateSignalListRequest(ctx context.Context, request admin.SignalListRequest) error

func ValidateSignalSetRequest 

func ValidateSignalSetRequest(ctx context.Context, db repositoryInterfaces.Repository, request admin.SignalSetRequest) error

func ValidateTask 

func ValidateTask(
	ctx context.Context, request admin.TaskCreateRequest, db repositoryInterfaces.Repository,
	platformTaskResources workflowengineInterfaces.TaskResources, 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 

func ValidateToken(token string) (int, error)

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 ValidateVersion(version string) error

func ValidateWorkflow 

func ValidateWorkflow(
	ctx context.Context, request admin.WorkflowCreateRequest, db repositoryInterfaces.Repository,
	config runtime.ApplicationConfiguration) error

func ValidateWorkflowAttributesDeleteRequest 

func ValidateWorkflowAttributesDeleteRequest(ctx context.Context, db repositoryInterfaces.Repository,
	config runtimeInterfaces.ApplicationConfiguration, request admin.WorkflowAttributesDeleteRequest) error

func ValidateWorkflowAttributesGetRequest 

func ValidateWorkflowAttributesGetRequest(ctx context.Context, db repositoryInterfaces.Repository,
	config runtimeInterfaces.ApplicationConfiguration, request admin.WorkflowAttributesGetRequest) error

func ValidateWorkflowAttributesUpdateRequest 

func ValidateWorkflowAttributesUpdateRequest(ctx context.Context, db repositoryInterfaces.Repository,
	config runtimeInterfaces.ApplicationConfiguration, request admin.WorkflowAttributesUpdateRequest) (
	admin.MatchableResource, error)

func ValidateWorkflowExecutionIdentifier 

func ValidateWorkflowExecutionIdentifier(identifier *core.WorkflowExecutionIdentifier) error

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.