validation

package
v0.0.0-...-267b159 Latest Latest
Warning

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

Go to latest
Published: Dec 17, 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 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 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 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 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 ValidateWorkflowExecutionIdentifier

func ValidateWorkflowExecutionIdentifier(identifier *core.WorkflowExecutionIdentifier) error

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL