Documentation ¶
Index ¶
- func NewMockLaunchPlanManager() interfaces.LaunchPlanInterface
- type CreateExecutionEventFunc
- type CreateExecutionFunc
- type CreateLaunchPlanFunc
- type CreateNodeEventFunc
- type CreateProjectFunc
- type CreateTaskExecutionEventFunc
- type CreateTaskFunc
- type CreateWorkflowFunc
- type GetActiveLaunchPlanFunc
- type GetExecutionDataFunc
- type GetExecutionFunc
- type GetLaunchPlanFunc
- type GetNodeExecutionDataFunc
- type GetNodeExecutionFunc
- type GetTaskExecutionDataFunc
- type GetTaskExecutionFunc
- type ListActiveLaunchPlansFunc
- type ListExecutionFunc
- type ListLaunchPlanIdsFunc
- type ListLaunchPlansFunc
- type ListNodeExecutionsForTaskFunc
- type ListNodeExecutionsFunc
- type ListProjectFunc
- type ListTaskExecutionsFunc
- type ListUniqueIdsFunc
- type MockExecutionManager
- func (m *MockExecutionManager) CreateExecution(ctx context.Context, request admin.ExecutionCreateRequest, ...) (*admin.ExecutionCreateResponse, error)
- func (m *MockExecutionManager) CreateWorkflowEvent(ctx context.Context, request admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error)
- func (m *MockExecutionManager) GetExecution(ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error)
- func (m *MockExecutionManager) GetExecutionData(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error)
- func (m *MockExecutionManager) ListExecutions(ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error)
- func (m *MockExecutionManager) 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) TerminateExecution(ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)
- type MockLaunchPlanManager
- func (r *MockLaunchPlanManager) CreateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)
- func (r *MockLaunchPlanManager) GetActiveLaunchPlan(ctx context.Context, request admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error)
- func (r *MockLaunchPlanManager) GetLaunchPlan(ctx context.Context, request admin.ObjectGetRequest) (*admin.LaunchPlan, error)
- func (r *MockLaunchPlanManager) ListActiveLaunchPlans(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (*admin.LaunchPlanList, error)
- func (r *MockLaunchPlanManager) ListLaunchPlanIds(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
- func (r *MockLaunchPlanManager) ListLaunchPlans(ctx context.Context, request admin.ResourceListRequest) (*admin.LaunchPlanList, error)
- func (r *MockLaunchPlanManager) SetCreateCallback(createFunction CreateLaunchPlanFunc)
- func (r *MockLaunchPlanManager) SetGetActiveLaunchPlanCallback(plansFunc GetActiveLaunchPlanFunc)
- func (r *MockLaunchPlanManager) SetListActiveLaunchPlansCallback(plansFunc ListActiveLaunchPlansFunc)
- func (r *MockLaunchPlanManager) SetListLaunchPlansCallback(listLaunchPlansFunc ListLaunchPlansFunc)
- func (r *MockLaunchPlanManager) SetUpdateLaunchPlan(updateFunction UpdateLaunchPlanFunc)
- func (r *MockLaunchPlanManager) UpdateLaunchPlan(ctx context.Context, request admin.LaunchPlanUpdateRequest) (*admin.LaunchPlanUpdateResponse, error)
- type MockNodeExecutionManager
- func (m *MockNodeExecutionManager) CreateNodeEvent(ctx context.Context, request admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error)
- func (m *MockNodeExecutionManager) GetNodeExecution(ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)
- func (m *MockNodeExecutionManager) GetNodeExecutionData(ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)
- func (m *MockNodeExecutionManager) ListNodeExecutions(ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)
- func (m *MockNodeExecutionManager) ListNodeExecutionsForTask(ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)
- func (m *MockNodeExecutionManager) SetCreateNodeEventCallback(createNodeEventFunc CreateNodeEventFunc)
- func (m *MockNodeExecutionManager) SetGetNodeExecutionDataFunc(getNodeExecutionDataFunc GetNodeExecutionDataFunc)
- func (m *MockNodeExecutionManager) SetGetNodeExecutionFunc(getNodeExecutionFunc GetNodeExecutionFunc)
- func (m *MockNodeExecutionManager) SetListNodeExecutionsForTaskFunc(listNodeExecutionsForTaskFunc ListNodeExecutionsForTaskFunc)
- func (m *MockNodeExecutionManager) SetListNodeExecutionsFunc(listNodeExecutionsFunc ListNodeExecutionsFunc)
- type MockProjectDomainManager
- type MockProjectManager
- func (m *MockProjectManager) CreateProject(ctx context.Context, request admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)
- func (m *MockProjectManager) ListProjects(ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error)
- func (m *MockProjectManager) SetCreateProject(createProjectFunc CreateProjectFunc)
- func (m *MockProjectManager) SetListCallback(listProjectFunc ListProjectFunc)
- type MockTaskExecutionManager
- func (m *MockTaskExecutionManager) CreateTaskExecutionEvent(ctx context.Context, request admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error)
- func (m *MockTaskExecutionManager) GetTaskExecution(ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)
- func (m *MockTaskExecutionManager) GetTaskExecutionData(ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)
- func (m *MockTaskExecutionManager) ListTaskExecutions(ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)
- func (m *MockTaskExecutionManager) SetCreateTaskEventCallback(createFunc CreateTaskExecutionEventFunc)
- func (m *MockTaskExecutionManager) SetGetTaskExecutionCallback(getTaskExecutionFunc GetTaskExecutionFunc)
- func (m *MockTaskExecutionManager) SetGetTaskExecutionDataCallback(getTaskExecutionDataFunc GetTaskExecutionDataFunc)
- func (m *MockTaskExecutionManager) SetListTaskExecutionsCallback(listTaskExecutionsFunc ListTaskExecutionsFunc)
- type MockTaskManager
- func (r *MockTaskManager) CreateTask(ctx context.Context, request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)
- func (r *MockTaskManager) GetTask(ctx context.Context, request admin.ObjectGetRequest) (*admin.Task, error)
- func (r *MockTaskManager) ListTasks(ctx context.Context, request admin.ResourceListRequest) (*admin.TaskList, error)
- func (r *MockTaskManager) ListUniqueTaskIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
- func (r *MockTaskManager) SetCreateCallback(createFunction CreateTaskFunc)
- func (r *MockTaskManager) SetListUniqueIdsFunc(fn ListUniqueIdsFunc)
- type MockWorkflowManager
- func (r *MockWorkflowManager) CreateWorkflow(ctx context.Context, request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)
- func (r *MockWorkflowManager) GetWorkflow(ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error)
- func (r *MockWorkflowManager) ListWorkflowIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
- func (r *MockWorkflowManager) ListWorkflows(ctx context.Context, request admin.ResourceListRequest) (*admin.WorkflowList, error)
- func (r *MockWorkflowManager) SetCreateCallback(createFunction CreateWorkflowFunc)
- type RelaunchExecutionFunc
- type TerminateExecutionFunc
- type UpdateLaunchPlanFunc
- type UpdateProjectDomainFunc
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 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 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 MockProjectDomainManager ¶ added in v0.1.4
type MockProjectDomainManager struct {
// contains filtered or unexported fields
}
func (*MockProjectDomainManager) SetUpdateProjectDomainAttributes ¶ added in v0.1.4
func (m *MockProjectDomainManager) SetUpdateProjectDomainAttributes(updateProjectDomainFunc UpdateProjectDomainFunc)
func (*MockProjectDomainManager) UpdateProjectDomain ¶ added in v0.1.4
func (m *MockProjectDomainManager) UpdateProjectDomain( ctx context.Context, request admin.ProjectDomainAttributesUpdateRequest) ( *admin.ProjectDomainAttributesUpdateResponse, error)
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)
type UpdateProjectDomainFunc ¶ added in v0.1.4
type UpdateProjectDomainFunc func(ctx context.Context, request admin.ProjectDomainAttributesUpdateRequest) ( *admin.ProjectDomainAttributesUpdateResponse, error)
Click to show internal directories.
Click to hide internal directories.