Stream sink message

Wrapper event over the emitted payload

streamId

string

groupId

string

tags

string[]

List of tags of the source processor of this message

sinkTopicName

string

Sink topic identifier

messageId

string

Id of the emitted message

processorId

string

Id of the processor that emitted the message

sequenceId

integer

Sequence number of the emitted message. The sequence number is given by the emitting processor and it is stored as a message property, different from the Pulsar sequence id

publishTimestamp

string

frameType

string

Type of the frame extracted from 'X-Vat-Stream-Frame-Type' message header

payloadSchema

enum<string>

Fully qualified AVRO schema of the payload

Available options:

null,

bytes,

string,

tech.vatis.schema.stream.processor.messages.transcription.TranscriptionResponseDto,

tech.vatis.schema.stream.processor.messages.diarization.DiarizationResponseDto,

tech.vatis.schema.stream.processor.messages.llm.LlmResponseDto

payload

object

Response from the transcription service

headers

object

Headers extracted from the message

Llm response Audio intelligence response

{
  "streamId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
  "groupId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
  "tags": [
    "<string>"
  ],
  "sinkTopicName": "<string>",
  "messageId": "<string>",
  "processorId": "<string>",
  "sequenceId": 123,
  "publishTimestamp": "2023-11-07T05:31:56Z",
  "frameType": "<string>",
  "payloadSchema": "null",
  "payload": {
    "transcription": "<string>",
    "words": [
      {
        "word": "<string>",
        "start": 123,
        "end": 123,
        "confidence": 123,
        "language": "<string>",
        "metadata": {}
      }
    ],
    "start": 123,
    "end": 123,
    "metadata": {},
    "channel": 123,
    "utterance": true
  },
  "headers": {}
}

API Documentation

Schemas

Authentication

Gateway

Streams

Webhooks

Export

Usage

Stream configuration

Processor