package agent
import (
_ "github.com/livekit/protocol/livekit/logger"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
structpb "google.golang.org/protobuf/types/known/structpb"
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type ChatRole int32
const (
ChatRole_DEVELOPER ChatRole = 0
ChatRole_SYSTEM ChatRole = 1
ChatRole_USER ChatRole = 2
ChatRole_ASSISTANT ChatRole = 3
)
var (
ChatRole_name = map[int32]string{
0: "DEVELOPER",
1: "SYSTEM",
2: "USER",
3: "ASSISTANT",
}
ChatRole_value = map[string]int32{
"DEVELOPER": 0,
"SYSTEM": 1,
"USER": 2,
"ASSISTANT": 3,
}
)
func (x ChatRole) Enum() *ChatRole {
p := new(ChatRole)
*p = x
return p
}
func (x ChatRole) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (ChatRole) Descriptor() protoreflect.EnumDescriptor {
return file_agent_livekit_agent_session_proto_enumTypes[0].Descriptor()
}
func (ChatRole) Type() protoreflect.EnumType {
return &file_agent_livekit_agent_session_proto_enumTypes[0]
}
func (x ChatRole) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
func (ChatRole) EnumDescriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{0}
}
type AgentState int32
const (
AgentState_AS_INITIALIZING AgentState = 0
AgentState_AS_IDLE AgentState = 1
AgentState_AS_LISTENING AgentState = 2
AgentState_AS_THINKING AgentState = 3
AgentState_AS_SPEAKING AgentState = 4
)
var (
AgentState_name = map[int32]string{
0: "AS_INITIALIZING",
1: "AS_IDLE",
2: "AS_LISTENING",
3: "AS_THINKING",
4: "AS_SPEAKING",
}
AgentState_value = map[string]int32{
"AS_INITIALIZING": 0,
"AS_IDLE": 1,
"AS_LISTENING": 2,
"AS_THINKING": 3,
"AS_SPEAKING": 4,
}
)
func (x AgentState) Enum() *AgentState {
p := new(AgentState)
*p = x
return p
}
func (x AgentState) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (AgentState) Descriptor() protoreflect.EnumDescriptor {
return file_agent_livekit_agent_session_proto_enumTypes[1].Descriptor()
}
func (AgentState) Type() protoreflect.EnumType {
return &file_agent_livekit_agent_session_proto_enumTypes[1]
}
func (x AgentState) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
func (AgentState) EnumDescriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{1}
}
type UserState int32
const (
UserState_US_SPEAKING UserState = 0
UserState_US_LISTENING UserState = 1
UserState_US_AWAY UserState = 2
)
var (
UserState_name = map[int32]string{
0: "US_SPEAKING",
1: "US_LISTENING",
2: "US_AWAY",
}
UserState_value = map[string]int32{
"US_SPEAKING": 0,
"US_LISTENING": 1,
"US_AWAY": 2,
}
)
func (x UserState) Enum() *UserState {
p := new(UserState)
*p = x
return p
}
func (x UserState) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (UserState) Descriptor() protoreflect.EnumDescriptor {
return file_agent_livekit_agent_session_proto_enumTypes[2].Descriptor()
}
func (UserState) Type() protoreflect.EnumType {
return &file_agent_livekit_agent_session_proto_enumTypes[2]
}
func (x UserState) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
func (UserState) EnumDescriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{2}
}
type MetricsReport struct {
state protoimpl.MessageState `protogen:"open.v1"`
StartedSpeakingAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=started_speaking_at,json=startedSpeakingAt,proto3" json:"started_speaking_at,omitempty"`
StoppedSpeakingAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=stopped_speaking_at,json=stoppedSpeakingAt,proto3" json:"stopped_speaking_at,omitempty"`
TranscriptionDelay *float64 `protobuf:"fixed64,3,opt,name=transcription_delay,json=transcriptionDelay,proto3,oneof" json:"transcription_delay,omitempty"`
EndOfTurnDelay *float64 `protobuf:"fixed64,4,opt,name=end_of_turn_delay,json=endOfTurnDelay,proto3,oneof" json:"end_of_turn_delay,omitempty"`
OnUserTurnCompletedDelay *float64 `protobuf:"fixed64,5,opt,name=on_user_turn_completed_delay,json=onUserTurnCompletedDelay,proto3,oneof" json:"on_user_turn_completed_delay,omitempty"`
LlmNodeTtft *float64 `protobuf:"fixed64,6,opt,name=llm_node_ttft,json=llmNodeTtft,proto3,oneof" json:"llm_node_ttft,omitempty"`
TtsNodeTtfb *float64 `protobuf:"fixed64,7,opt,name=tts_node_ttfb,json=ttsNodeTtfb,proto3,oneof" json:"tts_node_ttfb,omitempty"`
E2ELatency *float64 `protobuf:"fixed64,8,opt,name=e2e_latency,json=e2eLatency,proto3,oneof" json:"e2e_latency,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *MetricsReport) Reset() {
*x = MetricsReport{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *MetricsReport) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*MetricsReport) ProtoMessage() {}
func (x *MetricsReport) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*MetricsReport) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{0}
}
func (x *MetricsReport) GetStartedSpeakingAt() *timestamppb.Timestamp {
if x != nil {
return x.StartedSpeakingAt
}
return nil
}
func (x *MetricsReport) GetStoppedSpeakingAt() *timestamppb.Timestamp {
if x != nil {
return x.StoppedSpeakingAt
}
return nil
}
func (x *MetricsReport) GetTranscriptionDelay() float64 {
if x != nil && x.TranscriptionDelay != nil {
return *x.TranscriptionDelay
}
return 0
}
func (x *MetricsReport) GetEndOfTurnDelay() float64 {
if x != nil && x.EndOfTurnDelay != nil {
return *x.EndOfTurnDelay
}
return 0
}
func (x *MetricsReport) GetOnUserTurnCompletedDelay() float64 {
if x != nil && x.OnUserTurnCompletedDelay != nil {
return *x.OnUserTurnCompletedDelay
}
return 0
}
func (x *MetricsReport) GetLlmNodeTtft() float64 {
if x != nil && x.LlmNodeTtft != nil {
return *x.LlmNodeTtft
}
return 0
}
func (x *MetricsReport) GetTtsNodeTtfb() float64 {
if x != nil && x.TtsNodeTtfb != nil {
return *x.TtsNodeTtfb
}
return 0
}
func (x *MetricsReport) GetE2ELatency() float64 {
if x != nil && x.E2ELatency != nil {
return *x.E2ELatency
}
return 0
}
type ChatMessage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Role ChatRole `protobuf:"varint,2,opt,name=role,proto3,enum=livekit.agent.ChatRole" json:"role,omitempty"`
Content []*ChatMessage_ChatContent `protobuf:"bytes,3,rep,name=content,proto3" json:"content,omitempty"`
Interrupted bool `protobuf:"varint,4,opt,name=interrupted,proto3" json:"interrupted,omitempty"`
TranscriptConfidence *float64 `protobuf:"fixed64,5,opt,name=transcript_confidence,json=transcriptConfidence,proto3,oneof" json:"transcript_confidence,omitempty"`
Extra map[string]string `protobuf:"bytes,6,rep,name=extra,proto3" json:"extra,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
Metrics *MetricsReport `protobuf:"bytes,7,opt,name=metrics,proto3" json:"metrics,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ChatMessage) Reset() {
*x = ChatMessage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ChatMessage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ChatMessage) ProtoMessage() {}
func (x *ChatMessage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*ChatMessage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{1}
}
func (x *ChatMessage) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *ChatMessage) GetRole() ChatRole {
if x != nil {
return x.Role
}
return ChatRole_DEVELOPER
}
func (x *ChatMessage) GetContent() []*ChatMessage_ChatContent {
if x != nil {
return x.Content
}
return nil
}
func (x *ChatMessage) GetInterrupted() bool {
if x != nil {
return x.Interrupted
}
return false
}
func (x *ChatMessage) GetTranscriptConfidence() float64 {
if x != nil && x.TranscriptConfidence != nil {
return *x.TranscriptConfidence
}
return 0
}
func (x *ChatMessage) GetExtra() map[string]string {
if x != nil {
return x.Extra
}
return nil
}
func (x *ChatMessage) GetMetrics() *MetricsReport {
if x != nil {
return x.Metrics
}
return nil
}
func (x *ChatMessage) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
type FunctionCall struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
CallId string `protobuf:"bytes,2,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
Arguments string `protobuf:"bytes,3,opt,name=arguments,proto3" json:"arguments,omitempty"`
Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *FunctionCall) Reset() {
*x = FunctionCall{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *FunctionCall) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*FunctionCall) ProtoMessage() {}
func (x *FunctionCall) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*FunctionCall) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{2}
}
func (x *FunctionCall) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *FunctionCall) GetCallId() string {
if x != nil {
return x.CallId
}
return ""
}
func (x *FunctionCall) GetArguments() string {
if x != nil {
return x.Arguments
}
return ""
}
func (x *FunctionCall) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *FunctionCall) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
type FunctionCallOutput struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
CallId string `protobuf:"bytes,3,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
Output string `protobuf:"bytes,4,opt,name=output,proto3" json:"output,omitempty"`
IsError bool `protobuf:"varint,5,opt,name=is_error,json=isError,proto3" json:"is_error,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *FunctionCallOutput) Reset() {
*x = FunctionCallOutput{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *FunctionCallOutput) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*FunctionCallOutput) ProtoMessage() {}
func (x *FunctionCallOutput) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*FunctionCallOutput) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{3}
}
func (x *FunctionCallOutput) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *FunctionCallOutput) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *FunctionCallOutput) GetCallId() string {
if x != nil {
return x.CallId
}
return ""
}
func (x *FunctionCallOutput) GetOutput() string {
if x != nil {
return x.Output
}
return ""
}
func (x *FunctionCallOutput) GetIsError() bool {
if x != nil {
return x.IsError
}
return false
}
func (x *FunctionCallOutput) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
type AgentHandoff struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
OldAgentId *string `protobuf:"bytes,2,opt,name=old_agent_id,json=oldAgentId,proto3,oneof" json:"old_agent_id,omitempty"`
NewAgentId string `protobuf:"bytes,3,opt,name=new_agent_id,json=newAgentId,proto3" json:"new_agent_id,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentHandoff) Reset() {
*x = AgentHandoff{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentHandoff) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentHandoff) ProtoMessage() {}
func (x *AgentHandoff) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentHandoff) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{4}
}
func (x *AgentHandoff) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *AgentHandoff) GetOldAgentId() string {
if x != nil && x.OldAgentId != nil {
return *x.OldAgentId
}
return ""
}
func (x *AgentHandoff) GetNewAgentId() string {
if x != nil {
return x.NewAgentId
}
return ""
}
func (x *AgentHandoff) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
type AgentConfigUpdate struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Instructions *string `protobuf:"bytes,2,opt,name=instructions,proto3,oneof" json:"instructions,omitempty"`
ToolsAdded []string `protobuf:"bytes,3,rep,name=tools_added,json=toolsAdded,proto3" json:"tools_added,omitempty"`
ToolsRemoved []string `protobuf:"bytes,4,rep,name=tools_removed,json=toolsRemoved,proto3" json:"tools_removed,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentConfigUpdate) Reset() {
*x = AgentConfigUpdate{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentConfigUpdate) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentConfigUpdate) ProtoMessage() {}
func (x *AgentConfigUpdate) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[5]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentConfigUpdate) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{5}
}
func (x *AgentConfigUpdate) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *AgentConfigUpdate) GetInstructions() string {
if x != nil && x.Instructions != nil {
return *x.Instructions
}
return ""
}
func (x *AgentConfigUpdate) GetToolsAdded() []string {
if x != nil {
return x.ToolsAdded
}
return nil
}
func (x *AgentConfigUpdate) GetToolsRemoved() []string {
if x != nil {
return x.ToolsRemoved
}
return nil
}
func (x *AgentConfigUpdate) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
type ChatContext struct {
state protoimpl.MessageState `protogen:"open.v1"`
Items []*ChatContext_ChatItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ChatContext) Reset() {
*x = ChatContext{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ChatContext) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ChatContext) ProtoMessage() {}
func (x *ChatContext) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[6]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*ChatContext) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{6}
}
func (x *ChatContext) GetItems() []*ChatContext_ChatItem {
if x != nil {
return x.Items
}
return nil
}
type LLMModelUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
InputTokens int32 `protobuf:"varint,3,opt,name=input_tokens,json=inputTokens,proto3" json:"input_tokens,omitempty"`
InputCachedTokens int32 `protobuf:"varint,4,opt,name=input_cached_tokens,json=inputCachedTokens,proto3" json:"input_cached_tokens,omitempty"`
InputAudioTokens int32 `protobuf:"varint,5,opt,name=input_audio_tokens,json=inputAudioTokens,proto3" json:"input_audio_tokens,omitempty"`
InputCachedAudioTokens int32 `protobuf:"varint,6,opt,name=input_cached_audio_tokens,json=inputCachedAudioTokens,proto3" json:"input_cached_audio_tokens,omitempty"`
InputTextTokens int32 `protobuf:"varint,7,opt,name=input_text_tokens,json=inputTextTokens,proto3" json:"input_text_tokens,omitempty"`
InputCachedTextTokens int32 `protobuf:"varint,8,opt,name=input_cached_text_tokens,json=inputCachedTextTokens,proto3" json:"input_cached_text_tokens,omitempty"`
InputImageTokens int32 `protobuf:"varint,9,opt,name=input_image_tokens,json=inputImageTokens,proto3" json:"input_image_tokens,omitempty"`
InputCachedImageTokens int32 `protobuf:"varint,10,opt,name=input_cached_image_tokens,json=inputCachedImageTokens,proto3" json:"input_cached_image_tokens,omitempty"`
OutputTokens int32 `protobuf:"varint,11,opt,name=output_tokens,json=outputTokens,proto3" json:"output_tokens,omitempty"`
OutputAudioTokens int32 `protobuf:"varint,12,opt,name=output_audio_tokens,json=outputAudioTokens,proto3" json:"output_audio_tokens,omitempty"`
OutputTextTokens int32 `protobuf:"varint,13,opt,name=output_text_tokens,json=outputTextTokens,proto3" json:"output_text_tokens,omitempty"`
SessionDuration float64 `protobuf:"fixed64,14,opt,name=session_duration,json=sessionDuration,proto3" json:"session_duration,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *LLMModelUsage) Reset() {
*x = LLMModelUsage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *LLMModelUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*LLMModelUsage) ProtoMessage() {}
func (x *LLMModelUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[7]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*LLMModelUsage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{7}
}
func (x *LLMModelUsage) GetProvider() string {
if x != nil {
return x.Provider
}
return ""
}
func (x *LLMModelUsage) GetModel() string {
if x != nil {
return x.Model
}
return ""
}
func (x *LLMModelUsage) GetInputTokens() int32 {
if x != nil {
return x.InputTokens
}
return 0
}
func (x *LLMModelUsage) GetInputCachedTokens() int32 {
if x != nil {
return x.InputCachedTokens
}
return 0
}
func (x *LLMModelUsage) GetInputAudioTokens() int32 {
if x != nil {
return x.InputAudioTokens
}
return 0
}
func (x *LLMModelUsage) GetInputCachedAudioTokens() int32 {
if x != nil {
return x.InputCachedAudioTokens
}
return 0
}
func (x *LLMModelUsage) GetInputTextTokens() int32 {
if x != nil {
return x.InputTextTokens
}
return 0
}
func (x *LLMModelUsage) GetInputCachedTextTokens() int32 {
if x != nil {
return x.InputCachedTextTokens
}
return 0
}
func (x *LLMModelUsage) GetInputImageTokens() int32 {
if x != nil {
return x.InputImageTokens
}
return 0
}
func (x *LLMModelUsage) GetInputCachedImageTokens() int32 {
if x != nil {
return x.InputCachedImageTokens
}
return 0
}
func (x *LLMModelUsage) GetOutputTokens() int32 {
if x != nil {
return x.OutputTokens
}
return 0
}
func (x *LLMModelUsage) GetOutputAudioTokens() int32 {
if x != nil {
return x.OutputAudioTokens
}
return 0
}
func (x *LLMModelUsage) GetOutputTextTokens() int32 {
if x != nil {
return x.OutputTextTokens
}
return 0
}
func (x *LLMModelUsage) GetSessionDuration() float64 {
if x != nil {
return x.SessionDuration
}
return 0
}
type TTSModelUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
InputTokens int32 `protobuf:"varint,3,opt,name=input_tokens,json=inputTokens,proto3" json:"input_tokens,omitempty"`
OutputTokens int32 `protobuf:"varint,4,opt,name=output_tokens,json=outputTokens,proto3" json:"output_tokens,omitempty"`
CharactersCount int32 `protobuf:"varint,5,opt,name=characters_count,json=charactersCount,proto3" json:"characters_count,omitempty"`
AudioDuration float64 `protobuf:"fixed64,6,opt,name=audio_duration,json=audioDuration,proto3" json:"audio_duration,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TTSModelUsage) Reset() {
*x = TTSModelUsage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TTSModelUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TTSModelUsage) ProtoMessage() {}
func (x *TTSModelUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[8]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*TTSModelUsage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{8}
}
func (x *TTSModelUsage) GetProvider() string {
if x != nil {
return x.Provider
}
return ""
}
func (x *TTSModelUsage) GetModel() string {
if x != nil {
return x.Model
}
return ""
}
func (x *TTSModelUsage) GetInputTokens() int32 {
if x != nil {
return x.InputTokens
}
return 0
}
func (x *TTSModelUsage) GetOutputTokens() int32 {
if x != nil {
return x.OutputTokens
}
return 0
}
func (x *TTSModelUsage) GetCharactersCount() int32 {
if x != nil {
return x.CharactersCount
}
return 0
}
func (x *TTSModelUsage) GetAudioDuration() float64 {
if x != nil {
return x.AudioDuration
}
return 0
}
type STTModelUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
InputTokens int32 `protobuf:"varint,3,opt,name=input_tokens,json=inputTokens,proto3" json:"input_tokens,omitempty"`
OutputTokens int32 `protobuf:"varint,4,opt,name=output_tokens,json=outputTokens,proto3" json:"output_tokens,omitempty"`
AudioDuration float64 `protobuf:"fixed64,5,opt,name=audio_duration,json=audioDuration,proto3" json:"audio_duration,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *STTModelUsage) Reset() {
*x = STTModelUsage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *STTModelUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*STTModelUsage) ProtoMessage() {}
func (x *STTModelUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[9]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*STTModelUsage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{9}
}
func (x *STTModelUsage) GetProvider() string {
if x != nil {
return x.Provider
}
return ""
}
func (x *STTModelUsage) GetModel() string {
if x != nil {
return x.Model
}
return ""
}
func (x *STTModelUsage) GetInputTokens() int32 {
if x != nil {
return x.InputTokens
}
return 0
}
func (x *STTModelUsage) GetOutputTokens() int32 {
if x != nil {
return x.OutputTokens
}
return 0
}
func (x *STTModelUsage) GetAudioDuration() float64 {
if x != nil {
return x.AudioDuration
}
return 0
}
type InterruptionModelUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
TotalRequests int32 `protobuf:"varint,3,opt,name=total_requests,json=totalRequests,proto3" json:"total_requests,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *InterruptionModelUsage) Reset() {
*x = InterruptionModelUsage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *InterruptionModelUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*InterruptionModelUsage) ProtoMessage() {}
func (x *InterruptionModelUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[10]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*InterruptionModelUsage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{10}
}
func (x *InterruptionModelUsage) GetProvider() string {
if x != nil {
return x.Provider
}
return ""
}
func (x *InterruptionModelUsage) GetModel() string {
if x != nil {
return x.Model
}
return ""
}
func (x *InterruptionModelUsage) GetTotalRequests() int32 {
if x != nil {
return x.TotalRequests
}
return 0
}
type ModelUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Usage isModelUsage_Usage `protobuf_oneof:"usage"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ModelUsage) Reset() {
*x = ModelUsage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ModelUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ModelUsage) ProtoMessage() {}
func (x *ModelUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[11]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*ModelUsage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{11}
}
func (x *ModelUsage) GetUsage() isModelUsage_Usage {
if x != nil {
return x.Usage
}
return nil
}
func (x *ModelUsage) GetLlm() *LLMModelUsage {
if x != nil {
if x, ok := x.Usage.(*ModelUsage_Llm); ok {
return x.Llm
}
}
return nil
}
func (x *ModelUsage) GetTts() *TTSModelUsage {
if x != nil {
if x, ok := x.Usage.(*ModelUsage_Tts); ok {
return x.Tts
}
}
return nil
}
func (x *ModelUsage) GetStt() *STTModelUsage {
if x != nil {
if x, ok := x.Usage.(*ModelUsage_Stt); ok {
return x.Stt
}
}
return nil
}
func (x *ModelUsage) GetInterruption() *InterruptionModelUsage {
if x != nil {
if x, ok := x.Usage.(*ModelUsage_Interruption); ok {
return x.Interruption
}
}
return nil
}
type isModelUsage_Usage interface {
isModelUsage_Usage()
}
type ModelUsage_Llm struct {
Llm *LLMModelUsage `protobuf:"bytes,1,opt,name=llm,proto3,oneof"`
}
type ModelUsage_Tts struct {
Tts *TTSModelUsage `protobuf:"bytes,2,opt,name=tts,proto3,oneof"`
}
type ModelUsage_Stt struct {
Stt *STTModelUsage `protobuf:"bytes,3,opt,name=stt,proto3,oneof"`
}
type ModelUsage_Interruption struct {
Interruption *InterruptionModelUsage `protobuf:"bytes,4,opt,name=interruption,proto3,oneof"`
}
func (*ModelUsage_Llm) isModelUsage_Usage() {}
func (*ModelUsage_Tts) isModelUsage_Usage() {}
func (*ModelUsage_Stt) isModelUsage_Usage() {}
func (*ModelUsage_Interruption) isModelUsage_Usage() {}
type AgentSessionUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
ModelUsage []*ModelUsage `protobuf:"bytes,1,rep,name=model_usage,json=modelUsage,proto3" json:"model_usage,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionUsage) Reset() {
*x = AgentSessionUsage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionUsage) ProtoMessage() {}
func (x *AgentSessionUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[12]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionUsage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{12}
}
func (x *AgentSessionUsage) GetModelUsage() []*ModelUsage {
if x != nil {
return x.ModelUsage
}
return nil
}
type AgentSessionEvent struct {
state protoimpl.MessageState `protogen:"open.v1"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
Event isAgentSessionEvent_Event `protobuf_oneof:"event"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent) Reset() {
*x = AgentSessionEvent{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent) ProtoMessage() {}
func (x *AgentSessionEvent) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[13]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13}
}
func (x *AgentSessionEvent) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
func (x *AgentSessionEvent) GetEvent() isAgentSessionEvent_Event {
if x != nil {
return x.Event
}
return nil
}
func (x *AgentSessionEvent) GetAgentStateChanged() *AgentSessionEvent_AgentStateChanged {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_AgentStateChanged_); ok {
return x.AgentStateChanged
}
}
return nil
}
func (x *AgentSessionEvent) GetUserStateChanged() *AgentSessionEvent_UserStateChanged {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_UserStateChanged_); ok {
return x.UserStateChanged
}
}
return nil
}
func (x *AgentSessionEvent) GetConversationItemAdded() *AgentSessionEvent_ConversationItemAdded {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_ConversationItemAdded_); ok {
return x.ConversationItemAdded
}
}
return nil
}
func (x *AgentSessionEvent) GetUserInputTranscribed() *AgentSessionEvent_UserInputTranscribed {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_UserInputTranscribed_); ok {
return x.UserInputTranscribed
}
}
return nil
}
func (x *AgentSessionEvent) GetFunctionToolsExecuted() *AgentSessionEvent_FunctionToolsExecuted {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_FunctionToolsExecuted_); ok {
return x.FunctionToolsExecuted
}
}
return nil
}
func (x *AgentSessionEvent) GetError() *AgentSessionEvent_Error {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_Error_); ok {
return x.Error
}
}
return nil
}
func (x *AgentSessionEvent) GetOverlappingSpeech() *AgentSessionEvent_OverlappingSpeech {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_OverlappingSpeech_); ok {
return x.OverlappingSpeech
}
}
return nil
}
func (x *AgentSessionEvent) GetSessionUsageUpdated() *AgentSessionEvent_SessionUsageUpdated {
if x != nil {
if x, ok := x.Event.(*AgentSessionEvent_SessionUsageUpdated_); ok {
return x.SessionUsageUpdated
}
}
return nil
}
type isAgentSessionEvent_Event interface {
isAgentSessionEvent_Event()
}
type AgentSessionEvent_AgentStateChanged_ struct {
AgentStateChanged *AgentSessionEvent_AgentStateChanged `protobuf:"bytes,10,opt,name=agent_state_changed,json=agentStateChanged,proto3,oneof"`
}
type AgentSessionEvent_UserStateChanged_ struct {
UserStateChanged *AgentSessionEvent_UserStateChanged `protobuf:"bytes,11,opt,name=user_state_changed,json=userStateChanged,proto3,oneof"`
}
type AgentSessionEvent_ConversationItemAdded_ struct {
ConversationItemAdded *AgentSessionEvent_ConversationItemAdded `protobuf:"bytes,12,opt,name=conversation_item_added,json=conversationItemAdded,proto3,oneof"`
}
type AgentSessionEvent_UserInputTranscribed_ struct {
UserInputTranscribed *AgentSessionEvent_UserInputTranscribed `protobuf:"bytes,13,opt,name=user_input_transcribed,json=userInputTranscribed,proto3,oneof"`
}
type AgentSessionEvent_FunctionToolsExecuted_ struct {
FunctionToolsExecuted *AgentSessionEvent_FunctionToolsExecuted `protobuf:"bytes,14,opt,name=function_tools_executed,json=functionToolsExecuted,proto3,oneof"`
}
type AgentSessionEvent_Error_ struct {
Error *AgentSessionEvent_Error `protobuf:"bytes,15,opt,name=error,proto3,oneof"`
}
type AgentSessionEvent_OverlappingSpeech_ struct {
OverlappingSpeech *AgentSessionEvent_OverlappingSpeech `protobuf:"bytes,16,opt,name=overlapping_speech,json=overlappingSpeech,proto3,oneof"`
}
type AgentSessionEvent_SessionUsageUpdated_ struct {
SessionUsageUpdated *AgentSessionEvent_SessionUsageUpdated `protobuf:"bytes,17,opt,name=session_usage_updated,json=sessionUsageUpdated,proto3,oneof"`
}
func (*AgentSessionEvent_AgentStateChanged_) isAgentSessionEvent_Event() {}
func (*AgentSessionEvent_UserStateChanged_) isAgentSessionEvent_Event() {}
func (*AgentSessionEvent_ConversationItemAdded_) isAgentSessionEvent_Event() {}
func (*AgentSessionEvent_UserInputTranscribed_) isAgentSessionEvent_Event() {}
func (*AgentSessionEvent_FunctionToolsExecuted_) isAgentSessionEvent_Event() {}
func (*AgentSessionEvent_Error_) isAgentSessionEvent_Event() {}
func (*AgentSessionEvent_OverlappingSpeech_) isAgentSessionEvent_Event() {}
func (*AgentSessionEvent_SessionUsageUpdated_) isAgentSessionEvent_Event() {}
type SessionRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
Request isSessionRequest_Request `protobuf_oneof:"request"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest) Reset() {
*x = SessionRequest{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest) ProtoMessage() {}
func (x *SessionRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[14]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14}
}
func (x *SessionRequest) GetRequestId() string {
if x != nil {
return x.RequestId
}
return ""
}
func (x *SessionRequest) GetRequest() isSessionRequest_Request {
if x != nil {
return x.Request
}
return nil
}
func (x *SessionRequest) GetPing() *SessionRequest_Ping {
if x != nil {
if x, ok := x.Request.(*SessionRequest_Ping_); ok {
return x.Ping
}
}
return nil
}
func (x *SessionRequest) GetGetChatHistory() *SessionRequest_GetChatHistory {
if x != nil {
if x, ok := x.Request.(*SessionRequest_GetChatHistory_); ok {
return x.GetChatHistory
}
}
return nil
}
func (x *SessionRequest) GetRunInput() *SessionRequest_RunInput {
if x != nil {
if x, ok := x.Request.(*SessionRequest_RunInput_); ok {
return x.RunInput
}
}
return nil
}
func (x *SessionRequest) GetGetAgentInfo() *SessionRequest_GetAgentInfo {
if x != nil {
if x, ok := x.Request.(*SessionRequest_GetAgentInfo_); ok {
return x.GetAgentInfo
}
}
return nil
}
func (x *SessionRequest) GetGetSessionState() *SessionRequest_GetSessionState {
if x != nil {
if x, ok := x.Request.(*SessionRequest_GetSessionState_); ok {
return x.GetSessionState
}
}
return nil
}
func (x *SessionRequest) GetGetRtcStats() *SessionRequest_GetRTCStats {
if x != nil {
if x, ok := x.Request.(*SessionRequest_GetRtcStats); ok {
return x.GetRtcStats
}
}
return nil
}
func (x *SessionRequest) GetGetSessionUsage() *SessionRequest_GetSessionUsage {
if x != nil {
if x, ok := x.Request.(*SessionRequest_GetSessionUsage_); ok {
return x.GetSessionUsage
}
}
return nil
}
type isSessionRequest_Request interface {
isSessionRequest_Request()
}
type SessionRequest_Ping_ struct {
Ping *SessionRequest_Ping `protobuf:"bytes,2,opt,name=ping,proto3,oneof"`
}
type SessionRequest_GetChatHistory_ struct {
GetChatHistory *SessionRequest_GetChatHistory `protobuf:"bytes,4,opt,name=get_chat_history,json=getChatHistory,proto3,oneof"`
}
type SessionRequest_RunInput_ struct {
RunInput *SessionRequest_RunInput `protobuf:"bytes,5,opt,name=run_input,json=runInput,proto3,oneof"`
}
type SessionRequest_GetAgentInfo_ struct {
GetAgentInfo *SessionRequest_GetAgentInfo `protobuf:"bytes,6,opt,name=get_agent_info,json=getAgentInfo,proto3,oneof"`
}
type SessionRequest_GetSessionState_ struct {
GetSessionState *SessionRequest_GetSessionState `protobuf:"bytes,7,opt,name=get_session_state,json=getSessionState,proto3,oneof"`
}
type SessionRequest_GetRtcStats struct {
GetRtcStats *SessionRequest_GetRTCStats `protobuf:"bytes,8,opt,name=get_rtc_stats,json=getRtcStats,proto3,oneof"`
}
type SessionRequest_GetSessionUsage_ struct {
GetSessionUsage *SessionRequest_GetSessionUsage `protobuf:"bytes,9,opt,name=get_session_usage,json=getSessionUsage,proto3,oneof"`
}
func (*SessionRequest_Ping_) isSessionRequest_Request() {}
func (*SessionRequest_GetChatHistory_) isSessionRequest_Request() {}
func (*SessionRequest_RunInput_) isSessionRequest_Request() {}
func (*SessionRequest_GetAgentInfo_) isSessionRequest_Request() {}
func (*SessionRequest_GetSessionState_) isSessionRequest_Request() {}
func (*SessionRequest_GetRtcStats) isSessionRequest_Request() {}
func (*SessionRequest_GetSessionUsage_) isSessionRequest_Request() {}
type SessionResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
Error *string `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
Response isSessionResponse_Response `protobuf_oneof:"response"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse) Reset() {
*x = SessionResponse{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse) ProtoMessage() {}
func (x *SessionResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[15]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15}
}
func (x *SessionResponse) GetRequestId() string {
if x != nil {
return x.RequestId
}
return ""
}
func (x *SessionResponse) GetError() string {
if x != nil && x.Error != nil {
return *x.Error
}
return ""
}
func (x *SessionResponse) GetResponse() isSessionResponse_Response {
if x != nil {
return x.Response
}
return nil
}
func (x *SessionResponse) GetPong() *SessionResponse_Pong {
if x != nil {
if x, ok := x.Response.(*SessionResponse_Pong_); ok {
return x.Pong
}
}
return nil
}
func (x *SessionResponse) GetGetChatHistory() *SessionResponse_GetChatHistoryResponse {
if x != nil {
if x, ok := x.Response.(*SessionResponse_GetChatHistory); ok {
return x.GetChatHistory
}
}
return nil
}
func (x *SessionResponse) GetRunInput() *SessionResponse_RunInputResponse {
if x != nil {
if x, ok := x.Response.(*SessionResponse_RunInput); ok {
return x.RunInput
}
}
return nil
}
func (x *SessionResponse) GetGetAgentInfo() *SessionResponse_GetAgentInfoResponse {
if x != nil {
if x, ok := x.Response.(*SessionResponse_GetAgentInfo); ok {
return x.GetAgentInfo
}
}
return nil
}
func (x *SessionResponse) GetGetSessionState() *SessionResponse_GetSessionStateResponse {
if x != nil {
if x, ok := x.Response.(*SessionResponse_GetSessionState); ok {
return x.GetSessionState
}
}
return nil
}
func (x *SessionResponse) GetGetRtcStats() *SessionResponse_GetRTCStatsResponse {
if x != nil {
if x, ok := x.Response.(*SessionResponse_GetRtcStats); ok {
return x.GetRtcStats
}
}
return nil
}
func (x *SessionResponse) GetGetSessionUsage() *SessionResponse_GetSessionUsageResponse {
if x != nil {
if x, ok := x.Response.(*SessionResponse_GetSessionUsage); ok {
return x.GetSessionUsage
}
}
return nil
}
type isSessionResponse_Response interface {
isSessionResponse_Response()
}
type SessionResponse_Pong_ struct {
Pong *SessionResponse_Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}
type SessionResponse_GetChatHistory struct {
GetChatHistory *SessionResponse_GetChatHistoryResponse `protobuf:"bytes,5,opt,name=get_chat_history,json=getChatHistory,proto3,oneof"`
}
type SessionResponse_RunInput struct {
RunInput *SessionResponse_RunInputResponse `protobuf:"bytes,6,opt,name=run_input,json=runInput,proto3,oneof"`
}
type SessionResponse_GetAgentInfo struct {
GetAgentInfo *SessionResponse_GetAgentInfoResponse `protobuf:"bytes,7,opt,name=get_agent_info,json=getAgentInfo,proto3,oneof"`
}
type SessionResponse_GetSessionState struct {
GetSessionState *SessionResponse_GetSessionStateResponse `protobuf:"bytes,8,opt,name=get_session_state,json=getSessionState,proto3,oneof"`
}
type SessionResponse_GetRtcStats struct {
GetRtcStats *SessionResponse_GetRTCStatsResponse `protobuf:"bytes,9,opt,name=get_rtc_stats,json=getRtcStats,proto3,oneof"`
}
type SessionResponse_GetSessionUsage struct {
GetSessionUsage *SessionResponse_GetSessionUsageResponse `protobuf:"bytes,10,opt,name=get_session_usage,json=getSessionUsage,proto3,oneof"`
}
func (*SessionResponse_Pong_) isSessionResponse_Response() {}
func (*SessionResponse_GetChatHistory) isSessionResponse_Response() {}
func (*SessionResponse_RunInput) isSessionResponse_Response() {}
func (*SessionResponse_GetAgentInfo) isSessionResponse_Response() {}
func (*SessionResponse_GetSessionState) isSessionResponse_Response() {}
func (*SessionResponse_GetRtcStats) isSessionResponse_Response() {}
func (*SessionResponse_GetSessionUsage) isSessionResponse_Response() {}
type AgentSessionMessage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Message isAgentSessionMessage_Message `protobuf_oneof:"message"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionMessage) Reset() {
*x = AgentSessionMessage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionMessage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionMessage) ProtoMessage() {}
func (x *AgentSessionMessage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[16]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionMessage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{16}
}
func (x *AgentSessionMessage) GetMessage() isAgentSessionMessage_Message {
if x != nil {
return x.Message
}
return nil
}
func (x *AgentSessionMessage) GetAudioInput() *AgentSessionMessage_ConsoleIO_AudioFrame {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_AudioInput); ok {
return x.AudioInput
}
}
return nil
}
func (x *AgentSessionMessage) GetAudioOutput() *AgentSessionMessage_ConsoleIO_AudioFrame {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_AudioOutput); ok {
return x.AudioOutput
}
}
return nil
}
func (x *AgentSessionMessage) GetEvent() *AgentSessionEvent {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_Event); ok {
return x.Event
}
}
return nil
}
func (x *AgentSessionMessage) GetRequest() *SessionRequest {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_Request); ok {
return x.Request
}
}
return nil
}
func (x *AgentSessionMessage) GetResponse() *SessionResponse {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_Response); ok {
return x.Response
}
}
return nil
}
func (x *AgentSessionMessage) GetAudioPlaybackFlush() *AgentSessionMessage_ConsoleIO_AudioPlaybackFlush {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_AudioPlaybackFlush); ok {
return x.AudioPlaybackFlush
}
}
return nil
}
func (x *AgentSessionMessage) GetAudioPlaybackClear() *AgentSessionMessage_ConsoleIO_AudioPlaybackClear {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_AudioPlaybackClear); ok {
return x.AudioPlaybackClear
}
}
return nil
}
func (x *AgentSessionMessage) GetAudioPlaybackFinished() *AgentSessionMessage_ConsoleIO_AudioPlaybackFinished {
if x != nil {
if x, ok := x.Message.(*AgentSessionMessage_AudioPlaybackFinished); ok {
return x.AudioPlaybackFinished
}
}
return nil
}
type isAgentSessionMessage_Message interface {
isAgentSessionMessage_Message()
}
type AgentSessionMessage_AudioInput struct {
AudioInput *AgentSessionMessage_ConsoleIO_AudioFrame `protobuf:"bytes,1,opt,name=audio_input,json=audioInput,proto3,oneof"`
}
type AgentSessionMessage_AudioOutput struct {
AudioOutput *AgentSessionMessage_ConsoleIO_AudioFrame `protobuf:"bytes,2,opt,name=audio_output,json=audioOutput,proto3,oneof"`
}
type AgentSessionMessage_Event struct {
Event *AgentSessionEvent `protobuf:"bytes,3,opt,name=event,proto3,oneof"`
}
type AgentSessionMessage_Request struct {
Request *SessionRequest `protobuf:"bytes,4,opt,name=request,proto3,oneof"`
}
type AgentSessionMessage_Response struct {
Response *SessionResponse `protobuf:"bytes,5,opt,name=response,proto3,oneof"`
}
type AgentSessionMessage_AudioPlaybackFlush struct {
AudioPlaybackFlush *AgentSessionMessage_ConsoleIO_AudioPlaybackFlush `protobuf:"bytes,6,opt,name=audio_playback_flush,json=audioPlaybackFlush,proto3,oneof"`
}
type AgentSessionMessage_AudioPlaybackClear struct {
AudioPlaybackClear *AgentSessionMessage_ConsoleIO_AudioPlaybackClear `protobuf:"bytes,7,opt,name=audio_playback_clear,json=audioPlaybackClear,proto3,oneof"`
}
type AgentSessionMessage_AudioPlaybackFinished struct {
AudioPlaybackFinished *AgentSessionMessage_ConsoleIO_AudioPlaybackFinished `protobuf:"bytes,8,opt,name=audio_playback_finished,json=audioPlaybackFinished,proto3,oneof"`
}
func (*AgentSessionMessage_AudioInput) isAgentSessionMessage_Message() {}
func (*AgentSessionMessage_AudioOutput) isAgentSessionMessage_Message() {}
func (*AgentSessionMessage_Event) isAgentSessionMessage_Message() {}
func (*AgentSessionMessage_Request) isAgentSessionMessage_Message() {}
func (*AgentSessionMessage_Response) isAgentSessionMessage_Message() {}
func (*AgentSessionMessage_AudioPlaybackFlush) isAgentSessionMessage_Message() {}
func (*AgentSessionMessage_AudioPlaybackClear) isAgentSessionMessage_Message() {}
func (*AgentSessionMessage_AudioPlaybackFinished) isAgentSessionMessage_Message() {}
type ChatMessage_ChatContent struct {
state protoimpl.MessageState `protogen:"open.v1"`
Payload isChatMessage_ChatContent_Payload `protobuf_oneof:"payload"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ChatMessage_ChatContent) Reset() {
*x = ChatMessage_ChatContent{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ChatMessage_ChatContent) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ChatMessage_ChatContent) ProtoMessage() {}
func (x *ChatMessage_ChatContent) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[17]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*ChatMessage_ChatContent) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{1, 0}
}
func (x *ChatMessage_ChatContent) GetPayload() isChatMessage_ChatContent_Payload {
if x != nil {
return x.Payload
}
return nil
}
func (x *ChatMessage_ChatContent) GetText() string {
if x != nil {
if x, ok := x.Payload.(*ChatMessage_ChatContent_Text); ok {
return x.Text
}
}
return ""
}
type isChatMessage_ChatContent_Payload interface {
isChatMessage_ChatContent_Payload()
}
type ChatMessage_ChatContent_Text struct {
Text string `protobuf:"bytes,1,opt,name=text,proto3,oneof"`
}
func (*ChatMessage_ChatContent_Text) isChatMessage_ChatContent_Payload() {}
type ChatContext_ChatItem struct {
state protoimpl.MessageState `protogen:"open.v1"`
Item isChatContext_ChatItem_Item `protobuf_oneof:"item"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ChatContext_ChatItem) Reset() {
*x = ChatContext_ChatItem{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[19]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ChatContext_ChatItem) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ChatContext_ChatItem) ProtoMessage() {}
func (x *ChatContext_ChatItem) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[19]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*ChatContext_ChatItem) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{6, 0}
}
func (x *ChatContext_ChatItem) GetItem() isChatContext_ChatItem_Item {
if x != nil {
return x.Item
}
return nil
}
func (x *ChatContext_ChatItem) GetMessage() *ChatMessage {
if x != nil {
if x, ok := x.Item.(*ChatContext_ChatItem_Message); ok {
return x.Message
}
}
return nil
}
func (x *ChatContext_ChatItem) GetFunctionCall() *FunctionCall {
if x != nil {
if x, ok := x.Item.(*ChatContext_ChatItem_FunctionCall); ok {
return x.FunctionCall
}
}
return nil
}
func (x *ChatContext_ChatItem) GetFunctionCallOutput() *FunctionCallOutput {
if x != nil {
if x, ok := x.Item.(*ChatContext_ChatItem_FunctionCallOutput); ok {
return x.FunctionCallOutput
}
}
return nil
}
func (x *ChatContext_ChatItem) GetAgentHandoff() *AgentHandoff {
if x != nil {
if x, ok := x.Item.(*ChatContext_ChatItem_AgentHandoff); ok {
return x.AgentHandoff
}
}
return nil
}
func (x *ChatContext_ChatItem) GetAgentConfigUpdate() *AgentConfigUpdate {
if x != nil {
if x, ok := x.Item.(*ChatContext_ChatItem_AgentConfigUpdate); ok {
return x.AgentConfigUpdate
}
}
return nil
}
type isChatContext_ChatItem_Item interface {
isChatContext_ChatItem_Item()
}
type ChatContext_ChatItem_Message struct {
Message *ChatMessage `protobuf:"bytes,1,opt,name=message,proto3,oneof"`
}
type ChatContext_ChatItem_FunctionCall struct {
FunctionCall *FunctionCall `protobuf:"bytes,2,opt,name=function_call,json=functionCall,proto3,oneof"`
}
type ChatContext_ChatItem_FunctionCallOutput struct {
FunctionCallOutput *FunctionCallOutput `protobuf:"bytes,3,opt,name=function_call_output,json=functionCallOutput,proto3,oneof"`
}
type ChatContext_ChatItem_AgentHandoff struct {
AgentHandoff *AgentHandoff `protobuf:"bytes,4,opt,name=agent_handoff,json=agentHandoff,proto3,oneof"`
}
type ChatContext_ChatItem_AgentConfigUpdate struct {
AgentConfigUpdate *AgentConfigUpdate `protobuf:"bytes,5,opt,name=agent_config_update,json=agentConfigUpdate,proto3,oneof"`
}
func (*ChatContext_ChatItem_Message) isChatContext_ChatItem_Item() {}
func (*ChatContext_ChatItem_FunctionCall) isChatContext_ChatItem_Item() {}
func (*ChatContext_ChatItem_FunctionCallOutput) isChatContext_ChatItem_Item() {}
func (*ChatContext_ChatItem_AgentHandoff) isChatContext_ChatItem_Item() {}
func (*ChatContext_ChatItem_AgentConfigUpdate) isChatContext_ChatItem_Item() {}
type AgentSessionEvent_AgentStateChanged struct {
state protoimpl.MessageState `protogen:"open.v1"`
OldState AgentState `protobuf:"varint,1,opt,name=old_state,json=oldState,proto3,enum=livekit.agent.AgentState" json:"old_state,omitempty"`
NewState AgentState `protobuf:"varint,2,opt,name=new_state,json=newState,proto3,enum=livekit.agent.AgentState" json:"new_state,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_AgentStateChanged) Reset() {
*x = AgentSessionEvent_AgentStateChanged{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[20]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_AgentStateChanged) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_AgentStateChanged) ProtoMessage() {}
func (x *AgentSessionEvent_AgentStateChanged) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[20]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_AgentStateChanged) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 0}
}
func (x *AgentSessionEvent_AgentStateChanged) GetOldState() AgentState {
if x != nil {
return x.OldState
}
return AgentState_AS_INITIALIZING
}
func (x *AgentSessionEvent_AgentStateChanged) GetNewState() AgentState {
if x != nil {
return x.NewState
}
return AgentState_AS_INITIALIZING
}
type AgentSessionEvent_UserStateChanged struct {
state protoimpl.MessageState `protogen:"open.v1"`
OldState UserState `protobuf:"varint,1,opt,name=old_state,json=oldState,proto3,enum=livekit.agent.UserState" json:"old_state,omitempty"`
NewState UserState `protobuf:"varint,2,opt,name=new_state,json=newState,proto3,enum=livekit.agent.UserState" json:"new_state,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_UserStateChanged) Reset() {
*x = AgentSessionEvent_UserStateChanged{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[21]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_UserStateChanged) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_UserStateChanged) ProtoMessage() {}
func (x *AgentSessionEvent_UserStateChanged) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[21]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_UserStateChanged) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 1}
}
func (x *AgentSessionEvent_UserStateChanged) GetOldState() UserState {
if x != nil {
return x.OldState
}
return UserState_US_SPEAKING
}
func (x *AgentSessionEvent_UserStateChanged) GetNewState() UserState {
if x != nil {
return x.NewState
}
return UserState_US_SPEAKING
}
type AgentSessionEvent_ConversationItemAdded struct {
state protoimpl.MessageState `protogen:"open.v1"`
Item *ChatContext_ChatItem `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_ConversationItemAdded) Reset() {
*x = AgentSessionEvent_ConversationItemAdded{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[22]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_ConversationItemAdded) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_ConversationItemAdded) ProtoMessage() {}
func (x *AgentSessionEvent_ConversationItemAdded) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[22]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_ConversationItemAdded) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 2}
}
func (x *AgentSessionEvent_ConversationItemAdded) GetItem() *ChatContext_ChatItem {
if x != nil {
return x.Item
}
return nil
}
type AgentSessionEvent_UserInputTranscribed struct {
state protoimpl.MessageState `protogen:"open.v1"`
Transcript string `protobuf:"bytes,1,opt,name=transcript,proto3" json:"transcript,omitempty"`
IsFinal bool `protobuf:"varint,2,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`
Language *string `protobuf:"bytes,3,opt,name=language,proto3,oneof" json:"language,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_UserInputTranscribed) Reset() {
*x = AgentSessionEvent_UserInputTranscribed{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[23]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_UserInputTranscribed) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_UserInputTranscribed) ProtoMessage() {}
func (x *AgentSessionEvent_UserInputTranscribed) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[23]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_UserInputTranscribed) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 3}
}
func (x *AgentSessionEvent_UserInputTranscribed) GetTranscript() string {
if x != nil {
return x.Transcript
}
return ""
}
func (x *AgentSessionEvent_UserInputTranscribed) GetIsFinal() bool {
if x != nil {
return x.IsFinal
}
return false
}
func (x *AgentSessionEvent_UserInputTranscribed) GetLanguage() string {
if x != nil && x.Language != nil {
return *x.Language
}
return ""
}
type AgentSessionEvent_FunctionToolsExecuted struct {
state protoimpl.MessageState `protogen:"open.v1"`
FunctionCalls []*FunctionCall `protobuf:"bytes,1,rep,name=function_calls,json=functionCalls,proto3" json:"function_calls,omitempty"`
FunctionCallOutputs []*FunctionCallOutput `protobuf:"bytes,2,rep,name=function_call_outputs,json=functionCallOutputs,proto3" json:"function_call_outputs,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_FunctionToolsExecuted) Reset() {
*x = AgentSessionEvent_FunctionToolsExecuted{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[24]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_FunctionToolsExecuted) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_FunctionToolsExecuted) ProtoMessage() {}
func (x *AgentSessionEvent_FunctionToolsExecuted) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[24]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_FunctionToolsExecuted) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 4}
}
func (x *AgentSessionEvent_FunctionToolsExecuted) GetFunctionCalls() []*FunctionCall {
if x != nil {
return x.FunctionCalls
}
return nil
}
func (x *AgentSessionEvent_FunctionToolsExecuted) GetFunctionCallOutputs() []*FunctionCallOutput {
if x != nil {
return x.FunctionCallOutputs
}
return nil
}
type AgentSessionEvent_Error struct {
state protoimpl.MessageState `protogen:"open.v1"`
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_Error) Reset() {
*x = AgentSessionEvent_Error{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[25]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_Error) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_Error) ProtoMessage() {}
func (x *AgentSessionEvent_Error) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[25]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_Error) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 5}
}
func (x *AgentSessionEvent_Error) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type AgentSessionEvent_OverlappingSpeech struct {
state protoimpl.MessageState `protogen:"open.v1"`
IsInterruption bool `protobuf:"varint,1,opt,name=is_interruption,json=isInterruption,proto3" json:"is_interruption,omitempty"`
OverlapStartedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=overlap_started_at,json=overlapStartedAt,proto3,oneof" json:"overlap_started_at,omitempty"`
DetectionDelay float64 `protobuf:"fixed64,3,opt,name=detection_delay,json=detectionDelay,proto3" json:"detection_delay,omitempty"`
DetectedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=detected_at,json=detectedAt,proto3" json:"detected_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_OverlappingSpeech) Reset() {
*x = AgentSessionEvent_OverlappingSpeech{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[26]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_OverlappingSpeech) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_OverlappingSpeech) ProtoMessage() {}
func (x *AgentSessionEvent_OverlappingSpeech) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[26]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_OverlappingSpeech) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 6}
}
func (x *AgentSessionEvent_OverlappingSpeech) GetIsInterruption() bool {
if x != nil {
return x.IsInterruption
}
return false
}
func (x *AgentSessionEvent_OverlappingSpeech) GetOverlapStartedAt() *timestamppb.Timestamp {
if x != nil {
return x.OverlapStartedAt
}
return nil
}
func (x *AgentSessionEvent_OverlappingSpeech) GetDetectionDelay() float64 {
if x != nil {
return x.DetectionDelay
}
return 0
}
func (x *AgentSessionEvent_OverlappingSpeech) GetDetectedAt() *timestamppb.Timestamp {
if x != nil {
return x.DetectedAt
}
return nil
}
type AgentSessionEvent_SessionUsageUpdated struct {
state protoimpl.MessageState `protogen:"open.v1"`
Usage *AgentSessionUsage `protobuf:"bytes,1,opt,name=usage,proto3" json:"usage,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionEvent_SessionUsageUpdated) Reset() {
*x = AgentSessionEvent_SessionUsageUpdated{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[27]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionEvent_SessionUsageUpdated) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionEvent_SessionUsageUpdated) ProtoMessage() {}
func (x *AgentSessionEvent_SessionUsageUpdated) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[27]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionEvent_SessionUsageUpdated) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{13, 7}
}
func (x *AgentSessionEvent_SessionUsageUpdated) GetUsage() *AgentSessionUsage {
if x != nil {
return x.Usage
}
return nil
}
type SessionRequest_Ping struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest_Ping) Reset() {
*x = SessionRequest_Ping{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[28]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest_Ping) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest_Ping) ProtoMessage() {}
func (x *SessionRequest_Ping) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[28]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest_Ping) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14, 0}
}
type SessionRequest_GetChatHistory struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest_GetChatHistory) Reset() {
*x = SessionRequest_GetChatHistory{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[29]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest_GetChatHistory) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest_GetChatHistory) ProtoMessage() {}
func (x *SessionRequest_GetChatHistory) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[29]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest_GetChatHistory) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14, 1}
}
type SessionRequest_RunInput struct {
state protoimpl.MessageState `protogen:"open.v1"`
Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest_RunInput) Reset() {
*x = SessionRequest_RunInput{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[30]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest_RunInput) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest_RunInput) ProtoMessage() {}
func (x *SessionRequest_RunInput) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[30]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest_RunInput) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14, 2}
}
func (x *SessionRequest_RunInput) GetText() string {
if x != nil {
return x.Text
}
return ""
}
type SessionRequest_GetAgentInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest_GetAgentInfo) Reset() {
*x = SessionRequest_GetAgentInfo{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[31]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest_GetAgentInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest_GetAgentInfo) ProtoMessage() {}
func (x *SessionRequest_GetAgentInfo) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[31]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest_GetAgentInfo) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14, 3}
}
type SessionRequest_GetSessionState struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest_GetSessionState) Reset() {
*x = SessionRequest_GetSessionState{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[32]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest_GetSessionState) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest_GetSessionState) ProtoMessage() {}
func (x *SessionRequest_GetSessionState) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[32]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest_GetSessionState) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14, 4}
}
type SessionRequest_GetRTCStats struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest_GetRTCStats) Reset() {
*x = SessionRequest_GetRTCStats{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[33]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest_GetRTCStats) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest_GetRTCStats) ProtoMessage() {}
func (x *SessionRequest_GetRTCStats) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[33]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest_GetRTCStats) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14, 5}
}
type SessionRequest_GetSessionUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionRequest_GetSessionUsage) Reset() {
*x = SessionRequest_GetSessionUsage{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[34]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionRequest_GetSessionUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionRequest_GetSessionUsage) ProtoMessage() {}
func (x *SessionRequest_GetSessionUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[34]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionRequest_GetSessionUsage) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{14, 6}
}
type SessionResponse_Pong struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse_Pong) Reset() {
*x = SessionResponse_Pong{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[35]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse_Pong) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse_Pong) ProtoMessage() {}
func (x *SessionResponse_Pong) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[35]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse_Pong) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15, 0}
}
type SessionResponse_GetChatHistoryResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Items []*ChatContext_ChatItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse_GetChatHistoryResponse) Reset() {
*x = SessionResponse_GetChatHistoryResponse{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[36]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse_GetChatHistoryResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse_GetChatHistoryResponse) ProtoMessage() {}
func (x *SessionResponse_GetChatHistoryResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[36]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse_GetChatHistoryResponse) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15, 1}
}
func (x *SessionResponse_GetChatHistoryResponse) GetItems() []*ChatContext_ChatItem {
if x != nil {
return x.Items
}
return nil
}
type SessionResponse_GetAgentInfoResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Instructions *string `protobuf:"bytes,2,opt,name=instructions,proto3,oneof" json:"instructions,omitempty"`
Tools []string `protobuf:"bytes,3,rep,name=tools,proto3" json:"tools,omitempty"`
ChatCtx []*ChatContext_ChatItem `protobuf:"bytes,4,rep,name=chat_ctx,json=chatCtx,proto3" json:"chat_ctx,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse_GetAgentInfoResponse) Reset() {
*x = SessionResponse_GetAgentInfoResponse{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[37]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse_GetAgentInfoResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse_GetAgentInfoResponse) ProtoMessage() {}
func (x *SessionResponse_GetAgentInfoResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[37]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse_GetAgentInfoResponse) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15, 2}
}
func (x *SessionResponse_GetAgentInfoResponse) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *SessionResponse_GetAgentInfoResponse) GetInstructions() string {
if x != nil && x.Instructions != nil {
return *x.Instructions
}
return ""
}
func (x *SessionResponse_GetAgentInfoResponse) GetTools() []string {
if x != nil {
return x.Tools
}
return nil
}
func (x *SessionResponse_GetAgentInfoResponse) GetChatCtx() []*ChatContext_ChatItem {
if x != nil {
return x.ChatCtx
}
return nil
}
type SessionResponse_RunInputResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Items []*ChatContext_ChatItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse_RunInputResponse) Reset() {
*x = SessionResponse_RunInputResponse{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[38]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse_RunInputResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse_RunInputResponse) ProtoMessage() {}
func (x *SessionResponse_RunInputResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[38]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse_RunInputResponse) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15, 3}
}
func (x *SessionResponse_RunInputResponse) GetItems() []*ChatContext_ChatItem {
if x != nil {
return x.Items
}
return nil
}
type SessionResponse_GetSessionStateResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
AgentState AgentState `protobuf:"varint,1,opt,name=agent_state,json=agentState,proto3,enum=livekit.agent.AgentState" json:"agent_state,omitempty"`
UserState UserState `protobuf:"varint,2,opt,name=user_state,json=userState,proto3,enum=livekit.agent.UserState" json:"user_state,omitempty"`
AgentId string `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
Options map[string]string `protobuf:"bytes,4,rep,name=options,proto3" json:"options,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse_GetSessionStateResponse) Reset() {
*x = SessionResponse_GetSessionStateResponse{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[39]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse_GetSessionStateResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse_GetSessionStateResponse) ProtoMessage() {}
func (x *SessionResponse_GetSessionStateResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[39]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse_GetSessionStateResponse) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15, 4}
}
func (x *SessionResponse_GetSessionStateResponse) GetAgentState() AgentState {
if x != nil {
return x.AgentState
}
return AgentState_AS_INITIALIZING
}
func (x *SessionResponse_GetSessionStateResponse) GetUserState() UserState {
if x != nil {
return x.UserState
}
return UserState_US_SPEAKING
}
func (x *SessionResponse_GetSessionStateResponse) GetAgentId() string {
if x != nil {
return x.AgentId
}
return ""
}
func (x *SessionResponse_GetSessionStateResponse) GetOptions() map[string]string {
if x != nil {
return x.Options
}
return nil
}
func (x *SessionResponse_GetSessionStateResponse) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
type SessionResponse_GetRTCStatsResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
PublisherStats []*structpb.Struct `protobuf:"bytes,1,rep,name=publisher_stats,json=publisherStats,proto3" json:"publisher_stats,omitempty"`
SubscriberStats []*structpb.Struct `protobuf:"bytes,2,rep,name=subscriber_stats,json=subscriberStats,proto3" json:"subscriber_stats,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse_GetRTCStatsResponse) Reset() {
*x = SessionResponse_GetRTCStatsResponse{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[40]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse_GetRTCStatsResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse_GetRTCStatsResponse) ProtoMessage() {}
func (x *SessionResponse_GetRTCStatsResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[40]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse_GetRTCStatsResponse) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15, 5}
}
func (x *SessionResponse_GetRTCStatsResponse) GetPublisherStats() []*structpb.Struct {
if x != nil {
return x.PublisherStats
}
return nil
}
func (x *SessionResponse_GetRTCStatsResponse) GetSubscriberStats() []*structpb.Struct {
if x != nil {
return x.SubscriberStats
}
return nil
}
type SessionResponse_GetSessionUsageResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Usage *AgentSessionUsage `protobuf:"bytes,1,opt,name=usage,proto3" json:"usage,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SessionResponse_GetSessionUsageResponse) Reset() {
*x = SessionResponse_GetSessionUsageResponse{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[41]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SessionResponse_GetSessionUsageResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SessionResponse_GetSessionUsageResponse) ProtoMessage() {}
func (x *SessionResponse_GetSessionUsageResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[41]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*SessionResponse_GetSessionUsageResponse) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{15, 6}
}
func (x *SessionResponse_GetSessionUsageResponse) GetUsage() *AgentSessionUsage {
if x != nil {
return x.Usage
}
return nil
}
func (x *SessionResponse_GetSessionUsageResponse) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
type AgentSessionMessage_ConsoleIO struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionMessage_ConsoleIO) Reset() {
*x = AgentSessionMessage_ConsoleIO{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[43]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionMessage_ConsoleIO) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionMessage_ConsoleIO) ProtoMessage() {}
func (x *AgentSessionMessage_ConsoleIO) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[43]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionMessage_ConsoleIO) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{16, 0}
}
type AgentSessionMessage_ConsoleIO_AudioFrame struct {
state protoimpl.MessageState `protogen:"open.v1"`
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
SampleRate uint32 `protobuf:"varint,2,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
NumChannels uint32 `protobuf:"varint,3,opt,name=num_channels,json=numChannels,proto3" json:"num_channels,omitempty"`
SamplesPerChannel uint32 `protobuf:"varint,4,opt,name=samples_per_channel,json=samplesPerChannel,proto3" json:"samples_per_channel,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionMessage_ConsoleIO_AudioFrame) Reset() {
*x = AgentSessionMessage_ConsoleIO_AudioFrame{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[44]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionMessage_ConsoleIO_AudioFrame) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioFrame) ProtoMessage() {}
func (x *AgentSessionMessage_ConsoleIO_AudioFrame) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[44]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioFrame) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{16, 0, 0}
}
func (x *AgentSessionMessage_ConsoleIO_AudioFrame) GetData() []byte {
if x != nil {
return x.Data
}
return nil
}
func (x *AgentSessionMessage_ConsoleIO_AudioFrame) GetSampleRate() uint32 {
if x != nil {
return x.SampleRate
}
return 0
}
func (x *AgentSessionMessage_ConsoleIO_AudioFrame) GetNumChannels() uint32 {
if x != nil {
return x.NumChannels
}
return 0
}
func (x *AgentSessionMessage_ConsoleIO_AudioFrame) GetSamplesPerChannel() uint32 {
if x != nil {
return x.SamplesPerChannel
}
return 0
}
type AgentSessionMessage_ConsoleIO_AudioPlaybackFlush struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackFlush) Reset() {
*x = AgentSessionMessage_ConsoleIO_AudioPlaybackFlush{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[45]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackFlush) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioPlaybackFlush) ProtoMessage() {}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackFlush) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[45]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioPlaybackFlush) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{16, 0, 1}
}
type AgentSessionMessage_ConsoleIO_AudioPlaybackClear struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackClear) Reset() {
*x = AgentSessionMessage_ConsoleIO_AudioPlaybackClear{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[46]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackClear) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioPlaybackClear) ProtoMessage() {}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackClear) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[46]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioPlaybackClear) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{16, 0, 2}
}
type AgentSessionMessage_ConsoleIO_AudioPlaybackFinished struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackFinished) Reset() {
*x = AgentSessionMessage_ConsoleIO_AudioPlaybackFinished{}
mi := &file_agent_livekit_agent_session_proto_msgTypes[47]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackFinished) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioPlaybackFinished) ProtoMessage() {}
func (x *AgentSessionMessage_ConsoleIO_AudioPlaybackFinished) ProtoReflect() protoreflect.Message {
mi := &file_agent_livekit_agent_session_proto_msgTypes[47]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
func (*AgentSessionMessage_ConsoleIO_AudioPlaybackFinished) Descriptor() ([]byte, []int) {
return file_agent_livekit_agent_session_proto_rawDescGZIP(), []int{16, 0, 3}
}
var File_agent_livekit_agent_session_proto protoreflect.FileDescriptor
const file_agent_livekit_agent_session_proto_rawDesc = "" +
"\n" +
"!agent/livekit_agent_session.proto\x12\rlivekit.agent\x1a\x1cgoogle/protobuf/struct.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x14logger/options.proto\"\xcd\x04\n" +
"\rMetricsReport\x12J\n" +
"\x13started_speaking_at\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\x11startedSpeakingAt\x12J\n" +
"\x13stopped_speaking_at\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x11stoppedSpeakingAt\x124\n" +
"\x13transcription_delay\x18\x03 \x01(\x01H\x00R\x12transcriptionDelay\x88\x01\x01\x12.\n" +
"\x11end_of_turn_delay\x18\x04 \x01(\x01H\x01R\x0eendOfTurnDelay\x88\x01\x01\x12C\n" +
"\x1con_user_turn_completed_delay\x18\x05 \x01(\x01H\x02R\x18onUserTurnCompletedDelay\x88\x01\x01\x12'\n" +
"\rllm_node_ttft\x18\x06 \x01(\x01H\x03R\vllmNodeTtft\x88\x01\x01\x12'\n" +
"\rtts_node_ttfb\x18\a \x01(\x01H\x04R\vttsNodeTtfb\x88\x01\x01\x12$\n" +
"\ve2e_latency\x18\b \x01(\x01H\x05R\n" +
"e2eLatency\x88\x01\x01B\x16\n" +
"\x14_transcription_delayB\x14\n" +
"\x12_end_of_turn_delayB\x1f\n" +
"\x1d_on_user_turn_completed_delayB\x10\n" +
"\x0e_llm_node_ttftB\x10\n" +
"\x0e_tts_node_ttfbB\x0e\n" +
"\f_e2e_latency\"\x9c\x04\n" +
"\vChatMessage\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12+\n" +
"\x04role\x18\x02 \x01(\x0e2\x17.livekit.agent.ChatRoleR\x04role\x12@\n" +
"\acontent\x18\x03 \x03(\v2&.livekit.agent.ChatMessage.ChatContentR\acontent\x12 \n" +
"\vinterrupted\x18\x04 \x01(\bR\vinterrupted\x128\n" +
"\x15transcript_confidence\x18\x05 \x01(\x01H\x00R\x14transcriptConfidence\x88\x01\x01\x12;\n" +
"\x05extra\x18\x06 \x03(\v2%.livekit.agent.ChatMessage.ExtraEntryR\x05extra\x126\n" +
"\ametrics\x18\a \x01(\v2\x1c.livekit.agent.MetricsReportR\ametrics\x129\n" +
"\n" +
"created_at\x18\b \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x1a.\n" +
"\vChatContent\x12\x14\n" +
"\x04text\x18\x01 \x01(\tH\x00R\x04textB\t\n" +
"\apayload\x1a8\n" +
"\n" +
"ExtraEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01B\x18\n" +
"\x16_transcript_confidence\"\xb0\x01\n" +
"\fFunctionCall\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12#\n" +
"\acall_id\x18\x02 \x01(\tB\n" +
"\x9a\xec,\x06callIDR\x06callId\x12\x1c\n" +
"\targuments\x18\x03 \x01(\tR\targuments\x12\x12\n" +
"\x04name\x18\x04 \x01(\tR\x04name\x129\n" +
"\n" +
"created_at\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\"\xcb\x01\n" +
"\x12FunctionCallOutput\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12\x12\n" +
"\x04name\x18\x02 \x01(\tR\x04name\x12#\n" +
"\acall_id\x18\x03 \x01(\tB\n" +
"\x9a\xec,\x06callIDR\x06callId\x12\x16\n" +
"\x06output\x18\x04 \x01(\tR\x06output\x12\x19\n" +
"\bis_error\x18\x05 \x01(\bR\aisError\x129\n" +
"\n" +
"created_at\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\"\xd3\x01\n" +
"\fAgentHandoff\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x125\n" +
"\fold_agent_id\x18\x02 \x01(\tB\x0e\x9a\xec,\n" +
"oldAgentIDH\x00R\n" +
"oldAgentId\x88\x01\x01\x120\n" +
"\fnew_agent_id\x18\x03 \x01(\tB\x0e\x9a\xec,\n" +
"newAgentIDR\n" +
"newAgentId\x129\n" +
"\n" +
"created_at\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAtB\x0f\n" +
"\r_old_agent_id\"\xde\x01\n" +
"\x11AgentConfigUpdate\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12'\n" +
"\finstructions\x18\x02 \x01(\tH\x00R\finstructions\x88\x01\x01\x12\x1f\n" +
"\vtools_added\x18\x03 \x03(\tR\n" +
"toolsAdded\x12#\n" +
"\rtools_removed\x18\x04 \x03(\tR\ftoolsRemoved\x129\n" +
"\n" +
"created_at\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAtB\x0f\n" +
"\r_instructions\"\xc8\x03\n" +
"\vChatContext\x129\n" +
"\x05items\x18\x01 \x03(\v2#.livekit.agent.ChatContext.ChatItemR\x05items\x1a\xfd\x02\n" +
"\bChatItem\x126\n" +
"\amessage\x18\x01 \x01(\v2\x1a.livekit.agent.ChatMessageH\x00R\amessage\x12B\n" +
"\rfunction_call\x18\x02 \x01(\v2\x1b.livekit.agent.FunctionCallH\x00R\ffunctionCall\x12U\n" +
"\x14function_call_output\x18\x03 \x01(\v2!.livekit.agent.FunctionCallOutputH\x00R\x12functionCallOutput\x12B\n" +
"\ragent_handoff\x18\x04 \x01(\v2\x1b.livekit.agent.AgentHandoffH\x00R\fagentHandoff\x12R\n" +
"\x13agent_config_update\x18\x05 \x01(\v2 .livekit.agent.AgentConfigUpdateH\x00R\x11agentConfigUpdateB\x06\n" +
"\x04item\"\xf9\x04\n" +
"\rLLMModelUsage\x12\x1a\n" +
"\bprovider\x18\x01 \x01(\tR\bprovider\x12\x14\n" +
"\x05model\x18\x02 \x01(\tR\x05model\x12!\n" +
"\finput_tokens\x18\x03 \x01(\x05R\vinputTokens\x12.\n" +
"\x13input_cached_tokens\x18\x04 \x01(\x05R\x11inputCachedTokens\x12,\n" +
"\x12input_audio_tokens\x18\x05 \x01(\x05R\x10inputAudioTokens\x129\n" +
"\x19input_cached_audio_tokens\x18\x06 \x01(\x05R\x16inputCachedAudioTokens\x12*\n" +
"\x11input_text_tokens\x18\a \x01(\x05R\x0finputTextTokens\x127\n" +
"\x18input_cached_text_tokens\x18\b \x01(\x05R\x15inputCachedTextTokens\x12,\n" +
"\x12input_image_tokens\x18\t \x01(\x05R\x10inputImageTokens\x129\n" +
"\x19input_cached_image_tokens\x18\n" +
" \x01(\x05R\x16inputCachedImageTokens\x12#\n" +
"\routput_tokens\x18\v \x01(\x05R\foutputTokens\x12.\n" +
"\x13output_audio_tokens\x18\f \x01(\x05R\x11outputAudioTokens\x12,\n" +
"\x12output_text_tokens\x18\r \x01(\x05R\x10outputTextTokens\x12)\n" +
"\x10session_duration\x18\x0e \x01(\x01R\x0fsessionDuration\"\xdb\x01\n" +
"\rTTSModelUsage\x12\x1a\n" +
"\bprovider\x18\x01 \x01(\tR\bprovider\x12\x14\n" +
"\x05model\x18\x02 \x01(\tR\x05model\x12!\n" +
"\finput_tokens\x18\x03 \x01(\x05R\vinputTokens\x12#\n" +
"\routput_tokens\x18\x04 \x01(\x05R\foutputTokens\x12)\n" +
"\x10characters_count\x18\x05 \x01(\x05R\x0fcharactersCount\x12%\n" +
"\x0eaudio_duration\x18\x06 \x01(\x01R\raudioDuration\"\xb0\x01\n" +
"\rSTTModelUsage\x12\x1a\n" +
"\bprovider\x18\x01 \x01(\tR\bprovider\x12\x14\n" +
"\x05model\x18\x02 \x01(\tR\x05model\x12!\n" +
"\finput_tokens\x18\x03 \x01(\x05R\vinputTokens\x12#\n" +
"\routput_tokens\x18\x04 \x01(\x05R\foutputTokens\x12%\n" +
"\x0eaudio_duration\x18\x05 \x01(\x01R\raudioDuration\"q\n" +
"\x16InterruptionModelUsage\x12\x1a\n" +
"\bprovider\x18\x01 \x01(\tR\bprovider\x12\x14\n" +
"\x05model\x18\x02 \x01(\tR\x05model\x12%\n" +
"\x0etotal_requests\x18\x03 \x01(\x05R\rtotalRequests\"\xf8\x01\n" +
"\n" +
"ModelUsage\x120\n" +
"\x03llm\x18\x01 \x01(\v2\x1c.livekit.agent.LLMModelUsageH\x00R\x03llm\x120\n" +
"\x03tts\x18\x02 \x01(\v2\x1c.livekit.agent.TTSModelUsageH\x00R\x03tts\x120\n" +
"\x03stt\x18\x03 \x01(\v2\x1c.livekit.agent.STTModelUsageH\x00R\x03stt\x12K\n" +
"\finterruption\x18\x04 \x01(\v2%.livekit.agent.InterruptionModelUsageH\x00R\finterruptionB\a\n" +
"\x05usage\"O\n" +
"\x11AgentSessionUsage\x12:\n" +
"\vmodel_usage\x18\x01 \x03(\v2\x19.livekit.agent.ModelUsageR\n" +
"modelUsage\"\x92\x0f\n" +
"\x11AgentSessionEvent\x129\n" +
"\n" +
"created_at\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x12d\n" +
"\x13agent_state_changed\x18\n" +
" \x01(\v22.livekit.agent.AgentSessionEvent.AgentStateChangedH\x00R\x11agentStateChanged\x12a\n" +
"\x12user_state_changed\x18\v \x01(\v21.livekit.agent.AgentSessionEvent.UserStateChangedH\x00R\x10userStateChanged\x12p\n" +
"\x17conversation_item_added\x18\f \x01(\v26.livekit.agent.AgentSessionEvent.ConversationItemAddedH\x00R\x15conversationItemAdded\x12m\n" +
"\x16user_input_transcribed\x18\r \x01(\v25.livekit.agent.AgentSessionEvent.UserInputTranscribedH\x00R\x14userInputTranscribed\x12p\n" +
"\x17function_tools_executed\x18\x0e \x01(\v26.livekit.agent.AgentSessionEvent.FunctionToolsExecutedH\x00R\x15functionToolsExecuted\x12>\n" +
"\x05error\x18\x0f \x01(\v2&.livekit.agent.AgentSessionEvent.ErrorH\x00R\x05error\x12c\n" +
"\x12overlapping_speech\x18\x10 \x01(\v22.livekit.agent.AgentSessionEvent.OverlappingSpeechH\x00R\x11overlappingSpeech\x12j\n" +
"\x15session_usage_updated\x18\x11 \x01(\v24.livekit.agent.AgentSessionEvent.SessionUsageUpdatedH\x00R\x13sessionUsageUpdated\x1a\x83\x01\n" +
"\x11AgentStateChanged\x126\n" +
"\told_state\x18\x01 \x01(\x0e2\x19.livekit.agent.AgentStateR\boldState\x126\n" +
"\tnew_state\x18\x02 \x01(\x0e2\x19.livekit.agent.AgentStateR\bnewState\x1a\x80\x01\n" +
"\x10UserStateChanged\x125\n" +
"\told_state\x18\x01 \x01(\x0e2\x18.livekit.agent.UserStateR\boldState\x125\n" +
"\tnew_state\x18\x02 \x01(\x0e2\x18.livekit.agent.UserStateR\bnewState\x1aP\n" +
"\x15ConversationItemAdded\x127\n" +
"\x04item\x18\x01 \x01(\v2#.livekit.agent.ChatContext.ChatItemR\x04item\x1a\x7f\n" +
"\x14UserInputTranscribed\x12\x1e\n" +
"\n" +
"transcript\x18\x01 \x01(\tR\n" +
"transcript\x12\x19\n" +
"\bis_final\x18\x02 \x01(\bR\aisFinal\x12\x1f\n" +
"\blanguage\x18\x03 \x01(\tH\x00R\blanguage\x88\x01\x01B\v\n" +
"\t_language\x1a\xb2\x01\n" +
"\x15FunctionToolsExecuted\x12B\n" +
"\x0efunction_calls\x18\x01 \x03(\v2\x1b.livekit.agent.FunctionCallR\rfunctionCalls\x12U\n" +
"\x15function_call_outputs\x18\x02 \x03(\v2!.livekit.agent.FunctionCallOutputR\x13functionCallOutputs\x1a!\n" +
"\x05Error\x12\x18\n" +
"\amessage\x18\x01 \x01(\tR\amessage\x1a\x88\x02\n" +
"\x11OverlappingSpeech\x12'\n" +
"\x0fis_interruption\x18\x01 \x01(\bR\x0eisInterruption\x12M\n" +
"\x12overlap_started_at\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampH\x00R\x10overlapStartedAt\x88\x01\x01\x12'\n" +
"\x0fdetection_delay\x18\x03 \x01(\x01R\x0edetectionDelay\x12;\n" +
"\vdetected_at\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
"detectedAtB\x15\n" +
"\x13_overlap_started_at\x1aM\n" +
"\x13SessionUsageUpdated\x126\n" +
"\x05usage\x18\x01 \x01(\v2 .livekit.agent.AgentSessionUsageR\x05usageB\a\n" +
"\x05event\"\xf3\x05\n" +
"\x0eSessionRequest\x12\x1d\n" +
"\n" +
"request_id\x18\x01 \x01(\tR\trequestId\x128\n" +
"\x04ping\x18\x02 \x01(\v2\".livekit.agent.SessionRequest.PingH\x00R\x04ping\x12X\n" +
"\x10get_chat_history\x18\x04 \x01(\v2,.livekit.agent.SessionRequest.GetChatHistoryH\x00R\x0egetChatHistory\x12E\n" +
"\trun_input\x18\x05 \x01(\v2&.livekit.agent.SessionRequest.RunInputH\x00R\brunInput\x12R\n" +
"\x0eget_agent_info\x18\x06 \x01(\v2*.livekit.agent.SessionRequest.GetAgentInfoH\x00R\fgetAgentInfo\x12[\n" +
"\x11get_session_state\x18\a \x01(\v2-.livekit.agent.SessionRequest.GetSessionStateH\x00R\x0fgetSessionState\x12O\n" +
"\rget_rtc_stats\x18\b \x01(\v2).livekit.agent.SessionRequest.GetRTCStatsH\x00R\vgetRtcStats\x12[\n" +
"\x11get_session_usage\x18\t \x01(\v2-.livekit.agent.SessionRequest.GetSessionUsageH\x00R\x0fgetSessionUsage\x1a\x06\n" +
"\x04Ping\x1a\x10\n" +
"\x0eGetChatHistory\x1a\x1e\n" +
"\bRunInput\x12\x12\n" +
"\x04text\x18\x01 \x01(\tR\x04text\x1a\x0e\n" +
"\fGetAgentInfo\x1a\x11\n" +
"\x0fGetSessionState\x1a\r\n" +
"\vGetRTCStats\x1a\x11\n" +
"\x0fGetSessionUsageB\t\n" +
"\arequest\"\xe6\r\n" +
"\x0fSessionResponse\x12\x1d\n" +
"\n" +
"request_id\x18\x01 \x01(\tR\trequestId\x12\x19\n" +
"\x05error\x18\x02 \x01(\tH\x01R\x05error\x88\x01\x01\x129\n" +
"\x04pong\x18\x03 \x01(\v2#.livekit.agent.SessionResponse.PongH\x00R\x04pong\x12a\n" +
"\x10get_chat_history\x18\x05 \x01(\v25.livekit.agent.SessionResponse.GetChatHistoryResponseH\x00R\x0egetChatHistory\x12N\n" +
"\trun_input\x18\x06 \x01(\v2/.livekit.agent.SessionResponse.RunInputResponseH\x00R\brunInput\x12[\n" +
"\x0eget_agent_info\x18\a \x01(\v23.livekit.agent.SessionResponse.GetAgentInfoResponseH\x00R\fgetAgentInfo\x12d\n" +
"\x11get_session_state\x18\b \x01(\v26.livekit.agent.SessionResponse.GetSessionStateResponseH\x00R\x0fgetSessionState\x12X\n" +
"\rget_rtc_stats\x18\t \x01(\v22.livekit.agent.SessionResponse.GetRTCStatsResponseH\x00R\vgetRtcStats\x12d\n" +
"\x11get_session_usage\x18\n" +
" \x01(\v26.livekit.agent.SessionResponse.GetSessionUsageResponseH\x00R\x0fgetSessionUsage\x1a\x06\n" +
"\x04Pong\x1aS\n" +
"\x16GetChatHistoryResponse\x129\n" +
"\x05items\x18\x01 \x03(\v2#.livekit.agent.ChatContext.ChatItemR\x05items\x1a\xb6\x01\n" +
"\x14GetAgentInfoResponse\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12'\n" +
"\finstructions\x18\x02 \x01(\tH\x00R\finstructions\x88\x01\x01\x12\x14\n" +
"\x05tools\x18\x03 \x03(\tR\x05tools\x12>\n" +
"\bchat_ctx\x18\x04 \x03(\v2#.livekit.agent.ChatContext.ChatItemR\achatCtxB\x0f\n" +
"\r_instructions\x1aM\n" +
"\x10RunInputResponse\x129\n" +
"\x05items\x18\x01 \x03(\v2#.livekit.agent.ChatContext.ChatItemR\x05items\x1a\xff\x02\n" +
"\x17GetSessionStateResponse\x12:\n" +
"\vagent_state\x18\x01 \x01(\x0e2\x19.livekit.agent.AgentStateR\n" +
"agentState\x127\n" +
"\n" +
"user_state\x18\x02 \x01(\x0e2\x18.livekit.agent.UserStateR\tuserState\x12\x19\n" +
"\bagent_id\x18\x03 \x01(\tR\aagentId\x12]\n" +
"\aoptions\x18\x04 \x03(\v2C.livekit.agent.SessionResponse.GetSessionStateResponse.OptionsEntryR\aoptions\x129\n" +
"\n" +
"created_at\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x1a:\n" +
"\fOptionsEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\x1a\x9b\x01\n" +
"\x13GetRTCStatsResponse\x12@\n" +
"\x0fpublisher_stats\x18\x01 \x03(\v2\x17.google.protobuf.StructR\x0epublisherStats\x12B\n" +
"\x10subscriber_stats\x18\x02 \x03(\v2\x17.google.protobuf.StructR\x0fsubscriberStats\x1a\x8c\x01\n" +
"\x17GetSessionUsageResponse\x126\n" +
"\x05usage\x18\x01 \x01(\v2 .livekit.agent.AgentSessionUsageR\x05usage\x129\n" +
"\n" +
"created_at\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAtB\n" +
"\n" +
"\bresponseB\b\n" +
"\x06_error\"\xdf\a\n" +
"\x13AgentSessionMessage\x12Z\n" +
"\vaudio_input\x18\x01 \x01(\v27.livekit.agent.AgentSessionMessage.ConsoleIO.AudioFrameH\x00R\n" +
"audioInput\x12\\\n" +
"\faudio_output\x18\x02 \x01(\v27.livekit.agent.AgentSessionMessage.ConsoleIO.AudioFrameH\x00R\vaudioOutput\x128\n" +
"\x05event\x18\x03 \x01(\v2 .livekit.agent.AgentSessionEventH\x00R\x05event\x129\n" +
"\arequest\x18\x04 \x01(\v2\x1d.livekit.agent.SessionRequestH\x00R\arequest\x12<\n" +
"\bresponse\x18\x05 \x01(\v2\x1e.livekit.agent.SessionResponseH\x00R\bresponse\x12s\n" +
"\x14audio_playback_flush\x18\x06 \x01(\v2?.livekit.agent.AgentSessionMessage.ConsoleIO.AudioPlaybackFlushH\x00R\x12audioPlaybackFlush\x12s\n" +
"\x14audio_playback_clear\x18\a \x01(\v2?.livekit.agent.AgentSessionMessage.ConsoleIO.AudioPlaybackClearH\x00R\x12audioPlaybackClear\x12|\n" +
"\x17audio_playback_finished\x18\b \x01(\v2B.livekit.agent.AgentSessionMessage.ConsoleIO.AudioPlaybackFinishedH\x00R\x15audioPlaybackFinished\x1a\xe7\x01\n" +
"\tConsoleIO\x1a\x94\x01\n" +
"\n" +
"AudioFrame\x12\x12\n" +
"\x04data\x18\x01 \x01(\fR\x04data\x12\x1f\n" +
"\vsample_rate\x18\x02 \x01(\rR\n" +
"sampleRate\x12!\n" +
"\fnum_channels\x18\x03 \x01(\rR\vnumChannels\x12.\n" +
"\x13samples_per_channel\x18\x04 \x01(\rR\x11samplesPerChannel\x1a\x14\n" +
"\x12AudioPlaybackFlush\x1a\x14\n" +
"\x12AudioPlaybackClear\x1a\x17\n" +
"\x15AudioPlaybackFinishedB\t\n" +
"\amessage*>\n" +
"\bChatRole\x12\r\n" +
"\tDEVELOPER\x10\x00\x12\n" +
"\n" +
"\x06SYSTEM\x10\x01\x12\b\n" +
"\x04USER\x10\x02\x12\r\n" +
"\tASSISTANT\x10\x03*b\n" +
"\n" +
"AgentState\x12\x13\n" +
"\x0fAS_INITIALIZING\x10\x00\x12\v\n" +
"\aAS_IDLE\x10\x01\x12\x10\n" +
"\fAS_LISTENING\x10\x02\x12\x0f\n" +
"\vAS_THINKING\x10\x03\x12\x0f\n" +
"\vAS_SPEAKING\x10\x04*;\n" +
"\tUserState\x12\x0f\n" +
"\vUS_SPEAKING\x10\x00\x12\x10\n" +
"\fUS_LISTENING\x10\x01\x12\v\n" +
"\aUS_AWAY\x10\x02B+Z)github.com/livekit/protocol/livekit/agentb\x06proto3"
var (
file_agent_livekit_agent_session_proto_rawDescOnce sync.Once
file_agent_livekit_agent_session_proto_rawDescData []byte
)
func file_agent_livekit_agent_session_proto_rawDescGZIP() []byte {
file_agent_livekit_agent_session_proto_rawDescOnce.Do(func() {
file_agent_livekit_agent_session_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_agent_livekit_agent_session_proto_rawDesc), len(file_agent_livekit_agent_session_proto_rawDesc)))
})
return file_agent_livekit_agent_session_proto_rawDescData
}
var file_agent_livekit_agent_session_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
var file_agent_livekit_agent_session_proto_msgTypes = make([]protoimpl.MessageInfo, 48)
var file_agent_livekit_agent_session_proto_goTypes = []any{
(ChatRole)(0), (AgentState)(0), (UserState)(0), (*MetricsReport)(nil), (*ChatMessage)(nil), (*FunctionCall)(nil), (*FunctionCallOutput)(nil), (*AgentHandoff)(nil), (*AgentConfigUpdate)(nil), (*ChatContext)(nil), (*LLMModelUsage)(nil), (*TTSModelUsage)(nil), (*STTModelUsage)(nil), (*InterruptionModelUsage)(nil), (*ModelUsage)(nil), (*AgentSessionUsage)(nil), (*AgentSessionEvent)(nil), (*SessionRequest)(nil), (*SessionResponse)(nil), (*AgentSessionMessage)(nil), (*ChatMessage_ChatContent)(nil), nil, (*ChatContext_ChatItem)(nil), (*AgentSessionEvent_AgentStateChanged)(nil), (*AgentSessionEvent_UserStateChanged)(nil), (*AgentSessionEvent_ConversationItemAdded)(nil), (*AgentSessionEvent_UserInputTranscribed)(nil), (*AgentSessionEvent_FunctionToolsExecuted)(nil), (*AgentSessionEvent_Error)(nil), (*AgentSessionEvent_OverlappingSpeech)(nil), (*AgentSessionEvent_SessionUsageUpdated)(nil), (*SessionRequest_Ping)(nil), (*SessionRequest_GetChatHistory)(nil), (*SessionRequest_RunInput)(nil), (*SessionRequest_GetAgentInfo)(nil), (*SessionRequest_GetSessionState)(nil), (*SessionRequest_GetRTCStats)(nil), (*SessionRequest_GetSessionUsage)(nil), (*SessionResponse_Pong)(nil), (*SessionResponse_GetChatHistoryResponse)(nil), (*SessionResponse_GetAgentInfoResponse)(nil), (*SessionResponse_RunInputResponse)(nil), (*SessionResponse_GetSessionStateResponse)(nil), (*SessionResponse_GetRTCStatsResponse)(nil), (*SessionResponse_GetSessionUsageResponse)(nil), nil, (*AgentSessionMessage_ConsoleIO)(nil), (*AgentSessionMessage_ConsoleIO_AudioFrame)(nil), (*AgentSessionMessage_ConsoleIO_AudioPlaybackFlush)(nil), (*AgentSessionMessage_ConsoleIO_AudioPlaybackClear)(nil), (*AgentSessionMessage_ConsoleIO_AudioPlaybackFinished)(nil), (*timestamppb.Timestamp)(nil), (*structpb.Struct)(nil), }
var file_agent_livekit_agent_session_proto_depIdxs = []int32{
51, 51, 0, 20, 21, 3, 51, 51, 51, 51, 51, 22, 10, 11, 12, 13, 14, 51, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 41, 40, 42, 43, 44, 47, 47, 16, 17, 18, 48, 49, 50, 4, 5, 6, 7, 8, 1, 1, 2, 2, 22, 5, 6, 51, 51, 15, 22, 22, 22, 1, 2, 45, 51, 52, 52, 15, 51, 74, 74, 74, 74, 0, }
func init() { file_agent_livekit_agent_session_proto_init() }
func file_agent_livekit_agent_session_proto_init() {
if File_agent_livekit_agent_session_proto != nil {
return
}
file_agent_livekit_agent_session_proto_msgTypes[0].OneofWrappers = []any{}
file_agent_livekit_agent_session_proto_msgTypes[1].OneofWrappers = []any{}
file_agent_livekit_agent_session_proto_msgTypes[4].OneofWrappers = []any{}
file_agent_livekit_agent_session_proto_msgTypes[5].OneofWrappers = []any{}
file_agent_livekit_agent_session_proto_msgTypes[11].OneofWrappers = []any{
(*ModelUsage_Llm)(nil),
(*ModelUsage_Tts)(nil),
(*ModelUsage_Stt)(nil),
(*ModelUsage_Interruption)(nil),
}
file_agent_livekit_agent_session_proto_msgTypes[13].OneofWrappers = []any{
(*AgentSessionEvent_AgentStateChanged_)(nil),
(*AgentSessionEvent_UserStateChanged_)(nil),
(*AgentSessionEvent_ConversationItemAdded_)(nil),
(*AgentSessionEvent_UserInputTranscribed_)(nil),
(*AgentSessionEvent_FunctionToolsExecuted_)(nil),
(*AgentSessionEvent_Error_)(nil),
(*AgentSessionEvent_OverlappingSpeech_)(nil),
(*AgentSessionEvent_SessionUsageUpdated_)(nil),
}
file_agent_livekit_agent_session_proto_msgTypes[14].OneofWrappers = []any{
(*SessionRequest_Ping_)(nil),
(*SessionRequest_GetChatHistory_)(nil),
(*SessionRequest_RunInput_)(nil),
(*SessionRequest_GetAgentInfo_)(nil),
(*SessionRequest_GetSessionState_)(nil),
(*SessionRequest_GetRtcStats)(nil),
(*SessionRequest_GetSessionUsage_)(nil),
}
file_agent_livekit_agent_session_proto_msgTypes[15].OneofWrappers = []any{
(*SessionResponse_Pong_)(nil),
(*SessionResponse_GetChatHistory)(nil),
(*SessionResponse_RunInput)(nil),
(*SessionResponse_GetAgentInfo)(nil),
(*SessionResponse_GetSessionState)(nil),
(*SessionResponse_GetRtcStats)(nil),
(*SessionResponse_GetSessionUsage)(nil),
}
file_agent_livekit_agent_session_proto_msgTypes[16].OneofWrappers = []any{
(*AgentSessionMessage_AudioInput)(nil),
(*AgentSessionMessage_AudioOutput)(nil),
(*AgentSessionMessage_Event)(nil),
(*AgentSessionMessage_Request)(nil),
(*AgentSessionMessage_Response)(nil),
(*AgentSessionMessage_AudioPlaybackFlush)(nil),
(*AgentSessionMessage_AudioPlaybackClear)(nil),
(*AgentSessionMessage_AudioPlaybackFinished)(nil),
}
file_agent_livekit_agent_session_proto_msgTypes[17].OneofWrappers = []any{
(*ChatMessage_ChatContent_Text)(nil),
}
file_agent_livekit_agent_session_proto_msgTypes[19].OneofWrappers = []any{
(*ChatContext_ChatItem_Message)(nil),
(*ChatContext_ChatItem_FunctionCall)(nil),
(*ChatContext_ChatItem_FunctionCallOutput)(nil),
(*ChatContext_ChatItem_AgentHandoff)(nil),
(*ChatContext_ChatItem_AgentConfigUpdate)(nil),
}
file_agent_livekit_agent_session_proto_msgTypes[23].OneofWrappers = []any{}
file_agent_livekit_agent_session_proto_msgTypes[26].OneofWrappers = []any{}
file_agent_livekit_agent_session_proto_msgTypes[37].OneofWrappers = []any{}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_agent_livekit_agent_session_proto_rawDesc), len(file_agent_livekit_agent_session_proto_rawDesc)),
NumEnums: 3,
NumMessages: 48,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_agent_livekit_agent_session_proto_goTypes,
DependencyIndexes: file_agent_livekit_agent_session_proto_depIdxs,
EnumInfos: file_agent_livekit_agent_session_proto_enumTypes,
MessageInfos: file_agent_livekit_agent_session_proto_msgTypes,
}.Build()
File_agent_livekit_agent_session_proto = out.File
file_agent_livekit_agent_session_proto_goTypes = nil
file_agent_livekit_agent_session_proto_depIdxs = nil
}