Documentation ¶
Index ¶
- func NewMockLaunchPlanManager() interfaces.LaunchPlanInterface
- type CreateExecutionEventFunc
- type CreateExecutionFunc
- type CreateLaunchPlanFunc
- type CreateNodeEventFunc
- type CreateProjectFunc
- type CreateTaskExecutionEventFunc
- type CreateTaskFunc
- type CreateWorkflowFunc
- type DeleteProjectDomainFunc
- type GetActiveLaunchPlanFunc
- type GetExecutionDataFunc
- type GetExecutionFunc
- type GetLaunchPlanFunc
- type GetNamedEntityFunc
- type GetNodeExecutionDataFunc
- type GetNodeExecutionFunc
- type GetProjectDomainFunc
- type GetResourceFunc
- type GetTaskExecutionDataFunc
- type GetTaskExecutionFunc
- type ListActiveLaunchPlansFunc
- type ListExecutionFunc
- type ListLaunchPlanIdsFunc
- type ListLaunchPlansFunc
- type ListNamedEntitiesFunc
- type ListNodeExecutionsForTaskFunc
- type ListNodeExecutionsFunc
- type ListProjectFunc
- type ListResourceFunc
- type ListTaskExecutionsFunc
- type ListUniqueIdsFunc
- type MockExecutionManager
- 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
- 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
- func (m *MockNodeExecutionManager) CreateNodeEvent(ctx context.Context, request admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, 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
- 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
- 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) 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) SetUpdateProjectDomainAttributes(updateProjectDomainFunc UpdateProjectDomainFunc)
- 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
- 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
- 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
- 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)
- 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 RecoverExecutionFunc
- type RelaunchExecutionFunc
- type TerminateExecutionFunc
- type UpdateExecutionFunc
- type UpdateLaunchPlanFunc
- type UpdateNamedEntityFunc
- type UpdateProjectDomainFunc
- type UpdateProjectFunc
- type VersionInterface
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMockLaunchPlanManager ¶
func NewMockLaunchPlanManager() interfaces.LaunchPlanInterface
Types ¶
type CreateExecutionEventFunc ¶
type CreateExecutionEventFunc func(ctx context.Context, request admin.WorkflowExecutionEventRequest) ( *admin.WorkflowExecutionEventResponse, error)
type CreateExecutionFunc ¶
type CreateExecutionFunc func( ctx context.Context, request admin.ExecutionCreateRequest, requestedAt time.Time) ( *admin.ExecutionCreateResponse, error)
type CreateLaunchPlanFunc ¶
type CreateLaunchPlanFunc func(ctx context.Context, request admin.LaunchPlanCreateRequest) ( *admin.LaunchPlanCreateResponse, error)
type CreateNodeEventFunc ¶
type CreateNodeEventFunc func(ctx context.Context, request admin.NodeExecutionEventRequest) ( *admin.NodeExecutionEventResponse, error)
type CreateProjectFunc ¶
type CreateProjectFunc func(ctx context.Context, request admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)
type CreateTaskExecutionEventFunc ¶
type CreateTaskExecutionEventFunc func(ctx context.Context, request admin.TaskExecutionEventRequest) ( *admin.TaskExecutionEventResponse, error)
type CreateTaskFunc ¶
type CreateTaskFunc func(ctx context.Context, request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)
type CreateWorkflowFunc ¶
type CreateWorkflowFunc func(ctx context.Context, request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)
type DeleteProjectDomainFunc ¶ added in v0.3.38
type DeleteProjectDomainFunc func(ctx context.Context, request admin.ProjectDomainAttributesDeleteRequest) ( *admin.ProjectDomainAttributesDeleteResponse, error)
type GetActiveLaunchPlanFunc ¶
type GetActiveLaunchPlanFunc func(ctx context.Context, request admin.ActiveLaunchPlanRequest) ( *admin.LaunchPlan, error)
type GetExecutionDataFunc ¶
type GetExecutionDataFunc func(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) ( *admin.WorkflowExecutionGetDataResponse, error)
type GetExecutionFunc ¶
type GetLaunchPlanFunc ¶
type GetLaunchPlanFunc func(ctx context.Context, request admin.ObjectGetRequest) ( *admin.LaunchPlan, error)
type GetNamedEntityFunc ¶ added in v0.3.38
type GetNamedEntityFunc func(ctx context.Context, request admin.NamedEntityGetRequest) (*admin.NamedEntity, error)
type GetNodeExecutionDataFunc ¶
type GetNodeExecutionDataFunc func( ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)
type GetNodeExecutionFunc ¶
type GetNodeExecutionFunc func(ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)
type GetProjectDomainFunc ¶ added in v0.3.38
type GetProjectDomainFunc func(ctx context.Context, request admin.ProjectDomainAttributesGetRequest) ( *admin.ProjectDomainAttributesGetResponse, error)
type GetResourceFunc ¶ added in v0.3.38
type GetResourceFunc func(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, error)
type GetTaskExecutionDataFunc ¶
type GetTaskExecutionDataFunc func(ctx context.Context, request admin.TaskExecutionGetDataRequest) ( *admin.TaskExecutionGetDataResponse, error)
type GetTaskExecutionFunc ¶
type GetTaskExecutionFunc func(ctx context.Context, request admin.TaskExecutionGetRequest) ( *admin.TaskExecution, error)
type ListActiveLaunchPlansFunc ¶
type ListActiveLaunchPlansFunc func(ctx context.Context, request admin.ActiveLaunchPlanListRequest) ( *admin.LaunchPlanList, error)
type ListExecutionFunc ¶
type ListExecutionFunc func(ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error)
type ListLaunchPlanIdsFunc ¶
type ListLaunchPlanIdsFunc func(ctx context.Context, request admin.NamedEntityIdentifierListRequest) ( *admin.NamedEntityIdentifierList, error)
type ListLaunchPlansFunc ¶
type ListLaunchPlansFunc func(ctx context.Context, request admin.ResourceListRequest) ( *admin.LaunchPlanList, error)
type ListNamedEntitiesFunc ¶ added in v0.3.38
type ListNamedEntitiesFunc func(ctx context.Context, request admin.NamedEntityListRequest) (*admin.NamedEntityList, error)
type ListNodeExecutionsForTaskFunc ¶
type ListNodeExecutionsForTaskFunc func(ctx context.Context, request admin.NodeExecutionForTaskListRequest) ( *admin.NodeExecutionList, error)
type ListNodeExecutionsFunc ¶
type ListNodeExecutionsFunc func( ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)
type ListProjectFunc ¶
type ListResourceFunc ¶ added in v0.3.38
type ListResourceFunc func(ctx context.Context, request admin.ListMatchableAttributesRequest) ( *admin.ListMatchableAttributesResponse, error)
type ListTaskExecutionsFunc ¶
type ListTaskExecutionsFunc func(ctx context.Context, request admin.TaskExecutionListRequest) ( *admin.TaskExecutionList, error)
type ListUniqueIdsFunc ¶
type ListUniqueIdsFunc func(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
type MockExecutionManager ¶
type MockExecutionManager struct { RecoverExecutionFunc RecoverExecutionFunc // contains filtered or unexported fields }
func (*MockExecutionManager) CreateExecution ¶
func (m *MockExecutionManager) CreateExecution( ctx context.Context, request admin.ExecutionCreateRequest, requestedAt time.Time) ( *admin.ExecutionCreateResponse, error)
func (*MockExecutionManager) CreateWorkflowEvent ¶
func (m *MockExecutionManager) CreateWorkflowEvent( ctx context.Context, request admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error)
func (*MockExecutionManager) GetExecution ¶
func (m *MockExecutionManager) GetExecution( ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error)
func (*MockExecutionManager) GetExecutionData ¶
func (m *MockExecutionManager) GetExecutionData(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) ( *admin.WorkflowExecutionGetDataResponse, error)
func (*MockExecutionManager) ListExecutions ¶
func (m *MockExecutionManager) ListExecutions( ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error)
func (*MockExecutionManager) RecoverExecution ¶ added in v0.6.18
func (m *MockExecutionManager) RecoverExecution(ctx context.Context, request admin.ExecutionRecoverRequest, requestedAt time.Time) ( *admin.ExecutionCreateResponse, error)
func (*MockExecutionManager) RelaunchExecution ¶
func (m *MockExecutionManager) RelaunchExecution( ctx context.Context, request admin.ExecutionRelaunchRequest, requestedAt time.Time) ( *admin.ExecutionCreateResponse, error)
func (*MockExecutionManager) SetCreateCallback ¶
func (m *MockExecutionManager) SetCreateCallback(createFunction CreateExecutionFunc)
func (*MockExecutionManager) SetCreateEventCallback ¶
func (m *MockExecutionManager) SetCreateEventCallback(createEventFunc CreateExecutionEventFunc)
func (*MockExecutionManager) SetGetCallback ¶
func (m *MockExecutionManager) SetGetCallback(getExecutionFunc GetExecutionFunc)
func (*MockExecutionManager) SetGetDataCallback ¶
func (m *MockExecutionManager) SetGetDataCallback(getExecutionDataFunc GetExecutionDataFunc)
func (*MockExecutionManager) SetListCallback ¶
func (m *MockExecutionManager) SetListCallback(listExecutionFunc ListExecutionFunc)
func (*MockExecutionManager) SetRelaunchCallback ¶
func (m *MockExecutionManager) SetRelaunchCallback(relaunchFunction RelaunchExecutionFunc)
func (*MockExecutionManager) SetTerminateExecutionCallback ¶
func (m *MockExecutionManager) SetTerminateExecutionCallback(terminateExecutionFunc TerminateExecutionFunc)
func (*MockExecutionManager) SetUpdateExecutionCallback ¶ added in v0.6.77
func (m *MockExecutionManager) SetUpdateExecutionCallback(updateExecutionFunc UpdateExecutionFunc)
func (*MockExecutionManager) TerminateExecution ¶
func (m *MockExecutionManager) TerminateExecution( ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)
func (*MockExecutionManager) UpdateExecution ¶ added in v0.6.77
func (m *MockExecutionManager) UpdateExecution( ctx context.Context, request admin.ExecutionUpdateRequest) (*admin.ExecutionUpdateResponse, error)
type MockLaunchPlanManager ¶
type MockLaunchPlanManager struct {
// contains filtered or unexported fields
}
func (*MockLaunchPlanManager) CreateLaunchPlan ¶
func (r *MockLaunchPlanManager) CreateLaunchPlan( ctx context.Context, request admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)
func (*MockLaunchPlanManager) GetActiveLaunchPlan ¶
func (r *MockLaunchPlanManager) GetActiveLaunchPlan(ctx context.Context, request admin.ActiveLaunchPlanRequest) ( *admin.LaunchPlan, error)
func (*MockLaunchPlanManager) GetLaunchPlan ¶
func (r *MockLaunchPlanManager) GetLaunchPlan(ctx context.Context, request admin.ObjectGetRequest) ( *admin.LaunchPlan, error)
func (*MockLaunchPlanManager) ListActiveLaunchPlans ¶
func (r *MockLaunchPlanManager) ListActiveLaunchPlans(ctx context.Context, request admin.ActiveLaunchPlanListRequest) ( *admin.LaunchPlanList, error)
func (*MockLaunchPlanManager) ListLaunchPlanIds ¶
func (r *MockLaunchPlanManager) ListLaunchPlanIds(ctx context.Context, request admin.NamedEntityIdentifierListRequest) ( *admin.NamedEntityIdentifierList, error)
func (*MockLaunchPlanManager) ListLaunchPlans ¶
func (r *MockLaunchPlanManager) ListLaunchPlans(ctx context.Context, request admin.ResourceListRequest) ( *admin.LaunchPlanList, error)
func (*MockLaunchPlanManager) SetCreateCallback ¶
func (r *MockLaunchPlanManager) SetCreateCallback(createFunction CreateLaunchPlanFunc)
func (*MockLaunchPlanManager) SetGetActiveLaunchPlanCallback ¶
func (r *MockLaunchPlanManager) SetGetActiveLaunchPlanCallback(plansFunc GetActiveLaunchPlanFunc)
func (*MockLaunchPlanManager) SetListActiveLaunchPlansCallback ¶
func (r *MockLaunchPlanManager) SetListActiveLaunchPlansCallback(plansFunc ListActiveLaunchPlansFunc)
func (*MockLaunchPlanManager) SetListLaunchPlansCallback ¶
func (r *MockLaunchPlanManager) SetListLaunchPlansCallback(listLaunchPlansFunc ListLaunchPlansFunc)
func (*MockLaunchPlanManager) SetUpdateLaunchPlan ¶
func (r *MockLaunchPlanManager) SetUpdateLaunchPlan(updateFunction UpdateLaunchPlanFunc)
func (*MockLaunchPlanManager) UpdateLaunchPlan ¶
func (r *MockLaunchPlanManager) UpdateLaunchPlan(ctx context.Context, request admin.LaunchPlanUpdateRequest) ( *admin.LaunchPlanUpdateResponse, error)
type MockNodeExecutionManager ¶
type MockNodeExecutionManager struct {
// contains filtered or unexported fields
}
func (*MockNodeExecutionManager) CreateNodeEvent ¶
func (m *MockNodeExecutionManager) CreateNodeEvent( ctx context.Context, request admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error)
func (*MockNodeExecutionManager) GetNodeExecution ¶
func (m *MockNodeExecutionManager) GetNodeExecution( ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)
func (*MockNodeExecutionManager) GetNodeExecutionData ¶
func (m *MockNodeExecutionManager) GetNodeExecutionData( ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)
func (*MockNodeExecutionManager) ListNodeExecutions ¶
func (m *MockNodeExecutionManager) ListNodeExecutions( ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)
func (*MockNodeExecutionManager) ListNodeExecutionsForTask ¶
func (m *MockNodeExecutionManager) ListNodeExecutionsForTask( ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)
func (*MockNodeExecutionManager) SetCreateNodeEventCallback ¶
func (m *MockNodeExecutionManager) SetCreateNodeEventCallback(createNodeEventFunc CreateNodeEventFunc)
func (*MockNodeExecutionManager) SetGetNodeExecutionDataFunc ¶
func (m *MockNodeExecutionManager) SetGetNodeExecutionDataFunc(getNodeExecutionDataFunc GetNodeExecutionDataFunc)
func (*MockNodeExecutionManager) SetGetNodeExecutionFunc ¶
func (m *MockNodeExecutionManager) SetGetNodeExecutionFunc(getNodeExecutionFunc GetNodeExecutionFunc)
func (*MockNodeExecutionManager) SetListNodeExecutionsForTaskFunc ¶
func (m *MockNodeExecutionManager) SetListNodeExecutionsForTaskFunc(listNodeExecutionsForTaskFunc ListNodeExecutionsForTaskFunc)
func (*MockNodeExecutionManager) SetListNodeExecutionsFunc ¶
func (m *MockNodeExecutionManager) SetListNodeExecutionsFunc(listNodeExecutionsFunc ListNodeExecutionsFunc)
type MockProjectManager ¶
type MockProjectManager struct {
// contains filtered or unexported fields
}
func (*MockProjectManager) CreateProject ¶
func (m *MockProjectManager) CreateProject(ctx context.Context, request admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)
func (*MockProjectManager) ListProjects ¶
func (m *MockProjectManager) ListProjects( ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error)
func (*MockProjectManager) SetCreateProject ¶
func (m *MockProjectManager) SetCreateProject(createProjectFunc CreateProjectFunc)
func (*MockProjectManager) SetListCallback ¶
func (m *MockProjectManager) SetListCallback(listProjectFunc ListProjectFunc)
func (*MockProjectManager) UpdateProject ¶ added in v0.3.38
func (m *MockProjectManager) UpdateProject(ctx context.Context, request admin.Project) (*admin.ProjectUpdateResponse, error)
type MockResourceManager ¶ added in v0.3.38
type MockResourceManager struct { GetFunc GetProjectDomainFunc DeleteFunc DeleteProjectDomainFunc ListFunc ListResourceFunc GetResourceFunc GetResourceFunc // contains filtered or unexported fields }
func (*MockResourceManager) DeleteProjectDomainAttributes ¶ added in v0.3.38
func (m *MockResourceManager) DeleteProjectDomainAttributes( ctx context.Context, request admin.ProjectDomainAttributesDeleteRequest) ( *admin.ProjectDomainAttributesDeleteResponse, error)
func (*MockResourceManager) DeleteWorkflowAttributes ¶ added in v0.3.38
func (m *MockResourceManager) DeleteWorkflowAttributes(ctx context.Context, request admin.WorkflowAttributesDeleteRequest) ( *admin.WorkflowAttributesDeleteResponse, error)
func (*MockResourceManager) GetProjectDomainAttributes ¶ added in v0.3.38
func (m *MockResourceManager) GetProjectDomainAttributes( ctx context.Context, request admin.ProjectDomainAttributesGetRequest) ( *admin.ProjectDomainAttributesGetResponse, error)
func (*MockResourceManager) GetResource ¶ added in v0.3.38
func (m *MockResourceManager) GetResource(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, error)
func (*MockResourceManager) GetWorkflowAttributes ¶ added in v0.3.38
func (m *MockResourceManager) GetWorkflowAttributes(ctx context.Context, request admin.WorkflowAttributesGetRequest) ( *admin.WorkflowAttributesGetResponse, error)
func (*MockResourceManager) ListAll ¶ added in v0.3.38
func (m *MockResourceManager) ListAll(ctx context.Context, request admin.ListMatchableAttributesRequest) ( *admin.ListMatchableAttributesResponse, error)
func (*MockResourceManager) SetUpdateProjectDomainAttributes ¶ added in v0.3.38
func (m *MockResourceManager) SetUpdateProjectDomainAttributes(updateProjectDomainFunc UpdateProjectDomainFunc)
func (*MockResourceManager) UpdateProjectDomainAttributes ¶ added in v0.3.38
func (m *MockResourceManager) UpdateProjectDomainAttributes( ctx context.Context, request admin.ProjectDomainAttributesUpdateRequest) ( *admin.ProjectDomainAttributesUpdateResponse, error)
func (*MockResourceManager) UpdateWorkflowAttributes ¶ added in v0.3.38
func (m *MockResourceManager) UpdateWorkflowAttributes(ctx context.Context, request admin.WorkflowAttributesUpdateRequest) ( *admin.WorkflowAttributesUpdateResponse, error)
type MockTaskExecutionManager ¶
type MockTaskExecutionManager struct {
// contains filtered or unexported fields
}
func (*MockTaskExecutionManager) CreateTaskExecutionEvent ¶
func (m *MockTaskExecutionManager) CreateTaskExecutionEvent( ctx context.Context, request admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error)
func (*MockTaskExecutionManager) GetTaskExecution ¶
func (m *MockTaskExecutionManager) GetTaskExecution( ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)
func (*MockTaskExecutionManager) GetTaskExecutionData ¶
func (m *MockTaskExecutionManager) GetTaskExecutionData( ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)
func (*MockTaskExecutionManager) ListTaskExecutions ¶
func (m *MockTaskExecutionManager) ListTaskExecutions( ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)
func (*MockTaskExecutionManager) SetCreateTaskEventCallback ¶
func (m *MockTaskExecutionManager) SetCreateTaskEventCallback( createFunc CreateTaskExecutionEventFunc)
func (*MockTaskExecutionManager) SetGetTaskExecutionCallback ¶
func (m *MockTaskExecutionManager) SetGetTaskExecutionCallback( getTaskExecutionFunc GetTaskExecutionFunc)
func (*MockTaskExecutionManager) SetGetTaskExecutionDataCallback ¶
func (m *MockTaskExecutionManager) SetGetTaskExecutionDataCallback( getTaskExecutionDataFunc GetTaskExecutionDataFunc)
func (*MockTaskExecutionManager) SetListTaskExecutionsCallback ¶
func (m *MockTaskExecutionManager) SetListTaskExecutionsCallback( listTaskExecutionsFunc ListTaskExecutionsFunc)
type MockTaskManager ¶
type MockTaskManager struct {
// contains filtered or unexported fields
}
func (*MockTaskManager) CreateTask ¶
func (r *MockTaskManager) CreateTask( ctx context.Context, request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)
func (*MockTaskManager) GetTask ¶
func (r *MockTaskManager) GetTask(ctx context.Context, request admin.ObjectGetRequest) (*admin.Task, error)
func (*MockTaskManager) ListTasks ¶
func (r *MockTaskManager) ListTasks(ctx context.Context, request admin.ResourceListRequest) (*admin.TaskList, error)
func (*MockTaskManager) ListUniqueTaskIdentifiers ¶
func (r *MockTaskManager) ListUniqueTaskIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) ( *admin.NamedEntityIdentifierList, error)
func (*MockTaskManager) SetCreateCallback ¶
func (r *MockTaskManager) SetCreateCallback(createFunction CreateTaskFunc)
func (*MockTaskManager) SetListUniqueIdsFunc ¶
func (r *MockTaskManager) SetListUniqueIdsFunc(fn ListUniqueIdsFunc)
type MockWorkflowManager ¶
type MockWorkflowManager struct {
// contains filtered or unexported fields
}
func (*MockWorkflowManager) CreateWorkflow ¶
func (r *MockWorkflowManager) CreateWorkflow( ctx context.Context, request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)
func (*MockWorkflowManager) GetWorkflow ¶
func (r *MockWorkflowManager) GetWorkflow( ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error)
func (*MockWorkflowManager) ListWorkflowIdentifiers ¶
func (r *MockWorkflowManager) ListWorkflowIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) ( *admin.NamedEntityIdentifierList, error)
func (*MockWorkflowManager) ListWorkflows ¶
func (r *MockWorkflowManager) ListWorkflows(ctx context.Context, request admin.ResourceListRequest) (*admin.WorkflowList, error)
func (*MockWorkflowManager) SetCreateCallback ¶
func (r *MockWorkflowManager) SetCreateCallback(createFunction CreateWorkflowFunc)
type NamedEntityManager ¶ added in v0.3.38
type NamedEntityManager struct { GetNamedEntityFunc GetNamedEntityFunc UpdateNamedEntityFunc UpdateNamedEntityFunc ListNamedEntitiesFunc ListNamedEntitiesFunc }
func (*NamedEntityManager) GetNamedEntity ¶ added in v0.3.38
func (m *NamedEntityManager) GetNamedEntity(ctx context.Context, request admin.NamedEntityGetRequest) (*admin.NamedEntity, error)
func (*NamedEntityManager) ListNamedEntities ¶ added in v0.3.38
func (m *NamedEntityManager) ListNamedEntities(ctx context.Context, request admin.NamedEntityListRequest) (*admin.NamedEntityList, error)
func (*NamedEntityManager) UpdateNamedEntity ¶ added in v0.3.38
func (m *NamedEntityManager) UpdateNamedEntity(ctx context.Context, request admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)
type RecoverExecutionFunc ¶ added in v0.6.18
type RecoverExecutionFunc func(ctx context.Context, request admin.ExecutionRecoverRequest, requestedAt time.Time) ( *admin.ExecutionCreateResponse, error)
type RelaunchExecutionFunc ¶
type RelaunchExecutionFunc func( ctx context.Context, request admin.ExecutionRelaunchRequest, requestedAt time.Time) ( *admin.ExecutionCreateResponse, error)
type TerminateExecutionFunc ¶
type TerminateExecutionFunc func( ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)
type UpdateExecutionFunc ¶ added in v0.6.77
type UpdateExecutionFunc func(ctx context.Context, request admin.ExecutionUpdateRequest) (*admin.ExecutionUpdateResponse, error)
type UpdateLaunchPlanFunc ¶
type UpdateLaunchPlanFunc func(ctx context.Context, request admin.LaunchPlanUpdateRequest) ( *admin.LaunchPlanUpdateResponse, error)
type UpdateNamedEntityFunc ¶ added in v0.3.38
type UpdateNamedEntityFunc func(ctx context.Context, request admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)
type UpdateProjectDomainFunc ¶ added in v0.1.4
type UpdateProjectDomainFunc func(ctx context.Context, request admin.ProjectDomainAttributesUpdateRequest) ( *admin.ProjectDomainAttributesUpdateResponse, error)
type UpdateProjectFunc ¶ added in v0.3.38
type VersionInterface ¶ added in v0.4.10
VersionInterface is an autogenerated mock type for the VersionInterface type
func (*VersionInterface) GetVersion ¶ added in v0.4.10
func (_m *VersionInterface) GetVersion(ctx context.Context, r *admin.GetVersionRequest) (*admin.GetVersionResponse, error)
GetVersion provides a mock function with given fields: ctx, r
func (*VersionInterface) OnGetVersion ¶ added in v0.4.10
func (_m *VersionInterface) OnGetVersion(ctx context.Context, r *admin.GetVersionRequest) *VersionInterface_GetVersion
func (*VersionInterface) OnGetVersionMatch ¶ added in v0.4.10
func (_m *VersionInterface) OnGetVersionMatch(matchers ...interface{}) *VersionInterface_GetVersion
type VersionInterface_GetVersion ¶ added in v0.4.10
func (VersionInterface_GetVersion) Return ¶ added in v0.4.10
func (_m VersionInterface_GetVersion) Return(_a0 *admin.GetVersionResponse, _a1 error) *VersionInterface_GetVersion
Click to show internal directories.
Click to hide internal directories.