dao

package
v0.4.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateWorkflowExecution added in v0.4.0 

func CreateWorkflowExecution(
	ctx context.Context,
	mc model.ClientSet,
	opts CreateWorkflowExecutionOptions,
) (*model.WorkflowExecution, error)

func CreateWorkflowStageExecution added in v0.4.0 

func CreateWorkflowStageExecution(
	ctx context.Context,
	mc model.ClientSet,
	opts CreateWorkflowStageExecutionOptions,
) (*model.WorkflowStageExecution, error)

func CreateWorkflowStepExecution added in v0.4.0 

func CreateWorkflowStepExecution(
	ctx context.Context,
	mc model.ClientSet,
	opts CreateWorkflowStepExecutionOptions,
) (*model.WorkflowStepExecution, error)

func EnvironmentConnectorsEdgeSave 

func EnvironmentConnectorsEdgeSave(ctx context.Context, mc model.ClientSet, entity *model.Environment) error

EnvironmentConnectorsEdgeSave saves the edge connectors of model.Environment entity.

func EnvironmentVariablesEdgeSave added in v0.4.0 

func EnvironmentVariablesEdgeSave(ctx context.Context, mc model.ClientSet, entity *model.Environment) error

EnvironmentVariablesEdgeSave saves the edge variables of model.Environment entity.

func ExposeResourceDefinition added in v0.4.0 

func ExposeResourceDefinition(_rd *model.ResourceDefinition) *model.ResourceDefinitionOutput

ExposeResourceDefinition converts the ResourceDefinition to ResourceDefinitionOutput.

func ExposeResourceDefinitions added in v0.4.0 

func ExposeResourceDefinitions(_rds []*model.ResourceDefinition) []*model.ResourceDefinitionOutput

ExposeResourceDefinitions converts the ResourceDefinition slice to ResourceDefinitionOutput pointer slice.

func ExposeTemplateVersion added in v0.4.0 

func ExposeTemplateVersion(_tv *model.TemplateVersion) *model.TemplateVersionOutput

ExposeTemplateVersion converts the TemplateVersion to TemplateVersionOutput.

func ExposeTemplateVersions added in v0.4.0 

func ExposeTemplateVersions(_tvs []*model.TemplateVersion) []*model.TemplateVersionOutput

ExposeTemplateVersions converts the TemplateVersion slice to TemplateVersionOutput pointer slice.

func GetEnvironmentByID 

func GetEnvironmentByID(ctx context.Context, mc model.ClientSet, id object.ID) (*model.Environment, error)

GetEnvironmentByID gets an environment including project & connectors edges by ID.

func GetEnvironmentsByIDs 

func GetEnvironmentsByIDs(ctx context.Context, mc model.ClientSet, ids ...object.ID) ([]*model.Environment, error)

GetEnvironmentsByIDs gets environments including project & connectors edges by IDs.

func GetLatestRevisions 

func GetLatestRevisions(
	ctx context.Context,
	modelClient model.ClientSet,
	resourceIDs ...object.ID,
) ([]*model.ResourceRevision, error)

func GetRejectMessage added in v0.4.0 

func GetRejectMessage(ctx context.Context, mc model.ClientSet, entity *model.WorkflowStepExecution) (string, error)

GetRejectMessage returns the reject message of the workflow approval step execution.

func GetResourceDependantIDs added in v0.4.0 

func GetResourceDependantIDs(ctx context.Context, mc model.ClientSet, resourceIDs ...object.ID) ([]object.ID, error)

GetResourceDependantIDs gets IDs of resources that depend on the given resources.

func GetResourceDependantNames added in v0.4.0 

func GetResourceDependantNames(
	ctx context.Context,
	modelClient model.ClientSet,
	entity *model.Resource,
) ([]string, error)

GetResourceDependantNames gets names of resources that depends on the given resource.

func GetResourceNamesByIDs added in v0.4.0 

func GetResourceNamesByIDs(
	ctx context.Context,
	modelClient model.ClientSet,
	resourceIDs ...object.ID,
) ([]string, error)

func OverwriteWorkflowVariables added in v0.4.0 

func OverwriteWorkflowVariables(vars map[string]string, config types.WorkflowVariables) (map[string]string, error)

OverwriteWorkflowVariables merges the variables into the config.

func ProjectSubjectRolesEdgeSave 

func ProjectSubjectRolesEdgeSave(ctx context.Context, mc model.ClientSet, entity *model.Project) error

ProjectSubjectRolesEdgeSave saves the edge subject roles of model.Project entity.

func ResetWorkflowExecution added in v0.4.0 

func ResetWorkflowExecution(ctx context.Context, mc model.ClientSet, workflowExecution *model.WorkflowExecution) error

ResetWorkflowExecution resets the workflow execution and add execution times by 1. The workflow execution will be reset when rerun the workflow execution.

func ResetWorkflowStageExecution added in v0.4.0 

func ResetWorkflowStageExecution(
	ctx context.Context,
	mc model.ClientSet,
	stageExecution *model.WorkflowStageExecution,
) error

ResetWorkflowStageExecution resets the workflow stage execution and add execution times by 1. The workflow stage execution will be reset when rerun the workflow execution.

func ResetWorkflowStepExecution added in v0.4.0 

func ResetWorkflowStepExecution(
	ctx context.Context,
	mc model.ClientSet,
	stepExecution *model.WorkflowStepExecution,
) error

ResetWorkflowStepExecution resets the workflow step execution and add execution times by 1. The workflow step execution will be reset when rerun the workflow execution.

func ResourceComponentGetUniqueKey added in v0.4.0 

func ResourceComponentGetUniqueKey(r *model.ResourceComponent) string

ResourceComponentGetUniqueKey returns the unique index key of the given model.ResourceComponent.

func ResourceComponentInstancesEdgeSave added in v0.4.0 

func ResourceComponentInstancesEdgeSave(
	ctx context.Context,
	mc model.ClientSet,
	entity *model.ResourceComponent,
) error

ResourceComponentInstancesEdgeSave saves the edge instances of model.ResourceComponent entity.

func ResourceComponentRelationshipUpdateWithDependencies added in v0.4.0 

func ResourceComponentRelationshipUpdateWithDependencies(
	ctx context.Context,
	mc model.ClientSet,
	dependencies map[string][]string,
	recordResources,
	createResources model.ResourceComponents,
) error

ResourceComponentRelationshipUpdateWithDependencies updates the relationship with dependencies and resources.

func ResourceComponentShapeClassQuery added in v0.4.0 

func ResourceComponentShapeClassQuery(query *model.ResourceComponentQuery) *model.ResourceComponentQuery

ResourceComponentShapeClassQuery wraps the given model.ResourceComponent query to select all shape class resources and the owned components and dependencies of them.

func ResourceComponentToMap added in v0.4.0 

func ResourceComponentToMap(resources []*model.ResourceComponent) map[string]*model.ResourceComponent

ResourceComponentToMap recursive set a map of resource components indexed by its unique index.

func ResourceDefinitionMatchingRulesEdgeSave added in v0.4.0 

func ResourceDefinitionMatchingRulesEdgeSave(
	ctx context.Context,
	mc model.ClientSet,
	entity *model.ResourceDefinition,
) error

ResourceDefinitionMatchingRulesEdgeSave saves the edge matching rules of model.ResourceDefinition entity.

func ResourceDependenciesEdgeSave added in v0.4.0 

func ResourceDependenciesEdgeSave(ctx context.Context, mc model.ClientSet, entity *model.Resource) error

ResourceDependenciesEdgeSave saves the edge dependencies of model.Resource entity.

func ResourceRelationshipCheckCycle added in v0.4.0 

func ResourceRelationshipCheckCycle(s *model.ResourceRelationship) bool

ResourceRelationshipCheckCycle checks if the path contains a dependency cycle.

func ResourceRelationshipGetDependencyNames added in v0.4.0 

func ResourceRelationshipGetDependencyNames(entity *model.Resource) []string

ResourceRelationshipGetDependencyNames gets dependency resource names of the given resource.

func SubjectRolesEdgeSave 

func SubjectRolesEdgeSave(ctx context.Context, mc model.ClientSet, entity *model.Subject) error

SubjectRolesEdgeSave saves the global scope edge roles of model.Subject entity, the roles must not have project id.

func WorkflowStageStepsEdgeSave added in v0.4.0 

func WorkflowStageStepsEdgeSave(ctx context.Context, mc model.ClientSet, entity *model.WorkflowStage) error

WorkflowStageStepsEdgeSave saves the edge steps of model.WorkflowStage entity.

func WorkflowStagesEdgeSave added in v0.4.0 

func WorkflowStagesEdgeSave(ctx context.Context, mc model.ClientSet, entity *model.Workflow) error

Types

type CreateWorkflowExecutionOptions added in v0.4.0 

type CreateWorkflowExecutionOptions struct {
	Workflow *model.Workflow
	// Execution parameters that replace workflow variables config value.
	Variables map[string]string
	// Description is the description of the workflow execution.
	Description string
}

type CreateWorkflowStageExecutionOptions added in v0.4.0 

type CreateWorkflowStageExecutionOptions struct {
	CreateWorkflowExecutionOptions `json:",inline"`

	WorkflowExecution *model.WorkflowExecution
	Stage             *model.WorkflowStage
}

type CreateWorkflowStepExecutionOptions added in v0.4.0 

type CreateWorkflowStepExecutionOptions struct {
	CreateWorkflowExecutionOptions `json:",inline"`

	StageExecution *model.WorkflowStageExecution
	Step           *model.WorkflowStep
}

Source Files

View all Source files

Directories

Path Synopsis
annotation
extension
extension/view
catalog
connector
costreport
distributelock
enttest
environment
environmentconnectorrelationship
hook
intercept
internal
migrate
perspective
predicate
project
resource
resourcecomponent
resourcecomponentrelationship
resourcedefinition
resourcedefinitionmatchingrule
resourcerelationship
resourcerevision
role
runtime
setting
subject
subjectrolerelationship
template
templateversion
token
variable
workflow
workflowexecution
workflowstage
workflowstageexecution
workflowstep
workflowstepexecution
intercept
mixin
crypto
object
property
status

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.