impl

package
v1.0.15 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2023 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RequestLimit uint32 = 50
)

Variables

This section is empty.

Functions

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 NewVersionManager

func NewVersionManager() interfaces.VersionInterface

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

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

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

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

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

func (*MetricsManager) GetExecutionMetrics

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

type NamedEntityMetrics

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

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

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

type VersionManager struct {
	Version   string
	Build     string
	BuildTime string
}

func (*VersionManager) GetVersion

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