src/client/admin.go
func (c APIClient) ExtractPipeline(pipelineName string) (*pps.CreatePipelineRequest, error) {
	op, err := c.AdminAPIClient.ExtractPipeline(c.Ctx(), &admin.ExtractPipelineRequest{Pipeline: NewPipeline(pipelineName)})
	if err != nil {
		return nil, grpcutil.ScrubGRPC(err)
	}
	if op.Op1_9 == nil || op.Op1_9.Pipeline == nil {
		return nil, fmt.Errorf("malformed response is missing pipeline")
	}
	return op.Op1_9.Pipeline, nil
}
func (c APIClient) ExtractPipeline(pipelineName string) (*pps.CreatePipelineRequest, error) {
	op, err := c.AdminAPIClient.ExtractPipeline(c.Ctx(), &admin.ExtractPipelineRequest{Pipeline: NewPipeline(pipelineName)})
	if err != nil {
		return nil, grpcutil.ScrubGRPC(err)
	}
	if op.Op1_9 == nil || op.Op1_9.Pipeline == nil {
		return nil, fmt.Errorf("malformed response is missing pipeline")
	}
	return op.Op1_9.Pipeline, nil
}
func ( c APIClient ) ExtractPipeline ( pipelineName string ) ( * pps . CreatePipelineRequest , error ) { op , err := c . AdminAPIClient . ExtractPipeline ( c . Ctx ( ) , & admin . ExtractPipelineRequest { Pipeline : NewPipeline ( pipelineName ) } ) if err != nil { return nil , grpcutil . ScrubGRPC ( err ) } if op . Op1_9 == nil || op . Op1_9 . Pipeline == nil { return nil , fmt . Errorf ( " " ) } return op . Op1_9 . Pipeline , nil }
// ExtractPipeline extracts a single pipeline.
ExtractPipeline extracts a single pipeline .