impl

package
v1.10.7-b2 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2024 License: Apache-2.0 Imports: 52 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RequestLimit uint32 = 50
)

Variables

This section is empty.

Functions

func NewDescriptionEntityManager 

func NewDescriptionEntityManager(
	db repoInterfaces.Repository,
	config runtimeInterfaces.Configuration,
	scope promutils.Scope) interfaces.DescriptionEntityInterface

func NewExecutionManager 

func NewExecutionManager(db repositoryInterfaces.Repository, pluginRegistry *plugins.Registry, config runtimeInterfaces.Configuration,
	storageClient *storage.DataStore, systemScope promutils.Scope, userScope promutils.Scope,
	publisher notificationInterfaces.Publisher, urlData dataInterfaces.RemoteURLInterface,
	workflowManager interfaces.WorkflowInterface, namedEntityManager interfaces.NamedEntityInterface,
	eventPublisher notificationInterfaces.Publisher, cloudEventPublisher cloudeventInterfaces.Publisher,
	eventWriter eventWriter.WorkflowExecutionEventWriter, artifactRegistry *artifacts.ArtifactRegistry) interfaces.ExecutionInterface

func NewLaunchPlanManager 

func NewLaunchPlanManager(
	db repoInterfaces.Repository,
	config runtimeInterfaces.Configuration,
	scheduler scheduleInterfaces.EventScheduler,
	scope promutils.Scope,
	artifactRegistry *artifacts.ArtifactRegistry) interfaces.LaunchPlanInterface

func NewMetricsManager 

func NewMetricsManager(
	workflowManager interfaces.WorkflowInterface,
	executionManager interfaces.ExecutionInterface,
	nodeExecutionManager interfaces.NodeExecutionInterface,
	taskExecutionManager interfaces.TaskExecutionInterface,
	scope promutils.Scope) interfaces.MetricsInterface

NewMetricsManager returns a new MetricsManager constructed with the provided arguments.

func NewNamedEntityManager 

func NewNamedEntityManager(
	db repoInterfaces.Repository,
	config runtimeInterfaces.Configuration,
	scope promutils.Scope) interfaces.NamedEntityInterface

func NewNodeExecutionManager 

func NewNodeExecutionManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration,
	storagePrefix []string, storageClient *storage.DataStore, scope promutils.Scope, urlData dataInterfaces.RemoteURLInterface,
	eventPublisher notificationInterfaces.Publisher, cloudEventPublisher cloudeventInterfaces.Publisher,
	eventWriter eventWriter.NodeExecutionEventWriter) interfaces.NodeExecutionInterface

func NewProjectManager 

func NewProjectManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration) interfaces.ProjectInterface

func NewSignalManager 

func NewSignalManager(
	db repoInterfaces.Repository,
	scope promutils.Scope) interfaces.SignalInterface

func NewTaskExecutionManager 

func NewTaskExecutionManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration,
	storageClient *storage.DataStore, scope promutils.Scope, urlData dataInterfaces.RemoteURLInterface,
	publisher notificationInterfaces.Publisher, cloudEventsPublisher cloudeventInterfaces.Publisher) interfaces.TaskExecutionInterface

func NewTaskManager 

func NewTaskManager(
	db repoInterfaces.Repository,
	config runtimeInterfaces.Configuration, compiler workflowengine.Compiler,
	scope promutils.Scope,
	artifactRegistry *artifacts.ArtifactRegistry) interfaces.TaskInterface

func NewVersionManager 

func NewVersionManager() interfaces.VersionInterface

func NewWorkflowManager 

func NewWorkflowManager(
	db repoInterfaces.Repository,
	config runtimeInterfaces.Configuration,
	compiler workflowengineInterfaces.Compiler,
	storageClient *storage.DataStore,
	storagePrefix []string,
	scope promutils.Scope,
	artifactRegistry *artifacts.ArtifactRegistry) interfaces.WorkflowInterface

Types

type DescriptionEntityManager 

type DescriptionEntityManager struct {
	// contains filtered or unexported fields
}

func (*DescriptionEntityManager) GetDescriptionEntity 

func (d *DescriptionEntityManager) GetDescriptionEntity(ctx context.Context, request admin.ObjectGetRequest) (
	*admin.DescriptionEntity, error)

func (*DescriptionEntityManager) ListDescriptionEntity 

func (d *DescriptionEntityManager) ListDescriptionEntity(ctx context.Context, request admin.DescriptionEntityListRequest) (*admin.DescriptionEntityList, error)

type DescriptionEntityMetrics 

type DescriptionEntityMetrics struct {
	Scope promutils.Scope
}

type ExecutionManager 

type ExecutionManager struct {
	// contains filtered or unexported fields
}

func (*ExecutionManager) CreateExecution 

func (m *ExecutionManager) CreateExecution(
	ctx context.Context, request admin.ExecutionCreateRequest, requestedAt time.Time) (
	*admin.ExecutionCreateResponse, error)

func (*ExecutionManager) CreateWorkflowEvent 

func (m *ExecutionManager) CreateWorkflowEvent(ctx context.Context, request admin.WorkflowExecutionEventRequest) (
	*admin.WorkflowExecutionEventResponse, error)

func (*ExecutionManager) ExtractArtifactTrackers 

func (m *ExecutionManager) ExtractArtifactTrackers(artifactTrackers map[string]string, input *core.Literal)

ExtractArtifactTrackers pulls out artifact tracker strings from Literals for lineage

func (*ExecutionManager) GetExecution 

func (m *ExecutionManager) GetExecution(
	ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error)

func (*ExecutionManager) GetExecutionData 

func (m *ExecutionManager) GetExecutionData(
	ctx context.Context, request admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error)

func (*ExecutionManager) ListExecutions 

func (m *ExecutionManager) ListExecutions(
	ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error)

func (*ExecutionManager) RecoverExecution 

func (m *ExecutionManager) RecoverExecution(
	ctx context.Context, request admin.ExecutionRecoverRequest, requestedAt time.Time) (
	*admin.ExecutionCreateResponse, error)

func (*ExecutionManager) RelaunchExecution 

func (m *ExecutionManager) RelaunchExecution(
	ctx context.Context, request admin.ExecutionRelaunchRequest, requestedAt time.Time) (
	*admin.ExecutionCreateResponse, error)

func (*ExecutionManager) ResolveParameterMapArtifacts 

func (m *ExecutionManager) ResolveParameterMapArtifacts(ctx context.Context, inputs *core.ParameterMap, inputsForQueryTemplating map[string]*core.Literal) (*core.ParameterMap, []*core.ArtifactID, error)

ResolveParameterMapArtifacts will go through the parameter map, and resolve any artifact queries.

func (*ExecutionManager) TerminateExecution 

func (m *ExecutionManager) TerminateExecution(
	ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)

func (*ExecutionManager) UpdateExecution 

func (m *ExecutionManager) UpdateExecution(ctx context.Context, request admin.ExecutionUpdateRequest,
	requestedAt time.Time) (*admin.ExecutionUpdateResponse, error)

type LaunchPlanManager 

type LaunchPlanManager struct {
	// contains filtered or unexported fields
}

func (*LaunchPlanManager) CreateLaunchPlan 

func (m *LaunchPlanManager) CreateLaunchPlan(
	ctx context.Context,
	request admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)

func (*LaunchPlanManager) GetActiveLaunchPlan 

func (m *LaunchPlanManager) GetActiveLaunchPlan(ctx context.Context, request admin.ActiveLaunchPlanRequest) (
	*admin.LaunchPlan, error)

func (*LaunchPlanManager) GetLaunchPlan 

func (m *LaunchPlanManager) GetLaunchPlan(ctx context.Context, request admin.ObjectGetRequest) (
	*admin.LaunchPlan, error)

func (*LaunchPlanManager) ListActiveLaunchPlans 

func (m *LaunchPlanManager) ListActiveLaunchPlans(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (
	*admin.LaunchPlanList, error)

func (*LaunchPlanManager) ListLaunchPlanIds 

func (m *LaunchPlanManager) ListLaunchPlanIds(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
	*admin.NamedEntityIdentifierList, error)

At least project name and domain must be specified along with limit.

func (*LaunchPlanManager) ListLaunchPlans 

func (m *LaunchPlanManager) ListLaunchPlans(ctx context.Context, request admin.ResourceListRequest) (
	*admin.LaunchPlanList, error)

func (*LaunchPlanManager) UpdateLaunchPlan 

func (m *LaunchPlanManager) UpdateLaunchPlan(ctx context.Context, request admin.LaunchPlanUpdateRequest) (
	*admin.LaunchPlanUpdateResponse, error)

type MetricsManager 

type MetricsManager struct {
	// contains filtered or unexported fields
}

MetricsManager handles computation of workflow, node, and task execution metrics.

func (*MetricsManager) GetExecutionMetrics 

func (m *MetricsManager) GetExecutionMetrics(ctx context.Context,
	request admin.WorkflowExecutionGetMetricsRequest) (*admin.WorkflowExecutionGetMetricsResponse, error)

GetExecutionMetrics returns a Span hierarchically breaking down the workflow execution into a collection of Categorical and Reference Spans.

type NamedEntityManager 

type NamedEntityManager struct {
	// contains filtered or unexported fields
}

func (*NamedEntityManager) GetNamedEntity 

func (m *NamedEntityManager) GetNamedEntity(ctx context.Context, request admin.NamedEntityGetRequest) (
	*admin.NamedEntity, error)

func (*NamedEntityManager) ListNamedEntities 

func (m *NamedEntityManager) ListNamedEntities(ctx context.Context, request admin.NamedEntityListRequest) (
	*admin.NamedEntityList, error)

func (*NamedEntityManager) UpdateNamedEntity 

func (m *NamedEntityManager) UpdateNamedEntity(ctx context.Context, request admin.NamedEntityUpdateRequest) (
	*admin.NamedEntityUpdateResponse, error)

type NamedEntityMetrics 

type NamedEntityMetrics struct {
	Scope promutils.Scope
}

type NodeExecutionManager 

type NodeExecutionManager struct {
	// contains filtered or unexported fields
}

func (*NodeExecutionManager) CreateNodeEvent 

func (m *NodeExecutionManager) CreateNodeEvent(ctx context.Context, request admin.NodeExecutionEventRequest) (
	*admin.NodeExecutionEventResponse, error)

func (*NodeExecutionManager) GetNodeExecution 

func (m *NodeExecutionManager) GetNodeExecution(
	ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)

func (*NodeExecutionManager) GetNodeExecutionData 

func (m *NodeExecutionManager) GetNodeExecutionData(
	ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)

func (*NodeExecutionManager) ListNodeExecutions 

func (m *NodeExecutionManager) ListNodeExecutions(
	ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)

func (*NodeExecutionManager) ListNodeExecutionsForTask 

func (m *NodeExecutionManager) ListNodeExecutionsForTask(
	ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)

Filters on node executions matching the execution parameters (execution project, domain, and name) as well as the parent task execution id corresponding to the task execution identified in the request params.

type ProjectManager 

type ProjectManager struct {
	// contains filtered or unexported fields
}

func (*ProjectManager) CreateProject 

func (m *ProjectManager) CreateProject(ctx context.Context, request admin.ProjectRegisterRequest) (
	*admin.ProjectRegisterResponse, error)

func (*ProjectManager) ListProjects 

func (m *ProjectManager) ListProjects(ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error)

func (*ProjectManager) UpdateProject 

func (m *ProjectManager) UpdateProject(ctx context.Context, projectUpdate admin.Project) (*admin.ProjectUpdateResponse, error)

type SignalManager 

type SignalManager struct {
	// contains filtered or unexported fields
}

func (*SignalManager) GetOrCreateSignal 

func (s *SignalManager) GetOrCreateSignal(ctx context.Context, request admin.SignalGetOrCreateRequest) (*admin.Signal, error)

func (*SignalManager) ListSignals 

func (s *SignalManager) ListSignals(ctx context.Context, request admin.SignalListRequest) (*admin.SignalList, error)

func (*SignalManager) SetSignal 

func (s *SignalManager) SetSignal(ctx context.Context, request admin.SignalSetRequest) (*admin.SignalSetResponse, error)

type TaskExecutionManager 

type TaskExecutionManager struct {
	// contains filtered or unexported fields
}

func (*TaskExecutionManager) CreateTaskExecutionEvent 

func (m *TaskExecutionManager) CreateTaskExecutionEvent(ctx context.Context, request admin.TaskExecutionEventRequest) (
	*admin.TaskExecutionEventResponse, error)

func (*TaskExecutionManager) GetTaskExecution 

func (m *TaskExecutionManager) GetTaskExecution(
	ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)

func (*TaskExecutionManager) GetTaskExecutionData 

func (m *TaskExecutionManager) GetTaskExecutionData(
	ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)

func (*TaskExecutionManager) ListTaskExecutions 

func (m *TaskExecutionManager) ListTaskExecutions(
	ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)

type TaskManager 

type TaskManager struct {
	// contains filtered or unexported fields
}

func (*TaskManager) CreateTask 

func (t *TaskManager) CreateTask(
	ctx context.Context,
	request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)

func (*TaskManager) GetTask 

func (t *TaskManager) GetTask(ctx context.Context, request admin.ObjectGetRequest) (*admin.Task, error)

func (*TaskManager) ListTasks 

func (t *TaskManager) ListTasks(ctx context.Context, request admin.ResourceListRequest) (*admin.TaskList, error)

func (*TaskManager) ListUniqueTaskIdentifiers 

func (t *TaskManager) ListUniqueTaskIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
	*admin.NamedEntityIdentifierList, error)

This queries the unique tasks for the given query parameters. At least the project and domain must be specified. It will return all tasks, but only the one of each even if there are multiple versions.

type VersionManager 

type VersionManager struct {
	Version   string
	Build     string
	BuildTime string
}

func (*VersionManager) GetVersion 

func (v *VersionManager) GetVersion(ctx context.Context, r *admin.GetVersionRequest) (*admin.GetVersionResponse, error)

type WorkflowManager 

type WorkflowManager struct {
	// contains filtered or unexported fields
}

func (*WorkflowManager) CreateWorkflow 

func (w *WorkflowManager) CreateWorkflow(
	ctx context.Context,
	request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)

func (*WorkflowManager) GetWorkflow 

func (w *WorkflowManager) GetWorkflow(ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error)

func (*WorkflowManager) ListWorkflowIdentifiers 

func (w *WorkflowManager) ListWorkflowIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
	*admin.NamedEntityIdentifierList, error)

func (*WorkflowManager) ListWorkflows 

func (w *WorkflowManager) ListWorkflows(
	ctx context.Context, request admin.ResourceListRequest) (*admin.WorkflowList, error)

ListWorkflows returns workflows *without* a populated workflow closure.

Source Files

View all Source files

Directories

Path Synopsis
Shared constants for the manager implementation.
 Shared constants for the manager implementation.
Provides sample closures for use in tests.
 Provides sample closures for use in tests.
Util around parsing request filters
 Util around parsing request filters
Miscellaneous functions to validate that required proto and spec fields are non empty when required for execution.
 Miscellaneous functions to validate that required proto and spec fields are non empty when required for execution.

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.