impl

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Aug 12, 2020 License: Apache-2.0 Imports: 40 Imported by: 0

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

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
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 Shared method implementations.
Util around parsing request filters Shared method implementations.
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