Documentation ¶
Overview ¶
Code generated by go awsdoublegen; DO NOT EDIT. This file was generated at 2020-01-29T21:22:05+11:00 For SDKVersion 1.28.13 Package datapipelinedouble contains test double implementation of datapipelineiface.DataPipelineAPI
Package datapipelinedouble provides a TestDouble implementation of datapipelineiface.DataPipelineAPI ¶
Code generated by go awsdoublegen; DO NOT EDIT. This file was generated at 2020-01-29T21:22:05+11:00
Index ¶
- type DataPipelineDouble
- func (d *DataPipelineDouble) ActivatePipeline(i0 *datapipeline.ActivatePipelineInput) (r0 *datapipeline.ActivatePipelineOutput, r1 error)
- func (d *DataPipelineDouble) ActivatePipelineRequest(i0 *datapipeline.ActivatePipelineInput) (r0 *request.Request, r1 *datapipeline.ActivatePipelineOutput)
- func (d *DataPipelineDouble) ActivatePipelineWithContext(i0 context.Context, i1 *datapipeline.ActivatePipelineInput, ...) (r0 *datapipeline.ActivatePipelineOutput, r1 error)
- func (d *DataPipelineDouble) AddTags(i0 *datapipeline.AddTagsInput) (r0 *datapipeline.AddTagsOutput, r1 error)
- func (d *DataPipelineDouble) AddTagsRequest(i0 *datapipeline.AddTagsInput) (r0 *request.Request, r1 *datapipeline.AddTagsOutput)
- func (d *DataPipelineDouble) AddTagsWithContext(i0 context.Context, i1 *datapipeline.AddTagsInput, i2 ...request.Option) (r0 *datapipeline.AddTagsOutput, r1 error)
- func (d *DataPipelineDouble) CreatePipeline(i0 *datapipeline.CreatePipelineInput) (r0 *datapipeline.CreatePipelineOutput, r1 error)
- func (d *DataPipelineDouble) CreatePipelineRequest(i0 *datapipeline.CreatePipelineInput) (r0 *request.Request, r1 *datapipeline.CreatePipelineOutput)
- func (d *DataPipelineDouble) CreatePipelineWithContext(i0 context.Context, i1 *datapipeline.CreatePipelineInput, i2 ...request.Option) (r0 *datapipeline.CreatePipelineOutput, r1 error)
- func (d *DataPipelineDouble) DeactivatePipeline(i0 *datapipeline.DeactivatePipelineInput) (r0 *datapipeline.DeactivatePipelineOutput, r1 error)
- func (d *DataPipelineDouble) DeactivatePipelineRequest(i0 *datapipeline.DeactivatePipelineInput) (r0 *request.Request, r1 *datapipeline.DeactivatePipelineOutput)
- func (d *DataPipelineDouble) DeactivatePipelineWithContext(i0 context.Context, i1 *datapipeline.DeactivatePipelineInput, ...) (r0 *datapipeline.DeactivatePipelineOutput, r1 error)
- func (d *DataPipelineDouble) DeletePipeline(i0 *datapipeline.DeletePipelineInput) (r0 *datapipeline.DeletePipelineOutput, r1 error)
- func (d *DataPipelineDouble) DeletePipelineRequest(i0 *datapipeline.DeletePipelineInput) (r0 *request.Request, r1 *datapipeline.DeletePipelineOutput)
- func (d *DataPipelineDouble) DeletePipelineWithContext(i0 context.Context, i1 *datapipeline.DeletePipelineInput, i2 ...request.Option) (r0 *datapipeline.DeletePipelineOutput, r1 error)
- func (d *DataPipelineDouble) DescribeObjects(i0 *datapipeline.DescribeObjectsInput) (r0 *datapipeline.DescribeObjectsOutput, r1 error)
- func (d *DataPipelineDouble) DescribeObjectsPages(i0 *datapipeline.DescribeObjectsInput, ...) (r0 error)
- func (d *DataPipelineDouble) DescribeObjectsPagesWithContext(i0 context.Context, i1 *datapipeline.DescribeObjectsInput, ...) (r0 error)
- func (d *DataPipelineDouble) DescribeObjectsRequest(i0 *datapipeline.DescribeObjectsInput) (r0 *request.Request, r1 *datapipeline.DescribeObjectsOutput)
- func (d *DataPipelineDouble) DescribeObjectsWithContext(i0 context.Context, i1 *datapipeline.DescribeObjectsInput, ...) (r0 *datapipeline.DescribeObjectsOutput, r1 error)
- func (d *DataPipelineDouble) DescribePipelines(i0 *datapipeline.DescribePipelinesInput) (r0 *datapipeline.DescribePipelinesOutput, r1 error)
- func (d *DataPipelineDouble) DescribePipelinesRequest(i0 *datapipeline.DescribePipelinesInput) (r0 *request.Request, r1 *datapipeline.DescribePipelinesOutput)
- func (d *DataPipelineDouble) DescribePipelinesWithContext(i0 context.Context, i1 *datapipeline.DescribePipelinesInput, ...) (r0 *datapipeline.DescribePipelinesOutput, r1 error)
- func (d *DataPipelineDouble) EvaluateExpression(i0 *datapipeline.EvaluateExpressionInput) (r0 *datapipeline.EvaluateExpressionOutput, r1 error)
- func (d *DataPipelineDouble) EvaluateExpressionRequest(i0 *datapipeline.EvaluateExpressionInput) (r0 *request.Request, r1 *datapipeline.EvaluateExpressionOutput)
- func (d *DataPipelineDouble) EvaluateExpressionWithContext(i0 context.Context, i1 *datapipeline.EvaluateExpressionInput, ...) (r0 *datapipeline.EvaluateExpressionOutput, r1 error)
- func (d *DataPipelineDouble) GetPipelineDefinition(i0 *datapipeline.GetPipelineDefinitionInput) (r0 *datapipeline.GetPipelineDefinitionOutput, r1 error)
- func (d *DataPipelineDouble) GetPipelineDefinitionRequest(i0 *datapipeline.GetPipelineDefinitionInput) (r0 *request.Request, r1 *datapipeline.GetPipelineDefinitionOutput)
- func (d *DataPipelineDouble) GetPipelineDefinitionWithContext(i0 context.Context, i1 *datapipeline.GetPipelineDefinitionInput, ...) (r0 *datapipeline.GetPipelineDefinitionOutput, r1 error)
- func (d *DataPipelineDouble) ListPipelines(i0 *datapipeline.ListPipelinesInput) (r0 *datapipeline.ListPipelinesOutput, r1 error)
- func (d *DataPipelineDouble) ListPipelinesPages(i0 *datapipeline.ListPipelinesInput, ...) (r0 error)
- func (d *DataPipelineDouble) ListPipelinesPagesWithContext(i0 context.Context, i1 *datapipeline.ListPipelinesInput, ...) (r0 error)
- func (d *DataPipelineDouble) ListPipelinesRequest(i0 *datapipeline.ListPipelinesInput) (r0 *request.Request, r1 *datapipeline.ListPipelinesOutput)
- func (d *DataPipelineDouble) ListPipelinesWithContext(i0 context.Context, i1 *datapipeline.ListPipelinesInput, i2 ...request.Option) (r0 *datapipeline.ListPipelinesOutput, r1 error)
- func (d *DataPipelineDouble) PollForTask(i0 *datapipeline.PollForTaskInput) (r0 *datapipeline.PollForTaskOutput, r1 error)
- func (d *DataPipelineDouble) PollForTaskRequest(i0 *datapipeline.PollForTaskInput) (r0 *request.Request, r1 *datapipeline.PollForTaskOutput)
- func (d *DataPipelineDouble) PollForTaskWithContext(i0 context.Context, i1 *datapipeline.PollForTaskInput, i2 ...request.Option) (r0 *datapipeline.PollForTaskOutput, r1 error)
- func (d *DataPipelineDouble) PutPipelineDefinition(i0 *datapipeline.PutPipelineDefinitionInput) (r0 *datapipeline.PutPipelineDefinitionOutput, r1 error)
- func (d *DataPipelineDouble) PutPipelineDefinitionRequest(i0 *datapipeline.PutPipelineDefinitionInput) (r0 *request.Request, r1 *datapipeline.PutPipelineDefinitionOutput)
- func (d *DataPipelineDouble) PutPipelineDefinitionWithContext(i0 context.Context, i1 *datapipeline.PutPipelineDefinitionInput, ...) (r0 *datapipeline.PutPipelineDefinitionOutput, r1 error)
- func (d *DataPipelineDouble) QueryObjects(i0 *datapipeline.QueryObjectsInput) (r0 *datapipeline.QueryObjectsOutput, r1 error)
- func (d *DataPipelineDouble) QueryObjectsPages(i0 *datapipeline.QueryObjectsInput, ...) (r0 error)
- func (d *DataPipelineDouble) QueryObjectsPagesWithContext(i0 context.Context, i1 *datapipeline.QueryObjectsInput, ...) (r0 error)
- func (d *DataPipelineDouble) QueryObjectsRequest(i0 *datapipeline.QueryObjectsInput) (r0 *request.Request, r1 *datapipeline.QueryObjectsOutput)
- func (d *DataPipelineDouble) QueryObjectsWithContext(i0 context.Context, i1 *datapipeline.QueryObjectsInput, i2 ...request.Option) (r0 *datapipeline.QueryObjectsOutput, r1 error)
- func (d *DataPipelineDouble) RemoveTags(i0 *datapipeline.RemoveTagsInput) (r0 *datapipeline.RemoveTagsOutput, r1 error)
- func (d *DataPipelineDouble) RemoveTagsRequest(i0 *datapipeline.RemoveTagsInput) (r0 *request.Request, r1 *datapipeline.RemoveTagsOutput)
- func (d *DataPipelineDouble) RemoveTagsWithContext(i0 context.Context, i1 *datapipeline.RemoveTagsInput, i2 ...request.Option) (r0 *datapipeline.RemoveTagsOutput, r1 error)
- func (d *DataPipelineDouble) ReportTaskProgress(i0 *datapipeline.ReportTaskProgressInput) (r0 *datapipeline.ReportTaskProgressOutput, r1 error)
- func (d *DataPipelineDouble) ReportTaskProgressRequest(i0 *datapipeline.ReportTaskProgressInput) (r0 *request.Request, r1 *datapipeline.ReportTaskProgressOutput)
- func (d *DataPipelineDouble) ReportTaskProgressWithContext(i0 context.Context, i1 *datapipeline.ReportTaskProgressInput, ...) (r0 *datapipeline.ReportTaskProgressOutput, r1 error)
- func (d *DataPipelineDouble) ReportTaskRunnerHeartbeat(i0 *datapipeline.ReportTaskRunnerHeartbeatInput) (r0 *datapipeline.ReportTaskRunnerHeartbeatOutput, r1 error)
- func (d *DataPipelineDouble) ReportTaskRunnerHeartbeatRequest(i0 *datapipeline.ReportTaskRunnerHeartbeatInput) (r0 *request.Request, r1 *datapipeline.ReportTaskRunnerHeartbeatOutput)
- func (d *DataPipelineDouble) ReportTaskRunnerHeartbeatWithContext(i0 context.Context, i1 *datapipeline.ReportTaskRunnerHeartbeatInput, ...) (r0 *datapipeline.ReportTaskRunnerHeartbeatOutput, r1 error)
- func (d *DataPipelineDouble) SetStatus(i0 *datapipeline.SetStatusInput) (r0 *datapipeline.SetStatusOutput, r1 error)
- func (d *DataPipelineDouble) SetStatusRequest(i0 *datapipeline.SetStatusInput) (r0 *request.Request, r1 *datapipeline.SetStatusOutput)
- func (d *DataPipelineDouble) SetStatusWithContext(i0 context.Context, i1 *datapipeline.SetStatusInput, i2 ...request.Option) (r0 *datapipeline.SetStatusOutput, r1 error)
- func (d *DataPipelineDouble) SetTaskStatus(i0 *datapipeline.SetTaskStatusInput) (r0 *datapipeline.SetTaskStatusOutput, r1 error)
- func (d *DataPipelineDouble) SetTaskStatusRequest(i0 *datapipeline.SetTaskStatusInput) (r0 *request.Request, r1 *datapipeline.SetTaskStatusOutput)
- func (d *DataPipelineDouble) SetTaskStatusWithContext(i0 context.Context, i1 *datapipeline.SetTaskStatusInput, i2 ...request.Option) (r0 *datapipeline.SetTaskStatusOutput, r1 error)
- func (d *DataPipelineDouble) ValidatePipelineDefinition(i0 *datapipeline.ValidatePipelineDefinitionInput) (r0 *datapipeline.ValidatePipelineDefinitionOutput, r1 error)
- func (d *DataPipelineDouble) ValidatePipelineDefinitionRequest(i0 *datapipeline.ValidatePipelineDefinitionInput) (r0 *request.Request, r1 *datapipeline.ValidatePipelineDefinitionOutput)
- func (d *DataPipelineDouble) ValidatePipelineDefinitionWithContext(i0 context.Context, i1 *datapipeline.ValidatePipelineDefinitionInput, ...) (r0 *datapipeline.ValidatePipelineDefinitionOutput, r1 error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataPipelineDouble ¶
type DataPipelineDouble struct { datapipelineiface.DataPipelineAPI *awsdouble.AWSTestDouble }
DataPipelineDouble is TestDouble for datapipelineiface.DataPipelineAPI
func NewDouble ¶
func NewDouble(t godouble.T, configurators ...func(*awsdouble.AWSTestDouble)) *DataPipelineDouble
Constructor for DataPipelineDouble Default configuration will ensure
API operations not explicitly stubbed will return an empty output struct pointer, and nil error. To simulate long polling, "Poll" operations will return these values after a random delay of up to 100ms.
WithContext methods implement a 'Fake' method that returns a cancellation error if the context is cancelled before the method is called.
Pages and PagesWithContext methods similarly implement a 'Fake' method that paginates over the underlying method.
This allows tests to only stub the simple api methods and be generally unconcerned whether the SUT is using the Context or Pagination forms of the API.
func (*DataPipelineDouble) ActivatePipeline ¶
func (d *DataPipelineDouble) ActivatePipeline(i0 *datapipeline.ActivatePipelineInput) (r0 *datapipeline.ActivatePipelineOutput, r1 error)
func (*DataPipelineDouble) ActivatePipelineRequest ¶
func (d *DataPipelineDouble) ActivatePipelineRequest(i0 *datapipeline.ActivatePipelineInput) (r0 *request.Request, r1 *datapipeline.ActivatePipelineOutput)
func (*DataPipelineDouble) ActivatePipelineWithContext ¶
func (d *DataPipelineDouble) ActivatePipelineWithContext(i0 context.Context, i1 *datapipeline.ActivatePipelineInput, i2 ...request.Option) (r0 *datapipeline.ActivatePipelineOutput, r1 error)
func (*DataPipelineDouble) AddTags ¶
func (d *DataPipelineDouble) AddTags(i0 *datapipeline.AddTagsInput) (r0 *datapipeline.AddTagsOutput, r1 error)
func (*DataPipelineDouble) AddTagsRequest ¶
func (d *DataPipelineDouble) AddTagsRequest(i0 *datapipeline.AddTagsInput) (r0 *request.Request, r1 *datapipeline.AddTagsOutput)
func (*DataPipelineDouble) AddTagsWithContext ¶
func (d *DataPipelineDouble) AddTagsWithContext(i0 context.Context, i1 *datapipeline.AddTagsInput, i2 ...request.Option) (r0 *datapipeline.AddTagsOutput, r1 error)
func (*DataPipelineDouble) CreatePipeline ¶
func (d *DataPipelineDouble) CreatePipeline(i0 *datapipeline.CreatePipelineInput) (r0 *datapipeline.CreatePipelineOutput, r1 error)
func (*DataPipelineDouble) CreatePipelineRequest ¶
func (d *DataPipelineDouble) CreatePipelineRequest(i0 *datapipeline.CreatePipelineInput) (r0 *request.Request, r1 *datapipeline.CreatePipelineOutput)
func (*DataPipelineDouble) CreatePipelineWithContext ¶
func (d *DataPipelineDouble) CreatePipelineWithContext(i0 context.Context, i1 *datapipeline.CreatePipelineInput, i2 ...request.Option) (r0 *datapipeline.CreatePipelineOutput, r1 error)
func (*DataPipelineDouble) DeactivatePipeline ¶
func (d *DataPipelineDouble) DeactivatePipeline(i0 *datapipeline.DeactivatePipelineInput) (r0 *datapipeline.DeactivatePipelineOutput, r1 error)
func (*DataPipelineDouble) DeactivatePipelineRequest ¶
func (d *DataPipelineDouble) DeactivatePipelineRequest(i0 *datapipeline.DeactivatePipelineInput) (r0 *request.Request, r1 *datapipeline.DeactivatePipelineOutput)
func (*DataPipelineDouble) DeactivatePipelineWithContext ¶
func (d *DataPipelineDouble) DeactivatePipelineWithContext(i0 context.Context, i1 *datapipeline.DeactivatePipelineInput, i2 ...request.Option) (r0 *datapipeline.DeactivatePipelineOutput, r1 error)
func (*DataPipelineDouble) DeletePipeline ¶
func (d *DataPipelineDouble) DeletePipeline(i0 *datapipeline.DeletePipelineInput) (r0 *datapipeline.DeletePipelineOutput, r1 error)
func (*DataPipelineDouble) DeletePipelineRequest ¶
func (d *DataPipelineDouble) DeletePipelineRequest(i0 *datapipeline.DeletePipelineInput) (r0 *request.Request, r1 *datapipeline.DeletePipelineOutput)
func (*DataPipelineDouble) DeletePipelineWithContext ¶
func (d *DataPipelineDouble) DeletePipelineWithContext(i0 context.Context, i1 *datapipeline.DeletePipelineInput, i2 ...request.Option) (r0 *datapipeline.DeletePipelineOutput, r1 error)
func (*DataPipelineDouble) DescribeObjects ¶
func (d *DataPipelineDouble) DescribeObjects(i0 *datapipeline.DescribeObjectsInput) (r0 *datapipeline.DescribeObjectsOutput, r1 error)
func (*DataPipelineDouble) DescribeObjectsPages ¶
func (d *DataPipelineDouble) DescribeObjectsPages(i0 *datapipeline.DescribeObjectsInput, i1 func(*datapipeline.DescribeObjectsOutput, bool) bool) (r0 error)
func (*DataPipelineDouble) DescribeObjectsPagesWithContext ¶
func (d *DataPipelineDouble) DescribeObjectsPagesWithContext(i0 context.Context, i1 *datapipeline.DescribeObjectsInput, i2 func(*datapipeline.DescribeObjectsOutput, bool) bool, i3 ...request.Option) (r0 error)
func (*DataPipelineDouble) DescribeObjectsRequest ¶
func (d *DataPipelineDouble) DescribeObjectsRequest(i0 *datapipeline.DescribeObjectsInput) (r0 *request.Request, r1 *datapipeline.DescribeObjectsOutput)
func (*DataPipelineDouble) DescribeObjectsWithContext ¶
func (d *DataPipelineDouble) DescribeObjectsWithContext(i0 context.Context, i1 *datapipeline.DescribeObjectsInput, i2 ...request.Option) (r0 *datapipeline.DescribeObjectsOutput, r1 error)
func (*DataPipelineDouble) DescribePipelines ¶
func (d *DataPipelineDouble) DescribePipelines(i0 *datapipeline.DescribePipelinesInput) (r0 *datapipeline.DescribePipelinesOutput, r1 error)
func (*DataPipelineDouble) DescribePipelinesRequest ¶
func (d *DataPipelineDouble) DescribePipelinesRequest(i0 *datapipeline.DescribePipelinesInput) (r0 *request.Request, r1 *datapipeline.DescribePipelinesOutput)
func (*DataPipelineDouble) DescribePipelinesWithContext ¶
func (d *DataPipelineDouble) DescribePipelinesWithContext(i0 context.Context, i1 *datapipeline.DescribePipelinesInput, i2 ...request.Option) (r0 *datapipeline.DescribePipelinesOutput, r1 error)
func (*DataPipelineDouble) EvaluateExpression ¶
func (d *DataPipelineDouble) EvaluateExpression(i0 *datapipeline.EvaluateExpressionInput) (r0 *datapipeline.EvaluateExpressionOutput, r1 error)
func (*DataPipelineDouble) EvaluateExpressionRequest ¶
func (d *DataPipelineDouble) EvaluateExpressionRequest(i0 *datapipeline.EvaluateExpressionInput) (r0 *request.Request, r1 *datapipeline.EvaluateExpressionOutput)
func (*DataPipelineDouble) EvaluateExpressionWithContext ¶
func (d *DataPipelineDouble) EvaluateExpressionWithContext(i0 context.Context, i1 *datapipeline.EvaluateExpressionInput, i2 ...request.Option) (r0 *datapipeline.EvaluateExpressionOutput, r1 error)
func (*DataPipelineDouble) GetPipelineDefinition ¶
func (d *DataPipelineDouble) GetPipelineDefinition(i0 *datapipeline.GetPipelineDefinitionInput) (r0 *datapipeline.GetPipelineDefinitionOutput, r1 error)
func (*DataPipelineDouble) GetPipelineDefinitionRequest ¶
func (d *DataPipelineDouble) GetPipelineDefinitionRequest(i0 *datapipeline.GetPipelineDefinitionInput) (r0 *request.Request, r1 *datapipeline.GetPipelineDefinitionOutput)
func (*DataPipelineDouble) GetPipelineDefinitionWithContext ¶
func (d *DataPipelineDouble) GetPipelineDefinitionWithContext(i0 context.Context, i1 *datapipeline.GetPipelineDefinitionInput, i2 ...request.Option) (r0 *datapipeline.GetPipelineDefinitionOutput, r1 error)
func (*DataPipelineDouble) ListPipelines ¶
func (d *DataPipelineDouble) ListPipelines(i0 *datapipeline.ListPipelinesInput) (r0 *datapipeline.ListPipelinesOutput, r1 error)
func (*DataPipelineDouble) ListPipelinesPages ¶
func (d *DataPipelineDouble) ListPipelinesPages(i0 *datapipeline.ListPipelinesInput, i1 func(*datapipeline.ListPipelinesOutput, bool) bool) (r0 error)
func (*DataPipelineDouble) ListPipelinesPagesWithContext ¶
func (d *DataPipelineDouble) ListPipelinesPagesWithContext(i0 context.Context, i1 *datapipeline.ListPipelinesInput, i2 func(*datapipeline.ListPipelinesOutput, bool) bool, i3 ...request.Option) (r0 error)
func (*DataPipelineDouble) ListPipelinesRequest ¶
func (d *DataPipelineDouble) ListPipelinesRequest(i0 *datapipeline.ListPipelinesInput) (r0 *request.Request, r1 *datapipeline.ListPipelinesOutput)
func (*DataPipelineDouble) ListPipelinesWithContext ¶
func (d *DataPipelineDouble) ListPipelinesWithContext(i0 context.Context, i1 *datapipeline.ListPipelinesInput, i2 ...request.Option) (r0 *datapipeline.ListPipelinesOutput, r1 error)
func (*DataPipelineDouble) PollForTask ¶
func (d *DataPipelineDouble) PollForTask(i0 *datapipeline.PollForTaskInput) (r0 *datapipeline.PollForTaskOutput, r1 error)
func (*DataPipelineDouble) PollForTaskRequest ¶
func (d *DataPipelineDouble) PollForTaskRequest(i0 *datapipeline.PollForTaskInput) (r0 *request.Request, r1 *datapipeline.PollForTaskOutput)
func (*DataPipelineDouble) PollForTaskWithContext ¶
func (d *DataPipelineDouble) PollForTaskWithContext(i0 context.Context, i1 *datapipeline.PollForTaskInput, i2 ...request.Option) (r0 *datapipeline.PollForTaskOutput, r1 error)
func (*DataPipelineDouble) PutPipelineDefinition ¶
func (d *DataPipelineDouble) PutPipelineDefinition(i0 *datapipeline.PutPipelineDefinitionInput) (r0 *datapipeline.PutPipelineDefinitionOutput, r1 error)
func (*DataPipelineDouble) PutPipelineDefinitionRequest ¶
func (d *DataPipelineDouble) PutPipelineDefinitionRequest(i0 *datapipeline.PutPipelineDefinitionInput) (r0 *request.Request, r1 *datapipeline.PutPipelineDefinitionOutput)
func (*DataPipelineDouble) PutPipelineDefinitionWithContext ¶
func (d *DataPipelineDouble) PutPipelineDefinitionWithContext(i0 context.Context, i1 *datapipeline.PutPipelineDefinitionInput, i2 ...request.Option) (r0 *datapipeline.PutPipelineDefinitionOutput, r1 error)
func (*DataPipelineDouble) QueryObjects ¶
func (d *DataPipelineDouble) QueryObjects(i0 *datapipeline.QueryObjectsInput) (r0 *datapipeline.QueryObjectsOutput, r1 error)
func (*DataPipelineDouble) QueryObjectsPages ¶
func (d *DataPipelineDouble) QueryObjectsPages(i0 *datapipeline.QueryObjectsInput, i1 func(*datapipeline.QueryObjectsOutput, bool) bool) (r0 error)
func (*DataPipelineDouble) QueryObjectsPagesWithContext ¶
func (d *DataPipelineDouble) QueryObjectsPagesWithContext(i0 context.Context, i1 *datapipeline.QueryObjectsInput, i2 func(*datapipeline.QueryObjectsOutput, bool) bool, i3 ...request.Option) (r0 error)
func (*DataPipelineDouble) QueryObjectsRequest ¶
func (d *DataPipelineDouble) QueryObjectsRequest(i0 *datapipeline.QueryObjectsInput) (r0 *request.Request, r1 *datapipeline.QueryObjectsOutput)
func (*DataPipelineDouble) QueryObjectsWithContext ¶
func (d *DataPipelineDouble) QueryObjectsWithContext(i0 context.Context, i1 *datapipeline.QueryObjectsInput, i2 ...request.Option) (r0 *datapipeline.QueryObjectsOutput, r1 error)
func (*DataPipelineDouble) RemoveTags ¶
func (d *DataPipelineDouble) RemoveTags(i0 *datapipeline.RemoveTagsInput) (r0 *datapipeline.RemoveTagsOutput, r1 error)
func (*DataPipelineDouble) RemoveTagsRequest ¶
func (d *DataPipelineDouble) RemoveTagsRequest(i0 *datapipeline.RemoveTagsInput) (r0 *request.Request, r1 *datapipeline.RemoveTagsOutput)
func (*DataPipelineDouble) RemoveTagsWithContext ¶
func (d *DataPipelineDouble) RemoveTagsWithContext(i0 context.Context, i1 *datapipeline.RemoveTagsInput, i2 ...request.Option) (r0 *datapipeline.RemoveTagsOutput, r1 error)
func (*DataPipelineDouble) ReportTaskProgress ¶
func (d *DataPipelineDouble) ReportTaskProgress(i0 *datapipeline.ReportTaskProgressInput) (r0 *datapipeline.ReportTaskProgressOutput, r1 error)
func (*DataPipelineDouble) ReportTaskProgressRequest ¶
func (d *DataPipelineDouble) ReportTaskProgressRequest(i0 *datapipeline.ReportTaskProgressInput) (r0 *request.Request, r1 *datapipeline.ReportTaskProgressOutput)
func (*DataPipelineDouble) ReportTaskProgressWithContext ¶
func (d *DataPipelineDouble) ReportTaskProgressWithContext(i0 context.Context, i1 *datapipeline.ReportTaskProgressInput, i2 ...request.Option) (r0 *datapipeline.ReportTaskProgressOutput, r1 error)
func (*DataPipelineDouble) ReportTaskRunnerHeartbeat ¶
func (d *DataPipelineDouble) ReportTaskRunnerHeartbeat(i0 *datapipeline.ReportTaskRunnerHeartbeatInput) (r0 *datapipeline.ReportTaskRunnerHeartbeatOutput, r1 error)
func (*DataPipelineDouble) ReportTaskRunnerHeartbeatRequest ¶
func (d *DataPipelineDouble) ReportTaskRunnerHeartbeatRequest(i0 *datapipeline.ReportTaskRunnerHeartbeatInput) (r0 *request.Request, r1 *datapipeline.ReportTaskRunnerHeartbeatOutput)
func (*DataPipelineDouble) ReportTaskRunnerHeartbeatWithContext ¶
func (d *DataPipelineDouble) ReportTaskRunnerHeartbeatWithContext(i0 context.Context, i1 *datapipeline.ReportTaskRunnerHeartbeatInput, i2 ...request.Option) (r0 *datapipeline.ReportTaskRunnerHeartbeatOutput, r1 error)
func (*DataPipelineDouble) SetStatus ¶
func (d *DataPipelineDouble) SetStatus(i0 *datapipeline.SetStatusInput) (r0 *datapipeline.SetStatusOutput, r1 error)
func (*DataPipelineDouble) SetStatusRequest ¶
func (d *DataPipelineDouble) SetStatusRequest(i0 *datapipeline.SetStatusInput) (r0 *request.Request, r1 *datapipeline.SetStatusOutput)
func (*DataPipelineDouble) SetStatusWithContext ¶
func (d *DataPipelineDouble) SetStatusWithContext(i0 context.Context, i1 *datapipeline.SetStatusInput, i2 ...request.Option) (r0 *datapipeline.SetStatusOutput, r1 error)
func (*DataPipelineDouble) SetTaskStatus ¶
func (d *DataPipelineDouble) SetTaskStatus(i0 *datapipeline.SetTaskStatusInput) (r0 *datapipeline.SetTaskStatusOutput, r1 error)
func (*DataPipelineDouble) SetTaskStatusRequest ¶
func (d *DataPipelineDouble) SetTaskStatusRequest(i0 *datapipeline.SetTaskStatusInput) (r0 *request.Request, r1 *datapipeline.SetTaskStatusOutput)
func (*DataPipelineDouble) SetTaskStatusWithContext ¶
func (d *DataPipelineDouble) SetTaskStatusWithContext(i0 context.Context, i1 *datapipeline.SetTaskStatusInput, i2 ...request.Option) (r0 *datapipeline.SetTaskStatusOutput, r1 error)
func (*DataPipelineDouble) ValidatePipelineDefinition ¶
func (d *DataPipelineDouble) ValidatePipelineDefinition(i0 *datapipeline.ValidatePipelineDefinitionInput) (r0 *datapipeline.ValidatePipelineDefinitionOutput, r1 error)
func (*DataPipelineDouble) ValidatePipelineDefinitionRequest ¶
func (d *DataPipelineDouble) ValidatePipelineDefinitionRequest(i0 *datapipeline.ValidatePipelineDefinitionInput) (r0 *request.Request, r1 *datapipeline.ValidatePipelineDefinitionOutput)
func (*DataPipelineDouble) ValidatePipelineDefinitionWithContext ¶
func (d *DataPipelineDouble) ValidatePipelineDefinitionWithContext(i0 context.Context, i1 *datapipeline.ValidatePipelineDefinitionInput, i2 ...request.Option) (r0 *datapipeline.ValidatePipelineDefinitionOutput, r1 error)