Documentation
¶
Overview ¶
Handles translating gRPC request & response objects to and from repository model objects
Index ¶
- func CreateExecutionEventModel(request admin.WorkflowExecutionEventRequest) (*models.ExecutionEvent, error)
- func CreateExecutionModel(input CreateExecutionModelInput) (*models.Execution, error)
- func CreateLaunchPlan(request admin.LaunchPlanCreateRequest, expectedOutputs *core.VariableMap) admin.LaunchPlan
- func CreateLaunchPlanModel(launchPlan admin.LaunchPlan, workflowRepoID uint, digest []byte, ...) (models.LaunchPlan, error)
- func CreateNamedEntityModel(request *admin.NamedEntityUpdateRequest) models.NamedEntity
- func CreateNodeExecutionEventModel(request admin.NodeExecutionEventRequest) (*models.NodeExecutionEvent, error)
- func CreateNodeExecutionModel(input ToNodeExecutionModelInput) (*models.NodeExecution, error)
- func CreateProjectModel(project *admin.Project) models.Project
- func CreateTaskExecutionModel(input CreateTaskExecutionModelInput) (*models.TaskExecution, error)
- func CreateTaskModel(request admin.TaskCreateRequest, taskClosure admin.TaskClosure, digest []byte) (models.Task, error)
- func CreateWorkflowModel(request admin.WorkflowCreateRequest, remoteClosureIdentifier string, ...) (models.Workflow, error)
- func FromExecutionModel(executionModel models.Execution) (*admin.Execution, error)
- func FromExecutionModels(executionModels []models.Execution) ([]*admin.Execution, error)
- func FromLaunchPlanModel(model models.LaunchPlan) (*admin.LaunchPlan, error)
- func FromLaunchPlanModels(launchPlanModels []models.LaunchPlan) ([]*admin.LaunchPlan, error)
- func FromLaunchPlanModelsToIdentifiers(launchPlanModels []models.LaunchPlan) []*admin.NamedEntityIdentifier
- func FromNamedEntityMetadataFields(metadata models.NamedEntityMetadataFields) admin.NamedEntityMetadata
- func FromNamedEntityModel(model models.NamedEntity) admin.NamedEntity
- func FromNamedEntityModels(models []models.NamedEntity) []*admin.NamedEntity
- func FromNodeExecutionModel(nodeExecutionModel models.NodeExecution) (*admin.NodeExecution, error)
- func FromNodeExecutionModels(nodeExecutionModels []models.NodeExecution) ([]*admin.NodeExecution, error)
- func FromProjectModel(projectModel models.Project, domains []*admin.Domain) admin.Project
- func FromProjectModels(projectModels []models.Project, domains []*admin.Domain) []*admin.Project
- func FromResourceModelToMatchableAttributes(model models.Resource) (admin.MatchableAttributesConfiguration, error)
- func FromResourceModelToProjectDomainAttributes(model models.Resource) (admin.ProjectDomainAttributes, error)
- func FromResourceModelToWorkflowAttributes(model models.Resource) (admin.WorkflowAttributes, error)
- func FromResourceModelsToMatchableAttributes(models []models.Resource) ([]*admin.MatchableAttributesConfiguration, error)
- func FromTaskExecutionModel(taskExecutionModel models.TaskExecution) (*admin.TaskExecution, error)
- func FromTaskExecutionModels(taskExecutionModels []models.TaskExecution) ([]*admin.TaskExecution, error)
- func FromTaskModel(taskModel models.Task) (admin.Task, error)
- func FromTaskModels(taskModels []models.Task) ([]*admin.Task, error)
- func FromTaskModelsToIdentifiers(taskModels []models.Task) []*admin.NamedEntityIdentifier
- func FromWorkflowModel(workflowModel models.Workflow) (admin.Workflow, error)
- func FromWorkflowModels(workflowModels []models.Workflow) ([]*admin.Workflow, error)
- func FromWorkflowModelsToIdentifiers(workflowModels []models.Workflow) []*admin.NamedEntityIdentifier
- func GetExecutionIdentifier(executionModel *models.Execution) core.WorkflowExecutionIdentifier
- func MergeUpdateProjectDomainAttributes(ctx context.Context, model models.Resource, resource admin.MatchableResource, ...) (models.Resource, error)
- func MergeUpdateWorkflowAttributes(ctx context.Context, model models.Resource, resource admin.MatchableResource, ...) (models.Resource, error)
- func ProjectDomainAttributesToResourceModel(attributes admin.ProjectDomainAttributes, resource admin.MatchableResource) (models.Resource, error)
- func SetExecutionAborted(execution *models.Execution, cause, principal string) error
- func UpdateExecutionModelState(execution *models.Execution, request admin.WorkflowExecutionEventRequest) error
- func UpdateNodeExecutionModel(request *admin.NodeExecutionEventRequest, ...) error
- func UpdateTaskExecutionModel(request *admin.TaskExecutionEventRequest, ...) error
- func WorkflowAttributesToResourceModel(attributes admin.WorkflowAttributes, resource admin.MatchableResource) (models.Resource, error)
- type CreateExecutionModelInput
- type CreateProjectModelInput
- type CreateTaskExecutionModelInput
- type ToNodeExecutionModelInput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateExecutionEventModel ¶
func CreateExecutionEventModel(request admin.WorkflowExecutionEventRequest) (*models.ExecutionEvent, error)
Transforms a ExecutionEventCreateRequest to a ExecutionEvent model
func CreateExecutionModel ¶
func CreateExecutionModel(input CreateExecutionModelInput) (*models.Execution, error)
Transforms a ExecutionCreateRequest to a Execution model
func CreateLaunchPlan ¶
func CreateLaunchPlan( request admin.LaunchPlanCreateRequest, expectedOutputs *core.VariableMap) admin.LaunchPlan
func CreateLaunchPlanModel ¶
func CreateLaunchPlanModel( launchPlan admin.LaunchPlan, workflowRepoID uint, digest []byte, initState admin.LaunchPlanState) (models.LaunchPlan, error)
Transforms a admin.LaunchPlan object to a LaunchPlan model
func CreateNamedEntityModel ¶ added in v0.1.5
func CreateNamedEntityModel(request *admin.NamedEntityUpdateRequest) models.NamedEntity
func CreateNodeExecutionEventModel ¶
func CreateNodeExecutionEventModel(request admin.NodeExecutionEventRequest) (*models.NodeExecutionEvent, error)
Transforms a NodeExecutionEventRequest to a NodeExecutionEvent model
func CreateNodeExecutionModel ¶
func CreateNodeExecutionModel(input ToNodeExecutionModelInput) (*models.NodeExecution, error)
func CreateTaskExecutionModel ¶
func CreateTaskExecutionModel(input CreateTaskExecutionModelInput) (*models.TaskExecution, error)
func CreateTaskModel ¶
func CreateTaskModel( request admin.TaskCreateRequest, taskClosure admin.TaskClosure, digest []byte) (models.Task, error)
Transforms a TaskCreateRequest to a task model
func CreateWorkflowModel ¶
func CreateWorkflowModel(request admin.WorkflowCreateRequest, remoteClosureIdentifier string, digest []byte) (models.Workflow, error)
Transforms a WorkflowCreateRequest to a workflow model
func FromExecutionModel ¶
func FromExecutionModels ¶
func FromLaunchPlanModel ¶
func FromLaunchPlanModel(model models.LaunchPlan) (*admin.LaunchPlan, error)
Transforms a LaunchPlanModel to a LaunchPlan
func FromLaunchPlanModels ¶
func FromLaunchPlanModels(launchPlanModels []models.LaunchPlan) ([]*admin.LaunchPlan, error)
func FromLaunchPlanModelsToIdentifiers ¶
func FromLaunchPlanModelsToIdentifiers(launchPlanModels []models.LaunchPlan) []*admin.NamedEntityIdentifier
func FromNamedEntityMetadataFields ¶ added in v0.1.5
func FromNamedEntityMetadataFields(metadata models.NamedEntityMetadataFields) admin.NamedEntityMetadata
func FromNamedEntityModel ¶ added in v0.1.5
func FromNamedEntityModel(model models.NamedEntity) admin.NamedEntity
func FromNamedEntityModels ¶ added in v0.1.5
func FromNamedEntityModels(models []models.NamedEntity) []*admin.NamedEntity
func FromNodeExecutionModel ¶
func FromNodeExecutionModel(nodeExecutionModel models.NodeExecution) (*admin.NodeExecution, error)
func FromNodeExecutionModels ¶
func FromNodeExecutionModels( nodeExecutionModels []models.NodeExecution) ([]*admin.NodeExecution, error)
func FromProjectModel ¶
func FromProjectModels ¶
func FromResourceModelToMatchableAttributes ¶ added in v0.3.38
func FromResourceModelToMatchableAttributes(model models.Resource) (admin.MatchableAttributesConfiguration, error)
func FromResourceModelToProjectDomainAttributes ¶ added in v0.3.38
func FromResourceModelToProjectDomainAttributes(model models.Resource) (admin.ProjectDomainAttributes, error)
func FromResourceModelToWorkflowAttributes ¶ added in v0.3.38
func FromResourceModelToWorkflowAttributes(model models.Resource) (admin.WorkflowAttributes, error)
func FromResourceModelsToMatchableAttributes ¶ added in v0.3.38
func FromResourceModelsToMatchableAttributes(models []models.Resource) ( []*admin.MatchableAttributesConfiguration, error)
func FromTaskExecutionModel ¶
func FromTaskExecutionModel(taskExecutionModel models.TaskExecution) (*admin.TaskExecution, error)
func FromTaskExecutionModels ¶
func FromTaskExecutionModels(taskExecutionModels []models.TaskExecution) ([]*admin.TaskExecution, error)
func FromTaskModelsToIdentifiers ¶
func FromTaskModelsToIdentifiers(taskModels []models.Task) []*admin.NamedEntityIdentifier
func FromWorkflowModel ¶
func FromWorkflowModels ¶
func FromWorkflowModelsToIdentifiers ¶
func FromWorkflowModelsToIdentifiers(workflowModels []models.Workflow) []*admin.NamedEntityIdentifier
func GetExecutionIdentifier ¶
func GetExecutionIdentifier(executionModel *models.Execution) core.WorkflowExecutionIdentifier
func MergeUpdateProjectDomainAttributes ¶ added in v0.3.38
func MergeUpdateProjectDomainAttributes(ctx context.Context, model models.Resource, resource admin.MatchableResource, resourceID *repoInterfaces.ResourceID, attributes *admin.ProjectDomainAttributes) (models.Resource, error)
func MergeUpdateWorkflowAttributes ¶ added in v0.3.38
func MergeUpdateWorkflowAttributes(ctx context.Context, model models.Resource, resource admin.MatchableResource, resourceID *repoInterfaces.ResourceID, workflowAttributes *admin.WorkflowAttributes) (models.Resource, error)
func ProjectDomainAttributesToResourceModel ¶ added in v0.3.38
func ProjectDomainAttributesToResourceModel(attributes admin.ProjectDomainAttributes, resource admin.MatchableResource) (models.Resource, error)
func SetExecutionAborted ¶ added in v0.1.7
The execution abort metadata is recorded but the phase is not actually updated *until* the abort event is propagated by flytepropeller. The metadata is preemptively saved at the time of the abort.
func UpdateExecutionModelState ¶
func UpdateExecutionModelState( execution *models.Execution, request admin.WorkflowExecutionEventRequest) error
Updates an existing model given a WorkflowExecution event.
func UpdateNodeExecutionModel ¶
func UpdateNodeExecutionModel( request *admin.NodeExecutionEventRequest, nodeExecutionModel *models.NodeExecution, targetExecution *core.WorkflowExecutionIdentifier) error
func UpdateTaskExecutionModel ¶
func UpdateTaskExecutionModel(request *admin.TaskExecutionEventRequest, taskExecutionModel *models.TaskExecution) error
func WorkflowAttributesToResourceModel ¶ added in v0.3.38
func WorkflowAttributesToResourceModel(attributes admin.WorkflowAttributes, resource admin.MatchableResource) (models.Resource, error)
Types ¶
type CreateExecutionModelInput ¶
type CreateExecutionModelInput struct { WorkflowExecutionID core.WorkflowExecutionIdentifier RequestSpec *admin.ExecutionSpec LaunchPlanID uint WorkflowID uint TaskID uint Phase core.WorkflowExecution_Phase CreatedAt time.Time Notifications []*admin.Notification WorkflowIdentifier *core.Identifier ParentNodeExecutionID uint SourceExecutionID uint Cluster string InputsURI storage.DataReference UserInputsURI storage.DataReference }
Request parameters for calls to CreateExecutionModel.
type CreateProjectModelInput ¶
type CreateTaskExecutionModelInput ¶
type CreateTaskExecutionModelInput struct {
Request *admin.TaskExecutionEventRequest
}
type ToNodeExecutionModelInput ¶
type ToNodeExecutionModelInput struct { Request *admin.NodeExecutionEventRequest ParentTaskExecutionID uint ParentID *uint }