From 315b308b297c32d349f5ef562f044bc1a2d0694f Mon Sep 17 00:00:00 2001 From: Steve Yoon Date: Thu, 21 May 2026 16:08:09 -0400 Subject: [PATCH 1/2] use worker protocol version --- livekit/livekit_agent_worker.pb.go | 167 ++++++++++------------- livekit/livekit_agent_worker_protocol.go | 27 ++++ protobufs/livekit_agent_worker.proto | 16 +-- 3 files changed, 106 insertions(+), 104 deletions(-) create mode 100644 livekit/livekit_agent_worker_protocol.go diff --git a/livekit/livekit_agent_worker.pb.go b/livekit/livekit_agent_worker.pb.go index 5e3bc0406..114e9b08e 100644 --- a/livekit/livekit_agent_worker.pb.go +++ b/livekit/livekit_agent_worker.pb.go @@ -21,12 +21,12 @@ package livekit import ( + reflect "reflect" + sync "sync" + _ "github.com/livekit/protocol/livekit/logger" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" - reflect "reflect" - sync "sync" - unsafe "unsafe" ) const ( @@ -37,22 +37,25 @@ const ( ) type WorkerInfo struct { - state protoimpl.MessageState `protogen:"open.v1"` - WorkerType string `protobuf:"bytes,1,opt,name=worker_type,json=workerType,proto3" json:"worker_type,omitempty"` - AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` - ActiveJobs float32 `protobuf:"fixed32,3,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"` - SdkVersion string `protobuf:"bytes,4,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"` - WorkerLoad float32 `protobuf:"fixed32,5,opt,name=worker_load,json=workerLoad,proto3" json:"worker_load,omitempty"` - Flags *WorkerInfo_FeatureFlags `protobuf:"bytes,6,opt,name=flags,proto3" json:"flags,omitempty"` - unknownFields protoimpl.UnknownFields + state protoimpl.MessageState sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + WorkerType string `protobuf:"bytes,1,opt,name=worker_type,json=workerType,proto3" json:"worker_type,omitempty"` + AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` + ActiveJobs float32 `protobuf:"fixed32,3,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"` + SdkVersion string `protobuf:"bytes,4,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"` + WorkerLoad float32 `protobuf:"fixed32,5,opt,name=worker_load,json=workerLoad,proto3" json:"worker_load,omitempty"` + ProtocolVersion int32 `protobuf:"varint,6,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` } func (x *WorkerInfo) Reset() { *x = WorkerInfo{} - mi := &file_livekit_agent_worker_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) + if protoimpl.UnsafeEnabled { + mi := &file_livekit_agent_worker_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } func (x *WorkerInfo) String() string { @@ -63,7 +66,7 @@ func (*WorkerInfo) ProtoMessage() {} func (x *WorkerInfo) ProtoReflect() protoreflect.Message { mi := &file_livekit_agent_worker_proto_msgTypes[0] - if x != nil { + if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -113,102 +116,63 @@ func (x *WorkerInfo) GetWorkerLoad() float32 { return 0 } -func (x *WorkerInfo) GetFlags() *WorkerInfo_FeatureFlags { - if x != nil { - return x.Flags - } - return nil -} - -type WorkerInfo_FeatureFlags struct { - state protoimpl.MessageState `protogen:"open.v1"` - AgentDeploymentEnabled bool `protobuf:"varint,1,opt,name=agent_deployment_enabled,json=agentDeploymentEnabled,proto3" json:"agent_deployment_enabled,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *WorkerInfo_FeatureFlags) Reset() { - *x = WorkerInfo_FeatureFlags{} - mi := &file_livekit_agent_worker_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *WorkerInfo_FeatureFlags) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*WorkerInfo_FeatureFlags) ProtoMessage() {} - -func (x *WorkerInfo_FeatureFlags) ProtoReflect() protoreflect.Message { - mi := &file_livekit_agent_worker_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) -} - -// Deprecated: Use WorkerInfo_FeatureFlags.ProtoReflect.Descriptor instead. -func (*WorkerInfo_FeatureFlags) Descriptor() ([]byte, []int) { - return file_livekit_agent_worker_proto_rawDescGZIP(), []int{0, 0} -} - -func (x *WorkerInfo_FeatureFlags) GetAgentDeploymentEnabled() bool { +func (x *WorkerInfo) GetProtocolVersion() int32 { if x != nil { - return x.AgentDeploymentEnabled + return x.ProtocolVersion } - return false + return 0 } var File_livekit_agent_worker_proto protoreflect.FileDescriptor -const file_livekit_agent_worker_proto_rawDesc = "" + - "\n" + - "\x1alivekit_agent_worker.proto\x12\alivekit\x1a\x14logger/options.proto\"\xb1\x02\n" + - "\n" + - "WorkerInfo\x12\x1f\n" + - "\vworker_type\x18\x01 \x01(\tR\n" + - "workerType\x12\x1d\n" + - "\n" + - "agent_name\x18\x02 \x01(\tR\tagentName\x12\x1f\n" + - "\vactive_jobs\x18\x03 \x01(\x02R\n" + - "activeJobs\x12\x1f\n" + - "\vsdk_version\x18\x04 \x01(\tR\n" + - "sdkVersion\x12\x1f\n" + - "\vworker_load\x18\x05 \x01(\x02R\n" + - "workerLoad\x126\n" + - "\x05flags\x18\x06 \x01(\v2 .livekit.WorkerInfo.FeatureFlagsR\x05flags\x1aH\n" + - "\fFeatureFlags\x128\n" + - "\x18agent_deployment_enabled\x18\x01 \x01(\bR\x16agentDeploymentEnabledBFZ#github.com/livekit/protocol/livekit\xaa\x02\rLiveKit.Proto\xea\x02\x0eLiveKit::Protob\x06proto3" +var file_livekit_agent_worker_proto_rawDesc = []byte{ + 0x0a, 0x1a, 0x6c, 0x69, 0x76, 0x65, 0x6b, 0x69, 0x74, 0x5f, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x5f, + 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x07, 0x6c, 0x69, + 0x76, 0x65, 0x6b, 0x69, 0x74, 0x1a, 0x14, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x2f, 0x6f, 0x70, + 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xda, 0x01, 0x0a, 0x0a, + 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x1f, 0x0a, 0x0b, 0x77, 0x6f, + 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x61, + 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x09, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x61, 0x63, + 0x74, 0x69, 0x76, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x02, 0x52, + 0x0a, 0x61, 0x63, 0x74, 0x69, 0x76, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x73, + 0x64, 0x6b, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x0a, 0x73, 0x64, 0x6b, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, + 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, + 0x02, 0x52, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x4c, 0x6f, 0x61, 0x64, 0x12, 0x29, 0x0a, + 0x10, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, + 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x46, 0x5a, 0x23, 0x67, 0x69, 0x74, 0x68, + 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x69, 0x76, 0x65, 0x6b, 0x69, 0x74, 0x2f, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2f, 0x6c, 0x69, 0x76, 0x65, 0x6b, 0x69, 0x74, 0xaa, + 0x02, 0x0d, 0x4c, 0x69, 0x76, 0x65, 0x4b, 0x69, 0x74, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0xea, + 0x02, 0x0e, 0x4c, 0x69, 0x76, 0x65, 0x4b, 0x69, 0x74, 0x3a, 0x3a, 0x50, 0x72, 0x6f, 0x74, 0x6f, + 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} var ( file_livekit_agent_worker_proto_rawDescOnce sync.Once - file_livekit_agent_worker_proto_rawDescData []byte + file_livekit_agent_worker_proto_rawDescData = file_livekit_agent_worker_proto_rawDesc ) func file_livekit_agent_worker_proto_rawDescGZIP() []byte { file_livekit_agent_worker_proto_rawDescOnce.Do(func() { - file_livekit_agent_worker_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_livekit_agent_worker_proto_rawDesc), len(file_livekit_agent_worker_proto_rawDesc))) + file_livekit_agent_worker_proto_rawDescData = protoimpl.X.CompressGZIP(file_livekit_agent_worker_proto_rawDescData) }) return file_livekit_agent_worker_proto_rawDescData } -var file_livekit_agent_worker_proto_msgTypes = make([]protoimpl.MessageInfo, 2) -var file_livekit_agent_worker_proto_goTypes = []any{ - (*WorkerInfo)(nil), // 0: livekit.WorkerInfo - (*WorkerInfo_FeatureFlags)(nil), // 1: livekit.WorkerInfo.FeatureFlags +var file_livekit_agent_worker_proto_msgTypes = make([]protoimpl.MessageInfo, 1) +var file_livekit_agent_worker_proto_goTypes = []interface{}{ + (*WorkerInfo)(nil), // 0: livekit.WorkerInfo } var file_livekit_agent_worker_proto_depIdxs = []int32{ - 1, // 0: livekit.WorkerInfo.flags:type_name -> livekit.WorkerInfo.FeatureFlags - 1, // [1:1] is the sub-list for method output_type - 1, // [1:1] is the sub-list for method input_type - 1, // [1:1] is the sub-list for extension type_name - 1, // [1:1] is the sub-list for extension extendee - 0, // [0:1] is the sub-list for field type_name + 0, // [0:0] is the sub-list for method output_type + 0, // [0:0] is the sub-list for method input_type + 0, // [0:0] is the sub-list for extension type_name + 0, // [0:0] is the sub-list for extension extendee + 0, // [0:0] is the sub-list for field type_name } func init() { file_livekit_agent_worker_proto_init() } @@ -216,13 +180,27 @@ func file_livekit_agent_worker_proto_init() { if File_livekit_agent_worker_proto != nil { return } + if !protoimpl.UnsafeEnabled { + file_livekit_agent_worker_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*WorkerInfo); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_livekit_agent_worker_proto_rawDesc), len(file_livekit_agent_worker_proto_rawDesc)), + RawDescriptor: file_livekit_agent_worker_proto_rawDesc, NumEnums: 0, - NumMessages: 2, + NumMessages: 1, NumExtensions: 0, NumServices: 0, }, @@ -231,6 +209,7 @@ func file_livekit_agent_worker_proto_init() { MessageInfos: file_livekit_agent_worker_proto_msgTypes, }.Build() File_livekit_agent_worker_proto = out.File + file_livekit_agent_worker_proto_rawDesc = nil file_livekit_agent_worker_proto_goTypes = nil file_livekit_agent_worker_proto_depIdxs = nil } diff --git a/livekit/livekit_agent_worker_protocol.go b/livekit/livekit_agent_worker_protocol.go new file mode 100644 index 000000000..358677469 --- /dev/null +++ b/livekit/livekit_agent_worker_protocol.go @@ -0,0 +1,27 @@ +// Copyright 2023 LiveKit, Inc. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package livekit + +type WorkerProtocolVersion int + +const CurrentWorkerProtocol = 1 + +func (v WorkerProtocolVersion) SupportsAgentDeployment() bool { + return v > 0 +} + +func (info *WorkerInfo) Protocol() WorkerProtocolVersion { + return WorkerProtocolVersion(info.GetProtocolVersion()) +} diff --git a/protobufs/livekit_agent_worker.proto b/protobufs/livekit_agent_worker.proto index a123a0a43..f92075f8c 100644 --- a/protobufs/livekit_agent_worker.proto +++ b/protobufs/livekit_agent_worker.proto @@ -22,14 +22,10 @@ option ruby_package = "LiveKit::Proto"; import "logger/options.proto"; message WorkerInfo { - message FeatureFlags { - bool agent_deployment_enabled = 1; - } - - string worker_type = 1; - string agent_name = 2; - float active_jobs = 3; - string sdk_version = 4; - float worker_load = 5; - FeatureFlags flags = 6; + string worker_type = 1; + string agent_name = 2; + float active_jobs = 3; + string sdk_version = 4; + float worker_load = 5; + int32 protocol_version = 6; } From a4a4495524918ed6a2be544c92b9ddc9138010b1 Mon Sep 17 00:00:00 2001 From: github-actions <41898282+github-actions[bot]@users.noreply.github.com> Date: Thu, 21 May 2026 20:12:52 +0000 Subject: [PATCH 2/2] generated protobuf --- livekit/livekit_agent_worker.pb.go | 99 +++++++++++------------------- 1 file changed, 36 insertions(+), 63 deletions(-) diff --git a/livekit/livekit_agent_worker.pb.go b/livekit/livekit_agent_worker.pb.go index 114e9b08e..a8de95840 100644 --- a/livekit/livekit_agent_worker.pb.go +++ b/livekit/livekit_agent_worker.pb.go @@ -21,12 +21,12 @@ package livekit import ( - reflect "reflect" - sync "sync" - _ "github.com/livekit/protocol/livekit/logger" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" ) const ( @@ -37,25 +37,22 @@ const ( ) type WorkerInfo struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - WorkerType string `protobuf:"bytes,1,opt,name=worker_type,json=workerType,proto3" json:"worker_type,omitempty"` - AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` - ActiveJobs float32 `protobuf:"fixed32,3,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"` - SdkVersion string `protobuf:"bytes,4,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"` - WorkerLoad float32 `protobuf:"fixed32,5,opt,name=worker_load,json=workerLoad,proto3" json:"worker_load,omitempty"` - ProtocolVersion int32 `protobuf:"varint,6,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + WorkerType string `protobuf:"bytes,1,opt,name=worker_type,json=workerType,proto3" json:"worker_type,omitempty"` + AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` + ActiveJobs float32 `protobuf:"fixed32,3,opt,name=active_jobs,json=activeJobs,proto3" json:"active_jobs,omitempty"` + SdkVersion string `protobuf:"bytes,4,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"` + WorkerLoad float32 `protobuf:"fixed32,5,opt,name=worker_load,json=workerLoad,proto3" json:"worker_load,omitempty"` + ProtocolVersion int32 `protobuf:"varint,6,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *WorkerInfo) Reset() { *x = WorkerInfo{} - if protoimpl.UnsafeEnabled { - mi := &file_livekit_agent_worker_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } + mi := &file_livekit_agent_worker_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } func (x *WorkerInfo) String() string { @@ -66,7 +63,7 @@ func (*WorkerInfo) ProtoMessage() {} func (x *WorkerInfo) ProtoReflect() protoreflect.Message { mi := &file_livekit_agent_worker_proto_msgTypes[0] - if protoimpl.UnsafeEnabled && x != nil { + if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) @@ -125,46 +122,37 @@ func (x *WorkerInfo) GetProtocolVersion() int32 { var File_livekit_agent_worker_proto protoreflect.FileDescriptor -var file_livekit_agent_worker_proto_rawDesc = []byte{ - 0x0a, 0x1a, 0x6c, 0x69, 0x76, 0x65, 0x6b, 0x69, 0x74, 0x5f, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x5f, - 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x07, 0x6c, 0x69, - 0x76, 0x65, 0x6b, 0x69, 0x74, 0x1a, 0x14, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x2f, 0x6f, 0x70, - 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xda, 0x01, 0x0a, 0x0a, - 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x1f, 0x0a, 0x0b, 0x77, 0x6f, - 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x61, - 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x09, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x61, 0x63, - 0x74, 0x69, 0x76, 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x02, 0x52, - 0x0a, 0x61, 0x63, 0x74, 0x69, 0x76, 0x65, 0x4a, 0x6f, 0x62, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x73, - 0x64, 0x6b, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x0a, 0x73, 0x64, 0x6b, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, - 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, - 0x02, 0x52, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x4c, 0x6f, 0x61, 0x64, 0x12, 0x29, 0x0a, - 0x10, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, - 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, - 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x46, 0x5a, 0x23, 0x67, 0x69, 0x74, 0x68, - 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x69, 0x76, 0x65, 0x6b, 0x69, 0x74, 0x2f, 0x70, - 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2f, 0x6c, 0x69, 0x76, 0x65, 0x6b, 0x69, 0x74, 0xaa, - 0x02, 0x0d, 0x4c, 0x69, 0x76, 0x65, 0x4b, 0x69, 0x74, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0xea, - 0x02, 0x0e, 0x4c, 0x69, 0x76, 0x65, 0x4b, 0x69, 0x74, 0x3a, 0x3a, 0x50, 0x72, 0x6f, 0x74, 0x6f, - 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -} +const file_livekit_agent_worker_proto_rawDesc = "" + + "\n" + + "\x1alivekit_agent_worker.proto\x12\alivekit\x1a\x14logger/options.proto\"\xda\x01\n" + + "\n" + + "WorkerInfo\x12\x1f\n" + + "\vworker_type\x18\x01 \x01(\tR\n" + + "workerType\x12\x1d\n" + + "\n" + + "agent_name\x18\x02 \x01(\tR\tagentName\x12\x1f\n" + + "\vactive_jobs\x18\x03 \x01(\x02R\n" + + "activeJobs\x12\x1f\n" + + "\vsdk_version\x18\x04 \x01(\tR\n" + + "sdkVersion\x12\x1f\n" + + "\vworker_load\x18\x05 \x01(\x02R\n" + + "workerLoad\x12)\n" + + "\x10protocol_version\x18\x06 \x01(\x05R\x0fprotocolVersionBFZ#github.com/livekit/protocol/livekit\xaa\x02\rLiveKit.Proto\xea\x02\x0eLiveKit::Protob\x06proto3" var ( file_livekit_agent_worker_proto_rawDescOnce sync.Once - file_livekit_agent_worker_proto_rawDescData = file_livekit_agent_worker_proto_rawDesc + file_livekit_agent_worker_proto_rawDescData []byte ) func file_livekit_agent_worker_proto_rawDescGZIP() []byte { file_livekit_agent_worker_proto_rawDescOnce.Do(func() { - file_livekit_agent_worker_proto_rawDescData = protoimpl.X.CompressGZIP(file_livekit_agent_worker_proto_rawDescData) + file_livekit_agent_worker_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_livekit_agent_worker_proto_rawDesc), len(file_livekit_agent_worker_proto_rawDesc))) }) return file_livekit_agent_worker_proto_rawDescData } var file_livekit_agent_worker_proto_msgTypes = make([]protoimpl.MessageInfo, 1) -var file_livekit_agent_worker_proto_goTypes = []interface{}{ +var file_livekit_agent_worker_proto_goTypes = []any{ (*WorkerInfo)(nil), // 0: livekit.WorkerInfo } var file_livekit_agent_worker_proto_depIdxs = []int32{ @@ -180,25 +168,11 @@ func file_livekit_agent_worker_proto_init() { if File_livekit_agent_worker_proto != nil { return } - if !protoimpl.UnsafeEnabled { - file_livekit_agent_worker_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*WorkerInfo); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_livekit_agent_worker_proto_rawDesc, + RawDescriptor: unsafe.Slice(unsafe.StringData(file_livekit_agent_worker_proto_rawDesc), len(file_livekit_agent_worker_proto_rawDesc)), NumEnums: 0, NumMessages: 1, NumExtensions: 0, @@ -209,7 +183,6 @@ func file_livekit_agent_worker_proto_init() { MessageInfos: file_livekit_agent_worker_proto_msgTypes, }.Build() File_livekit_agent_worker_proto = out.File - file_livekit_agent_worker_proto_rawDesc = nil file_livekit_agent_worker_proto_goTypes = nil file_livekit_agent_worker_proto_depIdxs = nil }