impl

package
v1.1.44 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2022 License: Apache-2.0 Imports: 46 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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

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

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 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 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 (m *ExecutionManager) TerminateExecution(
	ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)

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

func (m *NamedEntityManager) UpdateNamedEntity(ctx context.Context, request admin.NamedEntityUpdateRequest) (
	*admin.NamedEntityUpdateResponse, error)

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 (m *NodeExecutionManager) CreateNodeEvent(ctx context.Context, request admin.NodeExecutionEventRequest) (
	*admin.NodeExecutionEventResponse, 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) 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 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 added in v0.4.10 

type VersionManager struct {
	Version   string
	Build     string
	BuildTime string
}

func (*VersionManager) GetVersion added in v0.4.10 

func (v *VersionManager) GetVersion(ctx context.Context, r *admin.GetVersionRequest) (*admin.GetVersionResponse, error)

type WorkflowExecutionConfigInterface added in v0.6.119 

type WorkflowExecutionConfigInterface interface {
	// GetMaxParallelism Can be used to control the number of parallel nodes to run within the workflow. This is useful to achieve fairness.
	GetMaxParallelism() int32
	// GetRawOutputDataConfig Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.).
	GetRawOutputDataConfig() *admin.RawOutputDataConfig
	// GetSecurityContext Indicates security context permissions for executions triggered with this matchable attribute.
	GetSecurityContext() *core.SecurityContext
	// GetAnnotations Custom annotations to be applied to a triggered execution resource.
	GetAnnotations() *admin.Annotations
	// GetLabels Custom labels to be applied to a triggered execution resource.
	GetLabels() *admin.Labels
	// GetInterruptible indicates a workflow should be flagged as interruptible for a single execution. If omitted, the workflow's default is used.
	GetInterruptible() *wrappers.BoolValue
}

WorkflowExecutionConfigInterface is used as common interface for capturing the common behavior catering to the needs of fetching the WorkflowExecutionConfig across LaunchPlanSpec, ExecutionCreateRequest MatchableResource_WORKFLOW_EXECUTION_CONFIG and ApplicationConfig

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)

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.