Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

Types

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) RelaunchExecution

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

func (*ExecutionManager) TerminateExecution

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 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 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 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
executions
resources
shared Shared constants for the manager implementation.
testutils Provides sample closures for use in tests.
util Util around parsing request filters Shared method implementations.
validation Miscellaneous functions to validate that required proto and spec fields are non empty when required for execution.