impl

package
v1.1.107 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2023 License: Apache-2.0 Imports: 49 Imported by: 2

Documentation

Index

Constants

View Source
const (
	RequestLimit uint32 = 50
)

Variables

This section is empty.

Functions

func NewMetricsManager added in v1.1.87

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 NewSignalManager added in v1.1.61

func NewVersionManager added in v0.4.10

func NewVersionManager() interfaces.VersionInterface

Types

type DescriptionEntityManager added in v1.1.67

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

func (*DescriptionEntityManager) GetDescriptionEntity added in v1.1.67

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

func (*DescriptionEntityManager) ListDescriptionEntity added in v1.1.67

type DescriptionEntityMetrics added in v1.1.67

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 (*ExecutionManager) GetExecution

func (*ExecutionManager) ListExecutions

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

func (*ExecutionManager) RecoverExecution added in v0.6.18

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 (*ExecutionManager) UpdateExecution added in v0.6.77

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 (*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

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

type MetricsManager added in v1.1.87

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

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

func (*MetricsManager) GetExecutionMetrics added in v1.1.87

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

type NamedEntityManager added in v0.1.5

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

func (*NamedEntityManager) GetNamedEntity added in v0.1.5

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

func (*NamedEntityManager) ListNamedEntities added in v0.1.5

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

func (*NamedEntityManager) UpdateNamedEntity added in v0.1.5

type NamedEntityMetrics added in v0.1.5

type NamedEntityMetrics struct {
	Scope promutils.Scope
}

type NodeExecutionManager

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

func (*NodeExecutionManager) CreateNodeEvent

func (*NodeExecutionManager) GetNodeExecution

func (*NodeExecutionManager) GetNodeExecutionData

func (*NodeExecutionManager) ListNodeExecutions

func (*NodeExecutionManager) ListNodeExecutionsForTask

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 (*ProjectManager) ListProjects

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

func (*ProjectManager) UpdateProject added in v0.3.38

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

type SignalManager added in v1.1.61

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

func (*SignalManager) GetOrCreateSignal added in v1.1.61

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

func (*SignalManager) ListSignals added in v1.1.61

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

func (*SignalManager) SetSignal added in v1.1.61

type TaskExecutionManager

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

func (*TaskExecutionManager) CreateTaskExecutionEvent

func (*TaskExecutionManager) GetTaskExecution

func (*TaskExecutionManager) GetTaskExecutionData

func (*TaskExecutionManager) ListTaskExecutions

type TaskManager

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

func (*TaskManager) CreateTask

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

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 added in v0.4.10

type VersionManager struct {
	Version   string
	Build     string
	BuildTime string
}

func (*VersionManager) GetVersion added in v0.4.10

type WorkflowManager

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

func (*WorkflowManager) CreateWorkflow

func (*WorkflowManager) GetWorkflow

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

func (*WorkflowManager) ListWorkflowIdentifiers

func (*WorkflowManager) ListWorkflows

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

Returns workflows *without* a populated workflow closure.

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