List Redpanda Connect pipelines Run in API Explorer

GET /v1/redpanda-connect/pipelines

List Redpanda Connect pipelines. Optional: filter based on pipeline name.

Query parameters

  • filter.name_contains string

    Substring match on pipeline name. Case-sensitive.

  • filter.tags[string] string

    This is a request variable of the map type. The query format is "map_name[key]=value", e.g. If the map name is Age, the key type is string, and the value type is integer, the query parameter is expressed as Age["bob"]=18

  • page_size integer(int32)

    Limit the paginated response to a number of items. Defaults to 100. Use -1 to disable pagination.

  • page_token string

    Value of the next_page_token field returned by the previous response. If not provided, the system assumes the first page is requested.

Responses

  • 200 application/json

    OK

    Hide response attributes Show response attributes object
    • next_page_token string
    • pipelines array[object]

      Defines the pipeline resource.

      Hide pipelines attributes Show pipelines attributes object
      • config_yaml string Required

        The Repanda Connect pipeline configuration in YAML format. See the Redpanda Connect Configuration documentation for more details.

      • description string

        Optional pipeline description.

      • display_name string Required

        User-friendly pipeline name.

      • id string Required

        Pipeline ID.

      • resources object
        Hide resources attributes Show resources attributes object
        • cpu_shares string Required

          cpu_shares is a string specifying the amount of CPU to allocate for the pipeline.

          This follows the Kubernetes quantity format. Acceptable units include:

          • Decimal SI units: "m" (e.g., "500m" for 500 millicores, "2" for 2 cores) CPU shares can be specified in millicores (1 core = 1000 millicores). If you don't specify a unit, the value is interpreted as the number of cores.
        • memory_shares string Required

          memory_shares is a string specifying the amount of memory to allocate for the pipeline.

          This follows the Kubernetes quantity format. Acceptable units include:

          • Decimal SI units: "K", "M", "G", "T", "P", "E" (e.g., "128M" for 128 megabytes)
          • Binary SI units: "Ki", "Mi", "Gi", "Ti", "Pi", "Ei" (e.g., "512Mi" for 512 mebibytes) If you don't specify a unit, the value is interpreted as bytes.
      • state string

        State of the pipeline.

        • STATE_STARTING: The pipeline is starting.
        • STATE_RUNNING: The pipeline is running.
        • STATE_STOPPING: The pipeline is in the process of stopping.
        • STATE_STOPPED: The pipeline is stopped and in paused state.
        • STATE_ERROR: The pipeline encountered an error. See Error Handling for further guidance.
        • STATE_COMPLETED: The pipeline has completed the job successfully.

        Values are STATE_STARTING, STATE_RUNNING, STATE_STOPPING, STATE_STOPPED, STATE_ERROR, or STATE_COMPLETED.

      • status object

        Pipeline status may contain an error message.

        Hide status attribute Show status attribute object
        • error string
      • tags object

        Tags are key-value pairs that can be assigned to a pipeline resource. They help organize pipelines and enable filtering when listing them.

        Hide tags attribute Show tags attribute object
        • * string Additional properties
      • url string

        URL to connect to the pipeline, for example, using http_server. May be empty if no http_server is used.

  • 401 application/json

    Unauthenticated.

    Hide response attributes Show response attributes object
    • code string(int32)

      RPC status code, as described here.

      Values are OK, CANCELLED, UNKNOWN, INVALID_ARGUMENT, DEADLINE_EXCEEDED, NOT_FOUND, ALREADY_EXISTS, PERMISSION_DENIED, UNAUTHENTICATED, RESOURCE_EXHAUSTED, FAILED_PRECONDITION, ABORTED, OUT_OF_RANGE, UNIMPLEMENTED, INTERNAL, UNAVAILABLE, or DATA_LOSS.

    • details array[object]

      A list of messages that carries the error details.

      Details of the error.

      Details of the error.

      One of:
    • message string

      Detailed error message. No compatibility guarantees are given for the text contained in this message.

  • 500 application/json

    Internal Server Error. Reach out to support.

    Hide response attributes Show response attributes object
    • code string(int32)

      RPC status code, as described here.

      Values are OK, CANCELLED, UNKNOWN, INVALID_ARGUMENT, DEADLINE_EXCEEDED, NOT_FOUND, ALREADY_EXISTS, PERMISSION_DENIED, UNAUTHENTICATED, RESOURCE_EXHAUSTED, FAILED_PRECONDITION, ABORTED, OUT_OF_RANGE, UNIMPLEMENTED, INTERNAL, UNAVAILABLE, or DATA_LOSS.

    • details array[object]

      A list of messages that carries the error details.

      Details of the error.

      Details of the error.

      One of:
    • message string

      Detailed error message. No compatibility guarantees are given for the text contained in this message.

  • default application/json

    An unexpected error response.

    Hide response attributes Show response attributes object
    • code string(int32)

      RPC status code, as described here.

      Values are OK, CANCELLED, UNKNOWN, INVALID_ARGUMENT, DEADLINE_EXCEEDED, NOT_FOUND, ALREADY_EXISTS, PERMISSION_DENIED, UNAUTHENTICATED, RESOURCE_EXHAUSTED, FAILED_PRECONDITION, ABORTED, OUT_OF_RANGE, UNIMPLEMENTED, INTERNAL, UNAVAILABLE, or DATA_LOSS.

    • details array[object]

      A list of messages that carries the error details.

      Details of the error.

      Details of the error.

      One of:
    • message string

      Detailed error message. No compatibility guarantees are given for the text contained in this message.

GET /v1/redpanda-connect/pipelines
curl \
 --request GET 'https://{dataplane_api_subdomain}.cloud.redpanda.com/v1/redpanda-connect/pipelines' \
 --header "Authorization: Bearer $ACCESS_TOKEN"
Response examples (200)
{
  "next_page_token": "string",
  "pipelines": [
    {
      "config_yaml": "string",
      "description": "string",
      "display_name": "string",
      "id": "string",
      "resources": {
        "cpu_shares": "string",
        "memory_shares": "string"
      },
      "state": "STATE_STARTING",
      "status": {
        "error": "string"
      },
      "tags": {
        "additionalProperty1": "string",
        "additionalProperty2": "string"
      },
      "url": "string"
    }
  ]
}
Response examples (401)
{
  "code": "OK",
  "details": [
    {
      "@type": "type.googleapis.com/google.rpc.BadRequest",
      "field_violations": [
        {
          "description": "string",
          "field": "string"
        }
      ]
    }
  ],
  "message": "string"
}
Response examples (500)
{
  "code": "OK",
  "details": [
    {
      "@type": "type.googleapis.com/google.rpc.BadRequest",
      "field_violations": [
        {
          "description": "string",
          "field": "string"
        }
      ]
    }
  ],
  "message": "string"
}
Response examples (default)
{
  "code": "OK",
  "details": [
    {
      "@type": "type.googleapis.com/google.rpc.BadRequest",
      "field_violations": [
        {
          "description": "string",
          "field": "string"
        }
      ]
    }
  ],
  "message": "string"
}