messagespb

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 21, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_messages_v1_messages_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ChatRequest 

type ChatRequest struct {
	RequestId       string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	UserId          string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Username        string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Message         string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	Query           string `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"` // alternative to message (EffectiveQuery picks first non-empty)
	Premium         bool   `protobuf:"varint,6,opt,name=premium,proto3" json:"premium,omitempty"`
	EnableRag       bool   `protobuf:"varint,7,opt,name=enable_rag,json=enableRag,proto3" json:"enable_rag,omitempty"`
	EnableReranker  bool   `protobuf:"varint,8,opt,name=enable_reranker,json=enableReranker,proto3" json:"enable_reranker,omitempty"`
	EnableStreaming bool   `protobuf:"varint,9,opt,name=enable_streaming,json=enableStreaming,proto3" json:"enable_streaming,omitempty"`
	TopK            int32  `protobuf:"varint,10,opt,name=top_k,json=topK,proto3" json:"top_k,omitempty"`
	Collection      string `protobuf:"bytes,11,opt,name=collection,proto3" json:"collection,omitempty"`
	EnableTts       bool   `protobuf:"varint,12,opt,name=enable_tts,json=enableTts,proto3" json:"enable_tts,omitempty"`
	SystemPrompt    string `protobuf:"bytes,13,opt,name=system_prompt,json=systemPrompt,proto3" json:"system_prompt,omitempty"`
	ResponseSubject string `protobuf:"bytes,14,opt,name=response_subject,json=responseSubject,proto3" json:"response_subject,omitempty"`
	// contains filtered or unexported fields
}

ChatRequest is an incoming chat message routed via NATS. Subject: ai.chat.user.{user_id}.message

func (*ChatRequest) Descriptor deprecated 

func (*ChatRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChatRequest.ProtoReflect.Descriptor instead.

func (*ChatRequest) GetCollection 

func (x *ChatRequest) GetCollection() string

func (*ChatRequest) GetEnableRag 

func (x *ChatRequest) GetEnableRag() bool

func (*ChatRequest) GetEnableReranker 

func (x *ChatRequest) GetEnableReranker() bool

func (*ChatRequest) GetEnableStreaming 

func (x *ChatRequest) GetEnableStreaming() bool

func (*ChatRequest) GetEnableTts 

func (x *ChatRequest) GetEnableTts() bool

func (*ChatRequest) GetMessage 

func (x *ChatRequest) GetMessage() string

func (*ChatRequest) GetPremium 

func (x *ChatRequest) GetPremium() bool

func (*ChatRequest) GetQuery 

func (x *ChatRequest) GetQuery() string

func (*ChatRequest) GetRequestId 

func (x *ChatRequest) GetRequestId() string

func (*ChatRequest) GetResponseSubject 

func (x *ChatRequest) GetResponseSubject() string

func (*ChatRequest) GetSystemPrompt 

func (x *ChatRequest) GetSystemPrompt() string

func (*ChatRequest) GetTopK 

func (x *ChatRequest) GetTopK() int32

func (*ChatRequest) GetUserId 

func (x *ChatRequest) GetUserId() string

func (*ChatRequest) GetUsername 

func (x *ChatRequest) GetUsername() string

func (*ChatRequest) ProtoMessage 

func (*ChatRequest) ProtoMessage()

func (*ChatRequest) ProtoReflect 

func (x *ChatRequest) ProtoReflect() protoreflect.Message

func (*ChatRequest) Reset 

func (x *ChatRequest) Reset()

func (*ChatRequest) String 

func (x *ChatRequest) String() string

type ChatResponse 

type ChatResponse struct {
	UserId       string   `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Response     string   `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	ResponseText string   `protobuf:"bytes,3,opt,name=response_text,json=responseText,proto3" json:"response_text,omitempty"`
	UsedRag      bool     `protobuf:"varint,4,opt,name=used_rag,json=usedRag,proto3" json:"used_rag,omitempty"`
	RagSources   []string `protobuf:"bytes,5,rep,name=rag_sources,json=ragSources,proto3" json:"rag_sources,omitempty"`
	Success      bool     `protobuf:"varint,6,opt,name=success,proto3" json:"success,omitempty"`
	Audio        []byte   `protobuf:"bytes,7,opt,name=audio,proto3" json:"audio,omitempty"`
	Error        string   `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ChatResponse is the full reply to a ChatRequest. Subject: ai.chat.response.{request_id} (or ChatRequest.response_subject)

func (*ChatResponse) Descriptor deprecated 

func (*ChatResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChatResponse.ProtoReflect.Descriptor instead.

func (*ChatResponse) GetAudio 

func (x *ChatResponse) GetAudio() []byte

func (*ChatResponse) GetError 

func (x *ChatResponse) GetError() string

func (*ChatResponse) GetRagSources 

func (x *ChatResponse) GetRagSources() []string

func (*ChatResponse) GetResponse 

func (x *ChatResponse) GetResponse() string

func (*ChatResponse) GetResponseText 

func (x *ChatResponse) GetResponseText() string

func (*ChatResponse) GetSuccess 

func (x *ChatResponse) GetSuccess() bool

func (*ChatResponse) GetUsedRag 

func (x *ChatResponse) GetUsedRag() bool

func (*ChatResponse) GetUserId 

func (x *ChatResponse) GetUserId() string

func (*ChatResponse) ProtoMessage 

func (*ChatResponse) ProtoMessage()

func (*ChatResponse) ProtoReflect 

func (x *ChatResponse) ProtoReflect() protoreflect.Message

func (*ChatResponse) Reset 

func (x *ChatResponse) Reset()

func (*ChatResponse) String 

func (x *ChatResponse) String() string

type ChatStreamChunk 

type ChatStreamChunk struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Type      string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // "chunk" | "done"
	Content   string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Done      bool   `protobuf:"varint,4,opt,name=done,proto3" json:"done,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

ChatStreamChunk is one piece of a streaming LLM response. Subject: ai.chat.response.stream.{request_id}

func (*ChatStreamChunk) Descriptor deprecated 

func (*ChatStreamChunk) Descriptor() ([]byte, []int)

Deprecated: Use ChatStreamChunk.ProtoReflect.Descriptor instead.

func (*ChatStreamChunk) GetContent 

func (x *ChatStreamChunk) GetContent() string

func (*ChatStreamChunk) GetDone 

func (x *ChatStreamChunk) GetDone() bool

func (*ChatStreamChunk) GetRequestId 

func (x *ChatStreamChunk) GetRequestId() string

func (*ChatStreamChunk) GetTimestamp 

func (x *ChatStreamChunk) GetTimestamp() int64

func (*ChatStreamChunk) GetType 

func (x *ChatStreamChunk) GetType() string

func (*ChatStreamChunk) ProtoMessage 

func (*ChatStreamChunk) ProtoMessage()

func (*ChatStreamChunk) ProtoReflect 

func (x *ChatStreamChunk) ProtoReflect() protoreflect.Message

func (*ChatStreamChunk) Reset 

func (x *ChatStreamChunk) Reset()

func (*ChatStreamChunk) String 

func (x *ChatStreamChunk) String() string

type DocumentSource 

type DocumentSource struct {
	Text  string  `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
	Score float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

DocumentSource is a single RAG search-result citation.

func (*DocumentSource) Descriptor deprecated 

func (*DocumentSource) Descriptor() ([]byte, []int)

Deprecated: Use DocumentSource.ProtoReflect.Descriptor instead.

func (*DocumentSource) GetScore 

func (x *DocumentSource) GetScore() float64

func (*DocumentSource) GetText 

func (x *DocumentSource) GetText() string

func (*DocumentSource) ProtoMessage 

func (*DocumentSource) ProtoMessage()

func (*DocumentSource) ProtoReflect 

func (x *DocumentSource) ProtoReflect() protoreflect.Message

func (*DocumentSource) Reset 

func (x *DocumentSource) Reset()

func (*DocumentSource) String 

func (x *DocumentSource) String() string

type ErrorResponse 

type ErrorResponse struct {
	Error   bool   `protobuf:"varint,1,opt,name=error,proto3" json:"error,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Type    string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

ErrorResponse is the standard error reply from any handler.

func (*ErrorResponse) Descriptor deprecated 

func (*ErrorResponse) Descriptor() ([]byte, []int)

Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.

func (*ErrorResponse) GetError 

func (x *ErrorResponse) GetError() bool

func (*ErrorResponse) GetMessage 

func (x *ErrorResponse) GetMessage() string

func (*ErrorResponse) GetType 

func (x *ErrorResponse) GetType() string

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) ProtoReflect 

func (x *ErrorResponse) ProtoReflect() protoreflect.Message

func (*ErrorResponse) Reset 

func (x *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (x *ErrorResponse) String() string

type GreetingRequest 

type GreetingRequest struct {
	UserId   string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Nickname string `protobuf:"bytes,3,opt,name=nickname,proto3" json:"nickname,omitempty"`
	Premium  bool   `protobuf:"varint,4,opt,name=premium,proto3" json:"premium,omitempty"`
	// contains filtered or unexported fields
}

GreetingRequest asks the LLM to generate a personalised greeting. Subject: ai.chat.user.{user_id}.greeting.request

func (*GreetingRequest) Descriptor deprecated 

func (*GreetingRequest) Descriptor() ([]byte, []int)

Deprecated: Use GreetingRequest.ProtoReflect.Descriptor instead.

func (*GreetingRequest) GetNickname 

func (x *GreetingRequest) GetNickname() string

func (*GreetingRequest) GetPremium 

func (x *GreetingRequest) GetPremium() bool

func (*GreetingRequest) GetUserId 

func (x *GreetingRequest) GetUserId() string

func (*GreetingRequest) GetUsername 

func (x *GreetingRequest) GetUsername() string

func (*GreetingRequest) ProtoMessage 

func (*GreetingRequest) ProtoMessage()

func (*GreetingRequest) ProtoReflect 

func (x *GreetingRequest) ProtoReflect() protoreflect.Message

func (*GreetingRequest) Reset 

func (x *GreetingRequest) Reset()

func (*GreetingRequest) String 

func (x *GreetingRequest) String() string

type GreetingResponse 

type GreetingResponse struct {
	UserId   string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Greeting string `protobuf:"bytes,2,opt,name=greeting,proto3" json:"greeting,omitempty"`
	// contains filtered or unexported fields
}

GreetingResponse carries the generated greeting text. Subject: ai.chat.user.{user_id}.greeting.response

func (*GreetingResponse) Descriptor deprecated 

func (*GreetingResponse) Descriptor() ([]byte, []int)

Deprecated: Use GreetingResponse.ProtoReflect.Descriptor instead.

func (*GreetingResponse) GetGreeting 

func (x *GreetingResponse) GetGreeting() string

func (*GreetingResponse) GetUserId 

func (x *GreetingResponse) GetUserId() string

func (*GreetingResponse) ProtoMessage 

func (*GreetingResponse) ProtoMessage()

func (*GreetingResponse) ProtoReflect 

func (x *GreetingResponse) ProtoReflect() protoreflect.Message

func (*GreetingResponse) Reset 

func (x *GreetingResponse) Reset()

func (*GreetingResponse) String 

func (x *GreetingResponse) String() string

type LoginEvent 

type LoginEvent struct {
	UserId    string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Username  string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Nickname  string `protobuf:"bytes,3,opt,name=nickname,proto3" json:"nickname,omitempty"`
	Premium   bool   `protobuf:"varint,4,opt,name=premium,proto3" json:"premium,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Unix seconds
	// contains filtered or unexported fields
}

LoginEvent is published when a user authenticates. Subject: ai.chat.user.{user_id}.login

func (*LoginEvent) Descriptor deprecated 

func (*LoginEvent) Descriptor() ([]byte, []int)

Deprecated: Use LoginEvent.ProtoReflect.Descriptor instead.

func (*LoginEvent) GetNickname 

func (x *LoginEvent) GetNickname() string

func (*LoginEvent) GetPremium 

func (x *LoginEvent) GetPremium() bool

func (*LoginEvent) GetTimestamp 

func (x *LoginEvent) GetTimestamp() int64

func (*LoginEvent) GetUserId 

func (x *LoginEvent) GetUserId() string

func (*LoginEvent) GetUsername 

func (x *LoginEvent) GetUsername() string

func (*LoginEvent) ProtoMessage 

func (*LoginEvent) ProtoMessage()

func (*LoginEvent) ProtoReflect 

func (x *LoginEvent) ProtoReflect() protoreflect.Message

func (*LoginEvent) Reset 

func (x *LoginEvent) Reset()

func (*LoginEvent) String 

func (x *LoginEvent) String() string

type PipelineStatus 

type PipelineStatus struct {
	RequestId          string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Status             string   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	RunId              string   `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Engine             string   `protobuf:"bytes,4,opt,name=engine,proto3" json:"engine,omitempty"`
	Pipeline           string   `protobuf:"bytes,5,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	SubmittedAt        string   `protobuf:"bytes,6,opt,name=submitted_at,json=submittedAt,proto3" json:"submitted_at,omitempty"`
	Error              string   `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	AvailablePipelines []string `protobuf:"bytes,8,rep,name=available_pipelines,json=availablePipelines,proto3" json:"available_pipelines,omitempty"`
	// contains filtered or unexported fields
}

PipelineStatus is the response / status update for a pipeline run. Subject: ai.pipeline.status.{request_id}

func (*PipelineStatus) Descriptor deprecated 

func (*PipelineStatus) Descriptor() ([]byte, []int)

Deprecated: Use PipelineStatus.ProtoReflect.Descriptor instead.

func (*PipelineStatus) GetAvailablePipelines 

func (x *PipelineStatus) GetAvailablePipelines() []string

func (*PipelineStatus) GetEngine 

func (x *PipelineStatus) GetEngine() string

func (*PipelineStatus) GetError 

func (x *PipelineStatus) GetError() string

func (*PipelineStatus) GetPipeline 

func (x *PipelineStatus) GetPipeline() string

func (*PipelineStatus) GetRequestId 

func (x *PipelineStatus) GetRequestId() string

func (*PipelineStatus) GetRunId 

func (x *PipelineStatus) GetRunId() string

func (*PipelineStatus) GetStatus 

func (x *PipelineStatus) GetStatus() string

func (*PipelineStatus) GetSubmittedAt 

func (x *PipelineStatus) GetSubmittedAt() string

func (*PipelineStatus) ProtoMessage 

func (*PipelineStatus) ProtoMessage()

func (*PipelineStatus) ProtoReflect 

func (x *PipelineStatus) ProtoReflect() protoreflect.Message

func (*PipelineStatus) Reset 

func (x *PipelineStatus) Reset()

func (*PipelineStatus) String 

func (x *PipelineStatus) String() string

type PipelineTrigger 

type PipelineTrigger struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Pipeline  string `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// Protobuf Struct could be used here, but a simple string map covers
	// all current use-cases and avoids a google/protobuf import.
	Parameters map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

PipelineTrigger is the request to start a pipeline. Subject: ai.pipeline.trigger

func (*PipelineTrigger) Descriptor deprecated 

func (*PipelineTrigger) Descriptor() ([]byte, []int)

Deprecated: Use PipelineTrigger.ProtoReflect.Descriptor instead.

func (*PipelineTrigger) GetParameters 

func (x *PipelineTrigger) GetParameters() map[string]string

func (*PipelineTrigger) GetPipeline 

func (x *PipelineTrigger) GetPipeline() string

func (*PipelineTrigger) GetRequestId 

func (x *PipelineTrigger) GetRequestId() string

func (*PipelineTrigger) ProtoMessage 

func (*PipelineTrigger) ProtoMessage()

func (*PipelineTrigger) ProtoReflect 

func (x *PipelineTrigger) ProtoReflect() protoreflect.Message

func (*PipelineTrigger) Reset 

func (x *PipelineTrigger) Reset()

func (*PipelineTrigger) String 

func (x *PipelineTrigger) String() string

type STTInterrupt 

type STTInterrupt struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Type      string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // "interrupt"
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	SpeakerId string `protobuf:"bytes,4,opt,name=speaker_id,json=speakerId,proto3" json:"speaker_id,omitempty"`
	// contains filtered or unexported fields
}

STTInterrupt is published when the STT module detects a user interrupt. Subject: ai.voice.transcription.{session_id}

func (*STTInterrupt) Descriptor deprecated 

func (*STTInterrupt) Descriptor() ([]byte, []int)

Deprecated: Use STTInterrupt.ProtoReflect.Descriptor instead.

func (*STTInterrupt) GetSessionId 

func (x *STTInterrupt) GetSessionId() string

func (*STTInterrupt) GetSpeakerId 

func (x *STTInterrupt) GetSpeakerId() string

func (*STTInterrupt) GetTimestamp 

func (x *STTInterrupt) GetTimestamp() int64

func (*STTInterrupt) GetType 

func (x *STTInterrupt) GetType() string

func (*STTInterrupt) ProtoMessage 

func (*STTInterrupt) ProtoMessage()

func (*STTInterrupt) ProtoReflect 

func (x *STTInterrupt) ProtoReflect() protoreflect.Message

func (*STTInterrupt) Reset 

func (x *STTInterrupt) Reset()

func (*STTInterrupt) String 

func (x *STTInterrupt) String() string

type STTStreamMessage 

type STTStreamMessage struct {
	Type      string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // "start" | "chunk" | "state_change" | "end"
	Audio     []byte `protobuf:"bytes,2,opt,name=audio,proto3" json:"audio,omitempty"`
	State     string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	SpeakerId string `protobuf:"bytes,4,opt,name=speaker_id,json=speakerId,proto3" json:"speaker_id,omitempty"`
	// contains filtered or unexported fields
}

STTStreamMessage is any message on the ai.voice.stream.{session_id} subject.

func (*STTStreamMessage) Descriptor deprecated 

func (*STTStreamMessage) Descriptor() ([]byte, []int)

Deprecated: Use STTStreamMessage.ProtoReflect.Descriptor instead.

func (*STTStreamMessage) GetAudio 

func (x *STTStreamMessage) GetAudio() []byte

func (*STTStreamMessage) GetSpeakerId 

func (x *STTStreamMessage) GetSpeakerId() string

func (*STTStreamMessage) GetState 

func (x *STTStreamMessage) GetState() string

func (*STTStreamMessage) GetType 

func (x *STTStreamMessage) GetType() string

func (*STTStreamMessage) ProtoMessage 

func (*STTStreamMessage) ProtoMessage()

func (*STTStreamMessage) ProtoReflect 

func (x *STTStreamMessage) ProtoReflect() protoreflect.Message

func (*STTStreamMessage) Reset 

func (x *STTStreamMessage) Reset()

func (*STTStreamMessage) String 

func (x *STTStreamMessage) String() string

type STTTranscription 

type STTTranscription struct {
	SessionId        string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Transcript       string `protobuf:"bytes,2,opt,name=transcript,proto3" json:"transcript,omitempty"`
	Sequence         int32  `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	IsPartial        bool   `protobuf:"varint,4,opt,name=is_partial,json=isPartial,proto3" json:"is_partial,omitempty"`
	IsFinal          bool   `protobuf:"varint,5,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`
	Timestamp        int64  `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	SpeakerId        string `protobuf:"bytes,7,opt,name=speaker_id,json=speakerId,proto3" json:"speaker_id,omitempty"`
	HasVoiceActivity bool   `protobuf:"varint,8,opt,name=has_voice_activity,json=hasVoiceActivity,proto3" json:"has_voice_activity,omitempty"`
	State            string `protobuf:"bytes,9,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

STTTranscription is the transcription result published by the STT module. Subject: ai.voice.transcription.{session_id}

func (*STTTranscription) Descriptor deprecated 

func (*STTTranscription) Descriptor() ([]byte, []int)

Deprecated: Use STTTranscription.ProtoReflect.Descriptor instead.

func (*STTTranscription) GetHasVoiceActivity 

func (x *STTTranscription) GetHasVoiceActivity() bool

func (*STTTranscription) GetIsFinal 

func (x *STTTranscription) GetIsFinal() bool

func (*STTTranscription) GetIsPartial 

func (x *STTTranscription) GetIsPartial() bool

func (*STTTranscription) GetSequence 

func (x *STTTranscription) GetSequence() int32

func (*STTTranscription) GetSessionId 

func (x *STTTranscription) GetSessionId() string

func (*STTTranscription) GetSpeakerId 

func (x *STTTranscription) GetSpeakerId() string

func (*STTTranscription) GetState 

func (x *STTTranscription) GetState() string

func (*STTTranscription) GetTimestamp 

func (x *STTTranscription) GetTimestamp() int64

func (*STTTranscription) GetTranscript 

func (x *STTTranscription) GetTranscript() string

func (*STTTranscription) ProtoMessage 

func (*STTTranscription) ProtoMessage()

func (*STTTranscription) ProtoReflect 

func (x *STTTranscription) ProtoReflect() protoreflect.Message

func (*STTTranscription) Reset 

func (x *STTTranscription) Reset()

func (*STTTranscription) String 

func (x *STTTranscription) String() string

type TTSAudioChunk 

type TTSAudioChunk struct {
	SessionId   string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ChunkIndex  int32  `protobuf:"varint,2,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`
	TotalChunks int32  `protobuf:"varint,3,opt,name=total_chunks,json=totalChunks,proto3" json:"total_chunks,omitempty"`
	Audio       []byte `protobuf:"bytes,4,opt,name=audio,proto3" json:"audio,omitempty"`
	IsLast      bool   `protobuf:"varint,5,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
	Timestamp   int64  `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	SampleRate  int32  `protobuf:"varint,7,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
	// contains filtered or unexported fields
}

TTSAudioChunk is a streamed audio chunk from TTS synthesis. Subject: ai.voice.tts.audio.{session_id}

func (*TTSAudioChunk) Descriptor deprecated 

func (*TTSAudioChunk) Descriptor() ([]byte, []int)

Deprecated: Use TTSAudioChunk.ProtoReflect.Descriptor instead.

func (*TTSAudioChunk) GetAudio 

func (x *TTSAudioChunk) GetAudio() []byte

func (*TTSAudioChunk) GetChunkIndex 

func (x *TTSAudioChunk) GetChunkIndex() int32

func (*TTSAudioChunk) GetIsLast 

func (x *TTSAudioChunk) GetIsLast() bool

func (*TTSAudioChunk) GetSampleRate 

func (x *TTSAudioChunk) GetSampleRate() int32

func (*TTSAudioChunk) GetSessionId 

func (x *TTSAudioChunk) GetSessionId() string

func (*TTSAudioChunk) GetTimestamp 

func (x *TTSAudioChunk) GetTimestamp() int64

func (*TTSAudioChunk) GetTotalChunks 

func (x *TTSAudioChunk) GetTotalChunks() int32

func (*TTSAudioChunk) ProtoMessage 

func (*TTSAudioChunk) ProtoMessage()

func (*TTSAudioChunk) ProtoReflect 

func (x *TTSAudioChunk) ProtoReflect() protoreflect.Message

func (*TTSAudioChunk) Reset 

func (x *TTSAudioChunk) Reset()

func (*TTSAudioChunk) String 

func (x *TTSAudioChunk) String() string

type TTSFullResponse 

type TTSFullResponse struct {
	SessionId  string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Audio      []byte `protobuf:"bytes,2,opt,name=audio,proto3" json:"audio,omitempty"`
	Timestamp  int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	SampleRate int32  `protobuf:"varint,4,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
	// contains filtered or unexported fields
}

TTSFullResponse is a non-streamed TTS response (whole audio blob). Subject: ai.voice.tts.audio.{session_id}

func (*TTSFullResponse) Descriptor deprecated 

func (*TTSFullResponse) Descriptor() ([]byte, []int)

Deprecated: Use TTSFullResponse.ProtoReflect.Descriptor instead.

func (*TTSFullResponse) GetAudio 

func (x *TTSFullResponse) GetAudio() []byte

func (*TTSFullResponse) GetSampleRate 

func (x *TTSFullResponse) GetSampleRate() int32

func (*TTSFullResponse) GetSessionId 

func (x *TTSFullResponse) GetSessionId() string

func (*TTSFullResponse) GetTimestamp 

func (x *TTSFullResponse) GetTimestamp() int64

func (*TTSFullResponse) ProtoMessage 

func (*TTSFullResponse) ProtoMessage()

func (*TTSFullResponse) ProtoReflect 

func (x *TTSFullResponse) ProtoReflect() protoreflect.Message

func (*TTSFullResponse) Reset 

func (x *TTSFullResponse) Reset()

func (*TTSFullResponse) String 

func (x *TTSFullResponse) String() string

type TTSRequest 

type TTSRequest struct {
	Text          string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
	Speaker       string `protobuf:"bytes,2,opt,name=speaker,proto3" json:"speaker,omitempty"`
	Language      string `protobuf:"bytes,3,opt,name=language,proto3" json:"language,omitempty"`
	SpeakerWavB64 string `protobuf:"bytes,4,opt,name=speaker_wav_b64,json=speakerWavB64,proto3" json:"speaker_wav_b64,omitempty"`
	Stream        bool   `protobuf:"varint,5,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

TTSRequest is a text-to-speech synthesis request. Subject: ai.voice.tts.request.{session_id}

func (*TTSRequest) Descriptor deprecated 

func (*TTSRequest) Descriptor() ([]byte, []int)

Deprecated: Use TTSRequest.ProtoReflect.Descriptor instead.

func (*TTSRequest) GetLanguage 

func (x *TTSRequest) GetLanguage() string

func (*TTSRequest) GetSpeaker 

func (x *TTSRequest) GetSpeaker() string

func (*TTSRequest) GetSpeakerWavB64 

func (x *TTSRequest) GetSpeakerWavB64() string

func (*TTSRequest) GetStream 

func (x *TTSRequest) GetStream() bool

func (*TTSRequest) GetText 

func (x *TTSRequest) GetText() string

func (*TTSRequest) ProtoMessage 

func (*TTSRequest) ProtoMessage()

func (*TTSRequest) ProtoReflect 

func (x *TTSRequest) ProtoReflect() protoreflect.Message

func (*TTSRequest) Reset 

func (x *TTSRequest) Reset()

func (*TTSRequest) String 

func (x *TTSRequest) String() string

type TTSStatus 

type TTSStatus struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Status    string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Message   string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

TTSStatus is a TTS processing status update. Subject: ai.voice.tts.status.{session_id}

func (*TTSStatus) Descriptor deprecated 

func (*TTSStatus) Descriptor() ([]byte, []int)

Deprecated: Use TTSStatus.ProtoReflect.Descriptor instead.

func (*TTSStatus) GetMessage 

func (x *TTSStatus) GetMessage() string

func (*TTSStatus) GetSessionId 

func (x *TTSStatus) GetSessionId() string

func (*TTSStatus) GetStatus 

func (x *TTSStatus) GetStatus() string

func (*TTSStatus) GetTimestamp 

func (x *TTSStatus) GetTimestamp() int64

func (*TTSStatus) ProtoMessage 

func (*TTSStatus) ProtoMessage()

func (*TTSStatus) ProtoReflect 

func (x *TTSStatus) ProtoReflect() protoreflect.Message

func (*TTSStatus) Reset 

func (x *TTSStatus) Reset()

func (*TTSStatus) String 

func (x *TTSStatus) String() string

type TTSVoiceInfo 

type TTSVoiceInfo struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Language  string `protobuf:"bytes,2,opt,name=language,proto3" json:"language,omitempty"`
	ModelType string `protobuf:"bytes,3,opt,name=model_type,json=modelType,proto3" json:"model_type,omitempty"`
	CreatedAt string `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

TTSVoiceInfo is summary info about a custom voice.

func (*TTSVoiceInfo) Descriptor deprecated 

func (*TTSVoiceInfo) Descriptor() ([]byte, []int)

Deprecated: Use TTSVoiceInfo.ProtoReflect.Descriptor instead.

func (*TTSVoiceInfo) GetCreatedAt 

func (x *TTSVoiceInfo) GetCreatedAt() string

func (*TTSVoiceInfo) GetLanguage 

func (x *TTSVoiceInfo) GetLanguage() string

func (*TTSVoiceInfo) GetModelType 

func (x *TTSVoiceInfo) GetModelType() string

func (*TTSVoiceInfo) GetName 

func (x *TTSVoiceInfo) GetName() string

func (*TTSVoiceInfo) ProtoMessage 

func (*TTSVoiceInfo) ProtoMessage()

func (*TTSVoiceInfo) ProtoReflect 

func (x *TTSVoiceInfo) ProtoReflect() protoreflect.Message

func (*TTSVoiceInfo) Reset 

func (x *TTSVoiceInfo) Reset()

func (*TTSVoiceInfo) String 

func (x *TTSVoiceInfo) String() string

type TTSVoiceListResponse 

type TTSVoiceListResponse struct {
	DefaultSpeaker string          `protobuf:"bytes,1,opt,name=default_speaker,json=defaultSpeaker,proto3" json:"default_speaker,omitempty"`
	CustomVoices   []*TTSVoiceInfo `protobuf:"bytes,2,rep,name=custom_voices,json=customVoices,proto3" json:"custom_voices,omitempty"`
	LastRefresh    int64           `protobuf:"varint,3,opt,name=last_refresh,json=lastRefresh,proto3" json:"last_refresh,omitempty"`
	Timestamp      int64           `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

TTSVoiceListResponse is the reply to a voice list request. Subject: ai.voice.tts.voices.list (request-reply)

func (*TTSVoiceListResponse) Descriptor deprecated 

func (*TTSVoiceListResponse) Descriptor() ([]byte, []int)

Deprecated: Use TTSVoiceListResponse.ProtoReflect.Descriptor instead.

func (*TTSVoiceListResponse) GetCustomVoices 

func (x *TTSVoiceListResponse) GetCustomVoices() []*TTSVoiceInfo

func (*TTSVoiceListResponse) GetDefaultSpeaker 

func (x *TTSVoiceListResponse) GetDefaultSpeaker() string

func (*TTSVoiceListResponse) GetLastRefresh 

func (x *TTSVoiceListResponse) GetLastRefresh() int64

func (*TTSVoiceListResponse) GetTimestamp 

func (x *TTSVoiceListResponse) GetTimestamp() int64

func (*TTSVoiceListResponse) ProtoMessage 

func (*TTSVoiceListResponse) ProtoMessage()

func (*TTSVoiceListResponse) ProtoReflect 

func (x *TTSVoiceListResponse) ProtoReflect() protoreflect.Message

func (*TTSVoiceListResponse) Reset 

func (x *TTSVoiceListResponse) Reset()

func (*TTSVoiceListResponse) String 

func (x *TTSVoiceListResponse) String() string

type TTSVoiceRefreshResponse 

type TTSVoiceRefreshResponse struct {
	Count        int32           `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	CustomVoices []*TTSVoiceInfo `protobuf:"bytes,2,rep,name=custom_voices,json=customVoices,proto3" json:"custom_voices,omitempty"`
	Timestamp    int64           `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

TTSVoiceRefreshResponse is the reply to a voice refresh request. Subject: ai.voice.tts.voices.refresh (request-reply)

func (*TTSVoiceRefreshResponse) Descriptor deprecated 

func (*TTSVoiceRefreshResponse) Descriptor() ([]byte, []int)

Deprecated: Use TTSVoiceRefreshResponse.ProtoReflect.Descriptor instead.

func (*TTSVoiceRefreshResponse) GetCount 

func (x *TTSVoiceRefreshResponse) GetCount() int32

func (*TTSVoiceRefreshResponse) GetCustomVoices 

func (x *TTSVoiceRefreshResponse) GetCustomVoices() []*TTSVoiceInfo

func (*TTSVoiceRefreshResponse) GetTimestamp 

func (x *TTSVoiceRefreshResponse) GetTimestamp() int64

func (*TTSVoiceRefreshResponse) ProtoMessage 

func (*TTSVoiceRefreshResponse) ProtoMessage()

func (*TTSVoiceRefreshResponse) ProtoReflect 

func (x *TTSVoiceRefreshResponse) ProtoReflect() protoreflect.Message

func (*TTSVoiceRefreshResponse) Reset 

func (x *TTSVoiceRefreshResponse) Reset()

func (*TTSVoiceRefreshResponse) String 

func (x *TTSVoiceRefreshResponse) String() string

type VoiceRequest 

type VoiceRequest struct {
	RequestId  string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Audio      []byte `protobuf:"bytes,2,opt,name=audio,proto3" json:"audio,omitempty"`
	Language   string `protobuf:"bytes,3,opt,name=language,proto3" json:"language,omitempty"`
	Collection string `protobuf:"bytes,4,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

VoiceRequest is an incoming voice-to-voice request. Subject: ai.voice.request

func (*VoiceRequest) Descriptor deprecated 

func (*VoiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use VoiceRequest.ProtoReflect.Descriptor instead.

func (*VoiceRequest) GetAudio 

func (x *VoiceRequest) GetAudio() []byte

func (*VoiceRequest) GetCollection 

func (x *VoiceRequest) GetCollection() string

func (*VoiceRequest) GetLanguage 

func (x *VoiceRequest) GetLanguage() string

func (*VoiceRequest) GetRequestId 

func (x *VoiceRequest) GetRequestId() string

func (*VoiceRequest) ProtoMessage 

func (*VoiceRequest) ProtoMessage()

func (*VoiceRequest) ProtoReflect 

func (x *VoiceRequest) ProtoReflect() protoreflect.Message

func (*VoiceRequest) Reset 

func (x *VoiceRequest) Reset()

func (*VoiceRequest) String 

func (x *VoiceRequest) String() string

type VoiceResponse 

type VoiceResponse struct {
	RequestId     string            `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Response      string            `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	Audio         []byte            `protobuf:"bytes,3,opt,name=audio,proto3" json:"audio,omitempty"`
	Transcription string            `protobuf:"bytes,4,opt,name=transcription,proto3" json:"transcription,omitempty"`
	Sources       []*DocumentSource `protobuf:"bytes,5,rep,name=sources,proto3" json:"sources,omitempty"`
	Error         string            `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

VoiceResponse is the reply to a VoiceRequest. Subject: ai.voice.response.{request_id}

func (*VoiceResponse) Descriptor deprecated 

func (*VoiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use VoiceResponse.ProtoReflect.Descriptor instead.

func (*VoiceResponse) GetAudio 

func (x *VoiceResponse) GetAudio() []byte

func (*VoiceResponse) GetError 

func (x *VoiceResponse) GetError() string

func (*VoiceResponse) GetRequestId 

func (x *VoiceResponse) GetRequestId() string

func (*VoiceResponse) GetResponse 

func (x *VoiceResponse) GetResponse() string

func (*VoiceResponse) GetSources 

func (x *VoiceResponse) GetSources() []*DocumentSource

func (*VoiceResponse) GetTranscription 

func (x *VoiceResponse) GetTranscription() string

func (*VoiceResponse) ProtoMessage 

func (*VoiceResponse) ProtoMessage()

func (*VoiceResponse) ProtoReflect 

func (x *VoiceResponse) ProtoReflect() protoreflect.Message

func (*VoiceResponse) Reset 

func (x *VoiceResponse) Reset()

func (*VoiceResponse) String 

func (x *VoiceResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.