mocks

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 21, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

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 GetExecutionDataFunc 

type GetExecutionDataFunc func(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) (
	*admin.WorkflowExecutionGetDataResponse, error)

type GetExecutionFunc 

type GetExecutionFunc func(ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error)

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 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 GetWorkflowFunc func(ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, 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 

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 ListProjectFunc func(ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error)

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 

type MetricsInterface struct {
	mock.Mock
}

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 

type MetricsInterface_GetExecutionMetrics struct {
	*mock.Call
}

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 

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) 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 

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 SignalInterface 

type SignalInterface struct {
	mock.Mock
}

SignalInterface is an autogenerated mock type for the SignalInterface type

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) OnGetOrCreateSignal 

func (_m *SignalInterface) OnGetOrCreateSignal(ctx context.Context, request admin.SignalGetOrCreateRequest) *SignalInterface_GetOrCreateSignal

func (*SignalInterface) OnGetOrCreateSignalMatch 

func (_m *SignalInterface) OnGetOrCreateSignalMatch(matchers ...interface{}) *SignalInterface_GetOrCreateSignal

func (*SignalInterface) OnListSignals 

func (_m *SignalInterface) OnListSignals(ctx context.Context, request admin.SignalListRequest) *SignalInterface_ListSignals

func (*SignalInterface) OnListSignalsMatch 

func (_m *SignalInterface) OnListSignalsMatch(matchers ...interface{}) *SignalInterface_ListSignals

func (*SignalInterface) OnSetSignal 

func (_m *SignalInterface) OnSetSignal(ctx context.Context, request admin.SignalSetRequest) *SignalInterface_SetSignal

func (*SignalInterface) OnSetSignalMatch 

func (_m *SignalInterface) OnSetSignalMatch(matchers ...interface{}) *SignalInterface_SetSignal

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_GetOrCreateSignal 

type SignalInterface_GetOrCreateSignal struct {
	*mock.Call
}

func (SignalInterface_GetOrCreateSignal) Return 

func (_m SignalInterface_GetOrCreateSignal) Return(_a0 *admin.Signal, _a1 error) *SignalInterface_GetOrCreateSignal

type SignalInterface_ListSignals 

type SignalInterface_ListSignals struct {
	*mock.Call
}

func (SignalInterface_ListSignals) Return 

func (_m SignalInterface_ListSignals) Return(_a0 *admin.SignalList, _a1 error) *SignalInterface_ListSignals

type SignalInterface_SetSignal 

type SignalInterface_SetSignal struct {
	*mock.Call
}

func (SignalInterface_SetSignal) Return 

func (_m SignalInterface_SetSignal) Return(_a0 *admin.SignalSetResponse, _a1 error) *SignalInterface_SetSignal

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 UpdateProjectFunc func(ctx context.Context, request admin.Project) (*admin.ProjectUpdateResponse, error)

type VersionInterface 

type VersionInterface struct {
	mock.Mock
}

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 

type VersionInterface_GetVersion struct {
	*mock.Call
}

func (VersionInterface_GetVersion) Return 

func (_m VersionInterface_GetVersion) Return(_a0 *admin.GetVersionResponse, _a1 error) *VersionInterface_GetVersion

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.