> ## Documentation Index
> Fetch the complete documentation index at: https://docs.streamkap.com/llms.txt
> Use this file to discover all available pages before exploring further.

# Get Metrics For Source

> Retrieve metrics for a specific source based on the provided parameters.

    This endpoint returns metrics data for a given source ID, allowing flexibility in the type of metrics
    returned (timeseries, timesummary, or latest), the time interval, and the time range. The response includes
    metadata about the metrics and is tailored to the specified time type.

    ### Parameters:
    - **source_id** (path): The unique identifier of the source for which metrics are requested.
    - **time_type** (query): Specifies the type of metrics to return:
        - `timeseries`: Metrics over a series of time intervals.
        - `timesummary`: Aggregated summary of metrics over the specified period.
        - `latest`: The most recent metrics available.
    - **time_interval** (query): The numeric interval between metrics data points (e.g., 1, 2, etc.).
    - **time_unit** (query): The unit of time for the interval (e.g., minute, hour, day, week, month).
        Combined with `time_interval` to define the granularity (e.g., 1 hour, 2 days).
    - **timestamp_from** (query, optional): The start time of the metrics data in UTC (ISO 8601 format, e.g.,
        `2025-03-02T07:10:15Z`). Defaults to 24 hours before the current time if not provided.
    - **timestamp_to** (query, optional): The end time of the metrics data in UTC (ISO 8601 format).
        Defaults to the current time if not provided.

    ### Authentication:
    - Requires a valid user token with the `read:source_metrics` permission.

    ### Returns:
    Depending on the `time_type`:
    - `SourceTimeseriesMetricsWithMetadata`: For `timeseries` metrics.
    - `SourceTimesummaryMetricsWithMetadata`: For `timesummary` metrics.
    - `SourceLatestMetricsWithMetadata`: For `latest` metrics.

    ### Errors:
    - **400 Bad Request**: Invalid parameters or unexpected errors during processing.
    - **404 Not Found**: Metrics not found for the specified source or connector plugin issues.
    - **500 Internal Server Error**: Connector plugin not found or misconfigured.

    ### Example Request:
    ```http
    https://api.streamkap.com/sources/67ad6e0af08a2365c729ba79/metrics?time_type=latest&time_interval=2&time_unit=hour&timestamp_from=2025-03-02T07:10:15Z&timestamp_to=2025-03-04T07:10:15Z
    ```
    ### Example Response:
    ```json
    {
        "data": {
            "SnapshotTotalNumberOfEventsSeen": 20254,
            "SnapshotMilliSecondsSinceLastEvent": 0,
            "StreamingMilliSecondsBehindSource": 0,
            "StreamingTotalNumberOfDeleteEventsSeen": 312,
            "StreamingTotalNumberOfUpdateEventsSeen": 0,
            "StreamingTotalNumberOfCreateEventsSeen": 73,
            "StreamingMilliSecondsSinceLastEvent": 0,
            "StreamingLastEvent": "position: {ord: 14}, key: {"id" : ""ceaafb88-2a60-4bd9-8515-719ba64ea05c-close""}",
            "recordRetryTotal": null,
            "byteTotal": 9018776,
            "sourceRecordWriteTotal": 28977,
            "SnapshotRunning": 0,
            "SnapshotCompleted": 0,
            "StreamingConnected": 1,
            "recordSendTotal": null,
            "state": "Streaming",
            "streamingState": "connected",
            "snapshotStatus": [
                {
                    "status": "completed",
                    "topic_id": "source_67a5c35e64af6fd83f4c17a6.Test.test_data1",
                    "submit_timestamp": null
                },
                {
                    "status": "completed",
                    "topic_id": "source_67a5c35e64af6fd83f4c17a6.Test.test_data2",
                    "submit_timestamp": null
                }
            ],
            "snapshotState": "completed",
            "recordWrittenTotal": null,
            "connector_status": "Active",
            "latency": 0
        },
        "metadata": {
            "state": {
                "name": "Enabled State",
                "unit": "enum"
            },
            "streamingState": {
                "name": "Streaming State",
                "unit": "enum"
            },
            "snapshotStatus": {
                "name": "Snapshot Status",
                "unit": "enum"
            },
            "snapshotState": {
                "name": "Snapshot State",
                "unit": "enum"
            },
            "connector_status": {
                "name": "Source State",
                "unit": "enum"
            },
            "latency": {
                "name": "Source Latency",
                "unit": "milliseconds"
            },
            "byteTotal": {
                "name": "Volume",
                "unit": "bytes"
            },
            "recordRetryTotal": {
                "name": "Retried",
                "unit": "count"
            },
            "recordSendTotal": {
                "name": "Received",
                "unit": "count"
            },
            "recordWrittenTotal": {
                "name": "Events Written",
                "unit": "count"
            },
            "SnapshotTotalNumberOfEventsSeen": {
                "name": "Events (Snapshot)",
                "unit": "count"
            },
            "SnapshotRunning": {
                "name": "Snapshot Running?",
                "unit": "boolean"
            },
            "SnapshotCompleted": {
                "name": "Snapshot Completed?",
                "unit": "boolean"
            },
            "SnapshotMilliSecondsSinceLastEvent": {
                "name": "Time Since Last Snapshot Event",
                "unit": "milliseconds"
            },
            "StreamingMilliSecondsBehindSource": {
                "name": "Latency Behind Source",
                "unit": "milliseconds"
            },
            "StreamingConnected": {
                "name": "Streaming Connected?",
                "unit": "boolean"
            },
            "StreamingTotalNumberOfDeleteEventsSeen": {
                "name": "Events (Delete)",
                "unit": "count"
            },
            "StreamingTotalNumberOfUpdateEventsSeen": {
                "name": "Events (Update)",
                "unit": "count"
            },
            "StreamingTotalNumberOfCreateEventsSeen": {
                "name": "Events (Create)",
                "unit": "count"
            },
            "StreamingMilliSecondsSinceLastEvent": {
                "name": "Time Since Last Streaming Event",
                "unit": "milliseconds"
            },
            "StreamingLastEvent": {
                "name": "Last Streaming Event",
                "unit": "id"
            },
            "sourceRecordWriteTotal": {
                "name": "Events Written",
                "unit": "count"
            }
        }
    }
    ```



## OpenAPI

````yaml /openapi/openapi.json get /sources/{source_id}/metrics
openapi: 3.1.0
info:
  title: Streamkap REST API
  description: >-
    The Streamkap REST API allows you to programmatically manage your CDC
    pipelines, sources, destinations, transforms, and more.


    Authenticate using a bearer token obtained from the [Access
    Token](/api-reference/auth/access-token) endpoint with your API client
    credentials.
  contact:
    name: Streamkap Support
    url: https://streamkap.com/
    email: support@streamkap.com
  license:
    name: Proprietary
  version: 2.0.0
servers:
  - url: https://api.streamkap.com
    description: Production
security: []
tags:
  - name: Alerts
    description: Manage alert subscribers, preferences, and notification credentials.
  - name: Authentication
    description: Obtain and refresh access tokens, manage client credentials and roles.
  - name: Billing
    description: Retrieve usage metrics, summaries, and export billing data.
  - name: Consumer Groups
    description: List, inspect, and reset Kafka consumer group offsets.
  - name: Dashboard
    description: Retrieve organisation-level statistics and overview data.
  - name: Destinations
    description: Create, configure, and manage data destinations and their lifecycle.
  - name: Kafka Access
    description: Manage Kafka users and their access permissions.
  - name: Logs
    description: Query and summarise system logs.
  - name: Pipelines
    description: Create, configure, and manage CDC pipelines and their lifecycle.
  - name: Project Keys
    description: Manage project keys that bundle API credentials and optional Kafka access.
  - name: Schema Registry
    description: Browse schema subjects, versions, and retrieve schema definitions.
  - name: Services
    description: View and switch service metadata.
  - name: Sources
    description: >-
      Create, configure, and manage data sources, snapshots, and their
      lifecycle.
  - name: Tags
    description: Create, update, and manage resource tags for organisation.
  - name: Topics
    description: Browse topic details, statistics, configurations, metrics, and messages.
  - name: Transforms
    description: >-
      Create, deploy, and manage data transforms, unit tests, and implementation
      details.
paths:
  /sources/{source_id}/metrics:
    get:
      tags:
        - Sources
      summary: Get Metrics For Source
      description: |-
        Retrieve metrics for a specific source based on the provided parameters.

            This endpoint returns metrics data for a given source ID, allowing flexibility in the type of metrics
            returned (timeseries, timesummary, or latest), the time interval, and the time range. The response includes
            metadata about the metrics and is tailored to the specified time type.

            ### Parameters:
            - **source_id** (path): The unique identifier of the source for which metrics are requested.
            - **time_type** (query): Specifies the type of metrics to return:
                - `timeseries`: Metrics over a series of time intervals.
                - `timesummary`: Aggregated summary of metrics over the specified period.
                - `latest`: The most recent metrics available.
            - **time_interval** (query): The numeric interval between metrics data points (e.g., 1, 2, etc.).
            - **time_unit** (query): The unit of time for the interval (e.g., minute, hour, day, week, month).
                Combined with `time_interval` to define the granularity (e.g., 1 hour, 2 days).
            - **timestamp_from** (query, optional): The start time of the metrics data in UTC (ISO 8601 format, e.g.,
                `2025-03-02T07:10:15Z`). Defaults to 24 hours before the current time if not provided.
            - **timestamp_to** (query, optional): The end time of the metrics data in UTC (ISO 8601 format).
                Defaults to the current time if not provided.

            ### Authentication:
            - Requires a valid user token with the `read:source_metrics` permission.

            ### Returns:
            Depending on the `time_type`:
            - `SourceTimeseriesMetricsWithMetadata`: For `timeseries` metrics.
            - `SourceTimesummaryMetricsWithMetadata`: For `timesummary` metrics.
            - `SourceLatestMetricsWithMetadata`: For `latest` metrics.

            ### Errors:
            - **400 Bad Request**: Invalid parameters or unexpected errors during processing.
            - **404 Not Found**: Metrics not found for the specified source or connector plugin issues.
            - **500 Internal Server Error**: Connector plugin not found or misconfigured.

            ### Example Request:
            ```http
            https://api.streamkap.com/sources/67ad6e0af08a2365c729ba79/metrics?time_type=latest&time_interval=2&time_unit=hour&timestamp_from=2025-03-02T07:10:15Z&timestamp_to=2025-03-04T07:10:15Z
            ```
            ### Example Response:
            ```json
            {
                "data": {
                    "SnapshotTotalNumberOfEventsSeen": 20254,
                    "SnapshotMilliSecondsSinceLastEvent": 0,
                    "StreamingMilliSecondsBehindSource": 0,
                    "StreamingTotalNumberOfDeleteEventsSeen": 312,
                    "StreamingTotalNumberOfUpdateEventsSeen": 0,
                    "StreamingTotalNumberOfCreateEventsSeen": 73,
                    "StreamingMilliSecondsSinceLastEvent": 0,
                    "StreamingLastEvent": "position: {ord: 14}, key: {"id" : ""ceaafb88-2a60-4bd9-8515-719ba64ea05c-close""}",
                    "recordRetryTotal": null,
                    "byteTotal": 9018776,
                    "sourceRecordWriteTotal": 28977,
                    "SnapshotRunning": 0,
                    "SnapshotCompleted": 0,
                    "StreamingConnected": 1,
                    "recordSendTotal": null,
                    "state": "Streaming",
                    "streamingState": "connected",
                    "snapshotStatus": [
                        {
                            "status": "completed",
                            "topic_id": "source_67a5c35e64af6fd83f4c17a6.Test.test_data1",
                            "submit_timestamp": null
                        },
                        {
                            "status": "completed",
                            "topic_id": "source_67a5c35e64af6fd83f4c17a6.Test.test_data2",
                            "submit_timestamp": null
                        }
                    ],
                    "snapshotState": "completed",
                    "recordWrittenTotal": null,
                    "connector_status": "Active",
                    "latency": 0
                },
                "metadata": {
                    "state": {
                        "name": "Enabled State",
                        "unit": "enum"
                    },
                    "streamingState": {
                        "name": "Streaming State",
                        "unit": "enum"
                    },
                    "snapshotStatus": {
                        "name": "Snapshot Status",
                        "unit": "enum"
                    },
                    "snapshotState": {
                        "name": "Snapshot State",
                        "unit": "enum"
                    },
                    "connector_status": {
                        "name": "Source State",
                        "unit": "enum"
                    },
                    "latency": {
                        "name": "Source Latency",
                        "unit": "milliseconds"
                    },
                    "byteTotal": {
                        "name": "Volume",
                        "unit": "bytes"
                    },
                    "recordRetryTotal": {
                        "name": "Retried",
                        "unit": "count"
                    },
                    "recordSendTotal": {
                        "name": "Received",
                        "unit": "count"
                    },
                    "recordWrittenTotal": {
                        "name": "Events Written",
                        "unit": "count"
                    },
                    "SnapshotTotalNumberOfEventsSeen": {
                        "name": "Events (Snapshot)",
                        "unit": "count"
                    },
                    "SnapshotRunning": {
                        "name": "Snapshot Running?",
                        "unit": "boolean"
                    },
                    "SnapshotCompleted": {
                        "name": "Snapshot Completed?",
                        "unit": "boolean"
                    },
                    "SnapshotMilliSecondsSinceLastEvent": {
                        "name": "Time Since Last Snapshot Event",
                        "unit": "milliseconds"
                    },
                    "StreamingMilliSecondsBehindSource": {
                        "name": "Latency Behind Source",
                        "unit": "milliseconds"
                    },
                    "StreamingConnected": {
                        "name": "Streaming Connected?",
                        "unit": "boolean"
                    },
                    "StreamingTotalNumberOfDeleteEventsSeen": {
                        "name": "Events (Delete)",
                        "unit": "count"
                    },
                    "StreamingTotalNumberOfUpdateEventsSeen": {
                        "name": "Events (Update)",
                        "unit": "count"
                    },
                    "StreamingTotalNumberOfCreateEventsSeen": {
                        "name": "Events (Create)",
                        "unit": "count"
                    },
                    "StreamingMilliSecondsSinceLastEvent": {
                        "name": "Time Since Last Streaming Event",
                        "unit": "milliseconds"
                    },
                    "StreamingLastEvent": {
                        "name": "Last Streaming Event",
                        "unit": "id"
                    },
                    "sourceRecordWriteTotal": {
                        "name": "Events Written",
                        "unit": "count"
                    }
                }
            }
            ```
      operationId: getSourceMetrics
      parameters:
        - name: source_id
          in: path
          required: true
          schema:
            type: string
            title: Source Id
        - name: time_type
          in: query
          required: false
          schema:
            enum:
              - timeseries
              - timesummary
              - latest
            type: string
            title: Time Type
            description: Type of the metrics.
            examples:
              - latest
            default: latest
          description: Type of the metrics.
        - name: time_interval
          in: query
          required: false
          schema:
            type: integer
            title: Time Interval
            description: The interval between each metrics data point.
            examples:
              - 1
            default: 1
          description: The interval between each metrics data point.
        - name: time_unit
          in: query
          required: false
          schema:
            enum:
              - minute
              - hour
              - day
              - week
              - month
            type: string
            title: Time Unit
            description: >-
              The unit of the time interval. Combined with time_interval to
              determine the interval between each metrics data point. For
              example, if time_interval=1 and time_unit=hour, the interval
              between each metrics data point is 1 hour.
            examples:
              - hour
            default: hour
          description: >-
            The unit of the time interval. Combined with time_interval to
            determine the interval between each metrics data point. For example,
            if time_interval=1 and time_unit=hour, the interval between each
            metrics data point is 1 hour.
        - name: timestamp_from
          in: query
          required: false
          schema:
            anyOf:
              - type: string
                format: date-time
              - type: 'null'
            title: Start Time
            description: >-
              Start time of the metrics data in UTC timezone. If not provided,
              start time is set to 24 hours before the current time.
            examples:
              - '2025-03-02T07:10:15Z'
          description: >-
            Start time of the metrics data in UTC timezone. If not provided,
            start time is set to 24 hours before the current time.
        - name: timestamp_to
          in: query
          required: false
          schema:
            anyOf:
              - type: string
                format: date-time
              - type: 'null'
            title: End Time
            description: >-
              End time of the metrics data in UTC timezone. If not provided, end
              time is set to the current time.
            examples:
              - '2025-03-04T07:10:15Z'
          description: >-
            End time of the metrics data in UTC timezone. If not provided, end
            time is set to the current time.
      responses:
        '200':
          description: Successful Response
          content:
            application/json:
              schema:
                anyOf:
                  - $ref: '#/components/schemas/SourceTimeseriesMetricsWithMetadata'
                  - $ref: '#/components/schemas/SourceLatestMetricsWithMetadata'
                  - $ref: '#/components/schemas/SourceTimesummaryMetricsWithMetadata'
                title: Response Getsourcemetrics
        '422':
          description: Validation Error
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/HTTPValidationError'
      security:
        - FronteggHTTPAuthentication: []
components:
  schemas:
    SourceTimeseriesMetricsWithMetadata:
      properties:
        data:
          $ref: '#/components/schemas/SourceTimeseriesMetrics'
        metadata:
          additionalProperties:
            additionalProperties:
              type: string
            type: object
          type: object
          title: Metadata
      additionalProperties: true
      type: object
      required:
        - data
        - metadata
      title: SourceTimeseriesMetricsWithMetadata
    SourceLatestMetricsWithMetadata:
      properties:
        data:
          $ref: '#/components/schemas/SourceLatestMetrics'
        metadata:
          additionalProperties:
            additionalProperties:
              type: string
            type: object
          type: object
          title: Metadata
      additionalProperties: true
      type: object
      required:
        - data
        - metadata
      title: SourceLatestMetricsWithMetadata
    SourceTimesummaryMetricsWithMetadata:
      properties:
        data:
          $ref: '#/components/schemas/SourceTimesummaryMetrics'
        metadata:
          additionalProperties:
            additionalProperties:
              type: string
            type: object
          type: object
          title: Metadata
      additionalProperties: true
      type: object
      required:
        - data
        - metadata
      title: SourceTimesummaryMetricsWithMetadata
    HTTPValidationError:
      properties:
        detail:
          items:
            $ref: '#/components/schemas/ValidationError'
          type: array
          title: Detail
      type: object
      title: HTTPValidationError
    SourceTimeseriesMetrics:
      properties:
        SnapshotMilliSecondsSinceLastEvent:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Snapshotmillisecondssincelastevent
          default: []
        SnapshotTotalNumberOfEventsSeen:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Snapshottotalnumberofeventsseen
          default: []
        StreamingMilliSecondsBehindSource:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Streamingmillisecondsbehindsource
          default: []
        StreamingMilliSecondsSinceLastEvent:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Streamingmillisecondssincelastevent
          default: []
        StreamingTotalNumberOfCreateEventsSeen:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Streamingtotalnumberofcreateeventsseen
          default: []
        StreamingTotalNumberOfDeleteEventsSeen:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Streamingtotalnumberofdeleteeventsseen
          default: []
        recordSendTotal:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Recordsendtotal
          default: []
        StreamingTotalNumberOfUpdateEventsSeen:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Streamingtotalnumberofupdateeventsseen
          default: []
        recordRetryTotal:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Recordretrytotal
          default: []
        recordWrittenTotal:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Recordwrittentotal
          default: []
        byteTotal:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Bytetotal
          default: []
        sourceRecordWriteTotal:
          items:
            $ref: '#/components/schemas/TimeseriesEntry'
          type: array
          title: Sourcerecordwritetotal
          default: []
      additionalProperties: true
      type: object
      title: SourceTimeseriesMetrics
      description: Source timeseries metrics.
      example:
        SnapshotMilliSecondsSinceLastEvent:
          - timestamp: '2025-03-02 08:00:00'
            value: 500
          - timestamp: '2025-03-02 09:00:00'
            value: 300
        SnapshotTotalNumberOfEventsSeen:
          - timestamp: '2025-03-02 08:00:00'
            value: 100
          - timestamp: '2025-03-02 09:00:00'
            value: 150
        StreamingMilliSecondsBehindSource:
          - timestamp: '2025-03-02 08:00:00'
            value: 1000
          - timestamp: '2025-03-02 09:00:00'
            value: 800
        StreamingMilliSecondsSinceLastEvent:
          - timestamp: '2025-03-02 08:00:00'
            value: 200
          - timestamp: '2025-03-02 09:00:00'
            value: 150
        StreamingTotalNumberOfCreateEventsSeen:
          - timestamp: '2025-03-02 08:00:00'
            value: 20
          - timestamp: '2025-03-02 09:00:00'
            value: 35
        StreamingTotalNumberOfDeleteEventsSeen:
          - timestamp: '2025-03-02 08:00:00'
            value: 5
          - timestamp: '2025-03-02 09:00:00'
            value: 8
        StreamingTotalNumberOfUpdateEventsSeen:
          - timestamp: '2025-03-02 08:00:00'
            value: 30
          - timestamp: '2025-03-02 09:00:00'
            value: 45
        byteTotal:
          - timestamp: '2025-03-02 08:00:00'
            value: 10000
          - timestamp: '2025-03-02 09:00:00'
            value: 15000
        recordRetryTotal:
          - timestamp: '2025-03-02 08:00:00'
            value: 2
          - timestamp: '2025-03-02 09:00:00'
            value: 3
        recordSendTotal:
          - timestamp: '2025-03-02 08:00:00'
            value: 50
          - timestamp: '2025-03-02 09:00:00'
            value: 70
        recordWrittenTotal:
          - timestamp: '2025-03-02 08:00:00'
            value: 40
          - timestamp: '2025-03-02 09:00:00'
            value: 60
        sourceRecordWriteTotal:
          - timestamp: '2025-03-02 08:00:00'
            value: 25
          - timestamp: '2025-03-02 09:00:00'
            value: 40
    SourceLatestMetrics:
      properties:
        SnapshotTotalNumberOfEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Snapshottotalnumberofeventsseen
        SnapshotMilliSecondsSinceLastEvent:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Snapshotmillisecondssincelastevent
        StreamingMilliSecondsBehindSource:
          anyOf:
            - type: number
            - type: string
            - type: 'null'
          title: Streamingmillisecondsbehindsource
        StreamingTotalNumberOfDeleteEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingtotalnumberofdeleteeventsseen
        StreamingTotalNumberOfUpdateEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingtotalnumberofupdateeventsseen
        StreamingTotalNumberOfCreateEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingtotalnumberofcreateeventsseen
        StreamingMilliSecondsSinceLastEvent:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingmillisecondssincelastevent
        StreamingLastEvent:
          anyOf:
            - type: string
            - type: 'null'
          title: Streaminglastevent
        recordRetryTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Recordretrytotal
        byteTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Bytetotal
        sourceRecordWriteTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Sourcerecordwritetotal
        SnapshotRunning:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Snapshotrunning
        SnapshotCompleted:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Snapshotcompleted
        StreamingConnected:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingconnected
        recordSendTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Recordsendtotal
        state:
          anyOf:
            - type: string
            - type: 'null'
          title: State
        streamingState:
          anyOf:
            - type: string
            - type: 'null'
          title: Streamingstate
        snapshotStatus:
          anyOf:
            - items:
                additionalProperties:
                  anyOf:
                    - type: string
                    - type: integer
                    - type: 'null'
                type: object
              type: array
            - type: 'null'
          title: Snapshotstatus
          default: []
        snapshotState:
          anyOf:
            - type: string
            - type: 'null'
          title: Snapshotstate
        recordWrittenTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Recordwrittentotal
        connector_status:
          anyOf:
            - type: string
            - type: 'null'
          title: Connector Status
        latency:
          anyOf:
            - type: number
            - type: string
            - type: 'null'
          title: Latency
      additionalProperties: true
      type: object
      title: SourceLatestMetrics
      description: Source latest metrics.
      example:
        SnapshotCompleted: 2
        SnapshotMilliSecondsSinceLastEvent: 3600000
        SnapshotRunning: 0
        SnapshotTotalNumberOfEventsSeen: 20254
        StreamingConnected: 1
        StreamingLastEvent: >-
          position: {ord: 14}, key: {"id" :
          ""ceaafb88-2a60-4bd9-8515-719ba64ea05c-close""}
        StreamingMilliSecondsBehindSource: 500
        StreamingMilliSecondsSinceLastEvent: 200
        StreamingTotalNumberOfCreateEventsSeen: 73
        StreamingTotalNumberOfDeleteEventsSeen: 312
        StreamingTotalNumberOfUpdateEventsSeen: 0
        byteTotal: 9018776
        connector_status: Active
        latency: 150
        recordRetryTotal: 10
        recordSendTotal: 400
        recordWrittenTotal: 395
        snapshotState: completed
        snapshotStatus:
          - status: completed
            submit_timestamp: '2023-10-01T10:00:00Z'
            topic_id: source_111111111111111111111111.Test.test_data1
          - status: completed
            submit_timestamp: '2023-10-01T10:10:00Z'
            topic_id: source_111111111111111111111111.Test.test_data2
        sourceRecordWriteTotal: 27785
        state: Streaming
        streamingState: connected
    SourceTimesummaryMetrics:
      properties:
        SnapshotTotalNumberOfEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Snapshottotalnumberofeventsseen
        SnapshotMilliSecondsSinceLastEvent:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Snapshotmillisecondssincelastevent
        StreamingMilliSecondsBehindSource:
          anyOf:
            - type: number
            - type: string
            - type: 'null'
          title: Streamingmillisecondsbehindsource
        StreamingTotalNumberOfDeleteEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingtotalnumberofdeleteeventsseen
        StreamingTotalNumberOfUpdateEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingtotalnumberofupdateeventsseen
        StreamingTotalNumberOfCreateEventsSeen:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingtotalnumberofcreateeventsseen
        StreamingMilliSecondsSinceLastEvent:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Streamingmillisecondssincelastevent
        recordRetryTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Recordretrytotal
        recordSendTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Recordsendtotal
        recordWrittenTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Recordwrittentotal
        byteTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Bytetotal
        sourceRecordWriteTotal:
          anyOf:
            - type: integer
            - type: string
            - type: 'null'
          title: Sourcerecordwritetotal
        snapshotStatus:
          anyOf:
            - items:
                additionalProperties:
                  anyOf:
                    - type: string
                    - type: integer
                    - type: 'null'
                type: object
              type: array
            - type: 'null'
          title: Snapshotstatus
          default: []
        snapshotState:
          anyOf:
            - type: string
            - type: 'null'
          title: Snapshotstate
        connector_status:
          anyOf:
            - type: string
            - type: 'null'
          title: Connector Status
        latency:
          anyOf:
            - type: number
            - type: string
            - type: 'null'
          title: Latency
      additionalProperties: true
      type: object
      title: SourceTimesummaryMetrics
      description: Source timesummary metrics.
      example:
        SnapshotMilliSecondsSinceLastEvent: 500
        SnapshotTotalNumberOfEventsSeen: 65
        StreamingMilliSecondsBehindSource: 200
        StreamingMilliSecondsSinceLastEvent: 100
        StreamingTotalNumberOfCreateEventsSeen: 20
        StreamingTotalNumberOfDeleteEventsSeen: 13
        StreamingTotalNumberOfUpdateEventsSeen: 25
        byteTotal: 6000
        connector_status: Active
        latency: 100
        recordRetryTotal: 5
        recordSendTotal: 60
        recordWrittenTotal: 58
        snapshotState: completed
        snapshotStatus:
          - status: completed
            submit_timestamp: '2023-10-01T12:00:00Z'
            topic_id: source_111111111111111111111111.Test.test_data1
          - status: completed
            submit_timestamp: '2023-10-01T12:05:00Z'
            topic_id: source_111111111111111111111111.Test.test_data2
        sourceRecordWriteTotal: 547
    ValidationError:
      properties:
        loc:
          items:
            anyOf:
              - type: string
              - type: integer
          type: array
          title: Location
        msg:
          type: string
          title: Message
        type:
          type: string
          title: Error Type
        input:
          title: Input
        ctx:
          type: object
          title: Context
      type: object
      required:
        - loc
        - msg
        - type
      title: ValidationError
    TimeseriesEntry:
      properties:
        value:
          anyOf:
            - type: integer
            - type: number
          title: Value
          description: The metric value at this timestamp
        timestamp:
          type: string
          title: Timestamp
          description: ISO 8601 timestamp for this data point
      additionalProperties: true
      type: object
      required:
        - value
        - timestamp
      title: TimeseriesEntry
      description: A single data point in a time series.
  securitySchemes:
    FronteggHTTPAuthentication:
      type: http
      scheme: bearer

````