## [DEPRECATED] Get Pipeline `client.Pipelines.Get(ctx, pipelineName, query) (*PipelineGetResponse, error)` **get** `/accounts/{account_id}/pipelines/{pipeline_name}` [DEPRECATED] Get configuration of a pipeline. Use the new /pipelines/v1/pipelines endpoint instead. ### Parameters - `pipelineName string` Defines the name of the pipeline. - `query PipelineGetParams` - `AccountID param.Field[string]` Specifies the public ID of the account. ### Returns - `type PipelineGetResponse struct{…}` [DEPRECATED] Describes the configuration of a pipeline. Use the new streams/sinks/pipelines API instead. - `ID string` Specifies the pipeline identifier. - `Destination PipelineGetResponseDestination` - `Batch PipelineGetResponseDestinationBatch` - `MaxBytes int64` Specifies rough maximum size of files. - `MaxDurationS float64` Specifies duration to wait to aggregate batches files. - `MaxRows int64` Specifies rough maximum number of rows per file. - `Compression PipelineGetResponseDestinationCompression` - `Type PipelineGetResponseDestinationCompressionType` Specifies the desired compression algorithm and format. - `const PipelineGetResponseDestinationCompressionTypeNone PipelineGetResponseDestinationCompressionType = "none"` - `const PipelineGetResponseDestinationCompressionTypeGzip PipelineGetResponseDestinationCompressionType = "gzip"` - `const PipelineGetResponseDestinationCompressionTypeDeflate PipelineGetResponseDestinationCompressionType = "deflate"` - `Format PipelineGetResponseDestinationFormat` Specifies the format of data to deliver. - `const PipelineGetResponseDestinationFormatJson PipelineGetResponseDestinationFormat = "json"` - `Path PipelineGetResponseDestinationPath` - `Bucket string` Specifies the R2 Bucket to store files. - `Filename string` Specifies the name pattern to for individual data files. - `Filepath string` Specifies the name pattern for directory. - `Prefix string` Specifies the base directory within the bucket. - `Type PipelineGetResponseDestinationType` Specifies the type of destination. - `const PipelineGetResponseDestinationTypeR2 PipelineGetResponseDestinationType = "r2"` - `Endpoint string` Indicates the endpoint URL to send traffic. - `Name string` Defines the name of the pipeline. - `Source []PipelineGetResponseSource` - `type PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSource struct{…}` [DEPRECATED] HTTP source configuration. Use the new streams API instead. - `Format PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat` Specifies the format of source data. - `const PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormatJson PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat = "json"` - `Type string` - `Authentication bool` Specifies whether authentication is required to send to this pipeline via HTTP. - `CORS PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS` - `Origins []string` Specifies allowed origins to allow Cross Origin HTTP Requests. - `type PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesBindingSource struct{…}` [DEPRECATED] Worker binding source configuration. Use the new streams API instead. - `Format PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat` Specifies the format of source data. - `const PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormatJson PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat = "json"` - `Type string` - `Version float64` Indicates the version number of last saved configuration. ### Example ```go package main import ( "context" "fmt" "github.com/cloudflare/cloudflare-go" "github.com/cloudflare/cloudflare-go/option" "github.com/cloudflare/cloudflare-go/pipelines" ) func main() { client := cloudflare.NewClient( option.WithAPIToken("Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY"), ) pipeline, err := client.Pipelines.Get( context.TODO(), "sample_pipeline", pipelines.PipelineGetParams{ AccountID: cloudflare.F("0123105f4ecef8ad9ca31a8372d0c353"), }, ) if err != nil { panic(err.Error()) } fmt.Printf("%+v\n", pipeline.ID) } ``` #### Response ```json { "result": { "id": "123f8a8258064ed892a347f173372359", "destination": { "batch": { "max_bytes": 1000, "max_duration_s": 0.25, "max_rows": 100 }, "compression": { "type": "gzip" }, "format": "json", "path": { "bucket": "bucket", "filename": "${slug}${extension}", "filepath": "${date}/${hour}", "prefix": "base" }, "type": "r2" }, "endpoint": "https://123f8a8258064ed892a347f173372359.pipelines.cloudflare.com", "name": "sample_pipeline", "source": [ { "format": "json", "type": "type", "authentication": true, "cors": { "origins": [ "*" ] } } ], "version": 2 }, "success": true } ```