List transforms Run in API Explorer

GET /v1/transforms

Retrieve a list of Wasm transforms. Optional: filter based on transform name.

Query parameters

  • filter.name_contains string

    Substring match on transform name. Case-sensitive.

  • 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.

  • page_size integer(int32)

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

Responses

  • 200 application/json

    OK

    Hide response attributes Show response attributes object
    • next_page_token string

      Token to retrieve the next page.

    • transforms array[object]
      Hide transforms attributes Show transforms attributes object
      • environment_variables array[object]

        The environment variables you want to apply to your transform's environment

        Hide environment_variables attributes Show environment_variables attributes object
        • key string Required

          The key of your environment variable.

        • value string Required

          The value of your environment variable.

      • input_topic_name string

        Input topic to apply the transform to.

      • name string

        Name of transform.

      • output_topic_names array[string]

        Output topics to write the transform results to.

      • statuses array[object]
        Hide statuses attributes Show statuses attributes object
        • broker_id integer(int32)
        • lag integer(int32)
        • partition_id integer(int32)
        • status string

          Values are PARTITION_STATUS_RUNNING, PARTITION_STATUS_INACTIVE, PARTITION_STATUS_ERRORED, or PARTITION_STATUS_UNKNOWN.

  • 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/transforms
curl \
 --request GET 'https://{dataplane_api_subdomain}.cloud.redpanda.com/v1/transforms' \
 --header "Authorization: Bearer $ACCESS_TOKEN"
Response examples (200)
{
  "transforms": [
    {
      "name": "transform1",
      "statuses": [
        {
          "lag": 1,
          "status": "PARTITION_STATUS_RUNNING",
          "broker_id": 1,
          "partition_id": 1
        }
      ],
      "input_topic_name": "topic1",
      "output_topic_names": [
        "output-topic11",
        "output-topic12"
      ],
      "environment_variables": []
    },
    {
      "name": "transform2",
      "statuses": [
        {
          "lag": 2,
          "status": "PARTITION_STATUS_RUNNING",
          "broker_id": 2,
          "partition_id": 2
        }
      ],
      "input_topic_name": "topic2",
      "output_topic_names": [
        "output-topic21",
        "output-topic22"
      ],
      "environment_variables": []
    }
  ],
  "next_page_token": ""
}
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"
}