Documentation
¶
Index ¶
- func NewExecutionManager(db repositories.RepositoryInterface, config runtimeInterfaces.Configuration, ...) interfaces.ExecutionInterface
- func NewLaunchPlanManager(db repositories.RepositoryInterface, config runtimeInterfaces.Configuration, ...) interfaces.LaunchPlanInterface
- func NewNodeExecutionManager(db repositories.RepositoryInterface, scope promutils.Scope, ...) interfaces.NodeExecutionInterface
- func NewProjectDomainManager(db repositories.RepositoryInterface, config runtimeInterfaces.Configuration) interfaces.ProjectDomainInterface
- func NewProjectManager(db repositories.RepositoryInterface, config runtimeInterfaces.Configuration) interfaces.ProjectInterface
- func NewTaskExecutionManager(db repositories.RepositoryInterface, scope promutils.Scope, ...) interfaces.TaskExecutionInterface
- func NewTaskManager(db repositories.RepositoryInterface, config runtimeInterfaces.Configuration, ...) interfaces.TaskInterface
- func NewWorkflowManager(db repositories.RepositoryInterface, 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) RelaunchExecution(ctx context.Context, request admin.ExecutionRelaunchRequest, ...) (*admin.ExecutionCreateResponse, error)
- func (m *ExecutionManager) TerminateExecution(ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, 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 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 ProjectDomainManager
- type ProjectManager
- 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 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 repositories.RepositoryInterface, config runtimeInterfaces.Configuration, storageClient *storage.DataStore, workflowExecutor workflowengineInterfaces.Executor, systemScope promutils.Scope, userScope promutils.Scope, publisher notificationInterfaces.Publisher, urlData dataInterfaces.RemoteURLInterface) interfaces.ExecutionInterface
func NewLaunchPlanManager ¶
func NewLaunchPlanManager( db repositories.RepositoryInterface, config runtimeInterfaces.Configuration, scheduler scheduleInterfaces.EventScheduler, scope promutils.Scope) interfaces.LaunchPlanInterface
func NewNodeExecutionManager ¶
func NewNodeExecutionManager( db repositories.RepositoryInterface, scope promutils.Scope, urlData dataInterfaces.RemoteURLInterface) interfaces.NodeExecutionInterface
func NewProjectDomainManager ¶ added in v0.1.4
func NewProjectDomainManager( db repositories.RepositoryInterface, config runtimeInterfaces.Configuration) interfaces.ProjectDomainInterface
func NewProjectManager ¶
func NewProjectManager(db repositories.RepositoryInterface, config runtimeInterfaces.Configuration) interfaces.ProjectInterface
func NewTaskExecutionManager ¶
func NewTaskExecutionManager( db repositories.RepositoryInterface, scope promutils.Scope, urlData dataInterfaces.RemoteURLInterface) interfaces.TaskExecutionInterface
func NewTaskManager ¶
func NewTaskManager( db repositories.RepositoryInterface, config runtimeInterfaces.Configuration, compiler workflowengine.Compiler, scope promutils.Scope) interfaces.TaskInterface
func NewWorkflowManager ¶
func NewWorkflowManager( db repositories.RepositoryInterface, 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) 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)
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 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 ProjectDomainManager ¶ added in v0.1.4
type ProjectDomainManager struct {
// contains filtered or unexported fields
}
func (*ProjectDomainManager) UpdateProjectDomain ¶ added in v0.1.4
func (m *ProjectDomainManager) UpdateProjectDomain( ctx context.Context, request admin.ProjectDomainAttributesUpdateRequest) ( *admin.ProjectDomainAttributesUpdateResponse, error)
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)
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 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 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. |
Click to show internal directories.
Click to hide internal directories.