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 ValidateCompiledWorkflow(identifier core.Identifier, workflow admin.WorkflowClosure, ...) error
- func ValidateCreateWorkflowEventRequest(request admin.WorkflowExecutionEventRequest) 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 ValidateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest, ...) error
- func ValidateLimit(limit uint32) error
- func ValidateMaxLengthStringField(field 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 ValidateNodeExecutionForTaskListRequest(request admin.NodeExecutionForTaskListRequest) error
- func ValidateNodeExecutionIdentifier(identifier *core.NodeExecutionIdentifier) error
- func ValidateNodeExecutionListRequest(request admin.NodeExecutionListRequest) error
- func ValidateProjectAndDomain(ctx context.Context, db repositories.RepositoryInterface, ...) error
- func ValidateProjectDomainAttributesDeleteRequest(request admin.ProjectDomainAttributesDeleteRequest) error
- func ValidateProjectDomainAttributesGetRequest(request admin.ProjectDomainAttributesGetRequest) error
- func ValidateProjectDomainAttributesUpdateRequest(request admin.ProjectDomainAttributesUpdateRequest) (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) error
- func ValidateToken(token string) (int, error)
- func ValidateVersion(version string) error
- func ValidateWorkflow(ctx context.Context, request admin.WorkflowCreateRequest, ...) error
- func ValidateWorkflowAttributesDeleteRequest(request admin.WorkflowAttributesDeleteRequest) error
- func ValidateWorkflowAttributesGetRequest(request admin.WorkflowAttributesGetRequest) error
- func ValidateWorkflowAttributesUpdateRequest(request admin.WorkflowAttributesUpdateRequest) (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 ValidateCompiledWorkflow ¶
func ValidateCompiledWorkflow(identifier core.Identifier, workflow admin.WorkflowClosure, config runtime.RegistrationValidationConfiguration) error
func ValidateCreateWorkflowEventRequest ¶
func ValidateCreateWorkflowEventRequest(request admin.WorkflowExecutionEventRequest) error
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
Validates that all required fields for an identifier are present.
func ValidateLaunchPlan ¶
func ValidateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest, db repositories.RepositoryInterface, config runtimeInterfaces.ApplicationConfiguration, workflowInterface *core.TypedInterface) error
func ValidateLimit ¶
func ValidateMaxLengthStringField ¶ added in v0.1.1
Validates that a string field does not exceed a certain character count
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
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 ValidateNodeExecutionForTaskListRequest ¶
func ValidateNodeExecutionForTaskListRequest(request admin.NodeExecutionForTaskListRequest) error
func ValidateNodeExecutionIdentifier ¶
func ValidateNodeExecutionIdentifier(identifier *core.NodeExecutionIdentifier) error
func ValidateNodeExecutionListRequest ¶
func ValidateNodeExecutionListRequest(request admin.NodeExecutionListRequest) error
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.2.0
func ValidateProjectDomainAttributesDeleteRequest(request admin.ProjectDomainAttributesDeleteRequest) error
func ValidateProjectDomainAttributesGetRequest ¶ added in v0.2.0
func ValidateProjectDomainAttributesGetRequest(request admin.ProjectDomainAttributesGetRequest) error
func ValidateProjectDomainAttributesUpdateRequest ¶ added in v0.1.4
func ValidateProjectDomainAttributesUpdateRequest(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) error
func 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.2.0
func ValidateWorkflowAttributesDeleteRequest(request admin.WorkflowAttributesDeleteRequest) error
func ValidateWorkflowAttributesGetRequest ¶ added in v0.2.0
func ValidateWorkflowAttributesGetRequest(request admin.WorkflowAttributesGetRequest) error
func ValidateWorkflowAttributesUpdateRequest ¶ added in v0.2.0
func ValidateWorkflowAttributesUpdateRequest(request admin.WorkflowAttributesUpdateRequest) ( admin.MatchableResource, error)
func ValidateWorkflowExecutionIdentifier ¶
func ValidateWorkflowExecutionIdentifier(identifier *core.WorkflowExecutionIdentifier) error
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.