Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + func NewMockLaunchPlanManager() interfaces.LaunchPlanInterface + type CreateExecutionEventFunc func(ctx context.Context, request admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error) + type CreateExecutionFunc func(ctx context.Context, request admin.ExecutionCreateRequest, ...) (*admin.ExecutionCreateResponse, error) + type CreateLaunchPlanFunc func(ctx context.Context, request admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error) + type CreateNodeEventFunc func(ctx context.Context, request admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error) + type CreateProjectFunc func(ctx context.Context, request admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error) + type CreateTaskExecutionEventFunc func(ctx context.Context, request admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error) + type CreateTaskFunc func(ctx context.Context, request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error) + type CreateWorkflowFunc func(ctx context.Context, request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error) + type DeleteProjectAttrFunc func(ctx context.Context, request admin.ProjectAttributesDeleteRequest) (*admin.ProjectAttributesDeleteResponse, error) + type DeleteProjectDomainFunc func(ctx context.Context, request admin.ProjectDomainAttributesDeleteRequest) (*admin.ProjectDomainAttributesDeleteResponse, error) + type GetActiveLaunchPlanFunc func(ctx context.Context, request admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error) + type GetExecutionDataFunc func(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error) + type GetExecutionFunc func(ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error) + type GetLaunchPlanFunc func(ctx context.Context, request admin.ObjectGetRequest) (*admin.LaunchPlan, error) + type GetNamedEntityFunc func(ctx context.Context, request admin.NamedEntityGetRequest) (*admin.NamedEntity, error) + type GetNodeExecutionDataFunc func(ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error) + type GetNodeExecutionFunc func(ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error) + type GetProjectAttrFunc func(ctx context.Context, request admin.ProjectAttributesGetRequest) (*admin.ProjectAttributesGetResponse, error) + type GetProjectDomainFunc func(ctx context.Context, request admin.ProjectDomainAttributesGetRequest) (*admin.ProjectDomainAttributesGetResponse, error) + type GetResourceFunc func(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, error) + type GetTaskExecutionDataFunc func(ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error) + type GetTaskExecutionFunc func(ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error) + type GetWorkflowFunc func(ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error) + type ListActiveLaunchPlansFunc func(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (*admin.LaunchPlanList, error) + type ListExecutionFunc func(ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error) + type ListLaunchPlanIdsFunc func(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error) + type ListLaunchPlansFunc func(ctx context.Context, request admin.ResourceListRequest) (*admin.LaunchPlanList, error) + type ListNamedEntitiesFunc func(ctx context.Context, request admin.NamedEntityListRequest) (*admin.NamedEntityList, error) + type ListNodeExecutionsForTaskFunc func(ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error) + type ListNodeExecutionsFunc func(ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error) + type ListProjectFunc func(ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error) + type ListResourceFunc func(ctx context.Context, request admin.ListMatchableAttributesRequest) (*admin.ListMatchableAttributesResponse, error) + type ListTaskExecutionsFunc func(ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error) + type ListUniqueIdsFunc func(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error) + type MetricsInterface struct + func (_m *MetricsInterface) GetExecutionMetrics(ctx context.Context, request admin.WorkflowExecutionGetMetricsRequest) (*admin.WorkflowExecutionGetMetricsResponse, error) + func (_m *MetricsInterface) OnGetExecutionMetrics(ctx context.Context, request admin.WorkflowExecutionGetMetricsRequest) *MetricsInterface_GetExecutionMetrics + func (_m *MetricsInterface) OnGetExecutionMetricsMatch(matchers ...interface{}) *MetricsInterface_GetExecutionMetrics + type MetricsInterface_GetExecutionMetrics struct + func (_m MetricsInterface_GetExecutionMetrics) Return(_a0 *admin.WorkflowExecutionGetMetricsResponse, _a1 error) *MetricsInterface_GetExecutionMetrics + type MockExecutionManager struct + RecoverExecutionFunc RecoverExecutionFunc + func (m *MockExecutionManager) CreateExecution(ctx context.Context, request admin.ExecutionCreateRequest, ...) (*admin.ExecutionCreateResponse, error) + func (m *MockExecutionManager) CreateWorkflowEvent(ctx context.Context, request admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error) + func (m *MockExecutionManager) GetExecution(ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error) + func (m *MockExecutionManager) GetExecutionData(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error) + func (m *MockExecutionManager) ListExecutions(ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error) + func (m *MockExecutionManager) RecoverExecution(ctx context.Context, request admin.ExecutionRecoverRequest, ...) (*admin.ExecutionCreateResponse, error) + func (m *MockExecutionManager) RelaunchExecution(ctx context.Context, request admin.ExecutionRelaunchRequest, ...) (*admin.ExecutionCreateResponse, error) + func (m *MockExecutionManager) SetCreateCallback(createFunction CreateExecutionFunc) + func (m *MockExecutionManager) SetCreateEventCallback(createEventFunc CreateExecutionEventFunc) + func (m *MockExecutionManager) SetGetCallback(getExecutionFunc GetExecutionFunc) + func (m *MockExecutionManager) SetGetDataCallback(getExecutionDataFunc GetExecutionDataFunc) + func (m *MockExecutionManager) SetListCallback(listExecutionFunc ListExecutionFunc) + func (m *MockExecutionManager) SetRelaunchCallback(relaunchFunction RelaunchExecutionFunc) + func (m *MockExecutionManager) SetTerminateExecutionCallback(terminateExecutionFunc TerminateExecutionFunc) + func (m *MockExecutionManager) SetUpdateExecutionCallback(updateExecutionFunc UpdateExecutionFunc) + func (m *MockExecutionManager) TerminateExecution(ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error) + func (m *MockExecutionManager) UpdateExecution(ctx context.Context, request admin.ExecutionUpdateRequest, ...) (*admin.ExecutionUpdateResponse, error) + type MockLaunchPlanManager struct + func (r *MockLaunchPlanManager) CreateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error) + func (r *MockLaunchPlanManager) GetActiveLaunchPlan(ctx context.Context, request admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error) + func (r *MockLaunchPlanManager) GetLaunchPlan(ctx context.Context, request admin.ObjectGetRequest) (*admin.LaunchPlan, error) + func (r *MockLaunchPlanManager) ListActiveLaunchPlans(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (*admin.LaunchPlanList, error) + func (r *MockLaunchPlanManager) ListLaunchPlanIds(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error) + func (r *MockLaunchPlanManager) ListLaunchPlans(ctx context.Context, request admin.ResourceListRequest) (*admin.LaunchPlanList, error) + func (r *MockLaunchPlanManager) SetCreateCallback(createFunction CreateLaunchPlanFunc) + func (r *MockLaunchPlanManager) SetGetActiveLaunchPlanCallback(plansFunc GetActiveLaunchPlanFunc) + func (r *MockLaunchPlanManager) SetListActiveLaunchPlansCallback(plansFunc ListActiveLaunchPlansFunc) + func (r *MockLaunchPlanManager) SetListLaunchPlansCallback(listLaunchPlansFunc ListLaunchPlansFunc) + func (r *MockLaunchPlanManager) SetUpdateLaunchPlan(updateFunction UpdateLaunchPlanFunc) + func (r *MockLaunchPlanManager) UpdateLaunchPlan(ctx context.Context, request admin.LaunchPlanUpdateRequest) (*admin.LaunchPlanUpdateResponse, error) + type MockNodeExecutionManager struct + func (m *MockNodeExecutionManager) CreateNodeEvent(ctx context.Context, request admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error) + func (m *MockNodeExecutionManager) GetDynamicNodeWorkflow(ctx context.Context, request admin.GetDynamicNodeWorkflowRequest) (*admin.DynamicNodeWorkflowResponse, error) + func (m *MockNodeExecutionManager) GetNodeExecution(ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error) + func (m *MockNodeExecutionManager) GetNodeExecutionData(ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error) + func (m *MockNodeExecutionManager) ListNodeExecutions(ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error) + func (m *MockNodeExecutionManager) ListNodeExecutionsForTask(ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error) + func (m *MockNodeExecutionManager) SetCreateNodeEventCallback(createNodeEventFunc CreateNodeEventFunc) + func (m *MockNodeExecutionManager) SetGetNodeExecutionDataFunc(getNodeExecutionDataFunc GetNodeExecutionDataFunc) + func (m *MockNodeExecutionManager) SetGetNodeExecutionFunc(getNodeExecutionFunc GetNodeExecutionFunc) + func (m *MockNodeExecutionManager) SetListNodeExecutionsForTaskFunc(listNodeExecutionsForTaskFunc ListNodeExecutionsForTaskFunc) + func (m *MockNodeExecutionManager) SetListNodeExecutionsFunc(listNodeExecutionsFunc ListNodeExecutionsFunc) + type MockProjectManager struct + func (m *MockProjectManager) CreateProject(ctx context.Context, request admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error) + func (m *MockProjectManager) ListProjects(ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error) + func (m *MockProjectManager) SetCreateProject(createProjectFunc CreateProjectFunc) + func (m *MockProjectManager) SetListCallback(listProjectFunc ListProjectFunc) + func (m *MockProjectManager) UpdateProject(ctx context.Context, request admin.Project) (*admin.ProjectUpdateResponse, error) + type MockResourceManager struct + DeleteFunc DeleteProjectDomainFunc + GetFunc GetProjectDomainFunc + GetResourceFunc GetResourceFunc + ListFunc ListResourceFunc + func (m *MockResourceManager) DeleteProjectAttributes(ctx context.Context, request admin.ProjectAttributesDeleteRequest) (*admin.ProjectAttributesDeleteResponse, error) + func (m *MockResourceManager) DeleteProjectDomainAttributes(ctx context.Context, request admin.ProjectDomainAttributesDeleteRequest) (*admin.ProjectDomainAttributesDeleteResponse, error) + func (m *MockResourceManager) DeleteWorkflowAttributes(ctx context.Context, request admin.WorkflowAttributesDeleteRequest) (*admin.WorkflowAttributesDeleteResponse, error) + func (m *MockResourceManager) GetProjectAttributes(ctx context.Context, request admin.ProjectAttributesGetRequest) (*admin.ProjectAttributesGetResponse, error) + func (m *MockResourceManager) GetProjectDomainAttributes(ctx context.Context, request admin.ProjectDomainAttributesGetRequest) (*admin.ProjectDomainAttributesGetResponse, error) + func (m *MockResourceManager) GetResource(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, error) + func (m *MockResourceManager) GetWorkflowAttributes(ctx context.Context, request admin.WorkflowAttributesGetRequest) (*admin.WorkflowAttributesGetResponse, error) + func (m *MockResourceManager) ListAll(ctx context.Context, request admin.ListMatchableAttributesRequest) (*admin.ListMatchableAttributesResponse, error) + func (m *MockResourceManager) SetDeleteProjectAttributes(deleteProjectFunc DeleteProjectAttrFunc) + func (m *MockResourceManager) SetGetProjectAttributes(getProjectFunc GetProjectAttrFunc) + func (m *MockResourceManager) SetUpdateProjectAttributes(updateProjectAttrsFunc UpdateProjectAttrsFunc) + func (m *MockResourceManager) SetUpdateProjectDomainAttributes(updateProjectDomainFunc UpdateProjectDomainFunc) + func (m *MockResourceManager) UpdateProjectAttributes(ctx context.Context, request admin.ProjectAttributesUpdateRequest) (*admin.ProjectAttributesUpdateResponse, error) + func (m *MockResourceManager) UpdateProjectDomainAttributes(ctx context.Context, request admin.ProjectDomainAttributesUpdateRequest) (*admin.ProjectDomainAttributesUpdateResponse, error) + func (m *MockResourceManager) UpdateWorkflowAttributes(ctx context.Context, request admin.WorkflowAttributesUpdateRequest) (*admin.WorkflowAttributesUpdateResponse, error) + type MockTaskExecutionManager struct + func (m *MockTaskExecutionManager) CreateTaskExecutionEvent(ctx context.Context, request admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error) + func (m *MockTaskExecutionManager) GetTaskExecution(ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error) + func (m *MockTaskExecutionManager) GetTaskExecutionData(ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error) + func (m *MockTaskExecutionManager) ListTaskExecutions(ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error) + func (m *MockTaskExecutionManager) SetCreateTaskEventCallback(createFunc CreateTaskExecutionEventFunc) + func (m *MockTaskExecutionManager) SetGetTaskExecutionCallback(getTaskExecutionFunc GetTaskExecutionFunc) + func (m *MockTaskExecutionManager) SetGetTaskExecutionDataCallback(getTaskExecutionDataFunc GetTaskExecutionDataFunc) + func (m *MockTaskExecutionManager) SetListTaskExecutionsCallback(listTaskExecutionsFunc ListTaskExecutionsFunc) + type MockTaskManager struct + func (r *MockTaskManager) CreateTask(ctx context.Context, request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error) + func (r *MockTaskManager) GetTask(ctx context.Context, request admin.ObjectGetRequest) (*admin.Task, error) + func (r *MockTaskManager) ListTasks(ctx context.Context, request admin.ResourceListRequest) (*admin.TaskList, error) + func (r *MockTaskManager) ListUniqueTaskIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error) + func (r *MockTaskManager) SetCreateCallback(createFunction CreateTaskFunc) + func (r *MockTaskManager) SetListUniqueIdsFunc(fn ListUniqueIdsFunc) + type MockWorkflowManager struct + func (r *MockWorkflowManager) CreateWorkflow(ctx context.Context, request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error) + func (r *MockWorkflowManager) GetWorkflow(ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error) + func (r *MockWorkflowManager) ListWorkflowIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error) + func (r *MockWorkflowManager) ListWorkflows(ctx context.Context, request admin.ResourceListRequest) (*admin.WorkflowList, error) + func (r *MockWorkflowManager) SetCreateCallback(createFunction CreateWorkflowFunc) + func (r *MockWorkflowManager) SetGetCallback(getFunction GetWorkflowFunc) + type NamedEntityManager struct + GetNamedEntityFunc GetNamedEntityFunc + ListNamedEntitiesFunc ListNamedEntitiesFunc + UpdateNamedEntityFunc UpdateNamedEntityFunc + 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 RecoverExecutionFunc func(ctx context.Context, request admin.ExecutionRecoverRequest, ...) (*admin.ExecutionCreateResponse, error) + type RelaunchExecutionFunc func(ctx context.Context, request admin.ExecutionRelaunchRequest, ...) (*admin.ExecutionCreateResponse, error) + type SignalInterface struct + func (_m *SignalInterface) GetOrCreateSignal(ctx context.Context, request admin.SignalGetOrCreateRequest) (*admin.Signal, error) + func (_m *SignalInterface) ListSignals(ctx context.Context, request admin.SignalListRequest) (*admin.SignalList, error) + func (_m *SignalInterface) OnGetOrCreateSignal(ctx context.Context, request admin.SignalGetOrCreateRequest) *SignalInterface_GetOrCreateSignal + func (_m *SignalInterface) OnGetOrCreateSignalMatch(matchers ...interface{}) *SignalInterface_GetOrCreateSignal + func (_m *SignalInterface) OnListSignals(ctx context.Context, request admin.SignalListRequest) *SignalInterface_ListSignals + func (_m *SignalInterface) OnListSignalsMatch(matchers ...interface{}) *SignalInterface_ListSignals + func (_m *SignalInterface) OnSetSignal(ctx context.Context, request admin.SignalSetRequest) *SignalInterface_SetSignal + func (_m *SignalInterface) OnSetSignalMatch(matchers ...interface{}) *SignalInterface_SetSignal + func (_m *SignalInterface) SetSignal(ctx context.Context, request admin.SignalSetRequest) (*admin.SignalSetResponse, error) + type SignalInterface_GetOrCreateSignal struct + func (_m SignalInterface_GetOrCreateSignal) Return(_a0 *admin.Signal, _a1 error) *SignalInterface_GetOrCreateSignal + type SignalInterface_ListSignals struct + func (_m SignalInterface_ListSignals) Return(_a0 *admin.SignalList, _a1 error) *SignalInterface_ListSignals + type SignalInterface_SetSignal struct + func (_m SignalInterface_SetSignal) Return(_a0 *admin.SignalSetResponse, _a1 error) *SignalInterface_SetSignal + type TerminateExecutionFunc func(ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error) + type UpdateExecutionFunc func(ctx context.Context, request admin.ExecutionUpdateRequest, ...) (*admin.ExecutionUpdateResponse, error) + type UpdateLaunchPlanFunc func(ctx context.Context, request admin.LaunchPlanUpdateRequest) (*admin.LaunchPlanUpdateResponse, error) + type UpdateNamedEntityFunc func(ctx context.Context, request admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error) + type UpdateProjectAttrsFunc func(ctx context.Context, request admin.ProjectAttributesUpdateRequest) (*admin.ProjectAttributesUpdateResponse, error) + type UpdateProjectDomainFunc func(ctx context.Context, request admin.ProjectDomainAttributesUpdateRequest) (*admin.ProjectDomainAttributesUpdateResponse, error) + type UpdateProjectFunc func(ctx context.Context, request admin.Project) (*admin.ProjectUpdateResponse, error) + type VersionInterface struct + func (_m *VersionInterface) GetVersion(ctx context.Context, r *admin.GetVersionRequest) (*admin.GetVersionResponse, error) + func (_m *VersionInterface) OnGetVersion(ctx context.Context, r *admin.GetVersionRequest) *VersionInterface_GetVersion + func (_m *VersionInterface) OnGetVersionMatch(matchers ...interface{}) *VersionInterface_GetVersion + type VersionInterface_GetVersion struct + func (_m VersionInterface_GetVersion) Return(_a0 *admin.GetVersionResponse, _a1 error) *VersionInterface_GetVersion
Go to main page