Documentation ¶
Overview ¶
Package datapipelinemock is a generated GoMock package.
Index ¶
- type MockDataPipelineAPI
- func (m *MockDataPipelineAPI) ActivatePipeline(arg0 *datapipeline.ActivatePipelineInput) (*datapipeline.ActivatePipelineOutput, error)
- func (m *MockDataPipelineAPI) ActivatePipelineRequest(arg0 *datapipeline.ActivatePipelineInput) (*request.Request, *datapipeline.ActivatePipelineOutput)
- func (m *MockDataPipelineAPI) ActivatePipelineWithContext(arg0 context.Context, arg1 *datapipeline.ActivatePipelineInput, ...) (*datapipeline.ActivatePipelineOutput, error)
- func (m *MockDataPipelineAPI) AddTags(arg0 *datapipeline.AddTagsInput) (*datapipeline.AddTagsOutput, error)
- func (m *MockDataPipelineAPI) AddTagsRequest(arg0 *datapipeline.AddTagsInput) (*request.Request, *datapipeline.AddTagsOutput)
- func (m *MockDataPipelineAPI) AddTagsWithContext(arg0 context.Context, arg1 *datapipeline.AddTagsInput, arg2 ...request.Option) (*datapipeline.AddTagsOutput, error)
- func (m *MockDataPipelineAPI) CreatePipeline(arg0 *datapipeline.CreatePipelineInput) (*datapipeline.CreatePipelineOutput, error)
- func (m *MockDataPipelineAPI) CreatePipelineRequest(arg0 *datapipeline.CreatePipelineInput) (*request.Request, *datapipeline.CreatePipelineOutput)
- func (m *MockDataPipelineAPI) CreatePipelineWithContext(arg0 context.Context, arg1 *datapipeline.CreatePipelineInput, ...) (*datapipeline.CreatePipelineOutput, error)
- func (m *MockDataPipelineAPI) DeactivatePipeline(arg0 *datapipeline.DeactivatePipelineInput) (*datapipeline.DeactivatePipelineOutput, error)
- func (m *MockDataPipelineAPI) DeactivatePipelineRequest(arg0 *datapipeline.DeactivatePipelineInput) (*request.Request, *datapipeline.DeactivatePipelineOutput)
- func (m *MockDataPipelineAPI) DeactivatePipelineWithContext(arg0 context.Context, arg1 *datapipeline.DeactivatePipelineInput, ...) (*datapipeline.DeactivatePipelineOutput, error)
- func (m *MockDataPipelineAPI) DeletePipeline(arg0 *datapipeline.DeletePipelineInput) (*datapipeline.DeletePipelineOutput, error)
- func (m *MockDataPipelineAPI) DeletePipelineRequest(arg0 *datapipeline.DeletePipelineInput) (*request.Request, *datapipeline.DeletePipelineOutput)
- func (m *MockDataPipelineAPI) DeletePipelineWithContext(arg0 context.Context, arg1 *datapipeline.DeletePipelineInput, ...) (*datapipeline.DeletePipelineOutput, error)
- func (m *MockDataPipelineAPI) DescribeObjects(arg0 *datapipeline.DescribeObjectsInput) (*datapipeline.DescribeObjectsOutput, error)
- func (m *MockDataPipelineAPI) DescribeObjectsPages(arg0 *datapipeline.DescribeObjectsInput, ...) error
- func (m *MockDataPipelineAPI) DescribeObjectsPagesWithContext(arg0 context.Context, arg1 *datapipeline.DescribeObjectsInput, ...) error
- func (m *MockDataPipelineAPI) DescribeObjectsRequest(arg0 *datapipeline.DescribeObjectsInput) (*request.Request, *datapipeline.DescribeObjectsOutput)
- func (m *MockDataPipelineAPI) DescribeObjectsWithContext(arg0 context.Context, arg1 *datapipeline.DescribeObjectsInput, ...) (*datapipeline.DescribeObjectsOutput, error)
- func (m *MockDataPipelineAPI) DescribePipelines(arg0 *datapipeline.DescribePipelinesInput) (*datapipeline.DescribePipelinesOutput, error)
- func (m *MockDataPipelineAPI) DescribePipelinesRequest(arg0 *datapipeline.DescribePipelinesInput) (*request.Request, *datapipeline.DescribePipelinesOutput)
- func (m *MockDataPipelineAPI) DescribePipelinesWithContext(arg0 context.Context, arg1 *datapipeline.DescribePipelinesInput, ...) (*datapipeline.DescribePipelinesOutput, error)
- func (m *MockDataPipelineAPI) EXPECT() *MockDataPipelineAPIMockRecorder
- func (m *MockDataPipelineAPI) EvaluateExpression(arg0 *datapipeline.EvaluateExpressionInput) (*datapipeline.EvaluateExpressionOutput, error)
- func (m *MockDataPipelineAPI) EvaluateExpressionRequest(arg0 *datapipeline.EvaluateExpressionInput) (*request.Request, *datapipeline.EvaluateExpressionOutput)
- func (m *MockDataPipelineAPI) EvaluateExpressionWithContext(arg0 context.Context, arg1 *datapipeline.EvaluateExpressionInput, ...) (*datapipeline.EvaluateExpressionOutput, error)
- func (m *MockDataPipelineAPI) GetPipelineDefinition(arg0 *datapipeline.GetPipelineDefinitionInput) (*datapipeline.GetPipelineDefinitionOutput, error)
- func (m *MockDataPipelineAPI) GetPipelineDefinitionRequest(arg0 *datapipeline.GetPipelineDefinitionInput) (*request.Request, *datapipeline.GetPipelineDefinitionOutput)
- func (m *MockDataPipelineAPI) GetPipelineDefinitionWithContext(arg0 context.Context, arg1 *datapipeline.GetPipelineDefinitionInput, ...) (*datapipeline.GetPipelineDefinitionOutput, error)
- func (m *MockDataPipelineAPI) ListPipelines(arg0 *datapipeline.ListPipelinesInput) (*datapipeline.ListPipelinesOutput, error)
- func (m *MockDataPipelineAPI) ListPipelinesPages(arg0 *datapipeline.ListPipelinesInput, ...) error
- func (m *MockDataPipelineAPI) ListPipelinesPagesWithContext(arg0 context.Context, arg1 *datapipeline.ListPipelinesInput, ...) error
- func (m *MockDataPipelineAPI) ListPipelinesRequest(arg0 *datapipeline.ListPipelinesInput) (*request.Request, *datapipeline.ListPipelinesOutput)
- func (m *MockDataPipelineAPI) ListPipelinesWithContext(arg0 context.Context, arg1 *datapipeline.ListPipelinesInput, ...) (*datapipeline.ListPipelinesOutput, error)
- func (m *MockDataPipelineAPI) PollForTask(arg0 *datapipeline.PollForTaskInput) (*datapipeline.PollForTaskOutput, error)
- func (m *MockDataPipelineAPI) PollForTaskRequest(arg0 *datapipeline.PollForTaskInput) (*request.Request, *datapipeline.PollForTaskOutput)
- func (m *MockDataPipelineAPI) PollForTaskWithContext(arg0 context.Context, arg1 *datapipeline.PollForTaskInput, ...) (*datapipeline.PollForTaskOutput, error)
- func (m *MockDataPipelineAPI) PutPipelineDefinition(arg0 *datapipeline.PutPipelineDefinitionInput) (*datapipeline.PutPipelineDefinitionOutput, error)
- func (m *MockDataPipelineAPI) PutPipelineDefinitionRequest(arg0 *datapipeline.PutPipelineDefinitionInput) (*request.Request, *datapipeline.PutPipelineDefinitionOutput)
- func (m *MockDataPipelineAPI) PutPipelineDefinitionWithContext(arg0 context.Context, arg1 *datapipeline.PutPipelineDefinitionInput, ...) (*datapipeline.PutPipelineDefinitionOutput, error)
- func (m *MockDataPipelineAPI) QueryObjects(arg0 *datapipeline.QueryObjectsInput) (*datapipeline.QueryObjectsOutput, error)
- func (m *MockDataPipelineAPI) QueryObjectsPages(arg0 *datapipeline.QueryObjectsInput, ...) error
- func (m *MockDataPipelineAPI) QueryObjectsPagesWithContext(arg0 context.Context, arg1 *datapipeline.QueryObjectsInput, ...) error
- func (m *MockDataPipelineAPI) QueryObjectsRequest(arg0 *datapipeline.QueryObjectsInput) (*request.Request, *datapipeline.QueryObjectsOutput)
- func (m *MockDataPipelineAPI) QueryObjectsWithContext(arg0 context.Context, arg1 *datapipeline.QueryObjectsInput, ...) (*datapipeline.QueryObjectsOutput, error)
- func (m *MockDataPipelineAPI) RemoveTags(arg0 *datapipeline.RemoveTagsInput) (*datapipeline.RemoveTagsOutput, error)
- func (m *MockDataPipelineAPI) RemoveTagsRequest(arg0 *datapipeline.RemoveTagsInput) (*request.Request, *datapipeline.RemoveTagsOutput)
- func (m *MockDataPipelineAPI) RemoveTagsWithContext(arg0 context.Context, arg1 *datapipeline.RemoveTagsInput, ...) (*datapipeline.RemoveTagsOutput, error)
- func (m *MockDataPipelineAPI) ReportTaskProgress(arg0 *datapipeline.ReportTaskProgressInput) (*datapipeline.ReportTaskProgressOutput, error)
- func (m *MockDataPipelineAPI) ReportTaskProgressRequest(arg0 *datapipeline.ReportTaskProgressInput) (*request.Request, *datapipeline.ReportTaskProgressOutput)
- func (m *MockDataPipelineAPI) ReportTaskProgressWithContext(arg0 context.Context, arg1 *datapipeline.ReportTaskProgressInput, ...) (*datapipeline.ReportTaskProgressOutput, error)
- func (m *MockDataPipelineAPI) ReportTaskRunnerHeartbeat(arg0 *datapipeline.ReportTaskRunnerHeartbeatInput) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)
- func (m *MockDataPipelineAPI) ReportTaskRunnerHeartbeatRequest(arg0 *datapipeline.ReportTaskRunnerHeartbeatInput) (*request.Request, *datapipeline.ReportTaskRunnerHeartbeatOutput)
- func (m *MockDataPipelineAPI) ReportTaskRunnerHeartbeatWithContext(arg0 context.Context, arg1 *datapipeline.ReportTaskRunnerHeartbeatInput, ...) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)
- func (m *MockDataPipelineAPI) SetStatus(arg0 *datapipeline.SetStatusInput) (*datapipeline.SetStatusOutput, error)
- func (m *MockDataPipelineAPI) SetStatusRequest(arg0 *datapipeline.SetStatusInput) (*request.Request, *datapipeline.SetStatusOutput)
- func (m *MockDataPipelineAPI) SetStatusWithContext(arg0 context.Context, arg1 *datapipeline.SetStatusInput, ...) (*datapipeline.SetStatusOutput, error)
- func (m *MockDataPipelineAPI) SetTaskStatus(arg0 *datapipeline.SetTaskStatusInput) (*datapipeline.SetTaskStatusOutput, error)
- func (m *MockDataPipelineAPI) SetTaskStatusRequest(arg0 *datapipeline.SetTaskStatusInput) (*request.Request, *datapipeline.SetTaskStatusOutput)
- func (m *MockDataPipelineAPI) SetTaskStatusWithContext(arg0 context.Context, arg1 *datapipeline.SetTaskStatusInput, ...) (*datapipeline.SetTaskStatusOutput, error)
- func (m *MockDataPipelineAPI) ValidatePipelineDefinition(arg0 *datapipeline.ValidatePipelineDefinitionInput) (*datapipeline.ValidatePipelineDefinitionOutput, error)
- func (m *MockDataPipelineAPI) ValidatePipelineDefinitionRequest(arg0 *datapipeline.ValidatePipelineDefinitionInput) (*request.Request, *datapipeline.ValidatePipelineDefinitionOutput)
- func (m *MockDataPipelineAPI) ValidatePipelineDefinitionWithContext(arg0 context.Context, arg1 *datapipeline.ValidatePipelineDefinitionInput, ...) (*datapipeline.ValidatePipelineDefinitionOutput, error)
- type MockDataPipelineAPIMockRecorder
- func (mr *MockDataPipelineAPIMockRecorder) ActivatePipeline(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ActivatePipelineRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ActivatePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) AddTags(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) AddTagsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) AddTagsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) CreatePipeline(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) CreatePipelineRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) CreatePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DeactivatePipeline(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DeactivatePipelineRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DeactivatePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DeletePipeline(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DeletePipelineRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DeletePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribeObjects(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribePipelines(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribePipelinesRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) DescribePipelinesWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) EvaluateExpression(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) EvaluateExpressionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) EvaluateExpressionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) GetPipelineDefinition(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) GetPipelineDefinitionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) GetPipelineDefinitionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ListPipelines(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) PollForTask(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) PollForTaskRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) PollForTaskWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) PutPipelineDefinition(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) PutPipelineDefinitionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) PutPipelineDefinitionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) QueryObjects(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) RemoveTags(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) RemoveTagsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) RemoveTagsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ReportTaskProgress(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ReportTaskProgressRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ReportTaskProgressWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeat(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeatRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeatWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) SetStatus(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) SetStatusRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) SetStatusWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) SetTaskStatus(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) SetTaskStatusRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) SetTaskStatusWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ValidatePipelineDefinition(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ValidatePipelineDefinitionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockDataPipelineAPIMockRecorder) ValidatePipelineDefinitionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockDataPipelineAPI ¶
type MockDataPipelineAPI struct {
// contains filtered or unexported fields
}
MockDataPipelineAPI is a mock of DataPipelineAPI interface
func NewMockDataPipelineAPI ¶
func NewMockDataPipelineAPI(ctrl *gomock.Controller) *MockDataPipelineAPI
NewMockDataPipelineAPI creates a new mock instance
func (*MockDataPipelineAPI) ActivatePipeline ¶
func (m *MockDataPipelineAPI) ActivatePipeline(arg0 *datapipeline.ActivatePipelineInput) (*datapipeline.ActivatePipelineOutput, error)
ActivatePipeline mocks base method
func (*MockDataPipelineAPI) ActivatePipelineRequest ¶
func (m *MockDataPipelineAPI) ActivatePipelineRequest(arg0 *datapipeline.ActivatePipelineInput) (*request.Request, *datapipeline.ActivatePipelineOutput)
ActivatePipelineRequest mocks base method
func (*MockDataPipelineAPI) ActivatePipelineWithContext ¶
func (m *MockDataPipelineAPI) ActivatePipelineWithContext(arg0 context.Context, arg1 *datapipeline.ActivatePipelineInput, arg2 ...request.Option) (*datapipeline.ActivatePipelineOutput, error)
ActivatePipelineWithContext mocks base method
func (*MockDataPipelineAPI) AddTags ¶
func (m *MockDataPipelineAPI) AddTags(arg0 *datapipeline.AddTagsInput) (*datapipeline.AddTagsOutput, error)
AddTags mocks base method
func (*MockDataPipelineAPI) AddTagsRequest ¶
func (m *MockDataPipelineAPI) AddTagsRequest(arg0 *datapipeline.AddTagsInput) (*request.Request, *datapipeline.AddTagsOutput)
AddTagsRequest mocks base method
func (*MockDataPipelineAPI) AddTagsWithContext ¶
func (m *MockDataPipelineAPI) AddTagsWithContext(arg0 context.Context, arg1 *datapipeline.AddTagsInput, arg2 ...request.Option) (*datapipeline.AddTagsOutput, error)
AddTagsWithContext mocks base method
func (*MockDataPipelineAPI) CreatePipeline ¶
func (m *MockDataPipelineAPI) CreatePipeline(arg0 *datapipeline.CreatePipelineInput) (*datapipeline.CreatePipelineOutput, error)
CreatePipeline mocks base method
func (*MockDataPipelineAPI) CreatePipelineRequest ¶
func (m *MockDataPipelineAPI) CreatePipelineRequest(arg0 *datapipeline.CreatePipelineInput) (*request.Request, *datapipeline.CreatePipelineOutput)
CreatePipelineRequest mocks base method
func (*MockDataPipelineAPI) CreatePipelineWithContext ¶
func (m *MockDataPipelineAPI) CreatePipelineWithContext(arg0 context.Context, arg1 *datapipeline.CreatePipelineInput, arg2 ...request.Option) (*datapipeline.CreatePipelineOutput, error)
CreatePipelineWithContext mocks base method
func (*MockDataPipelineAPI) DeactivatePipeline ¶
func (m *MockDataPipelineAPI) DeactivatePipeline(arg0 *datapipeline.DeactivatePipelineInput) (*datapipeline.DeactivatePipelineOutput, error)
DeactivatePipeline mocks base method
func (*MockDataPipelineAPI) DeactivatePipelineRequest ¶
func (m *MockDataPipelineAPI) DeactivatePipelineRequest(arg0 *datapipeline.DeactivatePipelineInput) (*request.Request, *datapipeline.DeactivatePipelineOutput)
DeactivatePipelineRequest mocks base method
func (*MockDataPipelineAPI) DeactivatePipelineWithContext ¶
func (m *MockDataPipelineAPI) DeactivatePipelineWithContext(arg0 context.Context, arg1 *datapipeline.DeactivatePipelineInput, arg2 ...request.Option) (*datapipeline.DeactivatePipelineOutput, error)
DeactivatePipelineWithContext mocks base method
func (*MockDataPipelineAPI) DeletePipeline ¶
func (m *MockDataPipelineAPI) DeletePipeline(arg0 *datapipeline.DeletePipelineInput) (*datapipeline.DeletePipelineOutput, error)
DeletePipeline mocks base method
func (*MockDataPipelineAPI) DeletePipelineRequest ¶
func (m *MockDataPipelineAPI) DeletePipelineRequest(arg0 *datapipeline.DeletePipelineInput) (*request.Request, *datapipeline.DeletePipelineOutput)
DeletePipelineRequest mocks base method
func (*MockDataPipelineAPI) DeletePipelineWithContext ¶
func (m *MockDataPipelineAPI) DeletePipelineWithContext(arg0 context.Context, arg1 *datapipeline.DeletePipelineInput, arg2 ...request.Option) (*datapipeline.DeletePipelineOutput, error)
DeletePipelineWithContext mocks base method
func (*MockDataPipelineAPI) DescribeObjects ¶
func (m *MockDataPipelineAPI) DescribeObjects(arg0 *datapipeline.DescribeObjectsInput) (*datapipeline.DescribeObjectsOutput, error)
DescribeObjects mocks base method
func (*MockDataPipelineAPI) DescribeObjectsPages ¶
func (m *MockDataPipelineAPI) DescribeObjectsPages(arg0 *datapipeline.DescribeObjectsInput, arg1 func(*datapipeline.DescribeObjectsOutput, bool) bool) error
DescribeObjectsPages mocks base method
func (*MockDataPipelineAPI) DescribeObjectsPagesWithContext ¶
func (m *MockDataPipelineAPI) DescribeObjectsPagesWithContext(arg0 context.Context, arg1 *datapipeline.DescribeObjectsInput, arg2 func(*datapipeline.DescribeObjectsOutput, bool) bool, arg3 ...request.Option) error
DescribeObjectsPagesWithContext mocks base method
func (*MockDataPipelineAPI) DescribeObjectsRequest ¶
func (m *MockDataPipelineAPI) DescribeObjectsRequest(arg0 *datapipeline.DescribeObjectsInput) (*request.Request, *datapipeline.DescribeObjectsOutput)
DescribeObjectsRequest mocks base method
func (*MockDataPipelineAPI) DescribeObjectsWithContext ¶
func (m *MockDataPipelineAPI) DescribeObjectsWithContext(arg0 context.Context, arg1 *datapipeline.DescribeObjectsInput, arg2 ...request.Option) (*datapipeline.DescribeObjectsOutput, error)
DescribeObjectsWithContext mocks base method
func (*MockDataPipelineAPI) DescribePipelines ¶
func (m *MockDataPipelineAPI) DescribePipelines(arg0 *datapipeline.DescribePipelinesInput) (*datapipeline.DescribePipelinesOutput, error)
DescribePipelines mocks base method
func (*MockDataPipelineAPI) DescribePipelinesRequest ¶
func (m *MockDataPipelineAPI) DescribePipelinesRequest(arg0 *datapipeline.DescribePipelinesInput) (*request.Request, *datapipeline.DescribePipelinesOutput)
DescribePipelinesRequest mocks base method
func (*MockDataPipelineAPI) DescribePipelinesWithContext ¶
func (m *MockDataPipelineAPI) DescribePipelinesWithContext(arg0 context.Context, arg1 *datapipeline.DescribePipelinesInput, arg2 ...request.Option) (*datapipeline.DescribePipelinesOutput, error)
DescribePipelinesWithContext mocks base method
func (*MockDataPipelineAPI) EXPECT ¶
func (m *MockDataPipelineAPI) EXPECT() *MockDataPipelineAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockDataPipelineAPI) EvaluateExpression ¶
func (m *MockDataPipelineAPI) EvaluateExpression(arg0 *datapipeline.EvaluateExpressionInput) (*datapipeline.EvaluateExpressionOutput, error)
EvaluateExpression mocks base method
func (*MockDataPipelineAPI) EvaluateExpressionRequest ¶
func (m *MockDataPipelineAPI) EvaluateExpressionRequest(arg0 *datapipeline.EvaluateExpressionInput) (*request.Request, *datapipeline.EvaluateExpressionOutput)
EvaluateExpressionRequest mocks base method
func (*MockDataPipelineAPI) EvaluateExpressionWithContext ¶
func (m *MockDataPipelineAPI) EvaluateExpressionWithContext(arg0 context.Context, arg1 *datapipeline.EvaluateExpressionInput, arg2 ...request.Option) (*datapipeline.EvaluateExpressionOutput, error)
EvaluateExpressionWithContext mocks base method
func (*MockDataPipelineAPI) GetPipelineDefinition ¶
func (m *MockDataPipelineAPI) GetPipelineDefinition(arg0 *datapipeline.GetPipelineDefinitionInput) (*datapipeline.GetPipelineDefinitionOutput, error)
GetPipelineDefinition mocks base method
func (*MockDataPipelineAPI) GetPipelineDefinitionRequest ¶
func (m *MockDataPipelineAPI) GetPipelineDefinitionRequest(arg0 *datapipeline.GetPipelineDefinitionInput) (*request.Request, *datapipeline.GetPipelineDefinitionOutput)
GetPipelineDefinitionRequest mocks base method
func (*MockDataPipelineAPI) GetPipelineDefinitionWithContext ¶
func (m *MockDataPipelineAPI) GetPipelineDefinitionWithContext(arg0 context.Context, arg1 *datapipeline.GetPipelineDefinitionInput, arg2 ...request.Option) (*datapipeline.GetPipelineDefinitionOutput, error)
GetPipelineDefinitionWithContext mocks base method
func (*MockDataPipelineAPI) ListPipelines ¶
func (m *MockDataPipelineAPI) ListPipelines(arg0 *datapipeline.ListPipelinesInput) (*datapipeline.ListPipelinesOutput, error)
ListPipelines mocks base method
func (*MockDataPipelineAPI) ListPipelinesPages ¶
func (m *MockDataPipelineAPI) ListPipelinesPages(arg0 *datapipeline.ListPipelinesInput, arg1 func(*datapipeline.ListPipelinesOutput, bool) bool) error
ListPipelinesPages mocks base method
func (*MockDataPipelineAPI) ListPipelinesPagesWithContext ¶
func (m *MockDataPipelineAPI) ListPipelinesPagesWithContext(arg0 context.Context, arg1 *datapipeline.ListPipelinesInput, arg2 func(*datapipeline.ListPipelinesOutput, bool) bool, arg3 ...request.Option) error
ListPipelinesPagesWithContext mocks base method
func (*MockDataPipelineAPI) ListPipelinesRequest ¶
func (m *MockDataPipelineAPI) ListPipelinesRequest(arg0 *datapipeline.ListPipelinesInput) (*request.Request, *datapipeline.ListPipelinesOutput)
ListPipelinesRequest mocks base method
func (*MockDataPipelineAPI) ListPipelinesWithContext ¶
func (m *MockDataPipelineAPI) ListPipelinesWithContext(arg0 context.Context, arg1 *datapipeline.ListPipelinesInput, arg2 ...request.Option) (*datapipeline.ListPipelinesOutput, error)
ListPipelinesWithContext mocks base method
func (*MockDataPipelineAPI) PollForTask ¶
func (m *MockDataPipelineAPI) PollForTask(arg0 *datapipeline.PollForTaskInput) (*datapipeline.PollForTaskOutput, error)
PollForTask mocks base method
func (*MockDataPipelineAPI) PollForTaskRequest ¶
func (m *MockDataPipelineAPI) PollForTaskRequest(arg0 *datapipeline.PollForTaskInput) (*request.Request, *datapipeline.PollForTaskOutput)
PollForTaskRequest mocks base method
func (*MockDataPipelineAPI) PollForTaskWithContext ¶
func (m *MockDataPipelineAPI) PollForTaskWithContext(arg0 context.Context, arg1 *datapipeline.PollForTaskInput, arg2 ...request.Option) (*datapipeline.PollForTaskOutput, error)
PollForTaskWithContext mocks base method
func (*MockDataPipelineAPI) PutPipelineDefinition ¶
func (m *MockDataPipelineAPI) PutPipelineDefinition(arg0 *datapipeline.PutPipelineDefinitionInput) (*datapipeline.PutPipelineDefinitionOutput, error)
PutPipelineDefinition mocks base method
func (*MockDataPipelineAPI) PutPipelineDefinitionRequest ¶
func (m *MockDataPipelineAPI) PutPipelineDefinitionRequest(arg0 *datapipeline.PutPipelineDefinitionInput) (*request.Request, *datapipeline.PutPipelineDefinitionOutput)
PutPipelineDefinitionRequest mocks base method
func (*MockDataPipelineAPI) PutPipelineDefinitionWithContext ¶
func (m *MockDataPipelineAPI) PutPipelineDefinitionWithContext(arg0 context.Context, arg1 *datapipeline.PutPipelineDefinitionInput, arg2 ...request.Option) (*datapipeline.PutPipelineDefinitionOutput, error)
PutPipelineDefinitionWithContext mocks base method
func (*MockDataPipelineAPI) QueryObjects ¶
func (m *MockDataPipelineAPI) QueryObjects(arg0 *datapipeline.QueryObjectsInput) (*datapipeline.QueryObjectsOutput, error)
QueryObjects mocks base method
func (*MockDataPipelineAPI) QueryObjectsPages ¶
func (m *MockDataPipelineAPI) QueryObjectsPages(arg0 *datapipeline.QueryObjectsInput, arg1 func(*datapipeline.QueryObjectsOutput, bool) bool) error
QueryObjectsPages mocks base method
func (*MockDataPipelineAPI) QueryObjectsPagesWithContext ¶
func (m *MockDataPipelineAPI) QueryObjectsPagesWithContext(arg0 context.Context, arg1 *datapipeline.QueryObjectsInput, arg2 func(*datapipeline.QueryObjectsOutput, bool) bool, arg3 ...request.Option) error
QueryObjectsPagesWithContext mocks base method
func (*MockDataPipelineAPI) QueryObjectsRequest ¶
func (m *MockDataPipelineAPI) QueryObjectsRequest(arg0 *datapipeline.QueryObjectsInput) (*request.Request, *datapipeline.QueryObjectsOutput)
QueryObjectsRequest mocks base method
func (*MockDataPipelineAPI) QueryObjectsWithContext ¶
func (m *MockDataPipelineAPI) QueryObjectsWithContext(arg0 context.Context, arg1 *datapipeline.QueryObjectsInput, arg2 ...request.Option) (*datapipeline.QueryObjectsOutput, error)
QueryObjectsWithContext mocks base method
func (*MockDataPipelineAPI) RemoveTags ¶
func (m *MockDataPipelineAPI) RemoveTags(arg0 *datapipeline.RemoveTagsInput) (*datapipeline.RemoveTagsOutput, error)
RemoveTags mocks base method
func (*MockDataPipelineAPI) RemoveTagsRequest ¶
func (m *MockDataPipelineAPI) RemoveTagsRequest(arg0 *datapipeline.RemoveTagsInput) (*request.Request, *datapipeline.RemoveTagsOutput)
RemoveTagsRequest mocks base method
func (*MockDataPipelineAPI) RemoveTagsWithContext ¶
func (m *MockDataPipelineAPI) RemoveTagsWithContext(arg0 context.Context, arg1 *datapipeline.RemoveTagsInput, arg2 ...request.Option) (*datapipeline.RemoveTagsOutput, error)
RemoveTagsWithContext mocks base method
func (*MockDataPipelineAPI) ReportTaskProgress ¶
func (m *MockDataPipelineAPI) ReportTaskProgress(arg0 *datapipeline.ReportTaskProgressInput) (*datapipeline.ReportTaskProgressOutput, error)
ReportTaskProgress mocks base method
func (*MockDataPipelineAPI) ReportTaskProgressRequest ¶
func (m *MockDataPipelineAPI) ReportTaskProgressRequest(arg0 *datapipeline.ReportTaskProgressInput) (*request.Request, *datapipeline.ReportTaskProgressOutput)
ReportTaskProgressRequest mocks base method
func (*MockDataPipelineAPI) ReportTaskProgressWithContext ¶
func (m *MockDataPipelineAPI) ReportTaskProgressWithContext(arg0 context.Context, arg1 *datapipeline.ReportTaskProgressInput, arg2 ...request.Option) (*datapipeline.ReportTaskProgressOutput, error)
ReportTaskProgressWithContext mocks base method
func (*MockDataPipelineAPI) ReportTaskRunnerHeartbeat ¶
func (m *MockDataPipelineAPI) ReportTaskRunnerHeartbeat(arg0 *datapipeline.ReportTaskRunnerHeartbeatInput) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)
ReportTaskRunnerHeartbeat mocks base method
func (*MockDataPipelineAPI) ReportTaskRunnerHeartbeatRequest ¶
func (m *MockDataPipelineAPI) ReportTaskRunnerHeartbeatRequest(arg0 *datapipeline.ReportTaskRunnerHeartbeatInput) (*request.Request, *datapipeline.ReportTaskRunnerHeartbeatOutput)
ReportTaskRunnerHeartbeatRequest mocks base method
func (*MockDataPipelineAPI) ReportTaskRunnerHeartbeatWithContext ¶
func (m *MockDataPipelineAPI) ReportTaskRunnerHeartbeatWithContext(arg0 context.Context, arg1 *datapipeline.ReportTaskRunnerHeartbeatInput, arg2 ...request.Option) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)
ReportTaskRunnerHeartbeatWithContext mocks base method
func (*MockDataPipelineAPI) SetStatus ¶
func (m *MockDataPipelineAPI) SetStatus(arg0 *datapipeline.SetStatusInput) (*datapipeline.SetStatusOutput, error)
SetStatus mocks base method
func (*MockDataPipelineAPI) SetStatusRequest ¶
func (m *MockDataPipelineAPI) SetStatusRequest(arg0 *datapipeline.SetStatusInput) (*request.Request, *datapipeline.SetStatusOutput)
SetStatusRequest mocks base method
func (*MockDataPipelineAPI) SetStatusWithContext ¶
func (m *MockDataPipelineAPI) SetStatusWithContext(arg0 context.Context, arg1 *datapipeline.SetStatusInput, arg2 ...request.Option) (*datapipeline.SetStatusOutput, error)
SetStatusWithContext mocks base method
func (*MockDataPipelineAPI) SetTaskStatus ¶
func (m *MockDataPipelineAPI) SetTaskStatus(arg0 *datapipeline.SetTaskStatusInput) (*datapipeline.SetTaskStatusOutput, error)
SetTaskStatus mocks base method
func (*MockDataPipelineAPI) SetTaskStatusRequest ¶
func (m *MockDataPipelineAPI) SetTaskStatusRequest(arg0 *datapipeline.SetTaskStatusInput) (*request.Request, *datapipeline.SetTaskStatusOutput)
SetTaskStatusRequest mocks base method
func (*MockDataPipelineAPI) SetTaskStatusWithContext ¶
func (m *MockDataPipelineAPI) SetTaskStatusWithContext(arg0 context.Context, arg1 *datapipeline.SetTaskStatusInput, arg2 ...request.Option) (*datapipeline.SetTaskStatusOutput, error)
SetTaskStatusWithContext mocks base method
func (*MockDataPipelineAPI) ValidatePipelineDefinition ¶
func (m *MockDataPipelineAPI) ValidatePipelineDefinition(arg0 *datapipeline.ValidatePipelineDefinitionInput) (*datapipeline.ValidatePipelineDefinitionOutput, error)
ValidatePipelineDefinition mocks base method
func (*MockDataPipelineAPI) ValidatePipelineDefinitionRequest ¶
func (m *MockDataPipelineAPI) ValidatePipelineDefinitionRequest(arg0 *datapipeline.ValidatePipelineDefinitionInput) (*request.Request, *datapipeline.ValidatePipelineDefinitionOutput)
ValidatePipelineDefinitionRequest mocks base method
func (*MockDataPipelineAPI) ValidatePipelineDefinitionWithContext ¶
func (m *MockDataPipelineAPI) ValidatePipelineDefinitionWithContext(arg0 context.Context, arg1 *datapipeline.ValidatePipelineDefinitionInput, arg2 ...request.Option) (*datapipeline.ValidatePipelineDefinitionOutput, error)
ValidatePipelineDefinitionWithContext mocks base method
type MockDataPipelineAPIMockRecorder ¶
type MockDataPipelineAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockDataPipelineAPIMockRecorder is the mock recorder for MockDataPipelineAPI
func (*MockDataPipelineAPIMockRecorder) ActivatePipeline ¶
func (mr *MockDataPipelineAPIMockRecorder) ActivatePipeline(arg0 interface{}) *gomock.Call
ActivatePipeline indicates an expected call of ActivatePipeline
func (*MockDataPipelineAPIMockRecorder) ActivatePipelineRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) ActivatePipelineRequest(arg0 interface{}) *gomock.Call
ActivatePipelineRequest indicates an expected call of ActivatePipelineRequest
func (*MockDataPipelineAPIMockRecorder) ActivatePipelineWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) ActivatePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ActivatePipelineWithContext indicates an expected call of ActivatePipelineWithContext
func (*MockDataPipelineAPIMockRecorder) AddTags ¶
func (mr *MockDataPipelineAPIMockRecorder) AddTags(arg0 interface{}) *gomock.Call
AddTags indicates an expected call of AddTags
func (*MockDataPipelineAPIMockRecorder) AddTagsRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) AddTagsRequest(arg0 interface{}) *gomock.Call
AddTagsRequest indicates an expected call of AddTagsRequest
func (*MockDataPipelineAPIMockRecorder) AddTagsWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) AddTagsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
AddTagsWithContext indicates an expected call of AddTagsWithContext
func (*MockDataPipelineAPIMockRecorder) CreatePipeline ¶
func (mr *MockDataPipelineAPIMockRecorder) CreatePipeline(arg0 interface{}) *gomock.Call
CreatePipeline indicates an expected call of CreatePipeline
func (*MockDataPipelineAPIMockRecorder) CreatePipelineRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) CreatePipelineRequest(arg0 interface{}) *gomock.Call
CreatePipelineRequest indicates an expected call of CreatePipelineRequest
func (*MockDataPipelineAPIMockRecorder) CreatePipelineWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) CreatePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreatePipelineWithContext indicates an expected call of CreatePipelineWithContext
func (*MockDataPipelineAPIMockRecorder) DeactivatePipeline ¶
func (mr *MockDataPipelineAPIMockRecorder) DeactivatePipeline(arg0 interface{}) *gomock.Call
DeactivatePipeline indicates an expected call of DeactivatePipeline
func (*MockDataPipelineAPIMockRecorder) DeactivatePipelineRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) DeactivatePipelineRequest(arg0 interface{}) *gomock.Call
DeactivatePipelineRequest indicates an expected call of DeactivatePipelineRequest
func (*MockDataPipelineAPIMockRecorder) DeactivatePipelineWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) DeactivatePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeactivatePipelineWithContext indicates an expected call of DeactivatePipelineWithContext
func (*MockDataPipelineAPIMockRecorder) DeletePipeline ¶
func (mr *MockDataPipelineAPIMockRecorder) DeletePipeline(arg0 interface{}) *gomock.Call
DeletePipeline indicates an expected call of DeletePipeline
func (*MockDataPipelineAPIMockRecorder) DeletePipelineRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) DeletePipelineRequest(arg0 interface{}) *gomock.Call
DeletePipelineRequest indicates an expected call of DeletePipelineRequest
func (*MockDataPipelineAPIMockRecorder) DeletePipelineWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) DeletePipelineWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeletePipelineWithContext indicates an expected call of DeletePipelineWithContext
func (*MockDataPipelineAPIMockRecorder) DescribeObjects ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribeObjects(arg0 interface{}) *gomock.Call
DescribeObjects indicates an expected call of DescribeObjects
func (*MockDataPipelineAPIMockRecorder) DescribeObjectsPages ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsPages(arg0, arg1 interface{}) *gomock.Call
DescribeObjectsPages indicates an expected call of DescribeObjectsPages
func (*MockDataPipelineAPIMockRecorder) DescribeObjectsPagesWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
DescribeObjectsPagesWithContext indicates an expected call of DescribeObjectsPagesWithContext
func (*MockDataPipelineAPIMockRecorder) DescribeObjectsRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsRequest(arg0 interface{}) *gomock.Call
DescribeObjectsRequest indicates an expected call of DescribeObjectsRequest
func (*MockDataPipelineAPIMockRecorder) DescribeObjectsWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribeObjectsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeObjectsWithContext indicates an expected call of DescribeObjectsWithContext
func (*MockDataPipelineAPIMockRecorder) DescribePipelines ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribePipelines(arg0 interface{}) *gomock.Call
DescribePipelines indicates an expected call of DescribePipelines
func (*MockDataPipelineAPIMockRecorder) DescribePipelinesRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribePipelinesRequest(arg0 interface{}) *gomock.Call
DescribePipelinesRequest indicates an expected call of DescribePipelinesRequest
func (*MockDataPipelineAPIMockRecorder) DescribePipelinesWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) DescribePipelinesWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribePipelinesWithContext indicates an expected call of DescribePipelinesWithContext
func (*MockDataPipelineAPIMockRecorder) EvaluateExpression ¶
func (mr *MockDataPipelineAPIMockRecorder) EvaluateExpression(arg0 interface{}) *gomock.Call
EvaluateExpression indicates an expected call of EvaluateExpression
func (*MockDataPipelineAPIMockRecorder) EvaluateExpressionRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) EvaluateExpressionRequest(arg0 interface{}) *gomock.Call
EvaluateExpressionRequest indicates an expected call of EvaluateExpressionRequest
func (*MockDataPipelineAPIMockRecorder) EvaluateExpressionWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) EvaluateExpressionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
EvaluateExpressionWithContext indicates an expected call of EvaluateExpressionWithContext
func (*MockDataPipelineAPIMockRecorder) GetPipelineDefinition ¶
func (mr *MockDataPipelineAPIMockRecorder) GetPipelineDefinition(arg0 interface{}) *gomock.Call
GetPipelineDefinition indicates an expected call of GetPipelineDefinition
func (*MockDataPipelineAPIMockRecorder) GetPipelineDefinitionRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) GetPipelineDefinitionRequest(arg0 interface{}) *gomock.Call
GetPipelineDefinitionRequest indicates an expected call of GetPipelineDefinitionRequest
func (*MockDataPipelineAPIMockRecorder) GetPipelineDefinitionWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) GetPipelineDefinitionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetPipelineDefinitionWithContext indicates an expected call of GetPipelineDefinitionWithContext
func (*MockDataPipelineAPIMockRecorder) ListPipelines ¶
func (mr *MockDataPipelineAPIMockRecorder) ListPipelines(arg0 interface{}) *gomock.Call
ListPipelines indicates an expected call of ListPipelines
func (*MockDataPipelineAPIMockRecorder) ListPipelinesPages ¶
func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesPages(arg0, arg1 interface{}) *gomock.Call
ListPipelinesPages indicates an expected call of ListPipelinesPages
func (*MockDataPipelineAPIMockRecorder) ListPipelinesPagesWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListPipelinesPagesWithContext indicates an expected call of ListPipelinesPagesWithContext
func (*MockDataPipelineAPIMockRecorder) ListPipelinesRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesRequest(arg0 interface{}) *gomock.Call
ListPipelinesRequest indicates an expected call of ListPipelinesRequest
func (*MockDataPipelineAPIMockRecorder) ListPipelinesWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) ListPipelinesWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListPipelinesWithContext indicates an expected call of ListPipelinesWithContext
func (*MockDataPipelineAPIMockRecorder) PollForTask ¶
func (mr *MockDataPipelineAPIMockRecorder) PollForTask(arg0 interface{}) *gomock.Call
PollForTask indicates an expected call of PollForTask
func (*MockDataPipelineAPIMockRecorder) PollForTaskRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) PollForTaskRequest(arg0 interface{}) *gomock.Call
PollForTaskRequest indicates an expected call of PollForTaskRequest
func (*MockDataPipelineAPIMockRecorder) PollForTaskWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) PollForTaskWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PollForTaskWithContext indicates an expected call of PollForTaskWithContext
func (*MockDataPipelineAPIMockRecorder) PutPipelineDefinition ¶
func (mr *MockDataPipelineAPIMockRecorder) PutPipelineDefinition(arg0 interface{}) *gomock.Call
PutPipelineDefinition indicates an expected call of PutPipelineDefinition
func (*MockDataPipelineAPIMockRecorder) PutPipelineDefinitionRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) PutPipelineDefinitionRequest(arg0 interface{}) *gomock.Call
PutPipelineDefinitionRequest indicates an expected call of PutPipelineDefinitionRequest
func (*MockDataPipelineAPIMockRecorder) PutPipelineDefinitionWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) PutPipelineDefinitionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PutPipelineDefinitionWithContext indicates an expected call of PutPipelineDefinitionWithContext
func (*MockDataPipelineAPIMockRecorder) QueryObjects ¶
func (mr *MockDataPipelineAPIMockRecorder) QueryObjects(arg0 interface{}) *gomock.Call
QueryObjects indicates an expected call of QueryObjects
func (*MockDataPipelineAPIMockRecorder) QueryObjectsPages ¶
func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsPages(arg0, arg1 interface{}) *gomock.Call
QueryObjectsPages indicates an expected call of QueryObjectsPages
func (*MockDataPipelineAPIMockRecorder) QueryObjectsPagesWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
QueryObjectsPagesWithContext indicates an expected call of QueryObjectsPagesWithContext
func (*MockDataPipelineAPIMockRecorder) QueryObjectsRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsRequest(arg0 interface{}) *gomock.Call
QueryObjectsRequest indicates an expected call of QueryObjectsRequest
func (*MockDataPipelineAPIMockRecorder) QueryObjectsWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) QueryObjectsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
QueryObjectsWithContext indicates an expected call of QueryObjectsWithContext
func (*MockDataPipelineAPIMockRecorder) RemoveTags ¶
func (mr *MockDataPipelineAPIMockRecorder) RemoveTags(arg0 interface{}) *gomock.Call
RemoveTags indicates an expected call of RemoveTags
func (*MockDataPipelineAPIMockRecorder) RemoveTagsRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) RemoveTagsRequest(arg0 interface{}) *gomock.Call
RemoveTagsRequest indicates an expected call of RemoveTagsRequest
func (*MockDataPipelineAPIMockRecorder) RemoveTagsWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) RemoveTagsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RemoveTagsWithContext indicates an expected call of RemoveTagsWithContext
func (*MockDataPipelineAPIMockRecorder) ReportTaskProgress ¶
func (mr *MockDataPipelineAPIMockRecorder) ReportTaskProgress(arg0 interface{}) *gomock.Call
ReportTaskProgress indicates an expected call of ReportTaskProgress
func (*MockDataPipelineAPIMockRecorder) ReportTaskProgressRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) ReportTaskProgressRequest(arg0 interface{}) *gomock.Call
ReportTaskProgressRequest indicates an expected call of ReportTaskProgressRequest
func (*MockDataPipelineAPIMockRecorder) ReportTaskProgressWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) ReportTaskProgressWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ReportTaskProgressWithContext indicates an expected call of ReportTaskProgressWithContext
func (*MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeat ¶
func (mr *MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeat(arg0 interface{}) *gomock.Call
ReportTaskRunnerHeartbeat indicates an expected call of ReportTaskRunnerHeartbeat
func (*MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeatRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeatRequest(arg0 interface{}) *gomock.Call
ReportTaskRunnerHeartbeatRequest indicates an expected call of ReportTaskRunnerHeartbeatRequest
func (*MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeatWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) ReportTaskRunnerHeartbeatWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ReportTaskRunnerHeartbeatWithContext indicates an expected call of ReportTaskRunnerHeartbeatWithContext
func (*MockDataPipelineAPIMockRecorder) SetStatus ¶
func (mr *MockDataPipelineAPIMockRecorder) SetStatus(arg0 interface{}) *gomock.Call
SetStatus indicates an expected call of SetStatus
func (*MockDataPipelineAPIMockRecorder) SetStatusRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) SetStatusRequest(arg0 interface{}) *gomock.Call
SetStatusRequest indicates an expected call of SetStatusRequest
func (*MockDataPipelineAPIMockRecorder) SetStatusWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) SetStatusWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetStatusWithContext indicates an expected call of SetStatusWithContext
func (*MockDataPipelineAPIMockRecorder) SetTaskStatus ¶
func (mr *MockDataPipelineAPIMockRecorder) SetTaskStatus(arg0 interface{}) *gomock.Call
SetTaskStatus indicates an expected call of SetTaskStatus
func (*MockDataPipelineAPIMockRecorder) SetTaskStatusRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) SetTaskStatusRequest(arg0 interface{}) *gomock.Call
SetTaskStatusRequest indicates an expected call of SetTaskStatusRequest
func (*MockDataPipelineAPIMockRecorder) SetTaskStatusWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) SetTaskStatusWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetTaskStatusWithContext indicates an expected call of SetTaskStatusWithContext
func (*MockDataPipelineAPIMockRecorder) ValidatePipelineDefinition ¶
func (mr *MockDataPipelineAPIMockRecorder) ValidatePipelineDefinition(arg0 interface{}) *gomock.Call
ValidatePipelineDefinition indicates an expected call of ValidatePipelineDefinition
func (*MockDataPipelineAPIMockRecorder) ValidatePipelineDefinitionRequest ¶
func (mr *MockDataPipelineAPIMockRecorder) ValidatePipelineDefinitionRequest(arg0 interface{}) *gomock.Call
ValidatePipelineDefinitionRequest indicates an expected call of ValidatePipelineDefinitionRequest
func (*MockDataPipelineAPIMockRecorder) ValidatePipelineDefinitionWithContext ¶
func (mr *MockDataPipelineAPIMockRecorder) ValidatePipelineDefinitionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ValidatePipelineDefinitionWithContext indicates an expected call of ValidatePipelineDefinitionWithContext