Documentation
¶
Index ¶
- func NewMockLaunchPlanManager() interfaces.LaunchPlanInterface
- type CreateExecutionEventFunc
- type CreateExecutionFunc
- type CreateLaunchPlanFunc
- type CreateNodeEventFunc
- type CreateProjectFunc
- type CreateTaskExecutionEventFunc
- type CreateTaskFunc
- type CreateWorkflowFunc
- type DeleteProjectAttrFunc
- type DeleteProjectDomainFunc
- type GetActiveLaunchPlanFunc
- type GetDomainsFunc
- type GetExecutionDataFunc
- type GetExecutionFunc
- type GetLaunchPlanFunc
- type GetNamedEntityFunc
- type GetNodeExecutionDataFunc
- type GetNodeExecutionFunc
- type GetProjectAttrFunc
- type GetProjectDomainFunc
- type GetProjectFunc
- type GetResourceFunc
- type GetTaskExecutionDataFunc
- type GetTaskExecutionFunc
- type GetWorkflowFunc
- type ListActiveLaunchPlansFunc
- type ListExecutionFunc
- type ListLaunchPlanIdsFunc
- type ListLaunchPlansFunc
- type ListNamedEntitiesFunc
- type ListNodeExecutionsForTaskFunc
- type ListNodeExecutionsFunc
- type ListProjectFunc
- type ListResourceFunc
- type ListTaskExecutionsFunc
- type ListUniqueIdsFunc
- type MetricsInterface
- 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
- 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) 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
- func (m *MockProjectManager) CreateProject(ctx context.Context, request *admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)
- func (m *MockProjectManager) GetDomains(ctx context.Context, request *admin.GetDomainRequest) *admin.GetDomainsResponse
- func (m *MockProjectManager) GetProject(ctx context.Context, request *admin.ProjectGetRequest) (*admin.Project, error)
- func (m *MockProjectManager) ListProjects(ctx context.Context, request *admin.ProjectListRequest) (*admin.Projects, error)
- func (m *MockProjectManager) SetCreateProject(createProjectFunc CreateProjectFunc)
- func (m *MockProjectManager) SetGetCallBack(getProjectFunc GetProjectFunc)
- func (m *MockProjectManager) SetListCallback(listProjectFunc ListProjectFunc)
- func (m *MockProjectManager) UpdateProject(ctx context.Context, request *admin.Project) (*admin.ProjectUpdateResponse, error)
- type MockResourceManager
- 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
- 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)
- func (r *MockWorkflowManager) SetGetCallback(getFunction GetWorkflowFunc)
- 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 ResourceInterface
- func (_m *ResourceInterface) DeleteProjectAttributes(ctx context.Context, request *admin.ProjectAttributesDeleteRequest) (*admin.ProjectAttributesDeleteResponse, error)
- func (_m *ResourceInterface) DeleteProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesDeleteRequest) (*admin.ProjectDomainAttributesDeleteResponse, error)
- func (_m *ResourceInterface) DeleteWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesDeleteRequest) (*admin.WorkflowAttributesDeleteResponse, error)
- func (_m *ResourceInterface) GetProjectAttributes(ctx context.Context, request *admin.ProjectAttributesGetRequest) (*admin.ProjectAttributesGetResponse, error)
- func (_m *ResourceInterface) GetProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesGetRequest) (*admin.ProjectDomainAttributesGetResponse, error)
- func (_m *ResourceInterface) GetResource(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, error)
- func (_m *ResourceInterface) GetWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesGetRequest) (*admin.WorkflowAttributesGetResponse, error)
- func (_m *ResourceInterface) ListAll(ctx context.Context, request *admin.ListMatchableAttributesRequest) (*admin.ListMatchableAttributesResponse, error)
- func (_m *ResourceInterface) OnDeleteProjectAttributes(ctx context.Context, request *admin.ProjectAttributesDeleteRequest) *ResourceInterface_DeleteProjectAttributes
- func (_m *ResourceInterface) OnDeleteProjectAttributesMatch(matchers ...interface{}) *ResourceInterface_DeleteProjectAttributes
- func (_m *ResourceInterface) OnDeleteProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesDeleteRequest) *ResourceInterface_DeleteProjectDomainAttributes
- func (_m *ResourceInterface) OnDeleteProjectDomainAttributesMatch(matchers ...interface{}) *ResourceInterface_DeleteProjectDomainAttributes
- func (_m *ResourceInterface) OnDeleteWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesDeleteRequest) *ResourceInterface_DeleteWorkflowAttributes
- func (_m *ResourceInterface) OnDeleteWorkflowAttributesMatch(matchers ...interface{}) *ResourceInterface_DeleteWorkflowAttributes
- func (_m *ResourceInterface) OnGetProjectAttributes(ctx context.Context, request *admin.ProjectAttributesGetRequest) *ResourceInterface_GetProjectAttributes
- func (_m *ResourceInterface) OnGetProjectAttributesMatch(matchers ...interface{}) *ResourceInterface_GetProjectAttributes
- func (_m *ResourceInterface) OnGetProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesGetRequest) *ResourceInterface_GetProjectDomainAttributes
- func (_m *ResourceInterface) OnGetProjectDomainAttributesMatch(matchers ...interface{}) *ResourceInterface_GetProjectDomainAttributes
- func (_m *ResourceInterface) OnGetResource(ctx context.Context, request interfaces.ResourceRequest) *ResourceInterface_GetResource
- func (_m *ResourceInterface) OnGetResourceMatch(matchers ...interface{}) *ResourceInterface_GetResource
- func (_m *ResourceInterface) OnGetWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesGetRequest) *ResourceInterface_GetWorkflowAttributes
- func (_m *ResourceInterface) OnGetWorkflowAttributesMatch(matchers ...interface{}) *ResourceInterface_GetWorkflowAttributes
- func (_m *ResourceInterface) OnListAll(ctx context.Context, request *admin.ListMatchableAttributesRequest) *ResourceInterface_ListAll
- func (_m *ResourceInterface) OnListAllMatch(matchers ...interface{}) *ResourceInterface_ListAll
- func (_m *ResourceInterface) OnUpdateProjectAttributes(ctx context.Context, request *admin.ProjectAttributesUpdateRequest) *ResourceInterface_UpdateProjectAttributes
- func (_m *ResourceInterface) OnUpdateProjectAttributesMatch(matchers ...interface{}) *ResourceInterface_UpdateProjectAttributes
- func (_m *ResourceInterface) OnUpdateProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesUpdateRequest) *ResourceInterface_UpdateProjectDomainAttributes
- func (_m *ResourceInterface) OnUpdateProjectDomainAttributesMatch(matchers ...interface{}) *ResourceInterface_UpdateProjectDomainAttributes
- func (_m *ResourceInterface) OnUpdateWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesUpdateRequest) *ResourceInterface_UpdateWorkflowAttributes
- func (_m *ResourceInterface) OnUpdateWorkflowAttributesMatch(matchers ...interface{}) *ResourceInterface_UpdateWorkflowAttributes
- func (_m *ResourceInterface) UpdateProjectAttributes(ctx context.Context, request *admin.ProjectAttributesUpdateRequest) (*admin.ProjectAttributesUpdateResponse, error)
- func (_m *ResourceInterface) UpdateProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesUpdateRequest) (*admin.ProjectDomainAttributesUpdateResponse, error)
- func (_m *ResourceInterface) UpdateWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesUpdateRequest) (*admin.WorkflowAttributesUpdateResponse, error)
- type ResourceInterface_DeleteProjectAttributes
- type ResourceInterface_DeleteProjectDomainAttributes
- type ResourceInterface_DeleteWorkflowAttributes
- type ResourceInterface_GetProjectAttributes
- type ResourceInterface_GetProjectDomainAttributes
- type ResourceInterface_GetResource
- type ResourceInterface_GetWorkflowAttributes
- type ResourceInterface_ListAll
- type ResourceInterface_UpdateProjectAttributes
- type ResourceInterface_UpdateProjectDomainAttributes
- type ResourceInterface_UpdateWorkflowAttributes
- type SignalInterface
- func (_m *SignalInterface) EXPECT() *SignalInterface_Expecter
- 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) SetSignal(ctx context.Context, request *admin.SignalSetRequest) (*admin.SignalSetResponse, error)
- type SignalInterface_Expecter
- func (_e *SignalInterface_Expecter) GetOrCreateSignal(ctx interface{}, request interface{}) *SignalInterface_GetOrCreateSignal_Call
- func (_e *SignalInterface_Expecter) ListSignals(ctx interface{}, request interface{}) *SignalInterface_ListSignals_Call
- func (_e *SignalInterface_Expecter) SetSignal(ctx interface{}, request interface{}) *SignalInterface_SetSignal_Call
- type SignalInterface_GetOrCreateSignal_Call
- func (_c *SignalInterface_GetOrCreateSignal_Call) Return(_a0 *admin.Signal, _a1 error) *SignalInterface_GetOrCreateSignal_Call
- func (_c *SignalInterface_GetOrCreateSignal_Call) Run(run func(ctx context.Context, request *admin.SignalGetOrCreateRequest)) *SignalInterface_GetOrCreateSignal_Call
- func (_c *SignalInterface_GetOrCreateSignal_Call) RunAndReturn(...) *SignalInterface_GetOrCreateSignal_Call
- type SignalInterface_ListSignals_Call
- func (_c *SignalInterface_ListSignals_Call) Return(_a0 *admin.SignalList, _a1 error) *SignalInterface_ListSignals_Call
- func (_c *SignalInterface_ListSignals_Call) Run(run func(ctx context.Context, request *admin.SignalListRequest)) *SignalInterface_ListSignals_Call
- func (_c *SignalInterface_ListSignals_Call) RunAndReturn(run func(context.Context, *admin.SignalListRequest) (*admin.SignalList, error)) *SignalInterface_ListSignals_Call
- type SignalInterface_SetSignal_Call
- func (_c *SignalInterface_SetSignal_Call) Return(_a0 *admin.SignalSetResponse, _a1 error) *SignalInterface_SetSignal_Call
- func (_c *SignalInterface_SetSignal_Call) Run(run func(ctx context.Context, request *admin.SignalSetRequest)) *SignalInterface_SetSignal_Call
- func (_c *SignalInterface_SetSignal_Call) RunAndReturn(...) *SignalInterface_SetSignal_Call
- type TerminateExecutionFunc
- type UpdateExecutionFunc
- type UpdateLaunchPlanFunc
- type UpdateNamedEntityFunc
- type UpdateProjectAttrsFunc
- 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 DeleteProjectAttrFunc ¶
type DeleteProjectAttrFunc func(ctx context.Context, request *admin.ProjectAttributesDeleteRequest) ( *admin.ProjectAttributesDeleteResponse, error)
type DeleteProjectDomainFunc ¶
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 GetDomainsFunc ¶ added in v1.13.0
type GetDomainsFunc func(ctx context.Context, request *admin.GetDomainRequest) *admin.GetDomainsResponse
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 ¶
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 GetProjectAttrFunc ¶
type GetProjectAttrFunc func(ctx context.Context, request *admin.ProjectAttributesGetRequest) ( *admin.ProjectAttributesGetResponse, error)
type GetProjectDomainFunc ¶
type GetProjectDomainFunc func(ctx context.Context, request *admin.ProjectDomainAttributesGetRequest) ( *admin.ProjectDomainAttributesGetResponse, error)
type GetProjectFunc ¶ added in v1.12.0
type GetResourceFunc ¶
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 GetWorkflowFunc ¶
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 ¶
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 ¶
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 MetricsInterface ¶
MetricsInterface is an autogenerated mock type for the MetricsInterface type
func (*MetricsInterface) GetExecutionMetrics ¶
func (_m *MetricsInterface) GetExecutionMetrics(ctx context.Context, request *admin.WorkflowExecutionGetMetricsRequest) (*admin.WorkflowExecutionGetMetricsResponse, error)
GetExecutionMetrics provides a mock function with given fields: ctx, request
func (*MetricsInterface) OnGetExecutionMetrics ¶
func (_m *MetricsInterface) OnGetExecutionMetrics(ctx context.Context, request *admin.WorkflowExecutionGetMetricsRequest) *MetricsInterface_GetExecutionMetrics
func (*MetricsInterface) OnGetExecutionMetricsMatch ¶
func (_m *MetricsInterface) OnGetExecutionMetricsMatch(matchers ...interface{}) *MetricsInterface_GetExecutionMetrics
type MetricsInterface_GetExecutionMetrics ¶
func (MetricsInterface_GetExecutionMetrics) Return ¶
func (_m MetricsInterface_GetExecutionMetrics) Return(_a0 *admin.WorkflowExecutionGetMetricsResponse, _a1 error) *MetricsInterface_GetExecutionMetrics
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 ¶
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 ¶
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 ¶
func (m *MockExecutionManager) UpdateExecution(ctx context.Context, request *admin.ExecutionUpdateRequest, requestedAt time.Time) (*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) GetDynamicNodeWorkflow ¶ added in v1.10.7
func (m *MockNodeExecutionManager) GetDynamicNodeWorkflow(ctx context.Context, request *admin.GetDynamicNodeWorkflowRequest) (*admin.DynamicNodeWorkflowResponse, 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) GetDomains ¶ added in v1.13.0
func (m *MockProjectManager) GetDomains(ctx context.Context, request *admin.GetDomainRequest) *admin.GetDomainsResponse
func (*MockProjectManager) GetProject ¶ added in v1.12.0
func (m *MockProjectManager) GetProject(ctx context.Context, request *admin.ProjectGetRequest) (*admin.Project, 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) SetGetCallBack ¶ added in v1.12.0
func (m *MockProjectManager) SetGetCallBack(getProjectFunc GetProjectFunc)
func (*MockProjectManager) SetListCallback ¶
func (m *MockProjectManager) SetListCallback(listProjectFunc ListProjectFunc)
func (*MockProjectManager) UpdateProject ¶
func (m *MockProjectManager) UpdateProject(ctx context.Context, request *admin.Project) (*admin.ProjectUpdateResponse, error)
type MockResourceManager ¶
type MockResourceManager struct { GetFunc GetProjectDomainFunc DeleteFunc DeleteProjectDomainFunc ListFunc ListResourceFunc GetResourceFunc GetResourceFunc // contains filtered or unexported fields }
func (*MockResourceManager) DeleteProjectAttributes ¶
func (m *MockResourceManager) DeleteProjectAttributes(ctx context.Context, request *admin.ProjectAttributesDeleteRequest) ( *admin.ProjectAttributesDeleteResponse, error)
func (*MockResourceManager) DeleteProjectDomainAttributes ¶
func (m *MockResourceManager) DeleteProjectDomainAttributes( ctx context.Context, request *admin.ProjectDomainAttributesDeleteRequest) ( *admin.ProjectDomainAttributesDeleteResponse, error)
func (*MockResourceManager) DeleteWorkflowAttributes ¶
func (m *MockResourceManager) DeleteWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesDeleteRequest) ( *admin.WorkflowAttributesDeleteResponse, error)
func (*MockResourceManager) GetProjectAttributes ¶
func (m *MockResourceManager) GetProjectAttributes(ctx context.Context, request *admin.ProjectAttributesGetRequest) ( *admin.ProjectAttributesGetResponse, error)
func (*MockResourceManager) GetProjectDomainAttributes ¶
func (m *MockResourceManager) GetProjectDomainAttributes( ctx context.Context, request *admin.ProjectDomainAttributesGetRequest) ( *admin.ProjectDomainAttributesGetResponse, error)
func (*MockResourceManager) GetResource ¶
func (m *MockResourceManager) GetResource(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, error)
func (*MockResourceManager) GetWorkflowAttributes ¶
func (m *MockResourceManager) GetWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesGetRequest) ( *admin.WorkflowAttributesGetResponse, error)
func (*MockResourceManager) ListAll ¶
func (m *MockResourceManager) ListAll(ctx context.Context, request *admin.ListMatchableAttributesRequest) ( *admin.ListMatchableAttributesResponse, error)
func (*MockResourceManager) SetDeleteProjectAttributes ¶
func (m *MockResourceManager) SetDeleteProjectAttributes(deleteProjectFunc DeleteProjectAttrFunc)
func (*MockResourceManager) SetGetProjectAttributes ¶
func (m *MockResourceManager) SetGetProjectAttributes(getProjectFunc GetProjectAttrFunc)
func (*MockResourceManager) SetUpdateProjectAttributes ¶
func (m *MockResourceManager) SetUpdateProjectAttributes(updateProjectAttrsFunc UpdateProjectAttrsFunc)
func (*MockResourceManager) SetUpdateProjectDomainAttributes ¶
func (m *MockResourceManager) SetUpdateProjectDomainAttributes(updateProjectDomainFunc UpdateProjectDomainFunc)
func (*MockResourceManager) UpdateProjectAttributes ¶
func (m *MockResourceManager) UpdateProjectAttributes(ctx context.Context, request *admin.ProjectAttributesUpdateRequest) ( *admin.ProjectAttributesUpdateResponse, error)
func (*MockResourceManager) UpdateProjectDomainAttributes ¶
func (m *MockResourceManager) UpdateProjectDomainAttributes( ctx context.Context, request *admin.ProjectDomainAttributesUpdateRequest) ( *admin.ProjectDomainAttributesUpdateResponse, error)
func (*MockResourceManager) UpdateWorkflowAttributes ¶
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)
func (*MockWorkflowManager) SetGetCallback ¶
func (r *MockWorkflowManager) SetGetCallback(getFunction GetWorkflowFunc)
type NamedEntityManager ¶
type NamedEntityManager struct { GetNamedEntityFunc GetNamedEntityFunc UpdateNamedEntityFunc UpdateNamedEntityFunc ListNamedEntitiesFunc ListNamedEntitiesFunc }
func (*NamedEntityManager) GetNamedEntity ¶
func (m *NamedEntityManager) GetNamedEntity(ctx context.Context, request *admin.NamedEntityGetRequest) (*admin.NamedEntity, error)
func (*NamedEntityManager) ListNamedEntities ¶
func (m *NamedEntityManager) ListNamedEntities(ctx context.Context, request *admin.NamedEntityListRequest) (*admin.NamedEntityList, error)
func (*NamedEntityManager) UpdateNamedEntity ¶
func (m *NamedEntityManager) UpdateNamedEntity(ctx context.Context, request *admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)
type RecoverExecutionFunc ¶
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 ResourceInterface ¶ added in v1.13.3
ResourceInterface is an autogenerated mock type for the ResourceInterface type
func (*ResourceInterface) DeleteProjectAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) DeleteProjectAttributes(ctx context.Context, request *admin.ProjectAttributesDeleteRequest) (*admin.ProjectAttributesDeleteResponse, error)
DeleteProjectAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) DeleteProjectDomainAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) DeleteProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesDeleteRequest) (*admin.ProjectDomainAttributesDeleteResponse, error)
DeleteProjectDomainAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) DeleteWorkflowAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) DeleteWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesDeleteRequest) (*admin.WorkflowAttributesDeleteResponse, error)
DeleteWorkflowAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) GetProjectAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) GetProjectAttributes(ctx context.Context, request *admin.ProjectAttributesGetRequest) (*admin.ProjectAttributesGetResponse, error)
GetProjectAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) GetProjectDomainAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) GetProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesGetRequest) (*admin.ProjectDomainAttributesGetResponse, error)
GetProjectDomainAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) GetResource ¶ added in v1.13.3
func (_m *ResourceInterface) GetResource(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, error)
GetResource provides a mock function with given fields: ctx, request
func (*ResourceInterface) GetWorkflowAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) GetWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesGetRequest) (*admin.WorkflowAttributesGetResponse, error)
GetWorkflowAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) ListAll ¶ added in v1.13.3
func (_m *ResourceInterface) ListAll(ctx context.Context, request *admin.ListMatchableAttributesRequest) (*admin.ListMatchableAttributesResponse, error)
ListAll provides a mock function with given fields: ctx, request
func (*ResourceInterface) OnDeleteProjectAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnDeleteProjectAttributes(ctx context.Context, request *admin.ProjectAttributesDeleteRequest) *ResourceInterface_DeleteProjectAttributes
func (*ResourceInterface) OnDeleteProjectAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnDeleteProjectAttributesMatch(matchers ...interface{}) *ResourceInterface_DeleteProjectAttributes
func (*ResourceInterface) OnDeleteProjectDomainAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnDeleteProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesDeleteRequest) *ResourceInterface_DeleteProjectDomainAttributes
func (*ResourceInterface) OnDeleteProjectDomainAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnDeleteProjectDomainAttributesMatch(matchers ...interface{}) *ResourceInterface_DeleteProjectDomainAttributes
func (*ResourceInterface) OnDeleteWorkflowAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnDeleteWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesDeleteRequest) *ResourceInterface_DeleteWorkflowAttributes
func (*ResourceInterface) OnDeleteWorkflowAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnDeleteWorkflowAttributesMatch(matchers ...interface{}) *ResourceInterface_DeleteWorkflowAttributes
func (*ResourceInterface) OnGetProjectAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetProjectAttributes(ctx context.Context, request *admin.ProjectAttributesGetRequest) *ResourceInterface_GetProjectAttributes
func (*ResourceInterface) OnGetProjectAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetProjectAttributesMatch(matchers ...interface{}) *ResourceInterface_GetProjectAttributes
func (*ResourceInterface) OnGetProjectDomainAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesGetRequest) *ResourceInterface_GetProjectDomainAttributes
func (*ResourceInterface) OnGetProjectDomainAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetProjectDomainAttributesMatch(matchers ...interface{}) *ResourceInterface_GetProjectDomainAttributes
func (*ResourceInterface) OnGetResource ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetResource(ctx context.Context, request interfaces.ResourceRequest) *ResourceInterface_GetResource
func (*ResourceInterface) OnGetResourceMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetResourceMatch(matchers ...interface{}) *ResourceInterface_GetResource
func (*ResourceInterface) OnGetWorkflowAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesGetRequest) *ResourceInterface_GetWorkflowAttributes
func (*ResourceInterface) OnGetWorkflowAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnGetWorkflowAttributesMatch(matchers ...interface{}) *ResourceInterface_GetWorkflowAttributes
func (*ResourceInterface) OnListAll ¶ added in v1.13.3
func (_m *ResourceInterface) OnListAll(ctx context.Context, request *admin.ListMatchableAttributesRequest) *ResourceInterface_ListAll
func (*ResourceInterface) OnListAllMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnListAllMatch(matchers ...interface{}) *ResourceInterface_ListAll
func (*ResourceInterface) OnUpdateProjectAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnUpdateProjectAttributes(ctx context.Context, request *admin.ProjectAttributesUpdateRequest) *ResourceInterface_UpdateProjectAttributes
func (*ResourceInterface) OnUpdateProjectAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnUpdateProjectAttributesMatch(matchers ...interface{}) *ResourceInterface_UpdateProjectAttributes
func (*ResourceInterface) OnUpdateProjectDomainAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnUpdateProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesUpdateRequest) *ResourceInterface_UpdateProjectDomainAttributes
func (*ResourceInterface) OnUpdateProjectDomainAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnUpdateProjectDomainAttributesMatch(matchers ...interface{}) *ResourceInterface_UpdateProjectDomainAttributes
func (*ResourceInterface) OnUpdateWorkflowAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) OnUpdateWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesUpdateRequest) *ResourceInterface_UpdateWorkflowAttributes
func (*ResourceInterface) OnUpdateWorkflowAttributesMatch ¶ added in v1.13.3
func (_m *ResourceInterface) OnUpdateWorkflowAttributesMatch(matchers ...interface{}) *ResourceInterface_UpdateWorkflowAttributes
func (*ResourceInterface) UpdateProjectAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) UpdateProjectAttributes(ctx context.Context, request *admin.ProjectAttributesUpdateRequest) (*admin.ProjectAttributesUpdateResponse, error)
UpdateProjectAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) UpdateProjectDomainAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) UpdateProjectDomainAttributes(ctx context.Context, request *admin.ProjectDomainAttributesUpdateRequest) (*admin.ProjectDomainAttributesUpdateResponse, error)
UpdateProjectDomainAttributes provides a mock function with given fields: ctx, request
func (*ResourceInterface) UpdateWorkflowAttributes ¶ added in v1.13.3
func (_m *ResourceInterface) UpdateWorkflowAttributes(ctx context.Context, request *admin.WorkflowAttributesUpdateRequest) (*admin.WorkflowAttributesUpdateResponse, error)
UpdateWorkflowAttributes provides a mock function with given fields: ctx, request
type ResourceInterface_DeleteProjectAttributes ¶ added in v1.13.3
func (ResourceInterface_DeleteProjectAttributes) Return ¶ added in v1.13.3
func (_m ResourceInterface_DeleteProjectAttributes) Return(_a0 *admin.ProjectAttributesDeleteResponse, _a1 error) *ResourceInterface_DeleteProjectAttributes
type ResourceInterface_DeleteProjectDomainAttributes ¶ added in v1.13.3
type ResourceInterface_DeleteWorkflowAttributes ¶ added in v1.13.3
func (ResourceInterface_DeleteWorkflowAttributes) Return ¶ added in v1.13.3
func (_m ResourceInterface_DeleteWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesDeleteResponse, _a1 error) *ResourceInterface_DeleteWorkflowAttributes
type ResourceInterface_GetProjectAttributes ¶ added in v1.13.3
func (ResourceInterface_GetProjectAttributes) Return ¶ added in v1.13.3
func (_m ResourceInterface_GetProjectAttributes) Return(_a0 *admin.ProjectAttributesGetResponse, _a1 error) *ResourceInterface_GetProjectAttributes
type ResourceInterface_GetProjectDomainAttributes ¶ added in v1.13.3
func (ResourceInterface_GetProjectDomainAttributes) Return ¶ added in v1.13.3
func (_m ResourceInterface_GetProjectDomainAttributes) Return(_a0 *admin.ProjectDomainAttributesGetResponse, _a1 error) *ResourceInterface_GetProjectDomainAttributes
type ResourceInterface_GetResource ¶ added in v1.13.3
func (ResourceInterface_GetResource) Return ¶ added in v1.13.3
func (_m ResourceInterface_GetResource) Return(_a0 *interfaces.ResourceResponse, _a1 error) *ResourceInterface_GetResource
type ResourceInterface_GetWorkflowAttributes ¶ added in v1.13.3
func (ResourceInterface_GetWorkflowAttributes) Return ¶ added in v1.13.3
func (_m ResourceInterface_GetWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesGetResponse, _a1 error) *ResourceInterface_GetWorkflowAttributes
type ResourceInterface_ListAll ¶ added in v1.13.3
func (ResourceInterface_ListAll) Return ¶ added in v1.13.3
func (_m ResourceInterface_ListAll) Return(_a0 *admin.ListMatchableAttributesResponse, _a1 error) *ResourceInterface_ListAll
type ResourceInterface_UpdateProjectAttributes ¶ added in v1.13.3
func (ResourceInterface_UpdateProjectAttributes) Return ¶ added in v1.13.3
func (_m ResourceInterface_UpdateProjectAttributes) Return(_a0 *admin.ProjectAttributesUpdateResponse, _a1 error) *ResourceInterface_UpdateProjectAttributes
type ResourceInterface_UpdateProjectDomainAttributes ¶ added in v1.13.3
type ResourceInterface_UpdateWorkflowAttributes ¶ added in v1.13.3
func (ResourceInterface_UpdateWorkflowAttributes) Return ¶ added in v1.13.3
func (_m ResourceInterface_UpdateWorkflowAttributes) Return(_a0 *admin.WorkflowAttributesUpdateResponse, _a1 error) *ResourceInterface_UpdateWorkflowAttributes
type SignalInterface ¶
SignalInterface is an autogenerated mock type for the SignalInterface type
func NewSignalInterface ¶ added in v1.13.0
func NewSignalInterface(t interface { mock.TestingT Cleanup(func()) }) *SignalInterface
NewSignalInterface creates a new instance of SignalInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SignalInterface) EXPECT ¶ added in v1.13.0
func (_m *SignalInterface) EXPECT() *SignalInterface_Expecter
func (*SignalInterface) GetOrCreateSignal ¶
func (_m *SignalInterface) GetOrCreateSignal(ctx context.Context, request *admin.SignalGetOrCreateRequest) (*admin.Signal, error)
GetOrCreateSignal provides a mock function with given fields: ctx, request
func (*SignalInterface) ListSignals ¶
func (_m *SignalInterface) ListSignals(ctx context.Context, request *admin.SignalListRequest) (*admin.SignalList, error)
ListSignals provides a mock function with given fields: ctx, request
func (*SignalInterface) SetSignal ¶
func (_m *SignalInterface) SetSignal(ctx context.Context, request *admin.SignalSetRequest) (*admin.SignalSetResponse, error)
SetSignal provides a mock function with given fields: ctx, request
type SignalInterface_Expecter ¶ added in v1.13.0
type SignalInterface_Expecter struct {
// contains filtered or unexported fields
}
func (*SignalInterface_Expecter) GetOrCreateSignal ¶ added in v1.13.0
func (_e *SignalInterface_Expecter) GetOrCreateSignal(ctx interface{}, request interface{}) *SignalInterface_GetOrCreateSignal_Call
GetOrCreateSignal is a helper method to define mock.On call
- ctx context.Context
- request *admin.SignalGetOrCreateRequest
func (*SignalInterface_Expecter) ListSignals ¶ added in v1.13.0
func (_e *SignalInterface_Expecter) ListSignals(ctx interface{}, request interface{}) *SignalInterface_ListSignals_Call
ListSignals is a helper method to define mock.On call
- ctx context.Context
- request *admin.SignalListRequest
func (*SignalInterface_Expecter) SetSignal ¶ added in v1.13.0
func (_e *SignalInterface_Expecter) SetSignal(ctx interface{}, request interface{}) *SignalInterface_SetSignal_Call
SetSignal is a helper method to define mock.On call
- ctx context.Context
- request *admin.SignalSetRequest
type SignalInterface_GetOrCreateSignal_Call ¶ added in v1.13.0
SignalInterface_GetOrCreateSignal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOrCreateSignal'
func (*SignalInterface_GetOrCreateSignal_Call) Return ¶ added in v1.13.0
func (_c *SignalInterface_GetOrCreateSignal_Call) Return(_a0 *admin.Signal, _a1 error) *SignalInterface_GetOrCreateSignal_Call
func (*SignalInterface_GetOrCreateSignal_Call) Run ¶ added in v1.13.0
func (_c *SignalInterface_GetOrCreateSignal_Call) Run(run func(ctx context.Context, request *admin.SignalGetOrCreateRequest)) *SignalInterface_GetOrCreateSignal_Call
func (*SignalInterface_GetOrCreateSignal_Call) RunAndReturn ¶ added in v1.13.0
func (_c *SignalInterface_GetOrCreateSignal_Call) RunAndReturn(run func(context.Context, *admin.SignalGetOrCreateRequest) (*admin.Signal, error)) *SignalInterface_GetOrCreateSignal_Call
type SignalInterface_ListSignals_Call ¶ added in v1.13.0
SignalInterface_ListSignals_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSignals'
func (*SignalInterface_ListSignals_Call) Return ¶ added in v1.13.0
func (_c *SignalInterface_ListSignals_Call) Return(_a0 *admin.SignalList, _a1 error) *SignalInterface_ListSignals_Call
func (*SignalInterface_ListSignals_Call) Run ¶ added in v1.13.0
func (_c *SignalInterface_ListSignals_Call) Run(run func(ctx context.Context, request *admin.SignalListRequest)) *SignalInterface_ListSignals_Call
func (*SignalInterface_ListSignals_Call) RunAndReturn ¶ added in v1.13.0
func (_c *SignalInterface_ListSignals_Call) RunAndReturn(run func(context.Context, *admin.SignalListRequest) (*admin.SignalList, error)) *SignalInterface_ListSignals_Call
type SignalInterface_SetSignal_Call ¶ added in v1.13.0
SignalInterface_SetSignal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetSignal'
func (*SignalInterface_SetSignal_Call) Return ¶ added in v1.13.0
func (_c *SignalInterface_SetSignal_Call) Return(_a0 *admin.SignalSetResponse, _a1 error) *SignalInterface_SetSignal_Call
func (*SignalInterface_SetSignal_Call) Run ¶ added in v1.13.0
func (_c *SignalInterface_SetSignal_Call) Run(run func(ctx context.Context, request *admin.SignalSetRequest)) *SignalInterface_SetSignal_Call
func (*SignalInterface_SetSignal_Call) RunAndReturn ¶ added in v1.13.0
func (_c *SignalInterface_SetSignal_Call) RunAndReturn(run func(context.Context, *admin.SignalSetRequest) (*admin.SignalSetResponse, error)) *SignalInterface_SetSignal_Call
type TerminateExecutionFunc ¶
type TerminateExecutionFunc func( ctx context.Context, request *admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)
type UpdateExecutionFunc ¶
type UpdateExecutionFunc func(ctx context.Context, request *admin.ExecutionUpdateRequest, requestedAt time.Time) ( *admin.ExecutionUpdateResponse, error)
type UpdateLaunchPlanFunc ¶
type UpdateLaunchPlanFunc func(ctx context.Context, request *admin.LaunchPlanUpdateRequest) ( *admin.LaunchPlanUpdateResponse, error)
type UpdateNamedEntityFunc ¶
type UpdateNamedEntityFunc func(ctx context.Context, request *admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)
type UpdateProjectAttrsFunc ¶
type UpdateProjectAttrsFunc func(ctx context.Context, request *admin.ProjectAttributesUpdateRequest) ( *admin.ProjectAttributesUpdateResponse, error)
type UpdateProjectDomainFunc ¶
type UpdateProjectDomainFunc func(ctx context.Context, request *admin.ProjectDomainAttributesUpdateRequest) ( *admin.ProjectDomainAttributesUpdateResponse, error)
type UpdateProjectFunc ¶
type VersionInterface ¶
VersionInterface is an autogenerated mock type for the VersionInterface type
func (*VersionInterface) GetVersion ¶
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 ¶
func (_m *VersionInterface) OnGetVersion(ctx context.Context, r *admin.GetVersionRequest) *VersionInterface_GetVersion
func (*VersionInterface) OnGetVersionMatch ¶
func (_m *VersionInterface) OnGetVersionMatch(matchers ...interface{}) *VersionInterface_GetVersion
type VersionInterface_GetVersion ¶
func (VersionInterface_GetVersion) Return ¶
func (_m VersionInterface_GetVersion) Return(_a0 *admin.GetVersionResponse, _a1 error) *VersionInterface_GetVersion