Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

datapipelineiface

package

Go to main page

Versions in this module

v1

v1.1.9

Mar 8, 2016

Changes in this version

+ type DataPipelineAPI interface

+ ActivatePipeline func(*datapipeline.ActivatePipelineInput) (*datapipeline.ActivatePipelineOutput, error)

+ ActivatePipelineRequest func(*datapipeline.ActivatePipelineInput) (*request.Request, *datapipeline.ActivatePipelineOutput)

+ AddTags func(*datapipeline.AddTagsInput) (*datapipeline.AddTagsOutput, error)

+ AddTagsRequest func(*datapipeline.AddTagsInput) (*request.Request, *datapipeline.AddTagsOutput)

+ CreatePipeline func(*datapipeline.CreatePipelineInput) (*datapipeline.CreatePipelineOutput, error)

+ CreatePipelineRequest func(*datapipeline.CreatePipelineInput) (*request.Request, *datapipeline.CreatePipelineOutput)

+ DeactivatePipeline func(*datapipeline.DeactivatePipelineInput) (*datapipeline.DeactivatePipelineOutput, error)

+ DeactivatePipelineRequest func(*datapipeline.DeactivatePipelineInput) (*request.Request, *datapipeline.DeactivatePipelineOutput)

+ DeletePipeline func(*datapipeline.DeletePipelineInput) (*datapipeline.DeletePipelineOutput, error)

+ DeletePipelineRequest func(*datapipeline.DeletePipelineInput) (*request.Request, *datapipeline.DeletePipelineOutput)

+ DescribeObjects func(*datapipeline.DescribeObjectsInput) (*datapipeline.DescribeObjectsOutput, error)

+ DescribeObjectsPages func(*datapipeline.DescribeObjectsInput, ...) error

+ DescribeObjectsRequest func(*datapipeline.DescribeObjectsInput) (*request.Request, *datapipeline.DescribeObjectsOutput)

+ DescribePipelines func(*datapipeline.DescribePipelinesInput) (*datapipeline.DescribePipelinesOutput, error)

+ DescribePipelinesRequest func(*datapipeline.DescribePipelinesInput) (*request.Request, *datapipeline.DescribePipelinesOutput)

+ EvaluateExpression func(*datapipeline.EvaluateExpressionInput) (*datapipeline.EvaluateExpressionOutput, error)

+ EvaluateExpressionRequest func(*datapipeline.EvaluateExpressionInput) (*request.Request, *datapipeline.EvaluateExpressionOutput)

+ GetPipelineDefinition func(*datapipeline.GetPipelineDefinitionInput) (*datapipeline.GetPipelineDefinitionOutput, error)

+ GetPipelineDefinitionRequest func(*datapipeline.GetPipelineDefinitionInput) (*request.Request, *datapipeline.GetPipelineDefinitionOutput)

+ ListPipelines func(*datapipeline.ListPipelinesInput) (*datapipeline.ListPipelinesOutput, error)

+ ListPipelinesPages func(*datapipeline.ListPipelinesInput, ...) error

+ ListPipelinesRequest func(*datapipeline.ListPipelinesInput) (*request.Request, *datapipeline.ListPipelinesOutput)

+ PollForTask func(*datapipeline.PollForTaskInput) (*datapipeline.PollForTaskOutput, error)

+ PollForTaskRequest func(*datapipeline.PollForTaskInput) (*request.Request, *datapipeline.PollForTaskOutput)

+ PutPipelineDefinition func(*datapipeline.PutPipelineDefinitionInput) (*datapipeline.PutPipelineDefinitionOutput, error)

+ PutPipelineDefinitionRequest func(*datapipeline.PutPipelineDefinitionInput) (*request.Request, *datapipeline.PutPipelineDefinitionOutput)

+ QueryObjects func(*datapipeline.QueryObjectsInput) (*datapipeline.QueryObjectsOutput, error)

+ QueryObjectsPages func(*datapipeline.QueryObjectsInput, ...) error

+ QueryObjectsRequest func(*datapipeline.QueryObjectsInput) (*request.Request, *datapipeline.QueryObjectsOutput)

+ RemoveTags func(*datapipeline.RemoveTagsInput) (*datapipeline.RemoveTagsOutput, error)

+ RemoveTagsRequest func(*datapipeline.RemoveTagsInput) (*request.Request, *datapipeline.RemoveTagsOutput)

+ ReportTaskProgress func(*datapipeline.ReportTaskProgressInput) (*datapipeline.ReportTaskProgressOutput, error)

+ ReportTaskProgressRequest func(*datapipeline.ReportTaskProgressInput) (*request.Request, *datapipeline.ReportTaskProgressOutput)

+ ReportTaskRunnerHeartbeat func(*datapipeline.ReportTaskRunnerHeartbeatInput) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)

+ ReportTaskRunnerHeartbeatRequest func(*datapipeline.ReportTaskRunnerHeartbeatInput) (*request.Request, *datapipeline.ReportTaskRunnerHeartbeatOutput)

+ SetStatus func(*datapipeline.SetStatusInput) (*datapipeline.SetStatusOutput, error)

+ SetStatusRequest func(*datapipeline.SetStatusInput) (*request.Request, *datapipeline.SetStatusOutput)

+ SetTaskStatus func(*datapipeline.SetTaskStatusInput) (*datapipeline.SetTaskStatusOutput, error)

+ SetTaskStatusRequest func(*datapipeline.SetTaskStatusInput) (*request.Request, *datapipeline.SetTaskStatusOutput)

+ ValidatePipelineDefinition func(*datapipeline.ValidatePipelineDefinitionInput) (*datapipeline.ValidatePipelineDefinitionOutput, error)

+ ValidatePipelineDefinitionRequest func(*datapipeline.ValidatePipelineDefinitionInput) (*request.Request, *datapipeline.ValidatePipelineDefinitionOutput)