Documentation ¶
Index ¶
- type IClient
- func (_m *IClient) ActivatePipeline(ctx context.Context, params *datapipeline.ActivatePipelineInput, ...) (*datapipeline.ActivatePipelineOutput, error)
- func (_m *IClient) AddTags(ctx context.Context, params *datapipeline.AddTagsInput, ...) (*datapipeline.AddTagsOutput, error)
- func (_m *IClient) CreatePipeline(ctx context.Context, params *datapipeline.CreatePipelineInput, ...) (*datapipeline.CreatePipelineOutput, error)
- func (_m *IClient) DeactivatePipeline(ctx context.Context, params *datapipeline.DeactivatePipelineInput, ...) (*datapipeline.DeactivatePipelineOutput, error)
- func (_m *IClient) DeletePipeline(ctx context.Context, params *datapipeline.DeletePipelineInput, ...) (*datapipeline.DeletePipelineOutput, error)
- func (_m *IClient) DescribeObjects(ctx context.Context, params *datapipeline.DescribeObjectsInput, ...) (*datapipeline.DescribeObjectsOutput, error)
- func (_m *IClient) DescribePipelines(ctx context.Context, params *datapipeline.DescribePipelinesInput, ...) (*datapipeline.DescribePipelinesOutput, error)
- func (_m *IClient) EvaluateExpression(ctx context.Context, params *datapipeline.EvaluateExpressionInput, ...) (*datapipeline.EvaluateExpressionOutput, error)
- func (_m *IClient) GetPipelineDefinition(ctx context.Context, params *datapipeline.GetPipelineDefinitionInput, ...) (*datapipeline.GetPipelineDefinitionOutput, error)
- func (_m *IClient) ListPipelines(ctx context.Context, params *datapipeline.ListPipelinesInput, ...) (*datapipeline.ListPipelinesOutput, error)
- func (_m *IClient) Options() datapipeline.Options
- func (_m *IClient) PollForTask(ctx context.Context, params *datapipeline.PollForTaskInput, ...) (*datapipeline.PollForTaskOutput, error)
- func (_m *IClient) PutPipelineDefinition(ctx context.Context, params *datapipeline.PutPipelineDefinitionInput, ...) (*datapipeline.PutPipelineDefinitionOutput, error)
- func (_m *IClient) QueryObjects(ctx context.Context, params *datapipeline.QueryObjectsInput, ...) (*datapipeline.QueryObjectsOutput, error)
- func (_m *IClient) RemoveTags(ctx context.Context, params *datapipeline.RemoveTagsInput, ...) (*datapipeline.RemoveTagsOutput, error)
- func (_m *IClient) ReportTaskProgress(ctx context.Context, params *datapipeline.ReportTaskProgressInput, ...) (*datapipeline.ReportTaskProgressOutput, error)
- func (_m *IClient) ReportTaskRunnerHeartbeat(ctx context.Context, params *datapipeline.ReportTaskRunnerHeartbeatInput, ...) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)
- func (_m *IClient) SetStatus(ctx context.Context, params *datapipeline.SetStatusInput, ...) (*datapipeline.SetStatusOutput, error)
- func (_m *IClient) SetTaskStatus(ctx context.Context, params *datapipeline.SetTaskStatusInput, ...) (*datapipeline.SetTaskStatusOutput, error)
- func (_m *IClient) ValidatePipelineDefinition(ctx context.Context, params *datapipeline.ValidatePipelineDefinitionInput, ...) (*datapipeline.ValidatePipelineDefinitionOutput, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IClient ¶
IClient is an autogenerated mock type for the IClient type
func NewIClient ¶
NewIClient creates a new instance of IClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*IClient) ActivatePipeline ¶
func (_m *IClient) ActivatePipeline(ctx context.Context, params *datapipeline.ActivatePipelineInput, optFns ...func(*datapipeline.Options)) (*datapipeline.ActivatePipelineOutput, error)
ActivatePipeline provides a mock function with given fields: ctx, params, optFns
func (*IClient) AddTags ¶
func (_m *IClient) AddTags(ctx context.Context, params *datapipeline.AddTagsInput, optFns ...func(*datapipeline.Options)) (*datapipeline.AddTagsOutput, error)
AddTags provides a mock function with given fields: ctx, params, optFns
func (*IClient) CreatePipeline ¶
func (_m *IClient) CreatePipeline(ctx context.Context, params *datapipeline.CreatePipelineInput, optFns ...func(*datapipeline.Options)) (*datapipeline.CreatePipelineOutput, error)
CreatePipeline provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeactivatePipeline ¶
func (_m *IClient) DeactivatePipeline(ctx context.Context, params *datapipeline.DeactivatePipelineInput, optFns ...func(*datapipeline.Options)) (*datapipeline.DeactivatePipelineOutput, error)
DeactivatePipeline provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeletePipeline ¶
func (_m *IClient) DeletePipeline(ctx context.Context, params *datapipeline.DeletePipelineInput, optFns ...func(*datapipeline.Options)) (*datapipeline.DeletePipelineOutput, error)
DeletePipeline provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeObjects ¶
func (_m *IClient) DescribeObjects(ctx context.Context, params *datapipeline.DescribeObjectsInput, optFns ...func(*datapipeline.Options)) (*datapipeline.DescribeObjectsOutput, error)
DescribeObjects provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribePipelines ¶
func (_m *IClient) DescribePipelines(ctx context.Context, params *datapipeline.DescribePipelinesInput, optFns ...func(*datapipeline.Options)) (*datapipeline.DescribePipelinesOutput, error)
DescribePipelines provides a mock function with given fields: ctx, params, optFns
func (*IClient) EvaluateExpression ¶
func (_m *IClient) EvaluateExpression(ctx context.Context, params *datapipeline.EvaluateExpressionInput, optFns ...func(*datapipeline.Options)) (*datapipeline.EvaluateExpressionOutput, error)
EvaluateExpression provides a mock function with given fields: ctx, params, optFns
func (*IClient) GetPipelineDefinition ¶
func (_m *IClient) GetPipelineDefinition(ctx context.Context, params *datapipeline.GetPipelineDefinitionInput, optFns ...func(*datapipeline.Options)) (*datapipeline.GetPipelineDefinitionOutput, error)
GetPipelineDefinition provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListPipelines ¶
func (_m *IClient) ListPipelines(ctx context.Context, params *datapipeline.ListPipelinesInput, optFns ...func(*datapipeline.Options)) (*datapipeline.ListPipelinesOutput, error)
ListPipelines provides a mock function with given fields: ctx, params, optFns
func (*IClient) Options ¶
func (_m *IClient) Options() datapipeline.Options
Options provides a mock function with given fields:
func (*IClient) PollForTask ¶
func (_m *IClient) PollForTask(ctx context.Context, params *datapipeline.PollForTaskInput, optFns ...func(*datapipeline.Options)) (*datapipeline.PollForTaskOutput, error)
PollForTask provides a mock function with given fields: ctx, params, optFns
func (*IClient) PutPipelineDefinition ¶
func (_m *IClient) PutPipelineDefinition(ctx context.Context, params *datapipeline.PutPipelineDefinitionInput, optFns ...func(*datapipeline.Options)) (*datapipeline.PutPipelineDefinitionOutput, error)
PutPipelineDefinition provides a mock function with given fields: ctx, params, optFns
func (*IClient) QueryObjects ¶
func (_m *IClient) QueryObjects(ctx context.Context, params *datapipeline.QueryObjectsInput, optFns ...func(*datapipeline.Options)) (*datapipeline.QueryObjectsOutput, error)
QueryObjects provides a mock function with given fields: ctx, params, optFns
func (*IClient) RemoveTags ¶
func (_m *IClient) RemoveTags(ctx context.Context, params *datapipeline.RemoveTagsInput, optFns ...func(*datapipeline.Options)) (*datapipeline.RemoveTagsOutput, error)
RemoveTags provides a mock function with given fields: ctx, params, optFns
func (*IClient) ReportTaskProgress ¶
func (_m *IClient) ReportTaskProgress(ctx context.Context, params *datapipeline.ReportTaskProgressInput, optFns ...func(*datapipeline.Options)) (*datapipeline.ReportTaskProgressOutput, error)
ReportTaskProgress provides a mock function with given fields: ctx, params, optFns
func (*IClient) ReportTaskRunnerHeartbeat ¶
func (_m *IClient) ReportTaskRunnerHeartbeat(ctx context.Context, params *datapipeline.ReportTaskRunnerHeartbeatInput, optFns ...func(*datapipeline.Options)) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)
ReportTaskRunnerHeartbeat provides a mock function with given fields: ctx, params, optFns
func (*IClient) SetStatus ¶
func (_m *IClient) SetStatus(ctx context.Context, params *datapipeline.SetStatusInput, optFns ...func(*datapipeline.Options)) (*datapipeline.SetStatusOutput, error)
SetStatus provides a mock function with given fields: ctx, params, optFns
func (*IClient) SetTaskStatus ¶
func (_m *IClient) SetTaskStatus(ctx context.Context, params *datapipeline.SetTaskStatusInput, optFns ...func(*datapipeline.Options)) (*datapipeline.SetTaskStatusOutput, error)
SetTaskStatus provides a mock function with given fields: ctx, params, optFns
func (*IClient) ValidatePipelineDefinition ¶
func (_m *IClient) ValidatePipelineDefinition(ctx context.Context, params *datapipeline.ValidatePipelineDefinitionInput, optFns ...func(*datapipeline.Options)) (*datapipeline.ValidatePipelineDefinitionOutput, error)
ValidatePipelineDefinition provides a mock function with given fields: ctx, params, optFns