impl

package
v1.13.3 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2024 License: Apache-2.0 Imports: 50 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) interfaces.ExecutionInterface

func NewLaunchPlanManager 

func NewLaunchPlanManager(
	db repoInterfaces.Repository,
	config runtimeInterfaces.Configuration,
	scheduler scheduleInterfaces.EventScheduler,
	scope promutils.Scope) 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) 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) 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) 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) 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) GetDynamicNodeWorkflow added in v1.10.7 

func (m *NodeExecutionManager) GetDynamicNodeWorkflow(ctx context.Context, request *admin.GetDynamicNodeWorkflowRequest) (*admin.DynamicNodeWorkflowResponse, 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) GetDomains added in v1.13.0 

func (m *ProjectManager) GetDomains(ctx context.Context, request *admin.GetDomainRequest) *admin.GetDomainsResponse

func (*ProjectManager) GetProject added in v1.12.0 

func (m *ProjectManager) GetProject(ctx context.Context, request *admin.ProjectGetRequest) (*admin.Project, 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.