Documentation
¶
Index ¶
- func NewExecutionManager(db repositoryInterfaces.Repository, pluginRegistry *plugins.Registry, ...) interfaces.ExecutionInterface
- func NewLaunchPlanManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration, ...) interfaces.LaunchPlanInterface
- func NewNamedEntityManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration, ...) interfaces.NamedEntityInterface
- func NewNodeExecutionManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration, ...) interfaces.NodeExecutionInterface
- func NewProjectManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration) interfaces.ProjectInterface
- func NewSignalManager(db repoInterfaces.Repository, scope promutils.Scope) interfaces.SignalInterface
- func NewTaskExecutionManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration, ...) interfaces.TaskExecutionInterface
- func NewTaskManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration, ...) interfaces.TaskInterface
- func NewVersionManager() interfaces.VersionInterface
- func NewWorkflowManager(db repoInterfaces.Repository, config runtimeInterfaces.Configuration, ...) interfaces.WorkflowInterface
- type ExecutionManager
- func (m *ExecutionManager) CreateExecution(ctx context.Context, request admin.ExecutionCreateRequest, ...) (*admin.ExecutionCreateResponse, error)
- func (m *ExecutionManager) CreateWorkflowEvent(ctx context.Context, request admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error)
- func (m *ExecutionManager) GetExecution(ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error)
- func (m *ExecutionManager) GetExecutionData(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error)
- func (m *ExecutionManager) ListExecutions(ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error)
- func (m *ExecutionManager) RecoverExecution(ctx context.Context, request admin.ExecutionRecoverRequest, ...) (*admin.ExecutionCreateResponse, error)
- func (m *ExecutionManager) RelaunchExecution(ctx context.Context, request admin.ExecutionRelaunchRequest, ...) (*admin.ExecutionCreateResponse, error)
- func (m *ExecutionManager) TerminateExecution(ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)
- func (m *ExecutionManager) UpdateExecution(ctx context.Context, request admin.ExecutionUpdateRequest, ...) (*admin.ExecutionUpdateResponse, error)
- type LaunchPlanManager
- func (m *LaunchPlanManager) CreateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)
- func (m *LaunchPlanManager) GetActiveLaunchPlan(ctx context.Context, request admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error)
- func (m *LaunchPlanManager) GetLaunchPlan(ctx context.Context, request admin.ObjectGetRequest) (*admin.LaunchPlan, error)
- func (m *LaunchPlanManager) ListActiveLaunchPlans(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (*admin.LaunchPlanList, error)
- func (m *LaunchPlanManager) ListLaunchPlanIds(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
- func (m *LaunchPlanManager) ListLaunchPlans(ctx context.Context, request admin.ResourceListRequest) (*admin.LaunchPlanList, error)
- func (m *LaunchPlanManager) UpdateLaunchPlan(ctx context.Context, request admin.LaunchPlanUpdateRequest) (*admin.LaunchPlanUpdateResponse, error)
- type NamedEntityManager
- func (m *NamedEntityManager) GetNamedEntity(ctx context.Context, request admin.NamedEntityGetRequest) (*admin.NamedEntity, error)
- func (m *NamedEntityManager) ListNamedEntities(ctx context.Context, request admin.NamedEntityListRequest) (*admin.NamedEntityList, error)
- func (m *NamedEntityManager) UpdateNamedEntity(ctx context.Context, request admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)
- type NamedEntityMetrics
- type NodeExecutionManager
- func (m *NodeExecutionManager) CreateNodeEvent(ctx context.Context, request admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error)
- func (m *NodeExecutionManager) GetNodeExecution(ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)
- func (m *NodeExecutionManager) GetNodeExecutionData(ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)
- func (m *NodeExecutionManager) ListNodeExecutions(ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)
- func (m *NodeExecutionManager) ListNodeExecutionsForTask(ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)
- type ProjectManager
- func (m *ProjectManager) CreateProject(ctx context.Context, request admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)
- func (m *ProjectManager) ListProjects(ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error)
- func (m *ProjectManager) UpdateProject(ctx context.Context, projectUpdate admin.Project) (*admin.ProjectUpdateResponse, error)
- type SignalManager
- func (s *SignalManager) GetOrCreateSignal(ctx context.Context, request admin.SignalGetOrCreateRequest) (*admin.Signal, error)
- func (s *SignalManager) ListSignals(ctx context.Context, request admin.SignalListRequest) (*admin.SignalList, error)
- func (s *SignalManager) SetSignal(ctx context.Context, request admin.SignalSetRequest) (*admin.SignalSetResponse, error)
- type TaskExecutionManager
- func (m *TaskExecutionManager) CreateTaskExecutionEvent(ctx context.Context, request admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error)
- func (m *TaskExecutionManager) GetTaskExecution(ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)
- func (m *TaskExecutionManager) GetTaskExecutionData(ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)
- func (m *TaskExecutionManager) ListTaskExecutions(ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)
- type TaskManager
- func (t *TaskManager) CreateTask(ctx context.Context, request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)
- func (t *TaskManager) GetTask(ctx context.Context, request admin.ObjectGetRequest) (*admin.Task, error)
- func (t *TaskManager) ListTasks(ctx context.Context, request admin.ResourceListRequest) (*admin.TaskList, error)
- func (t *TaskManager) ListUniqueTaskIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
- type VersionManager
- type WorkflowManager
- func (w *WorkflowManager) CreateWorkflow(ctx context.Context, request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)
- func (w *WorkflowManager) GetWorkflow(ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error)
- func (w *WorkflowManager) ListWorkflowIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
- func (w *WorkflowManager) ListWorkflows(ctx context.Context, request admin.ResourceListRequest) (*admin.WorkflowList, error)
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 NewSignalManager ¶ added in v1.1.61
func NewSignalManager( db repoInterfaces.Repository, scope promutils.Scope) interfaces.SignalInterface
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 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 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
func (s *SignalManager) SetSignal(ctx context.Context, request admin.SignalSetRequest) (*admin.SignalSetResponse, 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
func (*VersionManager) GetVersion ¶ added in v0.4.10
func (v *VersionManager) GetVersion(ctx context.Context, r *admin.GetVersionRequest) (*admin.GetVersionResponse, error)
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
¶
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. |
Click to show internal directories.
Click to hide internal directories.