mocks

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 24, 2019 License: Apache-2.0 Imports: 4 Imported by: 1

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

type GetTaskExecutionDataFunc func(ctx context.Context, request admin.TaskExecutionGetDataRequest) (
	*admin.TaskExecutionGetDataResponse, error)

type GetTaskExecutionFunc 

type GetTaskExecutionFunc func(ctx context.Context, request admin.TaskExecutionGetRequest) (
	*admin.TaskExecution, error)

type ListActiveLaunchPlansFunc 

type ListActiveLaunchPlansFunc func(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (
	*admin.LaunchPlanList, error)

type ListExecutionFunc 

type ListExecutionFunc func(ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error)

type ListLaunchPlanIdsFunc 

type ListLaunchPlanIdsFunc func(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
	*admin.NamedEntityIdentifierList, error)

type ListLaunchPlansFunc 

type ListLaunchPlansFunc func(ctx context.Context, request admin.ResourceListRequest) (
	*admin.LaunchPlanList, error)

type 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 ListUniqueIdsFunc 

type ListUniqueIdsFunc func(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)

type MockExecutionManager 

type MockExecutionManager struct {
	// 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) 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) TerminateExecution 

func (m *MockExecutionManager) TerminateExecution(
	ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)

type MockLaunchPlanManager 

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

func (*MockLaunchPlanManager) CreateLaunchPlan 

func (r *MockLaunchPlanManager) CreateLaunchPlan(
	ctx context.Context,
	request admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)

func (*MockLaunchPlanManager) GetActiveLaunchPlan 

func (r *MockLaunchPlanManager) GetActiveLaunchPlan(ctx context.Context, request admin.ActiveLaunchPlanRequest) (
	*admin.LaunchPlan, error)

func (*MockLaunchPlanManager) GetLaunchPlan 

func (r *MockLaunchPlanManager) GetLaunchPlan(ctx context.Context, request admin.ObjectGetRequest) (
	*admin.LaunchPlan, error)

func (*MockLaunchPlanManager) ListActiveLaunchPlans 

func (r *MockLaunchPlanManager) ListActiveLaunchPlans(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (
	*admin.LaunchPlanList, error)

func (*MockLaunchPlanManager) ListLaunchPlanIds 

func (r *MockLaunchPlanManager) ListLaunchPlanIds(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
	*admin.NamedEntityIdentifierList, error)

func (*MockLaunchPlanManager) ListLaunchPlans 

func (r *MockLaunchPlanManager) ListLaunchPlans(ctx context.Context, request admin.ResourceListRequest) (
	*admin.LaunchPlanList, error)

func (*MockLaunchPlanManager) SetCreateCallback 

func (r *MockLaunchPlanManager) SetCreateCallback(createFunction CreateLaunchPlanFunc)

func (*MockLaunchPlanManager) SetGetActiveLaunchPlanCallback 

func (r *MockLaunchPlanManager) SetGetActiveLaunchPlanCallback(plansFunc GetActiveLaunchPlanFunc)

func (*MockLaunchPlanManager) SetListActiveLaunchPlansCallback 

func (r *MockLaunchPlanManager) SetListActiveLaunchPlansCallback(plansFunc ListActiveLaunchPlansFunc)

func (*MockLaunchPlanManager) SetListLaunchPlansCallback 

func (r *MockLaunchPlanManager) SetListLaunchPlansCallback(listLaunchPlansFunc ListLaunchPlansFunc)

func (*MockLaunchPlanManager) SetUpdateLaunchPlan 

func (r *MockLaunchPlanManager) SetUpdateLaunchPlan(updateFunction UpdateLaunchPlanFunc)

func (*MockLaunchPlanManager) UpdateLaunchPlan 

func (r *MockLaunchPlanManager) UpdateLaunchPlan(ctx context.Context, request admin.LaunchPlanUpdateRequest) (
	*admin.LaunchPlanUpdateResponse, error)

type MockNodeExecutionManager 

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

func (*MockNodeExecutionManager) CreateNodeEvent 

func (m *MockNodeExecutionManager) CreateNodeEvent(
	ctx context.Context,
	request admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error)

func (*MockNodeExecutionManager) GetNodeExecution 

func (m *MockNodeExecutionManager) GetNodeExecution(
	ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)

func (*MockNodeExecutionManager) GetNodeExecutionData 

func (m *MockNodeExecutionManager) GetNodeExecutionData(
	ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)

func (*MockNodeExecutionManager) ListNodeExecutions 

func (m *MockNodeExecutionManager) ListNodeExecutions(
	ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)

func (*MockNodeExecutionManager) ListNodeExecutionsForTask 

func (m *MockNodeExecutionManager) ListNodeExecutionsForTask(
	ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)

func (*MockNodeExecutionManager) SetCreateNodeEventCallback 

func (m *MockNodeExecutionManager) SetCreateNodeEventCallback(createNodeEventFunc CreateNodeEventFunc)

func (*MockNodeExecutionManager) SetGetNodeExecutionDataFunc 

func (m *MockNodeExecutionManager) SetGetNodeExecutionDataFunc(getNodeExecutionDataFunc GetNodeExecutionDataFunc)

func (*MockNodeExecutionManager) SetGetNodeExecutionFunc 

func (m *MockNodeExecutionManager) SetGetNodeExecutionFunc(getNodeExecutionFunc GetNodeExecutionFunc)

func (*MockNodeExecutionManager) SetListNodeExecutionsForTaskFunc 

func (m *MockNodeExecutionManager) SetListNodeExecutionsForTaskFunc(listNodeExecutionsForTaskFunc ListNodeExecutionsForTaskFunc)

func (*MockNodeExecutionManager) SetListNodeExecutionsFunc 

func (m *MockNodeExecutionManager) SetListNodeExecutionsFunc(listNodeExecutionsFunc ListNodeExecutionsFunc)

type MockProjectManager 

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

func (*MockProjectManager) CreateProject 

func (m *MockProjectManager) CreateProject(ctx context.Context, request admin.ProjectRegisterRequest) (
	*admin.ProjectRegisterResponse, error)

func (*MockProjectManager) ListProjects 

func (m *MockProjectManager) ListProjects(
	ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error)

func (*MockProjectManager) SetCreateProject 

func (m *MockProjectManager) SetCreateProject(createProjectFunc CreateProjectFunc)

func (*MockProjectManager) SetListCallback 

func (m *MockProjectManager) SetListCallback(listProjectFunc ListProjectFunc)

type MockTaskExecutionManager 

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

func (*MockTaskExecutionManager) CreateTaskExecutionEvent 

func (m *MockTaskExecutionManager) CreateTaskExecutionEvent(
	ctx context.Context, request admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error)

func (*MockTaskExecutionManager) GetTaskExecution 

func (m *MockTaskExecutionManager) GetTaskExecution(
	ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)

func (*MockTaskExecutionManager) GetTaskExecutionData 

func (m *MockTaskExecutionManager) GetTaskExecutionData(
	ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)

func (*MockTaskExecutionManager) ListTaskExecutions 

func (m *MockTaskExecutionManager) ListTaskExecutions(
	ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)

func (*MockTaskExecutionManager) SetCreateTaskEventCallback 

func (m *MockTaskExecutionManager) SetCreateTaskEventCallback(
	createFunc CreateTaskExecutionEventFunc)

func (*MockTaskExecutionManager) SetGetTaskExecutionCallback 

func (m *MockTaskExecutionManager) SetGetTaskExecutionCallback(
	getTaskExecutionFunc GetTaskExecutionFunc)

func (*MockTaskExecutionManager) SetGetTaskExecutionDataCallback 

func (m *MockTaskExecutionManager) SetGetTaskExecutionDataCallback(
	getTaskExecutionDataFunc GetTaskExecutionDataFunc)

func (*MockTaskExecutionManager) SetListTaskExecutionsCallback 

func (m *MockTaskExecutionManager) SetListTaskExecutionsCallback(
	listTaskExecutionsFunc ListTaskExecutionsFunc)

type MockTaskManager 

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

func (*MockTaskManager) CreateTask 

func (r *MockTaskManager) CreateTask(
	ctx context.Context,
	request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)

func (*MockTaskManager) GetTask 

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

func (*MockTaskManager) ListTasks 

func (r *MockTaskManager) ListTasks(ctx context.Context, request admin.ResourceListRequest) (*admin.TaskList, error)

func (*MockTaskManager) ListUniqueTaskIdentifiers 

func (r *MockTaskManager) ListUniqueTaskIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
	*admin.NamedEntityIdentifierList, error)

func (*MockTaskManager) SetCreateCallback 

func (r *MockTaskManager) SetCreateCallback(createFunction CreateTaskFunc)

func (*MockTaskManager) SetListUniqueIdsFunc 

func (r *MockTaskManager) SetListUniqueIdsFunc(fn ListUniqueIdsFunc)

type MockWorkflowManager 

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

func (*MockWorkflowManager) CreateWorkflow 

func (r *MockWorkflowManager) CreateWorkflow(
	ctx context.Context,
	request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)

func (*MockWorkflowManager) GetWorkflow 

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

func (*MockWorkflowManager) ListWorkflowIdentifiers 

func (r *MockWorkflowManager) ListWorkflowIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
	*admin.NamedEntityIdentifierList, error)

func (*MockWorkflowManager) ListWorkflows 

func (r *MockWorkflowManager) ListWorkflows(ctx context.Context,
	request admin.ResourceListRequest) (*admin.WorkflowList, error)

func (*MockWorkflowManager) SetCreateCallback 

func (r *MockWorkflowManager) SetCreateCallback(createFunction CreateWorkflowFunc)

type RelaunchExecutionFunc 

type RelaunchExecutionFunc func(
	ctx context.Context, request admin.ExecutionRelaunchRequest, requestedAt time.Time) (
	*admin.ExecutionCreateResponse, error)

type TerminateExecutionFunc 

type TerminateExecutionFunc func(
	ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)

type UpdateLaunchPlanFunc 

type UpdateLaunchPlanFunc func(ctx context.Context, request admin.LaunchPlanUpdateRequest) (
	*admin.LaunchPlanUpdateResponse, error)

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.