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 CreateExecutionFunc

type CreateExecutionFunc func(
	ctx context.Context, request admin.ExecutionCreateRequest, requestedAt time.Time) (
	*admin.ExecutionCreateResponse, 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 GetActiveLaunchPlanFunc

type GetActiveLaunchPlanFunc func(ctx context.Context, request admin.ActiveLaunchPlanRequest) (
	*admin.LaunchPlan, 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 GetNodeExecutionFunc

type GetNodeExecutionFunc func(ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)

type GetResourceFunc

type GetResourceFunc func(ctx context.Context, request interfaces.ResourceRequest) (*interfaces.ResourceResponse, 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 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 ListTaskExecutionsFunc

type ListTaskExecutionsFunc func(ctx context.Context, request admin.TaskExecutionListRequest) (
	*admin.TaskExecutionList, error)

type MetricsInterface

type MetricsInterface struct {
	mock.Mock
}

MetricsInterface is an autogenerated mock type for the MetricsInterface type

func (*MetricsInterface) GetExecutionMetrics

GetExecutionMetrics provides a mock function with given fields: ctx, request

func (*MetricsInterface) OnGetExecutionMetricsMatch

func (_m *MetricsInterface) OnGetExecutionMetricsMatch(matchers ...interface{}) *MetricsInterface_GetExecutionMetrics

type MetricsInterface_GetExecutionMetrics

type MetricsInterface_GetExecutionMetrics struct {
	*mock.Call
}

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 (*MockExecutionManager) GetExecution

func (*MockExecutionManager) ListExecutions

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 (*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 (*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 (*MockLaunchPlanManager) ListLaunchPlanIds

func (*MockLaunchPlanManager) ListLaunchPlans

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

type MockNodeExecutionManager

type MockNodeExecutionManager struct {
	// contains filtered or unexported fields
}

func (*MockNodeExecutionManager) CreateNodeEvent

func (*MockNodeExecutionManager) GetDynamicNodeWorkflow

func (*MockNodeExecutionManager) GetNodeExecution

func (*MockNodeExecutionManager) GetNodeExecutionData

func (*MockNodeExecutionManager) ListNodeExecutions

func (*MockNodeExecutionManager) ListNodeExecutionsForTask

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 (*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 (*MockResourceManager) DeleteWorkflowAttributes

func (*MockResourceManager) GetProjectAttributes

func (*MockResourceManager) GetProjectDomainAttributes

func (*MockResourceManager) GetResource

func (*MockResourceManager) GetWorkflowAttributes

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 (*MockResourceManager) UpdateWorkflowAttributes

type MockTaskExecutionManager

type MockTaskExecutionManager struct {
	// contains filtered or unexported fields
}

func (*MockTaskExecutionManager) CreateTaskExecutionEvent

func (*MockTaskExecutionManager) GetTaskExecution

func (*MockTaskExecutionManager) GetTaskExecutionData

func (*MockTaskExecutionManager) ListTaskExecutions

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 (*MockTaskManager) GetTask

func (r *MockTaskManager) GetTask(ctx context.Context, request admin.ObjectGetRequest) (*admin.Task, error)

func (*MockTaskManager) ListTasks

func (*MockTaskManager) ListUniqueTaskIdentifiers

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 (*MockWorkflowManager) GetWorkflow

func (r *MockWorkflowManager) GetWorkflow(
	ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error)

func (*MockWorkflowManager) ListWorkflowIdentifiers

func (*MockWorkflowManager) ListWorkflows

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 (*NamedEntityManager) ListNamedEntities

func (*NamedEntityManager) UpdateNamedEntity

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 (*SignalInterface) OnGetOrCreateSignalMatch

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

func (*SignalInterface) OnListSignals

func (*SignalInterface) OnListSignalsMatch

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

func (*SignalInterface) OnSetSignal

func (*SignalInterface) OnSetSignalMatch

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

func (*SignalInterface) SetSignal

SetSignal provides a mock function with given fields: ctx, request

type SignalInterface_GetOrCreateSignal

type SignalInterface_GetOrCreateSignal struct {
	*mock.Call
}

func (SignalInterface_GetOrCreateSignal) Return

type SignalInterface_ListSignals

type SignalInterface_ListSignals struct {
	*mock.Call
}

func (SignalInterface_ListSignals) Return

type SignalInterface_SetSignal

type SignalInterface_SetSignal struct {
	*mock.Call
}

func (SignalInterface_SetSignal) Return

type UpdateExecutionFunc

type UpdateExecutionFunc func(ctx context.Context, request admin.ExecutionUpdateRequest, requestedAt time.Time) (
	*admin.ExecutionUpdateResponse, 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

GetVersion provides a mock function with given fields: ctx, r

func (*VersionInterface) OnGetVersion

func (*VersionInterface) OnGetVersionMatch

func (_m *VersionInterface) OnGetVersionMatch(matchers ...interface{}) *VersionInterface_GetVersion

type VersionInterface_GetVersion

type VersionInterface_GetVersion struct {
	*mock.Call
}

func (VersionInterface_GetVersion) Return

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL