Documentation ¶
Index ¶
- type AdminServiceClient
- func (_m *AdminServiceClient) CreateExecution(ctx context.Context, in *admin.ExecutionCreateRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)
- func (_m *AdminServiceClient) CreateLaunchPlan(ctx context.Context, in *admin.LaunchPlanCreateRequest, ...) (*admin.LaunchPlanCreateResponse, error)
- func (_m *AdminServiceClient) CreateNodeEvent(ctx context.Context, in *admin.NodeExecutionEventRequest, ...) (*admin.NodeExecutionEventResponse, error)
- func (_m *AdminServiceClient) CreateTask(ctx context.Context, in *admin.TaskCreateRequest, opts ...grpc.CallOption) (*admin.TaskCreateResponse, error)
- func (_m *AdminServiceClient) CreateTaskEvent(ctx context.Context, in *admin.TaskExecutionEventRequest, ...) (*admin.TaskExecutionEventResponse, error)
- func (_m *AdminServiceClient) CreateWorkflow(ctx context.Context, in *admin.WorkflowCreateRequest, opts ...grpc.CallOption) (*admin.WorkflowCreateResponse, error)
- func (_m *AdminServiceClient) CreateWorkflowEvent(ctx context.Context, in *admin.WorkflowExecutionEventRequest, ...) (*admin.WorkflowExecutionEventResponse, error)
- func (_m *AdminServiceClient) GetActiveLaunchPlan(ctx context.Context, in *admin.ActiveLaunchPlanRequest, ...) (*admin.LaunchPlan, error)
- func (_m *AdminServiceClient) GetExecution(ctx context.Context, in *admin.WorkflowExecutionGetRequest, ...) (*admin.Execution, error)
- func (_m *AdminServiceClient) GetExecutionData(ctx context.Context, in *admin.WorkflowExecutionGetDataRequest, ...) (*admin.WorkflowExecutionGetDataResponse, error)
- func (_m *AdminServiceClient) GetLaunchPlan(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)
- func (_m *AdminServiceClient) GetNodeExecution(ctx context.Context, in *admin.NodeExecutionGetRequest, ...) (*admin.NodeExecution, error)
- func (_m *AdminServiceClient) GetNodeExecutionData(ctx context.Context, in *admin.NodeExecutionGetDataRequest, ...) (*admin.NodeExecutionGetDataResponse, error)
- func (_m *AdminServiceClient) GetTask(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Task, error)
- func (_m *AdminServiceClient) GetTaskExecution(ctx context.Context, in *admin.TaskExecutionGetRequest, ...) (*admin.TaskExecution, error)
- func (_m *AdminServiceClient) GetTaskExecutionData(ctx context.Context, in *admin.TaskExecutionGetDataRequest, ...) (*admin.TaskExecutionGetDataResponse, error)
- func (_m *AdminServiceClient) GetWorkflow(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Workflow, error)
- func (_m *AdminServiceClient) ListActiveLaunchPlans(ctx context.Context, in *admin.ActiveLaunchPlanListRequest, ...) (*admin.LaunchPlanList, error)
- func (_m *AdminServiceClient) ListExecutions(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.ExecutionList, error)
- func (_m *AdminServiceClient) ListLaunchPlanIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, ...) (*admin.NamedEntityIdentifierList, error)
- func (_m *AdminServiceClient) ListLaunchPlans(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)
- func (_m *AdminServiceClient) ListNodeExecutions(ctx context.Context, in *admin.NodeExecutionListRequest, ...) (*admin.NodeExecutionList, error)
- func (_m *AdminServiceClient) ListNodeExecutionsForTask(ctx context.Context, in *admin.NodeExecutionForTaskListRequest, ...) (*admin.NodeExecutionList, error)
- func (_m *AdminServiceClient) ListProjects(ctx context.Context, in *admin.ProjectListRequest, opts ...grpc.CallOption) (*admin.Projects, error)
- func (_m *AdminServiceClient) ListTaskExecutions(ctx context.Context, in *admin.TaskExecutionListRequest, ...) (*admin.TaskExecutionList, error)
- func (_m *AdminServiceClient) ListTaskIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, ...) (*admin.NamedEntityIdentifierList, error)
- func (_m *AdminServiceClient) ListTasks(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.TaskList, error)
- func (_m *AdminServiceClient) ListWorkflowIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, ...) (*admin.NamedEntityIdentifierList, error)
- func (_m *AdminServiceClient) ListWorkflows(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.WorkflowList, error)
- func (_m *AdminServiceClient) RegisterProject(ctx context.Context, in *admin.ProjectRegisterRequest, opts ...grpc.CallOption) (*admin.ProjectRegisterResponse, error)
- func (_m *AdminServiceClient) RelaunchExecution(ctx context.Context, in *admin.ExecutionRelaunchRequest, ...) (*admin.ExecutionCreateResponse, error)
- func (_m *AdminServiceClient) TerminateExecution(ctx context.Context, in *admin.ExecutionTerminateRequest, ...) (*admin.ExecutionTerminateResponse, error)
- func (_m *AdminServiceClient) UpdateLaunchPlan(ctx context.Context, in *admin.LaunchPlanUpdateRequest, ...) (*admin.LaunchPlanUpdateResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AdminServiceClient ¶
AdminServiceClient is an autogenerated mock type for the AdminServiceClient type
func (*AdminServiceClient) CreateExecution ¶
func (_m *AdminServiceClient) CreateExecution(ctx context.Context, in *admin.ExecutionCreateRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)
CreateExecution provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) CreateLaunchPlan ¶
func (_m *AdminServiceClient) CreateLaunchPlan(ctx context.Context, in *admin.LaunchPlanCreateRequest, opts ...grpc.CallOption) (*admin.LaunchPlanCreateResponse, error)
CreateLaunchPlan provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) CreateNodeEvent ¶
func (_m *AdminServiceClient) CreateNodeEvent(ctx context.Context, in *admin.NodeExecutionEventRequest, opts ...grpc.CallOption) (*admin.NodeExecutionEventResponse, error)
CreateNodeEvent provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) CreateTask ¶
func (_m *AdminServiceClient) CreateTask(ctx context.Context, in *admin.TaskCreateRequest, opts ...grpc.CallOption) (*admin.TaskCreateResponse, error)
CreateTask provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) CreateTaskEvent ¶
func (_m *AdminServiceClient) CreateTaskEvent(ctx context.Context, in *admin.TaskExecutionEventRequest, opts ...grpc.CallOption) (*admin.TaskExecutionEventResponse, error)
CreateTaskEvent provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) CreateWorkflow ¶
func (_m *AdminServiceClient) CreateWorkflow(ctx context.Context, in *admin.WorkflowCreateRequest, opts ...grpc.CallOption) (*admin.WorkflowCreateResponse, error)
CreateWorkflow provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) CreateWorkflowEvent ¶
func (_m *AdminServiceClient) CreateWorkflowEvent(ctx context.Context, in *admin.WorkflowExecutionEventRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionEventResponse, error)
CreateWorkflowEvent provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetActiveLaunchPlan ¶ added in v0.1.1
func (_m *AdminServiceClient) GetActiveLaunchPlan(ctx context.Context, in *admin.ActiveLaunchPlanRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)
GetActiveLaunchPlan provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetExecution ¶
func (_m *AdminServiceClient) GetExecution(ctx context.Context, in *admin.WorkflowExecutionGetRequest, opts ...grpc.CallOption) (*admin.Execution, error)
GetExecution provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetExecutionData ¶
func (_m *AdminServiceClient) GetExecutionData(ctx context.Context, in *admin.WorkflowExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionGetDataResponse, error)
GetExecutionData provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetLaunchPlan ¶
func (_m *AdminServiceClient) GetLaunchPlan(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)
GetLaunchPlan provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetNodeExecution ¶
func (_m *AdminServiceClient) GetNodeExecution(ctx context.Context, in *admin.NodeExecutionGetRequest, opts ...grpc.CallOption) (*admin.NodeExecution, error)
GetNodeExecution provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetNodeExecutionData ¶
func (_m *AdminServiceClient) GetNodeExecutionData(ctx context.Context, in *admin.NodeExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.NodeExecutionGetDataResponse, error)
GetNodeExecutionData provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetTask ¶
func (_m *AdminServiceClient) GetTask(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Task, error)
GetTask provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetTaskExecution ¶
func (_m *AdminServiceClient) GetTaskExecution(ctx context.Context, in *admin.TaskExecutionGetRequest, opts ...grpc.CallOption) (*admin.TaskExecution, error)
GetTaskExecution provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetTaskExecutionData ¶
func (_m *AdminServiceClient) GetTaskExecutionData(ctx context.Context, in *admin.TaskExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.TaskExecutionGetDataResponse, error)
GetTaskExecutionData provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) GetWorkflow ¶
func (_m *AdminServiceClient) GetWorkflow(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Workflow, error)
GetWorkflow provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListActiveLaunchPlans ¶ added in v0.1.1
func (_m *AdminServiceClient) ListActiveLaunchPlans(ctx context.Context, in *admin.ActiveLaunchPlanListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)
ListActiveLaunchPlans provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListExecutions ¶
func (_m *AdminServiceClient) ListExecutions(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.ExecutionList, error)
ListExecutions provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListLaunchPlanIds ¶
func (_m *AdminServiceClient) ListLaunchPlanIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)
ListLaunchPlanIds provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListLaunchPlans ¶
func (_m *AdminServiceClient) ListLaunchPlans(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)
ListLaunchPlans provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListNodeExecutions ¶
func (_m *AdminServiceClient) ListNodeExecutions(ctx context.Context, in *admin.NodeExecutionListRequest, opts ...grpc.CallOption) (*admin.NodeExecutionList, error)
ListNodeExecutions provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListNodeExecutionsForTask ¶
func (_m *AdminServiceClient) ListNodeExecutionsForTask(ctx context.Context, in *admin.NodeExecutionForTaskListRequest, opts ...grpc.CallOption) (*admin.NodeExecutionList, error)
ListNodeExecutionsForTask provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListProjects ¶
func (_m *AdminServiceClient) ListProjects(ctx context.Context, in *admin.ProjectListRequest, opts ...grpc.CallOption) (*admin.Projects, error)
ListProjects provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListTaskExecutions ¶
func (_m *AdminServiceClient) ListTaskExecutions(ctx context.Context, in *admin.TaskExecutionListRequest, opts ...grpc.CallOption) (*admin.TaskExecutionList, error)
ListTaskExecutions provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListTaskIds ¶
func (_m *AdminServiceClient) ListTaskIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)
ListTaskIds provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListTasks ¶
func (_m *AdminServiceClient) ListTasks(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.TaskList, error)
ListTasks provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListWorkflowIds ¶
func (_m *AdminServiceClient) ListWorkflowIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)
ListWorkflowIds provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) ListWorkflows ¶
func (_m *AdminServiceClient) ListWorkflows(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.WorkflowList, error)
ListWorkflows provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) RegisterProject ¶
func (_m *AdminServiceClient) RegisterProject(ctx context.Context, in *admin.ProjectRegisterRequest, opts ...grpc.CallOption) (*admin.ProjectRegisterResponse, error)
RegisterProject provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) RelaunchExecution ¶
func (_m *AdminServiceClient) RelaunchExecution(ctx context.Context, in *admin.ExecutionRelaunchRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)
RelaunchExecution provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) TerminateExecution ¶
func (_m *AdminServiceClient) TerminateExecution(ctx context.Context, in *admin.ExecutionTerminateRequest, opts ...grpc.CallOption) (*admin.ExecutionTerminateResponse, error)
TerminateExecution provides a mock function with given fields: ctx, in, opts
func (*AdminServiceClient) UpdateLaunchPlan ¶
func (_m *AdminServiceClient) UpdateLaunchPlan(ctx context.Context, in *admin.LaunchPlanUpdateRequest, opts ...grpc.CallOption) (*admin.LaunchPlanUpdateResponse, error)
UpdateLaunchPlan provides a mock function with given fields: ctx, in, opts