From fed965f8e0c783b1839f993b94b4d5eda3f2597f Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Tue, 5 May 2026 13:22:55 -0700 Subject: [PATCH 1/4] rename agent environment to deployment --- agent/environment.go | 18 +- infra/link.pb.go | 4 +- infra/link_grpc.pb.go | 10 +- livekit/agent/livekit_agent_dev.pb.go | 4 +- livekit/agent/livekit_agent_inference.pb.go | 4 +- livekit/agent/livekit_agent_session.pb.go | 4 +- livekit/cloud_replay.pb.go | 4 +- livekit/livekit_agent.pb.go | 32 +-- livekit/livekit_agent_dispatch.pb.go | 44 ++-- livekit/livekit_agent_dispatch.twirp.go | 74 +++--- livekit/livekit_agent_simulation.pb.go | 4 +- livekit/livekit_analytics.pb.go | 4 +- livekit/livekit_cloud_agent.pb.go | 4 +- livekit/livekit_connector.pb.go | 4 +- livekit/livekit_connector_twilio.pb.go | 4 +- livekit/livekit_connector_whatsapp.pb.go | 4 +- livekit/livekit_egress.pb.go | 4 +- livekit/livekit_ingress.pb.go | 4 +- livekit/livekit_internal.pb.go | 4 +- livekit/livekit_metrics.pb.go | 4 +- livekit/livekit_models.pb.go | 4 +- livekit/livekit_phone_number.pb.go | 4 +- livekit/livekit_room.pb.go | 4 +- livekit/livekit_rtc.pb.go | 4 +- livekit/livekit_sip.pb.go | 4 +- livekit/livekit_token_source.pb.go | 4 +- livekit/livekit_webhook.pb.go | 4 +- livekit/logger/options.pb.go | 4 +- observability/agentsv2obs/agent.go | 42 ---- observability/agentsv2obs/gen_reporter.go | 142 ------------ .../agentsv2obs/gen_reporter_noop.go | 214 ------------------ observability/agentsv2obs/gen_source.go | 55 ----- observability/reporter.go | 8 +- protobufs/livekit_agent.proto | 4 +- protobufs/livekit_agent_dispatch.proto | 6 +- rpc/agent.pb.go | 4 +- rpc/agent_dispatch.pb.go | 4 +- rpc/analytics.pb.go | 4 +- rpc/analytics_grpc.pb.go | 12 +- rpc/egress.pb.go | 4 +- rpc/ingress.pb.go | 4 +- rpc/io.pb.go | 4 +- rpc/keepalive.pb.go | 4 +- rpc/participant.pb.go | 4 +- rpc/room.pb.go | 4 +- rpc/roommanager.pb.go | 4 +- rpc/signal.pb.go | 4 +- rpc/sip.pb.go | 4 +- rpc/whip_signal.pb.go | 4 +- 49 files changed, 181 insertions(+), 624 deletions(-) delete mode 100644 observability/agentsv2obs/agent.go delete mode 100644 observability/agentsv2obs/gen_reporter.go delete mode 100644 observability/agentsv2obs/gen_reporter_noop.go delete mode 100644 observability/agentsv2obs/gen_source.go diff --git a/agent/environment.go b/agent/environment.go index 4c1a5ff16..24acbb323 100644 --- a/agent/environment.go +++ b/agent/environment.go @@ -2,22 +2,22 @@ package agent import "fmt" -const MaxEnvironmentLength = 64 +const MaxDeploymentLength = 64 -func ValidateEnvironment(env string) error { - if env == "" { +func ValidateDeployment(deployment string) error { + if deployment == "" { return nil } - if len(env) > MaxEnvironmentLength { - return fmt.Errorf("environment exceeds %d bytes", MaxEnvironmentLength) + if len(deployment) > MaxDeploymentLength { + return fmt.Errorf("deployment exceeds %d bytes", MaxDeploymentLength) } - for i := 0; i < len(env); i++ { - c := env[i] + for i := 0; i < len(deployment); i++ { + c := deployment[i] switch { case c == '_': - return fmt.Errorf("environment contains reserved character %q", c) + return fmt.Errorf("deployment contains reserved character %q", c) case c <= ' ' || c == 0x7f: - return fmt.Errorf("environment contains whitespace or control byte at position %d", i) + return fmt.Errorf("deployment contains whitespace or control byte at position %d", i) } } return nil diff --git a/infra/link.pb.go b/infra/link.pb.go index 13859fa1d..551467630 100644 --- a/infra/link.pb.go +++ b/infra/link.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: infra/link.proto package infra diff --git a/infra/link_grpc.pb.go b/infra/link_grpc.pb.go index f5e2075a1..5da909b80 100644 --- a/infra/link_grpc.pb.go +++ b/infra/link_grpc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.6.1 -// - protoc v4.23.4 +// - protoc-gen-go-grpc v1.5.1 +// - protoc v6.33.0 // source: infra/link.proto package infra @@ -99,10 +99,10 @@ type LinkServer interface { type UnimplementedLinkServer struct{} func (UnimplementedLinkServer) WatchLocalLinks(*WatchLocalLinksRequest, grpc.ServerStreamingServer[WatchLocalLinksResponse]) error { - return status.Error(codes.Unimplemented, "method WatchLocalLinks not implemented") + return status.Errorf(codes.Unimplemented, "method WatchLocalLinks not implemented") } func (UnimplementedLinkServer) SimulateLinkState(context.Context, *SimulateLinkStateRequest) (*SimulateLinkStateResponse, error) { - return nil, status.Error(codes.Unimplemented, "method SimulateLinkState not implemented") + return nil, status.Errorf(codes.Unimplemented, "method SimulateLinkState not implemented") } func (UnimplementedLinkServer) mustEmbedUnimplementedLinkServer() {} func (UnimplementedLinkServer) testEmbeddedByValue() {} @@ -115,7 +115,7 @@ type UnsafeLinkServer interface { } func RegisterLinkServer(s grpc.ServiceRegistrar, srv LinkServer) { - // If the following call panics, it indicates UnimplementedLinkServer was + // If the following call pancis, it indicates UnimplementedLinkServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. diff --git a/livekit/agent/livekit_agent_dev.pb.go b/livekit/agent/livekit_agent_dev.pb.go index 4658f504d..c1ab13d10 100644 --- a/livekit/agent/livekit_agent_dev.pb.go +++ b/livekit/agent/livekit_agent_dev.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: agent/livekit_agent_dev.proto package agent diff --git a/livekit/agent/livekit_agent_inference.pb.go b/livekit/agent/livekit_agent_inference.pb.go index 7be8deb3e..101f2081a 100644 --- a/livekit/agent/livekit_agent_inference.pb.go +++ b/livekit/agent/livekit_agent_inference.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: agent/livekit_agent_inference.proto package agent diff --git a/livekit/agent/livekit_agent_session.pb.go b/livekit/agent/livekit_agent_session.pb.go index a7f3faccd..47658a649 100644 --- a/livekit/agent/livekit_agent_session.pb.go +++ b/livekit/agent/livekit_agent_session.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: agent/livekit_agent_session.proto package agent diff --git a/livekit/cloud_replay.pb.go b/livekit/cloud_replay.pb.go index f57c11a57..9b317995b 100644 --- a/livekit/cloud_replay.pb.go +++ b/livekit/cloud_replay.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: cloud_replay.proto package livekit diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go index 1725a6ccf..88afa73e0 100644 --- a/livekit/livekit_agent.pb.go +++ b/livekit/livekit_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_agent.proto package livekit @@ -196,7 +196,7 @@ type Job struct { AgentName string `protobuf:"bytes,7,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` State *JobState `protobuf:"bytes,8,opt,name=state,proto3" json:"state,omitempty"` EnableRecording bool `protobuf:"varint,10,opt,name=enable_recording,json=enableRecording,proto3" json:"enable_recording,omitempty"` - Environment string `protobuf:"bytes,11,opt,name=environment,proto3" json:"environment,omitempty"` + Deployment string `protobuf:"bytes,11,opt,name=deployment,proto3" json:"deployment,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -302,9 +302,9 @@ func (x *Job) GetEnableRecording() bool { return false } -func (x *Job) GetEnvironment() string { +func (x *Job) GetDeployment() string { if x != nil { - return x.Environment + return x.Deployment } return "" } @@ -875,7 +875,7 @@ type RegisterWorkerRequest struct { PingInterval uint32 `protobuf:"varint,5,opt,name=ping_interval,json=pingInterval,proto3" json:"ping_interval,omitempty"` Namespace *string `protobuf:"bytes,6,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` AllowedPermissions *ParticipantPermission `protobuf:"bytes,7,opt,name=allowed_permissions,json=allowedPermissions,proto3" json:"allowed_permissions,omitempty"` - Environment string `protobuf:"bytes,9,opt,name=environment,proto3" json:"environment,omitempty"` + Deployment string `protobuf:"bytes,9,opt,name=deployment,proto3" json:"deployment,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -952,9 +952,9 @@ func (x *RegisterWorkerRequest) GetAllowedPermissions() *ParticipantPermission { return nil } -func (x *RegisterWorkerRequest) GetEnvironment() string { +func (x *RegisterWorkerRequest) GetDeployment() string { if x != nil { - return x.Environment + return x.Deployment } return "" } @@ -1441,7 +1441,7 @@ var File_livekit_agent_proto protoreflect.FileDescriptor const file_livekit_agent_proto_rawDesc = "" + "\n" + - "\x13livekit_agent.proto\x12\alivekit\x1a\x14livekit_models.proto\x1a\x14logger/options.proto\"\xb2\x03\n" + + "\x13livekit_agent.proto\x12\alivekit\x1a\x14livekit_models.proto\x1a\x14logger/options.proto\"\xb0\x03\n" + "\x03Job\x12\x0e\n" + "\x02id\x18\x01 \x01(\tR\x02id\x12.\n" + "\vdispatch_id\x18\t \x01(\tB\r\xbaP\n" + @@ -1456,8 +1456,10 @@ const file_livekit_agent_proto_rawDesc = "" + "agent_name\x18\a \x01(\tR\tagentName\x12'\n" + "\x05state\x18\b \x01(\v2\x11.livekit.JobStateR\x05state\x12)\n" + "\x10enable_recording\x18\n" + - " \x01(\bR\x0fenableRecording\x12 \n" + - "\venvironment\x18\v \x01(\tR\venvironmentB\x0e\n" + + " \x01(\bR\x0fenableRecording\x12\x1e\n" + + "\n" + + "deployment\x18\v \x01(\tR\n" + + "deploymentB\x0e\n" + "\f_participant\"\xa9\x02\n" + "\bJobState\x12*\n" + "\x06status\x18\x01 \x01(\x0e2\x12.livekit.JobStatusR\x06status\x12\x14\n" + @@ -1501,7 +1503,7 @@ const file_livekit_agent_proto_rawDesc = "" + "\n" + "WorkerPong\x12%\n" + "\x0elast_timestamp\x18\x01 \x01(\x03R\rlastTimestamp\x12\x1c\n" + - "\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\"\xbf\x02\n" + + "\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\"\xbd\x02\n" + "\x15RegisterWorkerRequest\x12$\n" + "\x04type\x18\x01 \x01(\x0e2\x10.livekit.JobTypeR\x04type\x12\x1d\n" + "\n" + @@ -1509,8 +1511,10 @@ const file_livekit_agent_proto_rawDesc = "" + "\aversion\x18\x03 \x01(\tR\aversion\x12#\n" + "\rping_interval\x18\x05 \x01(\rR\fpingInterval\x12!\n" + "\tnamespace\x18\x06 \x01(\tH\x00R\tnamespace\x88\x01\x01\x12O\n" + - "\x13allowed_permissions\x18\a \x01(\v2\x1e.livekit.ParticipantPermissionR\x12allowedPermissions\x12 \n" + - "\venvironment\x18\t \x01(\tR\venvironmentB\f\n" + + "\x13allowed_permissions\x18\a \x01(\v2\x1e.livekit.ParticipantPermissionR\x12allowedPermissions\x12\x1e\n" + + "\n" + + "deployment\x18\t \x01(\tR\n" + + "deploymentB\f\n" + "\n" + "_namespace\"x\n" + "\x16RegisterWorkerResponse\x12(\n" + diff --git a/livekit/livekit_agent_dispatch.pb.go b/livekit/livekit_agent_dispatch.pb.go index 9afaf6d67..6a394c035 100644 --- a/livekit/livekit_agent_dispatch.pb.go +++ b/livekit/livekit_agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_agent_dispatch.proto package livekit @@ -88,7 +88,7 @@ type CreateAgentDispatchRequest struct { Room string `protobuf:"bytes,2,opt,name=room,proto3" json:"room,omitempty"` Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` RestartPolicy JobRestartPolicy `protobuf:"varint,4,opt,name=restart_policy,json=restartPolicy,proto3,enum=livekit.JobRestartPolicy" json:"restart_policy,omitempty"` // cloud only - Environment string `protobuf:"bytes,5,opt,name=environment,proto3" json:"environment,omitempty"` + Deployment string `protobuf:"bytes,5,opt,name=deployment,proto3" json:"deployment,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -151,9 +151,9 @@ func (x *CreateAgentDispatchRequest) GetRestartPolicy() JobRestartPolicy { return JobRestartPolicy_JRP_ON_FAILURE } -func (x *CreateAgentDispatchRequest) GetEnvironment() string { +func (x *CreateAgentDispatchRequest) GetDeployment() string { if x != nil { - return x.Environment + return x.Deployment } return "" } @@ -163,7 +163,7 @@ type RoomAgentDispatch struct { AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` RestartPolicy JobRestartPolicy `protobuf:"varint,3,opt,name=restart_policy,json=restartPolicy,proto3,enum=livekit.JobRestartPolicy" json:"restart_policy,omitempty"` // cloud only - Environment string `protobuf:"bytes,4,opt,name=environment,proto3" json:"environment,omitempty"` + Deployment string `protobuf:"bytes,4,opt,name=deployment,proto3" json:"deployment,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -219,9 +219,9 @@ func (x *RoomAgentDispatch) GetRestartPolicy() JobRestartPolicy { return JobRestartPolicy_JRP_ON_FAILURE } -func (x *RoomAgentDispatch) GetEnvironment() string { +func (x *RoomAgentDispatch) GetDeployment() string { if x != nil { - return x.Environment + return x.Deployment } return "" } @@ -382,7 +382,7 @@ type AgentDispatch struct { Metadata string `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` State *AgentDispatchState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"` RestartPolicy JobRestartPolicy `protobuf:"varint,6,opt,name=restart_policy,json=restartPolicy,proto3,enum=livekit.JobRestartPolicy" json:"restart_policy,omitempty"` // cloud only - Environment string `protobuf:"bytes,7,opt,name=environment,proto3" json:"environment,omitempty"` + Deployment string `protobuf:"bytes,7,opt,name=deployment,proto3" json:"deployment,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -459,9 +459,9 @@ func (x *AgentDispatch) GetRestartPolicy() JobRestartPolicy { return JobRestartPolicy_JRP_ON_FAILURE } -func (x *AgentDispatch) GetEnvironment() string { +func (x *AgentDispatch) GetDeployment() string { if x != nil { - return x.Environment + return x.Deployment } return "" } @@ -532,20 +532,24 @@ var File_livekit_agent_dispatch_proto protoreflect.FileDescriptor const file_livekit_agent_dispatch_proto_rawDesc = "" + "\n" + - "\x1clivekit_agent_dispatch.proto\x12\alivekit\x1a\x13livekit_agent.proto\x1a\x14logger/options.proto\"\xd4\x01\n" + + "\x1clivekit_agent_dispatch.proto\x12\alivekit\x1a\x13livekit_agent.proto\x1a\x14logger/options.proto\"\xd2\x01\n" + "\x1aCreateAgentDispatchRequest\x12\x1d\n" + "\n" + "agent_name\x18\x01 \x01(\tR\tagentName\x12\x12\n" + "\x04room\x18\x02 \x01(\tR\x04room\x12\x1f\n" + "\bmetadata\x18\x03 \x01(\tB\x03\xa8P\x01R\bmetadata\x12@\n" + - "\x0erestart_policy\x18\x04 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12 \n" + - "\venvironment\x18\x05 \x01(\tR\venvironment\"\xb7\x01\n" + + "\x0erestart_policy\x18\x04 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12\x1e\n" + + "\n" + + "deployment\x18\x05 \x01(\tR\n" + + "deployment\"\xb5\x01\n" + "\x11RoomAgentDispatch\x12\x1d\n" + "\n" + "agent_name\x18\x01 \x01(\tR\tagentName\x12\x1f\n" + "\bmetadata\x18\x02 \x01(\tB\x03\xa8P\x01R\bmetadata\x12@\n" + - "\x0erestart_policy\x18\x03 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12 \n" + - "\venvironment\x18\x04 \x01(\tR\venvironment\"`\n" + + "\x0erestart_policy\x18\x03 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12\x1e\n" + + "\n" + + "deployment\x18\x04 \x01(\tR\n" + + "deployment\"`\n" + "\x1aDeleteAgentDispatchRequest\x12.\n" + "\vdispatch_id\x18\x01 \x01(\tB\r\xbaP\n" + "dispatchIDR\n" + @@ -557,7 +561,7 @@ const file_livekit_agent_dispatch_proto_rawDesc = "" + "dispatchId\x12\x12\n" + "\x04room\x18\x02 \x01(\tR\x04room\"^\n" + "\x19ListAgentDispatchResponse\x12A\n" + - "\x10agent_dispatches\x18\x01 \x03(\v2\x16.livekit.AgentDispatchR\x0fagentDispatches\"\x8a\x02\n" + + "\x10agent_dispatches\x18\x01 \x03(\v2\x16.livekit.AgentDispatchR\x0fagentDispatches\"\x88\x02\n" + "\rAgentDispatch\x12\x0e\n" + "\x02id\x18\x01 \x01(\tR\x02id\x12\x1d\n" + "\n" + @@ -565,8 +569,10 @@ const file_livekit_agent_dispatch_proto_rawDesc = "" + "\x04room\x18\x03 \x01(\tR\x04room\x12\x1f\n" + "\bmetadata\x18\x04 \x01(\tB\x03\xa8P\x01R\bmetadata\x121\n" + "\x05state\x18\x05 \x01(\v2\x1b.livekit.AgentDispatchStateR\x05state\x12@\n" + - "\x0erestart_policy\x18\x06 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12 \n" + - "\venvironment\x18\a \x01(\tR\venvironment\"t\n" + + "\x0erestart_policy\x18\x06 \x01(\x0e2\x19.livekit.JobRestartPolicyR\rrestartPolicy\x12\x1e\n" + + "\n" + + "deployment\x18\a \x01(\tR\n" + + "deployment\"t\n" + "\x12AgentDispatchState\x12 \n" + "\x04jobs\x18\x01 \x03(\v2\f.livekit.JobR\x04jobs\x12\x1d\n" + "\n" + diff --git a/livekit/livekit_agent_dispatch.twirp.go b/livekit/livekit_agent_dispatch.twirp.go index c0831900d..eff396030 100644 --- a/livekit/livekit_agent_dispatch.twirp.go +++ b/livekit/livekit_agent_dispatch.twirp.go @@ -1076,41 +1076,41 @@ func (s *agentDispatchServiceServer) PathPrefix() string { var twirpFileDescriptor1 = []byte{ // 582 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x54, 0xc1, 0x6e, 0xd3, 0x4c, - 0x10, 0xfe, 0x6d, 0xa7, 0xed, 0x9f, 0x49, 0x63, 0xc2, 0x52, 0x21, 0xd7, 0x80, 0x08, 0xe9, 0xa5, - 0xe2, 0xe0, 0x8a, 0x20, 0x2e, 0x3d, 0x91, 0x92, 0x54, 0x6a, 0x09, 0x21, 0x5a, 0x54, 0x0e, 0x1c, - 0x30, 0x1b, 0x7b, 0x94, 0x2e, 0xc4, 0xde, 0x60, 0x6f, 0x23, 0xf1, 0x0a, 0xf0, 0x22, 0x88, 0x17, - 0x40, 0xe2, 0x39, 0x78, 0x0a, 0x9e, 0x02, 0x79, 0xed, 0x98, 0xb8, 0xb1, 0x01, 0xa9, 0xe2, 0xe6, - 0xf9, 0xe6, 0xf3, 0xec, 0xb7, 0x33, 0xdf, 0x2c, 0xdc, 0x9e, 0xf1, 0x05, 0xbe, 0xe3, 0xd2, 0x65, - 0x53, 0x0c, 0xa5, 0xeb, 0xf3, 0x78, 0xce, 0xa4, 0x77, 0xee, 0xcc, 0x23, 0x21, 0x05, 0xd9, 0xca, - 0xb2, 0xf6, 0x8d, 0x02, 0x2d, 0xcd, 0xda, 0x3b, 0x33, 0x31, 0x9d, 0x62, 0x74, 0x20, 0xe6, 0x92, - 0x8b, 0x30, 0x4e, 0xd1, 0xce, 0x77, 0x0d, 0xec, 0x27, 0x11, 0x32, 0x89, 0xbd, 0x84, 0xdb, 0xcf, - 0x2a, 0x52, 0x7c, 0x7f, 0x81, 0xb1, 0x24, 0x77, 0x00, 0xd2, 0xa3, 0x42, 0x16, 0xa0, 0xa5, 0xb5, - 0xb5, 0xfd, 0x3a, 0xad, 0x2b, 0x64, 0xc4, 0x02, 0x24, 0x04, 0x6a, 0x91, 0x10, 0x81, 0xa5, 0xab, - 0x84, 0xfa, 0x26, 0x77, 0xe1, 0xff, 0x00, 0x25, 0xf3, 0x99, 0x64, 0x96, 0x91, 0xe0, 0x47, 0xc6, - 0xe7, 0xb1, 0x46, 0x73, 0x90, 0x3c, 0x06, 0x33, 0xc2, 0x58, 0xb2, 0x48, 0xba, 0x73, 0x31, 0xe3, - 0xde, 0x07, 0xab, 0xd6, 0xd6, 0xf6, 0xcd, 0xee, 0xae, 0x93, 0xc9, 0x76, 0x4e, 0xc5, 0x84, 0xa6, - 0x8c, 0xb1, 0x22, 0xd0, 0x66, 0xb4, 0x1a, 0x92, 0x36, 0x34, 0x30, 0x5c, 0xf0, 0x48, 0x84, 0x01, - 0x86, 0xd2, 0xda, 0x50, 0xa7, 0xaf, 0x42, 0x9d, 0xaf, 0x1a, 0x5c, 0xa7, 0x42, 0x04, 0x85, 0x4b, - 0xfd, 0xe9, 0x36, 0xab, 0xca, 0xf5, 0xbf, 0x53, 0x6e, 0x5c, 0x4d, 0x79, 0x6d, 0x5d, 0xf9, 0x1b, - 0xb0, 0xfb, 0x38, 0xc3, 0x8a, 0x79, 0x38, 0xd0, 0x58, 0x0e, 0xdd, 0xe5, 0x7e, 0x7a, 0x85, 0xa3, - 0xe6, 0xb7, 0x31, 0x2c, 0xd1, 0x93, 0x3e, 0xfd, 0xf5, 0xed, 0x97, 0x0d, 0xa8, 0xf3, 0x1a, 0xac, - 0x21, 0x8f, 0xe5, 0x3f, 0xac, 0xbf, 0x5b, 0x52, 0x3f, 0x9e, 0x8b, 0x30, 0x46, 0xd2, 0x83, 0x56, - 0xd1, 0xbb, 0x18, 0x5b, 0x5a, 0xdb, 0xd8, 0x6f, 0x74, 0x6f, 0xe6, 0x4d, 0x2c, 0xfe, 0x79, 0x8d, - 0xad, 0x86, 0x18, 0x77, 0x3e, 0xea, 0xd0, 0x2c, 0xce, 0xd5, 0x04, 0x7d, 0x29, 0x96, 0xea, 0xdc, - 0xbf, 0x34, 0x67, 0xbd, 0xca, 0xb5, 0x46, 0x85, 0x6b, 0x6b, 0x65, 0xb3, 0x7f, 0x00, 0x1b, 0xb1, - 0x64, 0x12, 0x95, 0xdb, 0x1a, 0xdd, 0x5b, 0xe5, 0x6a, 0x5f, 0x24, 0x14, 0x9a, 0x32, 0x4b, 0xec, - 0xb2, 0x79, 0x35, 0xbb, 0x6c, 0xad, 0xdb, 0x45, 0x02, 0x59, 0x17, 0x40, 0xda, 0x50, 0x7b, 0x2b, - 0x26, 0xcb, 0xce, 0x6e, 0x17, 0xce, 0x53, 0x99, 0xa4, 0x45, 0x9e, 0x5a, 0x7b, 0xdf, 0x65, 0x52, - 0xb5, 0xc8, 0xa0, 0xf5, 0x0c, 0xe9, 0xa9, 0xbd, 0xf7, 0x95, 0x0b, 0x55, 0xda, 0x48, 0xd3, 0x19, - 0xd2, 0x93, 0xf7, 0x1f, 0x41, 0xeb, 0xb2, 0x74, 0x42, 0xc0, 0x3c, 0xa5, 0x63, 0xf7, 0xf9, 0xc8, - 0x3d, 0xee, 0x9d, 0x0c, 0xcf, 0xe8, 0xa0, 0xf5, 0x1f, 0x69, 0x42, 0x3d, 0xc1, 0x46, 0x83, 0x97, - 0x03, 0xda, 0xd2, 0xba, 0x9f, 0x74, 0xd8, 0x29, 0xaa, 0xc5, 0x68, 0xc1, 0x3d, 0x24, 0xcf, 0xc0, - 0x4c, 0x1f, 0xa1, 0x7c, 0xa4, 0x7b, 0xb9, 0xe6, 0xea, 0xd7, 0xc9, 0xae, 0xb0, 0x4c, 0x52, 0x2e, - 0xdd, 0xa1, 0x92, 0x72, 0xd5, 0xcb, 0x55, 0x59, 0xee, 0x0c, 0xb6, 0x13, 0x43, 0xe7, 0xf1, 0xbd, - 0x9c, 0x57, 0xb5, 0x47, 0x76, 0xe7, 0x77, 0x94, 0x74, 0x15, 0x8e, 0x8e, 0x5f, 0xed, 0x4d, 0xb9, - 0x3c, 0xbf, 0x98, 0x38, 0x9e, 0x08, 0x0e, 0x32, 0xfe, 0x81, 0x7a, 0x96, 0x3d, 0x31, 0x5b, 0x02, - 0x5f, 0xf4, 0xe6, 0x90, 0x2f, 0xf0, 0x29, 0x97, 0xce, 0x38, 0x49, 0xfd, 0xd0, 0xcd, 0x2c, 0x3e, - 0x3c, 0x54, 0xc0, 0x64, 0x53, 0xfd, 0xf2, 0xf0, 0x67, 0x00, 0x00, 0x00, 0xff, 0xff, 0x8c, 0xb8, - 0xd3, 0x09, 0x1d, 0x06, 0x00, 0x00, + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x54, 0xcd, 0x6e, 0xd3, 0x4c, + 0x14, 0xfd, 0x6c, 0xa7, 0xed, 0x97, 0x9b, 0xc6, 0x84, 0xa1, 0x42, 0xae, 0xf9, 0x0b, 0xe9, 0x26, + 0x62, 0xe1, 0x88, 0x20, 0x36, 0x5d, 0x91, 0x90, 0x54, 0x6a, 0x09, 0x21, 0x1a, 0x54, 0x16, 0x2c, + 0x30, 0x13, 0x7b, 0x94, 0x0e, 0xd8, 0x19, 0x63, 0x4f, 0x23, 0xf5, 0x0d, 0x90, 0x78, 0x11, 0xc4, + 0x9e, 0x0d, 0x8f, 0xc1, 0x63, 0xf0, 0x14, 0xc8, 0xe3, 0x1f, 0xe2, 0xc6, 0x06, 0xa4, 0x8a, 0x9d, + 0xe7, 0xdc, 0xe3, 0x7b, 0xcf, 0xdc, 0x7b, 0xee, 0xc0, 0x6d, 0x8f, 0xad, 0xe8, 0x7b, 0x26, 0x6c, + 0xb2, 0xa0, 0x4b, 0x61, 0xbb, 0x2c, 0x0a, 0x88, 0x70, 0xce, 0xac, 0x20, 0xe4, 0x82, 0xa3, 0x9d, + 0x34, 0x6a, 0xde, 0x28, 0xd0, 0x92, 0xa8, 0xb9, 0xe7, 0xf1, 0xc5, 0x82, 0x86, 0x3d, 0x1e, 0x08, + 0xc6, 0x97, 0x51, 0x82, 0x76, 0xbe, 0x2b, 0x60, 0x3e, 0x0d, 0x29, 0x11, 0x74, 0x10, 0x73, 0x47, + 0x69, 0x46, 0x4c, 0x3f, 0x9c, 0xd3, 0x48, 0xa0, 0x3b, 0x00, 0x49, 0xa9, 0x25, 0xf1, 0xa9, 0xa1, + 0xb4, 0x95, 0x6e, 0x1d, 0xd7, 0x25, 0x32, 0x25, 0x3e, 0x45, 0x08, 0x6a, 0x21, 0xe7, 0xbe, 0xa1, + 0xca, 0x80, 0xfc, 0x46, 0xf7, 0xe0, 0x7f, 0x9f, 0x0a, 0xe2, 0x12, 0x41, 0x0c, 0x2d, 0xc6, 0x87, + 0xda, 0xe7, 0x99, 0x82, 0x73, 0x10, 0x3d, 0x01, 0x3d, 0xa4, 0x91, 0x20, 0xa1, 0xb0, 0x03, 0xee, + 0x31, 0xe7, 0xc2, 0xa8, 0xb5, 0x95, 0xae, 0xde, 0xdf, 0xb7, 0x52, 0xd9, 0xd6, 0x09, 0x9f, 0xe3, + 0x84, 0x31, 0x93, 0x04, 0xdc, 0x0c, 0xd7, 0x8f, 0xe8, 0x2e, 0x80, 0x4b, 0x03, 0x8f, 0x5f, 0xf8, + 0x74, 0x29, 0x8c, 0x2d, 0x59, 0x7c, 0x0d, 0xe9, 0x7c, 0x55, 0xe0, 0x3a, 0xe6, 0xdc, 0x2f, 0x5c, + 0xe9, 0x4f, 0x77, 0x59, 0xd7, 0xad, 0xfe, 0x9d, 0x6e, 0xed, 0x4a, 0xba, 0x6b, 0x1b, 0xba, 0xdf, + 0x82, 0x39, 0xa2, 0x1e, 0xad, 0x98, 0x85, 0x05, 0x8d, 0x6c, 0xe0, 0x36, 0x73, 0x93, 0x0b, 0x0c, + 0x9b, 0xdf, 0x66, 0x90, 0xa1, 0xc7, 0x23, 0xfc, 0xeb, 0xdb, 0x2d, 0x1b, 0x4e, 0xe7, 0x0d, 0x18, + 0x13, 0x16, 0x89, 0x7f, 0x98, 0x7f, 0xbf, 0x24, 0x7f, 0x14, 0xf0, 0x65, 0x44, 0xd1, 0x00, 0x5a, + 0x45, 0xdf, 0xd2, 0xc8, 0x50, 0xda, 0x5a, 0xb7, 0xd1, 0xbf, 0x99, 0xb7, 0xb0, 0xf8, 0xe7, 0x35, + 0xb2, 0x7e, 0xa4, 0x51, 0xe7, 0xa3, 0x0a, 0xcd, 0xe2, 0x54, 0x75, 0x50, 0x33, 0xb1, 0x58, 0x65, + 0xee, 0xa5, 0x29, 0xab, 0x55, 0x8e, 0xd5, 0x2a, 0x1c, 0x5b, 0x2b, 0x9b, 0xfc, 0x43, 0xd8, 0x8a, + 0x04, 0x11, 0x54, 0x5a, 0xad, 0xd1, 0xbf, 0x55, 0xae, 0xf6, 0x65, 0x4c, 0xc1, 0x09, 0xb3, 0xc4, + 0x2c, 0xdb, 0x57, 0x32, 0xcb, 0xce, 0x86, 0x59, 0x04, 0xa0, 0xcd, 0xf2, 0xa8, 0x0d, 0xb5, 0x77, + 0x7c, 0x9e, 0xf5, 0x75, 0xb7, 0x50, 0x4d, 0x46, 0xe2, 0x06, 0x39, 0x72, 0xe1, 0x5d, 0x9b, 0x08, + 0xd9, 0x20, 0x0d, 0xd7, 0x53, 0x64, 0x20, 0x37, 0xde, 0x95, 0x1e, 0x94, 0x61, 0x2d, 0x09, 0xa7, + 0xc8, 0x40, 0x3c, 0x78, 0x0c, 0xad, 0xcb, 0xc2, 0x11, 0x02, 0xfd, 0x04, 0xcf, 0xec, 0x17, 0x53, + 0xfb, 0x68, 0x70, 0x3c, 0x39, 0xc5, 0xe3, 0xd6, 0x7f, 0xa8, 0x09, 0xf5, 0x18, 0x9b, 0x8e, 0x5f, + 0x8d, 0x71, 0x4b, 0xe9, 0x7f, 0x52, 0x61, 0xaf, 0xa8, 0x96, 0x86, 0x2b, 0xe6, 0x50, 0xf4, 0x1c, + 0xf4, 0xe4, 0xf9, 0xc9, 0x07, 0x7a, 0x90, 0x6b, 0xae, 0x7e, 0x97, 0xcc, 0x0a, 0xc3, 0xc4, 0xe9, + 0x92, 0x0d, 0x2a, 0x49, 0x57, 0xbd, 0x5a, 0x95, 0xe9, 0x4e, 0x61, 0x37, 0xb6, 0x73, 0x7e, 0xbe, + 0x9f, 0xf3, 0xaa, 0xb6, 0xc8, 0xec, 0xfc, 0x8e, 0x92, 0x2c, 0xc2, 0xf0, 0xe8, 0xf5, 0xc1, 0x82, + 0x89, 0xb3, 0xf3, 0xb9, 0xe5, 0x70, 0xbf, 0x97, 0xf2, 0x7b, 0xf2, 0x41, 0x76, 0xb8, 0x97, 0x01, + 0x5f, 0xd4, 0xe6, 0x84, 0xad, 0xe8, 0x33, 0x26, 0xac, 0x59, 0x1c, 0xfa, 0xa1, 0xea, 0xe9, 0xf9, + 0xf0, 0x50, 0x02, 0xf3, 0x6d, 0xf9, 0xcb, 0xa3, 0x9f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x0d, 0xcf, + 0x6a, 0x4d, 0x17, 0x06, 0x00, 0x00, } diff --git a/livekit/livekit_agent_simulation.pb.go b/livekit/livekit_agent_simulation.pb.go index 6b38b18eb..b68678731 100644 --- a/livekit/livekit_agent_simulation.pb.go +++ b/livekit/livekit_agent_simulation.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_agent_simulation.proto package livekit diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go index 71596ea97..9212a8d7d 100644 --- a/livekit/livekit_analytics.pb.go +++ b/livekit/livekit_analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_analytics.proto package livekit diff --git a/livekit/livekit_cloud_agent.pb.go b/livekit/livekit_cloud_agent.pb.go index 7060acc86..dd38ec618 100644 --- a/livekit/livekit_cloud_agent.pb.go +++ b/livekit/livekit_cloud_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_cloud_agent.proto package livekit diff --git a/livekit/livekit_connector.pb.go b/livekit/livekit_connector.pb.go index 1cfe227f8..e9edce4aa 100644 --- a/livekit/livekit_connector.pb.go +++ b/livekit/livekit_connector.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_connector.proto package livekit diff --git a/livekit/livekit_connector_twilio.pb.go b/livekit/livekit_connector_twilio.pb.go index 18cb8d0c8..dbef57de5 100644 --- a/livekit/livekit_connector_twilio.pb.go +++ b/livekit/livekit_connector_twilio.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_connector_twilio.proto package livekit diff --git a/livekit/livekit_connector_whatsapp.pb.go b/livekit/livekit_connector_whatsapp.pb.go index b42f502c0..442a24c11 100644 --- a/livekit/livekit_connector_whatsapp.pb.go +++ b/livekit/livekit_connector_whatsapp.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_connector_whatsapp.proto package livekit diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go index 91a10dab0..245c0aaea 100644 --- a/livekit/livekit_egress.pb.go +++ b/livekit/livekit_egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_egress.proto package livekit diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go index d457d5e63..6aeb756d0 100644 --- a/livekit/livekit_ingress.pb.go +++ b/livekit/livekit_ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_ingress.proto package livekit diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go index d27a15194..311bb0791 100644 --- a/livekit/livekit_internal.pb.go +++ b/livekit/livekit_internal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_internal.proto package livekit diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index 2163d33cc..29332e6a9 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_metrics.proto package livekit diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index d9cb42bc1..0c4fb0536 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_models.proto package livekit diff --git a/livekit/livekit_phone_number.pb.go b/livekit/livekit_phone_number.pb.go index 7b2ad1eae..37ca28e58 100644 --- a/livekit/livekit_phone_number.pb.go +++ b/livekit/livekit_phone_number.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_phone_number.proto package livekit diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go index 013c26127..fc5e17525 100644 --- a/livekit/livekit_room.pb.go +++ b/livekit/livekit_room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_room.proto package livekit diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index f3fae5149..e32e37235 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_rtc.proto package livekit diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go index 4704c69e8..888f937a7 100644 --- a/livekit/livekit_sip.pb.go +++ b/livekit/livekit_sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_sip.proto package livekit diff --git a/livekit/livekit_token_source.pb.go b/livekit/livekit_token_source.pb.go index 4952c9ec7..2241c9568 100644 --- a/livekit/livekit_token_source.pb.go +++ b/livekit/livekit_token_source.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_token_source.proto package livekit diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go index 09594da82..6c9a0f5e1 100644 --- a/livekit/livekit_webhook.pb.go +++ b/livekit/livekit_webhook.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: livekit_webhook.proto package livekit diff --git a/livekit/logger/options.pb.go b/livekit/logger/options.pb.go index 455da6120..6edc2b8cc 100644 --- a/livekit/logger/options.pb.go +++ b/livekit/logger/options.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: logger/options.proto package logger diff --git a/observability/agentsv2obs/agent.go b/observability/agentsv2obs/agent.go deleted file mode 100644 index 8e7860680..000000000 --- a/observability/agentsv2obs/agent.go +++ /dev/null @@ -1,42 +0,0 @@ -package agentsv2obs - -import "github.com/livekit/protocol/livekit" - -func JobKindFromProto(kind livekit.JobType) JobKind { - switch kind { - case livekit.JobType_JT_ROOM: - return JobKindRoom - case livekit.JobType_JT_PUBLISHER: - return JobKindPublisher - case livekit.JobType_JT_PARTICIPANT: - return JobKindParticipant - default: - return JobKindUndefined - } -} - -func JobStatusFromProto(status livekit.JobStatus) JobStatus { - switch status { - case livekit.JobStatus_JS_PENDING: - return JobStatusPending - case livekit.JobStatus_JS_RUNNING: - return JobStatusRunning - case livekit.JobStatus_JS_SUCCESS: - return JobStatusSuccess - case livekit.JobStatus_JS_FAILED: - return JobStatusFailed - default: - return JobStatusUndefined - } -} - -func WorkerStatusFromProto(status livekit.WorkerStatus) WorkerStatus { - switch status { - case livekit.WorkerStatus_WS_AVAILABLE: - return WorkerStatusAvailable - case livekit.WorkerStatus_WS_FULL: - return WorkerStatusFull - default: - return WorkerStatusUndefined - } -} diff --git a/observability/agentsv2obs/gen_reporter.go b/observability/agentsv2obs/gen_reporter.go deleted file mode 100644 index 3407ab7a4..000000000 --- a/observability/agentsv2obs/gen_reporter.go +++ /dev/null @@ -1,142 +0,0 @@ -// Code generated; DO NOT EDIT. - -package agentsv2obs - -import ( - "time" -) - -const Version_Q2H41LG = true - -type KeyResolver interface { - Resolve(string) - Reset() -} - -type Reporter interface { - WithProject(id string) ProjectReporter - WithDeferredProject() (ProjectReporter, KeyResolver) -} - -type projectReporter interface { -} - -type ProjectTx interface { - projectReporter -} - -type ProjectReporter interface { - RegisterFunc(func(ts time.Time, tx ProjectTx) bool) - Tx(func(tx ProjectTx)) - TxAt(time.Time, func(tx ProjectTx)) - WithEnv(name string) EnvReporter - WithDeferredEnv() (EnvReporter, KeyResolver) - projectReporter -} - -type envReporter interface { -} - -type EnvTx interface { - Project() ProjectTx - envReporter -} - -type EnvReporter interface { - RegisterFunc(func(ts time.Time, tx EnvTx) bool) - Tx(func(tx EnvTx)) - TxAt(time.Time, func(tx EnvTx)) - WithCloudAgent(id string) CloudAgentReporter - WithDeferredCloudAgent() (CloudAgentReporter, KeyResolver) - envReporter -} - -type cloudAgentReporter interface { -} - -type CloudAgentTx interface { - Env() EnvTx - cloudAgentReporter -} - -type CloudAgentReporter interface { - RegisterFunc(func(ts time.Time, tx CloudAgentTx) bool) - Tx(func(tx CloudAgentTx)) - TxAt(time.Time, func(tx CloudAgentTx)) - WithAgent(name string) AgentReporter - WithDeferredAgent() (AgentReporter, KeyResolver) - cloudAgentReporter -} - -type agentReporter interface { -} - -type AgentTx interface { - CloudAgent() CloudAgentTx - agentReporter -} - -type AgentReporter interface { - RegisterFunc(func(ts time.Time, tx AgentTx) bool) - Tx(func(tx AgentTx)) - TxAt(time.Time, func(tx AgentTx)) - WithWorker(id string) WorkerReporter - WithDeferredWorker() (WorkerReporter, KeyResolver) - agentReporter -} - -type workerReporter interface { - ReportLoad(v float32) - ReportStatus(v WorkerStatus) - ReportStartTime(v time.Time) - ReportEndTime(v time.Time) - ReportJobsCurrent(v uint32) - ReportLive(v uint8) - ReportCPU(v int64) - ReportCPULimit(v int64) - ReportMem(v int64) - ReportMemLimit(v int64) - ReportRegion(v string) - ReportVersion(v string) - ReportSdkVersion(v string) - ReportState(v WorkerState) -} - -type WorkerTx interface { - Agent() AgentTx - workerReporter -} - -type WorkerReporter interface { - RegisterFunc(func(ts time.Time, tx WorkerTx) bool) - Tx(func(tx WorkerTx)) - TxAt(time.Time, func(tx WorkerTx)) - WithJob(id string) JobReporter - WithDeferredJob() (JobReporter, KeyResolver) - workerReporter -} - -type jobReporter interface { - ReportRoomSessionID(v string) - ReportKind(v JobKind) - ReportWorkerKind(v WorkerKind) - ReportStatus(v JobStatus) - ReportDuration(v uint32) - ReportDurationSeconds(v uint32) - ReportDurationMinutes(v uint8) - ReportStartTime(v time.Time) - ReportEndTime(v time.Time) - ReportJoinLatency(v uint32) -} - -type JobTx interface { - Worker() WorkerTx - jobReporter -} - -type JobReporter interface { - RegisterFunc(func(ts time.Time, tx JobTx) bool) - Tx(func(tx JobTx)) - TxAt(time.Time, func(tx JobTx)) - jobReporter -} diff --git a/observability/agentsv2obs/gen_reporter_noop.go b/observability/agentsv2obs/gen_reporter_noop.go deleted file mode 100644 index 5694bd54c..000000000 --- a/observability/agentsv2obs/gen_reporter_noop.go +++ /dev/null @@ -1,214 +0,0 @@ -// Code generated; DO NOT EDIT. - -package agentsv2obs - -import ( - "time" -) - -var ( - _ Reporter = (*noopReporter)(nil) - _ ProjectReporter = (*noopProjectReporter)(nil) - _ ProjectTx = (*noopProjectTx)(nil) - _ EnvReporter = (*noopEnvReporter)(nil) - _ EnvTx = (*noopEnvTx)(nil) - _ CloudAgentReporter = (*noopCloudAgentReporter)(nil) - _ CloudAgentTx = (*noopCloudAgentTx)(nil) - _ AgentReporter = (*noopAgentReporter)(nil) - _ AgentTx = (*noopAgentTx)(nil) - _ WorkerReporter = (*noopWorkerReporter)(nil) - _ WorkerTx = (*noopWorkerTx)(nil) - _ JobReporter = (*noopJobReporter)(nil) - _ JobTx = (*noopJobTx)(nil) -) - -type noopKeyResolver struct{} - -func (noopKeyResolver) Resolve(string) {} -func (noopKeyResolver) Reset() {} - -type noopReporter struct{} - -func NewNoopReporter() Reporter { - return &noopReporter{} -} - -func (r *noopReporter) WithProject(id string) ProjectReporter { - return &noopProjectReporter{} -} - -func (r *noopReporter) WithDeferredProject() (ProjectReporter, KeyResolver) { - return &noopProjectReporter{}, noopKeyResolver{} -} - -type noopProjectReporter struct{} - -func NewNoopProjectReporter() ProjectReporter { - return &noopProjectReporter{} -} - -func (r *noopProjectReporter) RegisterFunc(f func(ts time.Time, tx ProjectTx) bool) {} -func (r *noopProjectReporter) Tx(f func(ProjectTx)) {} -func (r *noopProjectReporter) TxAt(ts time.Time, f func(ProjectTx)) {} -func (r *noopProjectReporter) WithEnv(name string) EnvReporter { - return &noopEnvReporter{} -} -func (r *noopProjectReporter) WithDeferredEnv() (EnvReporter, KeyResolver) { - return &noopEnvReporter{}, noopKeyResolver{} -} - -type noopProjectTx struct{} - -type noopEnvReporter struct{} - -func NewNoopEnvReporter() EnvReporter { - return &noopEnvReporter{} -} - -func (r *noopEnvReporter) RegisterFunc(f func(ts time.Time, tx EnvTx) bool) {} -func (r *noopEnvReporter) Tx(f func(EnvTx)) {} -func (r *noopEnvReporter) TxAt(ts time.Time, f func(EnvTx)) {} -func (r *noopEnvReporter) WithCloudAgent(id string) CloudAgentReporter { - return &noopCloudAgentReporter{} -} -func (r *noopEnvReporter) WithDeferredCloudAgent() (CloudAgentReporter, KeyResolver) { - return &noopCloudAgentReporter{}, noopKeyResolver{} -} - -type noopEnvTx struct{} - -func (t *noopEnvTx) Project() ProjectTx { - return &noopProjectTx{} -} - -type noopCloudAgentReporter struct{} - -func NewNoopCloudAgentReporter() CloudAgentReporter { - return &noopCloudAgentReporter{} -} - -func (r *noopCloudAgentReporter) RegisterFunc(f func(ts time.Time, tx CloudAgentTx) bool) {} -func (r *noopCloudAgentReporter) Tx(f func(CloudAgentTx)) {} -func (r *noopCloudAgentReporter) TxAt(ts time.Time, f func(CloudAgentTx)) {} -func (r *noopCloudAgentReporter) WithAgent(name string) AgentReporter { - return &noopAgentReporter{} -} -func (r *noopCloudAgentReporter) WithDeferredAgent() (AgentReporter, KeyResolver) { - return &noopAgentReporter{}, noopKeyResolver{} -} - -type noopCloudAgentTx struct{} - -func (t *noopCloudAgentTx) Env() EnvTx { - return &noopEnvTx{} -} - -type noopAgentReporter struct{} - -func NewNoopAgentReporter() AgentReporter { - return &noopAgentReporter{} -} - -func (r *noopAgentReporter) RegisterFunc(f func(ts time.Time, tx AgentTx) bool) {} -func (r *noopAgentReporter) Tx(f func(AgentTx)) {} -func (r *noopAgentReporter) TxAt(ts time.Time, f func(AgentTx)) {} -func (r *noopAgentReporter) WithWorker(id string) WorkerReporter { - return &noopWorkerReporter{} -} -func (r *noopAgentReporter) WithDeferredWorker() (WorkerReporter, KeyResolver) { - return &noopWorkerReporter{}, noopKeyResolver{} -} - -type noopAgentTx struct{} - -func (t *noopAgentTx) CloudAgent() CloudAgentTx { - return &noopCloudAgentTx{} -} - -type noopWorkerReporter struct{} - -func NewNoopWorkerReporter() WorkerReporter { - return &noopWorkerReporter{} -} - -func (r *noopWorkerReporter) RegisterFunc(f func(ts time.Time, tx WorkerTx) bool) {} -func (r *noopWorkerReporter) Tx(f func(WorkerTx)) {} -func (r *noopWorkerReporter) TxAt(ts time.Time, f func(WorkerTx)) {} -func (r *noopWorkerReporter) ReportLoad(v float32) {} -func (r *noopWorkerReporter) ReportStatus(v WorkerStatus) {} -func (r *noopWorkerReporter) ReportStartTime(v time.Time) {} -func (r *noopWorkerReporter) ReportEndTime(v time.Time) {} -func (r *noopWorkerReporter) ReportJobsCurrent(v uint32) {} -func (r *noopWorkerReporter) ReportLive(v uint8) {} -func (r *noopWorkerReporter) ReportCPU(v int64) {} -func (r *noopWorkerReporter) ReportCPULimit(v int64) {} -func (r *noopWorkerReporter) ReportMem(v int64) {} -func (r *noopWorkerReporter) ReportMemLimit(v int64) {} -func (r *noopWorkerReporter) ReportRegion(v string) {} -func (r *noopWorkerReporter) ReportVersion(v string) {} -func (r *noopWorkerReporter) ReportSdkVersion(v string) {} -func (r *noopWorkerReporter) ReportState(v WorkerState) {} -func (r *noopWorkerReporter) WithJob(id string) JobReporter { - return &noopJobReporter{} -} -func (r *noopWorkerReporter) WithDeferredJob() (JobReporter, KeyResolver) { - return &noopJobReporter{}, noopKeyResolver{} -} - -type noopWorkerTx struct{} - -func (t *noopWorkerTx) Agent() AgentTx { - return &noopAgentTx{} -} - -func (t *noopWorkerTx) ReportLoad(v float32) {} -func (t *noopWorkerTx) ReportStatus(v WorkerStatus) {} -func (t *noopWorkerTx) ReportStartTime(v time.Time) {} -func (t *noopWorkerTx) ReportEndTime(v time.Time) {} -func (t *noopWorkerTx) ReportJobsCurrent(v uint32) {} -func (t *noopWorkerTx) ReportLive(v uint8) {} -func (t *noopWorkerTx) ReportCPU(v int64) {} -func (t *noopWorkerTx) ReportCPULimit(v int64) {} -func (t *noopWorkerTx) ReportMem(v int64) {} -func (t *noopWorkerTx) ReportMemLimit(v int64) {} -func (t *noopWorkerTx) ReportRegion(v string) {} -func (t *noopWorkerTx) ReportVersion(v string) {} -func (t *noopWorkerTx) ReportSdkVersion(v string) {} -func (t *noopWorkerTx) ReportState(v WorkerState) {} - -type noopJobReporter struct{} - -func NewNoopJobReporter() JobReporter { - return &noopJobReporter{} -} - -func (r *noopJobReporter) RegisterFunc(f func(ts time.Time, tx JobTx) bool) {} -func (r *noopJobReporter) Tx(f func(JobTx)) {} -func (r *noopJobReporter) TxAt(ts time.Time, f func(JobTx)) {} -func (r *noopJobReporter) ReportRoomSessionID(v string) {} -func (r *noopJobReporter) ReportKind(v JobKind) {} -func (r *noopJobReporter) ReportWorkerKind(v WorkerKind) {} -func (r *noopJobReporter) ReportStatus(v JobStatus) {} -func (r *noopJobReporter) ReportDuration(v uint32) {} -func (r *noopJobReporter) ReportDurationSeconds(v uint32) {} -func (r *noopJobReporter) ReportDurationMinutes(v uint8) {} -func (r *noopJobReporter) ReportStartTime(v time.Time) {} -func (r *noopJobReporter) ReportEndTime(v time.Time) {} -func (r *noopJobReporter) ReportJoinLatency(v uint32) {} - -type noopJobTx struct{} - -func (t *noopJobTx) Worker() WorkerTx { - return &noopWorkerTx{} -} - -func (t *noopJobTx) ReportRoomSessionID(v string) {} -func (t *noopJobTx) ReportKind(v JobKind) {} -func (t *noopJobTx) ReportWorkerKind(v WorkerKind) {} -func (t *noopJobTx) ReportStatus(v JobStatus) {} -func (t *noopJobTx) ReportDuration(v uint32) {} -func (t *noopJobTx) ReportDurationSeconds(v uint32) {} -func (t *noopJobTx) ReportDurationMinutes(v uint8) {} -func (t *noopJobTx) ReportStartTime(v time.Time) {} -func (t *noopJobTx) ReportEndTime(v time.Time) {} -func (t *noopJobTx) ReportJoinLatency(v uint32) {} diff --git a/observability/agentsv2obs/gen_source.go b/observability/agentsv2obs/gen_source.go deleted file mode 100644 index 30680c903..000000000 --- a/observability/agentsv2obs/gen_source.go +++ /dev/null @@ -1,55 +0,0 @@ -// Code generated; DO NOT EDIT. -package agentsv2obs - -type WorkerStatus string - -const ( - WorkerStatusUndefined WorkerStatus = "" - WorkerStatusAvailable WorkerStatus = "available" - WorkerStatusFull WorkerStatus = "full" -) - -type WorkerState string - -const ( - WorkerStateUndefined WorkerState = "" - WorkerStateOnline WorkerState = "online" - WorkerStateOffline WorkerState = "offline" -) - -type JobKind string - -const ( - JobKindUndefined JobKind = "" - JobKindRoom JobKind = "room" - JobKindPublisher JobKind = "publisher" - JobKindParticipant JobKind = "participant" -) - -type WorkerKind string - -const ( - WorkerKindUndefined WorkerKind = "" - WorkerKindCloud WorkerKind = "cloud" - WorkerKindSelfhost WorkerKind = "selfhost" -) - -type JobStatus string - -const ( - JobStatusUndefined JobStatus = "" - JobStatusPending JobStatus = "pending" - JobStatusRunning JobStatus = "running" - JobStatusSuccess JobStatus = "success" - JobStatusFailed JobStatus = "failed" -) - -type Rollup string - -const ( - RollupUndefined Rollup = "" - RollupAgent Rollup = "agent" - RollupWorker Rollup = "worker" - RollupWorkerSeries Rollup = "worker_series" - RollupJob Rollup = "job" -) diff --git a/observability/reporter.go b/observability/reporter.go index eff488b9f..0adcb1210 100644 --- a/observability/reporter.go +++ b/observability/reporter.go @@ -3,7 +3,7 @@ package observability import ( "github.com/livekit/protocol/logger" "github.com/livekit/protocol/observability/agentsobs" - "github.com/livekit/protocol/observability/agentsv2obs" + "github.com/livekit/protocol/observability/agentsv3obs" "github.com/livekit/protocol/observability/corecallobs" "github.com/livekit/protocol/observability/egressobs" "github.com/livekit/protocol/observability/gatewayobs" @@ -20,7 +20,7 @@ type Reporter interface { Logger(name, projectID string) (logger.Logger, error) Room() roomobs.Reporter Agent() agentsobs.Reporter - AgentV2() agentsv2obs.Reporter + AgentV3() agentsv3obs.Reporter Gateway() gatewayobs.Reporter Telephony() telephonyobs.Reporter Egress() egressobs.Reporter @@ -49,8 +49,8 @@ func (reporter) Agent() agentsobs.Reporter { return agentsobs.NewNoopReporter() } -func (reporter) AgentV2() agentsv2obs.Reporter { - return agentsv2obs.NewNoopReporter() +func (reporter) AgentV3() agentsv3obs.Reporter { + return agentsv3obs.NewNoopReporter() } func (reporter) Gateway() gatewayobs.Reporter { diff --git a/protobufs/livekit_agent.proto b/protobufs/livekit_agent.proto index 7e00c2268..e269ab55a 100644 --- a/protobufs/livekit_agent.proto +++ b/protobufs/livekit_agent.proto @@ -33,7 +33,7 @@ message Job { string agent_name = 7; JobState state = 8; bool enable_recording = 10; - string environment = 11; + string deployment = 11; } message JobState { @@ -121,7 +121,7 @@ message RegisterWorkerRequest { uint32 ping_interval = 5; optional string namespace = 6; ParticipantPermission allowed_permissions = 7; - string environment = 9; + string deployment = 9; } message RegisterWorkerResponse { diff --git a/protobufs/livekit_agent_dispatch.proto b/protobufs/livekit_agent_dispatch.proto index 981981dc9..630efbff9 100644 --- a/protobufs/livekit_agent_dispatch.proto +++ b/protobufs/livekit_agent_dispatch.proto @@ -38,14 +38,14 @@ message CreateAgentDispatchRequest { string room = 2; string metadata = 3 [(logger.redact) = true]; JobRestartPolicy restart_policy = 4; // cloud only - string environment = 5; + string deployment = 5; } message RoomAgentDispatch { string agent_name = 1; string metadata = 2 [(logger.redact) = true]; JobRestartPolicy restart_policy = 3; // cloud only - string environment = 4; + string deployment = 4; } message DeleteAgentDispatchRequest { @@ -69,7 +69,7 @@ message AgentDispatch { string metadata = 4 [(logger.redact) = true]; AgentDispatchState state = 5; JobRestartPolicy restart_policy = 6; // cloud only - string environment = 7; + string deployment = 7; } message AgentDispatchState { diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go index 0ea4d2475..a0dd6fa8f 100644 --- a/rpc/agent.pb.go +++ b/rpc/agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/agent.proto package rpc diff --git a/rpc/agent_dispatch.pb.go b/rpc/agent_dispatch.pb.go index 85a469027..47ec4b924 100644 --- a/rpc/agent_dispatch.pb.go +++ b/rpc/agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/agent_dispatch.proto package rpc diff --git a/rpc/analytics.pb.go b/rpc/analytics.pb.go index 0e3352e2a..649c23f8a 100644 --- a/rpc/analytics.pb.go +++ b/rpc/analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/analytics.proto package rpc diff --git a/rpc/analytics_grpc.pb.go b/rpc/analytics_grpc.pb.go index 5c8c48002..994221a48 100644 --- a/rpc/analytics_grpc.pb.go +++ b/rpc/analytics_grpc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.6.1 -// - protoc v4.23.4 +// - protoc-gen-go-grpc v1.5.1 +// - protoc v6.33.0 // source: rpc/analytics.proto package rpc @@ -114,13 +114,13 @@ type AnalyticsRecorderServiceServer interface { type UnimplementedAnalyticsRecorderServiceServer struct{} func (UnimplementedAnalyticsRecorderServiceServer) IngestStats(grpc.ClientStreamingServer[livekit.AnalyticsStats, emptypb.Empty]) error { - return status.Error(codes.Unimplemented, "method IngestStats not implemented") + return status.Errorf(codes.Unimplemented, "method IngestStats not implemented") } func (UnimplementedAnalyticsRecorderServiceServer) IngestEvents(grpc.ClientStreamingServer[livekit.AnalyticsEvents, emptypb.Empty]) error { - return status.Error(codes.Unimplemented, "method IngestEvents not implemented") + return status.Errorf(codes.Unimplemented, "method IngestEvents not implemented") } func (UnimplementedAnalyticsRecorderServiceServer) IngestNodeRoomStates(grpc.ClientStreamingServer[livekit.AnalyticsNodeRooms, emptypb.Empty]) error { - return status.Error(codes.Unimplemented, "method IngestNodeRoomStates not implemented") + return status.Errorf(codes.Unimplemented, "method IngestNodeRoomStates not implemented") } func (UnimplementedAnalyticsRecorderServiceServer) mustEmbedUnimplementedAnalyticsRecorderServiceServer() { } @@ -134,7 +134,7 @@ type UnsafeAnalyticsRecorderServiceServer interface { } func RegisterAnalyticsRecorderServiceServer(s grpc.ServiceRegistrar, srv AnalyticsRecorderServiceServer) { - // If the following call panics, it indicates UnimplementedAnalyticsRecorderServiceServer was + // If the following call pancis, it indicates UnimplementedAnalyticsRecorderServiceServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go index 2a508d73a..dfba0fced 100644 --- a/rpc/egress.pb.go +++ b/rpc/egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/egress.proto package rpc diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go index 8ccc1d5c4..fe4760663 100644 --- a/rpc/ingress.pb.go +++ b/rpc/ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/ingress.proto package rpc diff --git a/rpc/io.pb.go b/rpc/io.pb.go index d038c33c4..0bd9db031 100644 --- a/rpc/io.pb.go +++ b/rpc/io.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/io.proto package rpc diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go index 1890702a2..71e94e740 100644 --- a/rpc/keepalive.pb.go +++ b/rpc/keepalive.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/keepalive.proto package rpc diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go index cffcbb5eb..3d53ad385 100644 --- a/rpc/participant.pb.go +++ b/rpc/participant.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/participant.proto package rpc diff --git a/rpc/room.pb.go b/rpc/room.pb.go index 2d25c8c79..69a8430ef 100644 --- a/rpc/room.pb.go +++ b/rpc/room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/room.proto package rpc diff --git a/rpc/roommanager.pb.go b/rpc/roommanager.pb.go index 54861c5a4..dc2219e19 100644 --- a/rpc/roommanager.pb.go +++ b/rpc/roommanager.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/roommanager.proto package rpc diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go index b9477d103..344eae247 100644 --- a/rpc/signal.pb.go +++ b/rpc/signal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/signal.proto package rpc diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go index ecfa1de69..c275b5ea1 100644 --- a/rpc/sip.pb.go +++ b/rpc/sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/sip.proto package rpc diff --git a/rpc/whip_signal.pb.go b/rpc/whip_signal.pb.go index e7a80bd45..e3ea2472c 100644 --- a/rpc/whip_signal.pb.go +++ b/rpc/whip_signal.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.11 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v6.33.0 // source: rpc/whip_signal.proto package rpc From 7a260f40c91275a0f22f67c70b79826ce05b39eb Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Tue, 5 May 2026 13:28:14 -0700 Subject: [PATCH 2/4] missing files --- observability/agentsv3obs/agent.go | 42 ++++ observability/agentsv3obs/gen_reporter.go | 142 ++++++++++++ .../agentsv3obs/gen_reporter_noop.go | 214 ++++++++++++++++++ observability/agentsv3obs/gen_source.go | 55 +++++ 4 files changed, 453 insertions(+) create mode 100644 observability/agentsv3obs/agent.go create mode 100644 observability/agentsv3obs/gen_reporter.go create mode 100644 observability/agentsv3obs/gen_reporter_noop.go create mode 100644 observability/agentsv3obs/gen_source.go diff --git a/observability/agentsv3obs/agent.go b/observability/agentsv3obs/agent.go new file mode 100644 index 000000000..fd677ca32 --- /dev/null +++ b/observability/agentsv3obs/agent.go @@ -0,0 +1,42 @@ +package agentsv3obs + +import "github.com/livekit/protocol/livekit" + +func JobKindFromProto(kind livekit.JobType) JobKind { + switch kind { + case livekit.JobType_JT_ROOM: + return JobKindRoom + case livekit.JobType_JT_PUBLISHER: + return JobKindPublisher + case livekit.JobType_JT_PARTICIPANT: + return JobKindParticipant + default: + return JobKindUndefined + } +} + +func JobStatusFromProto(status livekit.JobStatus) JobStatus { + switch status { + case livekit.JobStatus_JS_PENDING: + return JobStatusPending + case livekit.JobStatus_JS_RUNNING: + return JobStatusRunning + case livekit.JobStatus_JS_SUCCESS: + return JobStatusSuccess + case livekit.JobStatus_JS_FAILED: + return JobStatusFailed + default: + return JobStatusUndefined + } +} + +func WorkerStatusFromProto(status livekit.WorkerStatus) WorkerStatus { + switch status { + case livekit.WorkerStatus_WS_AVAILABLE: + return WorkerStatusAvailable + case livekit.WorkerStatus_WS_FULL: + return WorkerStatusFull + default: + return WorkerStatusUndefined + } +} diff --git a/observability/agentsv3obs/gen_reporter.go b/observability/agentsv3obs/gen_reporter.go new file mode 100644 index 000000000..bede61b73 --- /dev/null +++ b/observability/agentsv3obs/gen_reporter.go @@ -0,0 +1,142 @@ +// Code generated; DO NOT EDIT. + +package agentsv3obs + +import ( + "time" +) + +const Version_MAT8U20 = true + +type KeyResolver interface { + Resolve(string) + Reset() +} + +type Reporter interface { + WithProject(id string) ProjectReporter + WithDeferredProject() (ProjectReporter, KeyResolver) +} + +type projectReporter interface { +} + +type ProjectTx interface { + projectReporter +} + +type ProjectReporter interface { + RegisterFunc(func(ts time.Time, tx ProjectTx) bool) + Tx(func(tx ProjectTx)) + TxAt(time.Time, func(tx ProjectTx)) + WithCloudAgent(id string) CloudAgentReporter + WithDeferredCloudAgent() (CloudAgentReporter, KeyResolver) + projectReporter +} + +type cloudAgentReporter interface { +} + +type CloudAgentTx interface { + Project() ProjectTx + cloudAgentReporter +} + +type CloudAgentReporter interface { + RegisterFunc(func(ts time.Time, tx CloudAgentTx) bool) + Tx(func(tx CloudAgentTx)) + TxAt(time.Time, func(tx CloudAgentTx)) + WithAgent(name string) AgentReporter + WithDeferredAgent() (AgentReporter, KeyResolver) + cloudAgentReporter +} + +type agentReporter interface { +} + +type AgentTx interface { + CloudAgent() CloudAgentTx + agentReporter +} + +type AgentReporter interface { + RegisterFunc(func(ts time.Time, tx AgentTx) bool) + Tx(func(tx AgentTx)) + TxAt(time.Time, func(tx AgentTx)) + WithDeployment(name string) DeploymentReporter + WithDeferredDeployment() (DeploymentReporter, KeyResolver) + agentReporter +} + +type deploymentReporter interface { +} + +type DeploymentTx interface { + Agent() AgentTx + deploymentReporter +} + +type DeploymentReporter interface { + RegisterFunc(func(ts time.Time, tx DeploymentTx) bool) + Tx(func(tx DeploymentTx)) + TxAt(time.Time, func(tx DeploymentTx)) + WithWorker(id string) WorkerReporter + WithDeferredWorker() (WorkerReporter, KeyResolver) + deploymentReporter +} + +type workerReporter interface { + ReportLoad(v float32) + ReportStatus(v WorkerStatus) + ReportStartTime(v time.Time) + ReportEndTime(v time.Time) + ReportJobsCurrent(v uint32) + ReportLive(v uint8) + ReportCPU(v int64) + ReportCPULimit(v int64) + ReportMem(v int64) + ReportMemLimit(v int64) + ReportRegion(v string) + ReportVersion(v string) + ReportSdkVersion(v string) + ReportState(v WorkerState) +} + +type WorkerTx interface { + Deployment() DeploymentTx + workerReporter +} + +type WorkerReporter interface { + RegisterFunc(func(ts time.Time, tx WorkerTx) bool) + Tx(func(tx WorkerTx)) + TxAt(time.Time, func(tx WorkerTx)) + WithJob(id string) JobReporter + WithDeferredJob() (JobReporter, KeyResolver) + workerReporter +} + +type jobReporter interface { + ReportRoomSessionID(v string) + ReportKind(v JobKind) + ReportWorkerKind(v WorkerKind) + ReportStatus(v JobStatus) + ReportDuration(v uint32) + ReportDurationSeconds(v uint32) + ReportDurationMinutes(v uint8) + ReportStartTime(v time.Time) + ReportEndTime(v time.Time) + ReportJoinLatency(v uint32) +} + +type JobTx interface { + Worker() WorkerTx + jobReporter +} + +type JobReporter interface { + RegisterFunc(func(ts time.Time, tx JobTx) bool) + Tx(func(tx JobTx)) + TxAt(time.Time, func(tx JobTx)) + jobReporter +} diff --git a/observability/agentsv3obs/gen_reporter_noop.go b/observability/agentsv3obs/gen_reporter_noop.go new file mode 100644 index 000000000..250c2e160 --- /dev/null +++ b/observability/agentsv3obs/gen_reporter_noop.go @@ -0,0 +1,214 @@ +// Code generated; DO NOT EDIT. + +package agentsv3obs + +import ( + "time" +) + +var ( + _ Reporter = (*noopReporter)(nil) + _ ProjectReporter = (*noopProjectReporter)(nil) + _ ProjectTx = (*noopProjectTx)(nil) + _ CloudAgentReporter = (*noopCloudAgentReporter)(nil) + _ CloudAgentTx = (*noopCloudAgentTx)(nil) + _ AgentReporter = (*noopAgentReporter)(nil) + _ AgentTx = (*noopAgentTx)(nil) + _ DeploymentReporter = (*noopDeploymentReporter)(nil) + _ DeploymentTx = (*noopDeploymentTx)(nil) + _ WorkerReporter = (*noopWorkerReporter)(nil) + _ WorkerTx = (*noopWorkerTx)(nil) + _ JobReporter = (*noopJobReporter)(nil) + _ JobTx = (*noopJobTx)(nil) +) + +type noopKeyResolver struct{} + +func (noopKeyResolver) Resolve(string) {} +func (noopKeyResolver) Reset() {} + +type noopReporter struct{} + +func NewNoopReporter() Reporter { + return &noopReporter{} +} + +func (r *noopReporter) WithProject(id string) ProjectReporter { + return &noopProjectReporter{} +} + +func (r *noopReporter) WithDeferredProject() (ProjectReporter, KeyResolver) { + return &noopProjectReporter{}, noopKeyResolver{} +} + +type noopProjectReporter struct{} + +func NewNoopProjectReporter() ProjectReporter { + return &noopProjectReporter{} +} + +func (r *noopProjectReporter) RegisterFunc(f func(ts time.Time, tx ProjectTx) bool) {} +func (r *noopProjectReporter) Tx(f func(ProjectTx)) {} +func (r *noopProjectReporter) TxAt(ts time.Time, f func(ProjectTx)) {} +func (r *noopProjectReporter) WithCloudAgent(id string) CloudAgentReporter { + return &noopCloudAgentReporter{} +} +func (r *noopProjectReporter) WithDeferredCloudAgent() (CloudAgentReporter, KeyResolver) { + return &noopCloudAgentReporter{}, noopKeyResolver{} +} + +type noopProjectTx struct{} + +type noopCloudAgentReporter struct{} + +func NewNoopCloudAgentReporter() CloudAgentReporter { + return &noopCloudAgentReporter{} +} + +func (r *noopCloudAgentReporter) RegisterFunc(f func(ts time.Time, tx CloudAgentTx) bool) {} +func (r *noopCloudAgentReporter) Tx(f func(CloudAgentTx)) {} +func (r *noopCloudAgentReporter) TxAt(ts time.Time, f func(CloudAgentTx)) {} +func (r *noopCloudAgentReporter) WithAgent(name string) AgentReporter { + return &noopAgentReporter{} +} +func (r *noopCloudAgentReporter) WithDeferredAgent() (AgentReporter, KeyResolver) { + return &noopAgentReporter{}, noopKeyResolver{} +} + +type noopCloudAgentTx struct{} + +func (t *noopCloudAgentTx) Project() ProjectTx { + return &noopProjectTx{} +} + +type noopAgentReporter struct{} + +func NewNoopAgentReporter() AgentReporter { + return &noopAgentReporter{} +} + +func (r *noopAgentReporter) RegisterFunc(f func(ts time.Time, tx AgentTx) bool) {} +func (r *noopAgentReporter) Tx(f func(AgentTx)) {} +func (r *noopAgentReporter) TxAt(ts time.Time, f func(AgentTx)) {} +func (r *noopAgentReporter) WithDeployment(name string) DeploymentReporter { + return &noopDeploymentReporter{} +} +func (r *noopAgentReporter) WithDeferredDeployment() (DeploymentReporter, KeyResolver) { + return &noopDeploymentReporter{}, noopKeyResolver{} +} + +type noopAgentTx struct{} + +func (t *noopAgentTx) CloudAgent() CloudAgentTx { + return &noopCloudAgentTx{} +} + +type noopDeploymentReporter struct{} + +func NewNoopDeploymentReporter() DeploymentReporter { + return &noopDeploymentReporter{} +} + +func (r *noopDeploymentReporter) RegisterFunc(f func(ts time.Time, tx DeploymentTx) bool) {} +func (r *noopDeploymentReporter) Tx(f func(DeploymentTx)) {} +func (r *noopDeploymentReporter) TxAt(ts time.Time, f func(DeploymentTx)) {} +func (r *noopDeploymentReporter) WithWorker(id string) WorkerReporter { + return &noopWorkerReporter{} +} +func (r *noopDeploymentReporter) WithDeferredWorker() (WorkerReporter, KeyResolver) { + return &noopWorkerReporter{}, noopKeyResolver{} +} + +type noopDeploymentTx struct{} + +func (t *noopDeploymentTx) Agent() AgentTx { + return &noopAgentTx{} +} + +type noopWorkerReporter struct{} + +func NewNoopWorkerReporter() WorkerReporter { + return &noopWorkerReporter{} +} + +func (r *noopWorkerReporter) RegisterFunc(f func(ts time.Time, tx WorkerTx) bool) {} +func (r *noopWorkerReporter) Tx(f func(WorkerTx)) {} +func (r *noopWorkerReporter) TxAt(ts time.Time, f func(WorkerTx)) {} +func (r *noopWorkerReporter) ReportLoad(v float32) {} +func (r *noopWorkerReporter) ReportStatus(v WorkerStatus) {} +func (r *noopWorkerReporter) ReportStartTime(v time.Time) {} +func (r *noopWorkerReporter) ReportEndTime(v time.Time) {} +func (r *noopWorkerReporter) ReportJobsCurrent(v uint32) {} +func (r *noopWorkerReporter) ReportLive(v uint8) {} +func (r *noopWorkerReporter) ReportCPU(v int64) {} +func (r *noopWorkerReporter) ReportCPULimit(v int64) {} +func (r *noopWorkerReporter) ReportMem(v int64) {} +func (r *noopWorkerReporter) ReportMemLimit(v int64) {} +func (r *noopWorkerReporter) ReportRegion(v string) {} +func (r *noopWorkerReporter) ReportVersion(v string) {} +func (r *noopWorkerReporter) ReportSdkVersion(v string) {} +func (r *noopWorkerReporter) ReportState(v WorkerState) {} +func (r *noopWorkerReporter) WithJob(id string) JobReporter { + return &noopJobReporter{} +} +func (r *noopWorkerReporter) WithDeferredJob() (JobReporter, KeyResolver) { + return &noopJobReporter{}, noopKeyResolver{} +} + +type noopWorkerTx struct{} + +func (t *noopWorkerTx) Deployment() DeploymentTx { + return &noopDeploymentTx{} +} + +func (t *noopWorkerTx) ReportLoad(v float32) {} +func (t *noopWorkerTx) ReportStatus(v WorkerStatus) {} +func (t *noopWorkerTx) ReportStartTime(v time.Time) {} +func (t *noopWorkerTx) ReportEndTime(v time.Time) {} +func (t *noopWorkerTx) ReportJobsCurrent(v uint32) {} +func (t *noopWorkerTx) ReportLive(v uint8) {} +func (t *noopWorkerTx) ReportCPU(v int64) {} +func (t *noopWorkerTx) ReportCPULimit(v int64) {} +func (t *noopWorkerTx) ReportMem(v int64) {} +func (t *noopWorkerTx) ReportMemLimit(v int64) {} +func (t *noopWorkerTx) ReportRegion(v string) {} +func (t *noopWorkerTx) ReportVersion(v string) {} +func (t *noopWorkerTx) ReportSdkVersion(v string) {} +func (t *noopWorkerTx) ReportState(v WorkerState) {} + +type noopJobReporter struct{} + +func NewNoopJobReporter() JobReporter { + return &noopJobReporter{} +} + +func (r *noopJobReporter) RegisterFunc(f func(ts time.Time, tx JobTx) bool) {} +func (r *noopJobReporter) Tx(f func(JobTx)) {} +func (r *noopJobReporter) TxAt(ts time.Time, f func(JobTx)) {} +func (r *noopJobReporter) ReportRoomSessionID(v string) {} +func (r *noopJobReporter) ReportKind(v JobKind) {} +func (r *noopJobReporter) ReportWorkerKind(v WorkerKind) {} +func (r *noopJobReporter) ReportStatus(v JobStatus) {} +func (r *noopJobReporter) ReportDuration(v uint32) {} +func (r *noopJobReporter) ReportDurationSeconds(v uint32) {} +func (r *noopJobReporter) ReportDurationMinutes(v uint8) {} +func (r *noopJobReporter) ReportStartTime(v time.Time) {} +func (r *noopJobReporter) ReportEndTime(v time.Time) {} +func (r *noopJobReporter) ReportJoinLatency(v uint32) {} + +type noopJobTx struct{} + +func (t *noopJobTx) Worker() WorkerTx { + return &noopWorkerTx{} +} + +func (t *noopJobTx) ReportRoomSessionID(v string) {} +func (t *noopJobTx) ReportKind(v JobKind) {} +func (t *noopJobTx) ReportWorkerKind(v WorkerKind) {} +func (t *noopJobTx) ReportStatus(v JobStatus) {} +func (t *noopJobTx) ReportDuration(v uint32) {} +func (t *noopJobTx) ReportDurationSeconds(v uint32) {} +func (t *noopJobTx) ReportDurationMinutes(v uint8) {} +func (t *noopJobTx) ReportStartTime(v time.Time) {} +func (t *noopJobTx) ReportEndTime(v time.Time) {} +func (t *noopJobTx) ReportJoinLatency(v uint32) {} diff --git a/observability/agentsv3obs/gen_source.go b/observability/agentsv3obs/gen_source.go new file mode 100644 index 000000000..876176517 --- /dev/null +++ b/observability/agentsv3obs/gen_source.go @@ -0,0 +1,55 @@ +// Code generated; DO NOT EDIT. +package agentsv3obs + +type WorkerStatus string + +const ( + WorkerStatusUndefined WorkerStatus = "" + WorkerStatusAvailable WorkerStatus = "available" + WorkerStatusFull WorkerStatus = "full" +) + +type WorkerState string + +const ( + WorkerStateUndefined WorkerState = "" + WorkerStateOnline WorkerState = "online" + WorkerStateOffline WorkerState = "offline" +) + +type JobKind string + +const ( + JobKindUndefined JobKind = "" + JobKindRoom JobKind = "room" + JobKindPublisher JobKind = "publisher" + JobKindParticipant JobKind = "participant" +) + +type WorkerKind string + +const ( + WorkerKindUndefined WorkerKind = "" + WorkerKindCloud WorkerKind = "cloud" + WorkerKindSelfhost WorkerKind = "selfhost" +) + +type JobStatus string + +const ( + JobStatusUndefined JobStatus = "" + JobStatusPending JobStatus = "pending" + JobStatusRunning JobStatus = "running" + JobStatusSuccess JobStatus = "success" + JobStatusFailed JobStatus = "failed" +) + +type Rollup string + +const ( + RollupUndefined Rollup = "" + RollupAgent Rollup = "agent" + RollupWorker Rollup = "worker" + RollupWorkerSeries Rollup = "worker_series" + RollupJob Rollup = "job" +) From 5b855de2ec528d631460b037eb095a13683a9da7 Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Tue, 5 May 2026 13:28:39 -0700 Subject: [PATCH 3/4] Create purple-needles-juggle.md --- .changeset/purple-needles-juggle.md | 5 +++++ 1 file changed, 5 insertions(+) create mode 100644 .changeset/purple-needles-juggle.md diff --git a/.changeset/purple-needles-juggle.md b/.changeset/purple-needles-juggle.md new file mode 100644 index 000000000..829f5a9b8 --- /dev/null +++ b/.changeset/purple-needles-juggle.md @@ -0,0 +1,5 @@ +--- +"@livekit/protocol": patch +--- + +rename agent environment to deployment From 80c8ea4f94e79ce062d1a21b2ba2b506a90ecfff Mon Sep 17 00:00:00 2001 From: github-actions <41898282+github-actions[bot]@users.noreply.github.com> Date: Tue, 5 May 2026 20:30:21 +0000 Subject: [PATCH 4/4] generated protobuf --- infra/link.pb.go | 4 ++-- infra/link_grpc.pb.go | 10 +++++----- livekit/agent/livekit_agent_dev.pb.go | 4 ++-- livekit/agent/livekit_agent_inference.pb.go | 4 ++-- livekit/agent/livekit_agent_session.pb.go | 4 ++-- livekit/cloud_replay.pb.go | 4 ++-- livekit/livekit_agent.pb.go | 4 ++-- livekit/livekit_agent_dispatch.pb.go | 4 ++-- livekit/livekit_agent_simulation.pb.go | 4 ++-- livekit/livekit_analytics.pb.go | 4 ++-- livekit/livekit_cloud_agent.pb.go | 4 ++-- livekit/livekit_connector.pb.go | 4 ++-- livekit/livekit_connector_twilio.pb.go | 4 ++-- livekit/livekit_connector_whatsapp.pb.go | 4 ++-- livekit/livekit_egress.pb.go | 4 ++-- livekit/livekit_ingress.pb.go | 4 ++-- livekit/livekit_internal.pb.go | 4 ++-- livekit/livekit_metrics.pb.go | 4 ++-- livekit/livekit_models.pb.go | 4 ++-- livekit/livekit_phone_number.pb.go | 4 ++-- livekit/livekit_room.pb.go | 4 ++-- livekit/livekit_rtc.pb.go | 4 ++-- livekit/livekit_sip.pb.go | 4 ++-- livekit/livekit_token_source.pb.go | 4 ++-- livekit/livekit_webhook.pb.go | 4 ++-- livekit/logger/options.pb.go | 4 ++-- rpc/agent.pb.go | 4 ++-- rpc/agent_dispatch.pb.go | 4 ++-- rpc/analytics.pb.go | 4 ++-- rpc/analytics_grpc.pb.go | 12 ++++++------ rpc/egress.pb.go | 4 ++-- rpc/ingress.pb.go | 4 ++-- rpc/io.pb.go | 4 ++-- rpc/keepalive.pb.go | 4 ++-- rpc/participant.pb.go | 4 ++-- rpc/room.pb.go | 4 ++-- rpc/roommanager.pb.go | 4 ++-- rpc/signal.pb.go | 4 ++-- rpc/sip.pb.go | 4 ++-- rpc/whip_signal.pb.go | 4 ++-- 40 files changed, 87 insertions(+), 87 deletions(-) diff --git a/infra/link.pb.go b/infra/link.pb.go index 551467630..13859fa1d 100644 --- a/infra/link.pb.go +++ b/infra/link.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: infra/link.proto package infra diff --git a/infra/link_grpc.pb.go b/infra/link_grpc.pb.go index 5da909b80..f5e2075a1 100644 --- a/infra/link_grpc.pb.go +++ b/infra/link_grpc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.5.1 -// - protoc v6.33.0 +// - protoc-gen-go-grpc v1.6.1 +// - protoc v4.23.4 // source: infra/link.proto package infra @@ -99,10 +99,10 @@ type LinkServer interface { type UnimplementedLinkServer struct{} func (UnimplementedLinkServer) WatchLocalLinks(*WatchLocalLinksRequest, grpc.ServerStreamingServer[WatchLocalLinksResponse]) error { - return status.Errorf(codes.Unimplemented, "method WatchLocalLinks not implemented") + return status.Error(codes.Unimplemented, "method WatchLocalLinks not implemented") } func (UnimplementedLinkServer) SimulateLinkState(context.Context, *SimulateLinkStateRequest) (*SimulateLinkStateResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method SimulateLinkState not implemented") + return nil, status.Error(codes.Unimplemented, "method SimulateLinkState not implemented") } func (UnimplementedLinkServer) mustEmbedUnimplementedLinkServer() {} func (UnimplementedLinkServer) testEmbeddedByValue() {} @@ -115,7 +115,7 @@ type UnsafeLinkServer interface { } func RegisterLinkServer(s grpc.ServiceRegistrar, srv LinkServer) { - // If the following call pancis, it indicates UnimplementedLinkServer was + // If the following call panics, it indicates UnimplementedLinkServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. diff --git a/livekit/agent/livekit_agent_dev.pb.go b/livekit/agent/livekit_agent_dev.pb.go index c1ab13d10..4658f504d 100644 --- a/livekit/agent/livekit_agent_dev.pb.go +++ b/livekit/agent/livekit_agent_dev.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: agent/livekit_agent_dev.proto package agent diff --git a/livekit/agent/livekit_agent_inference.pb.go b/livekit/agent/livekit_agent_inference.pb.go index 101f2081a..7be8deb3e 100644 --- a/livekit/agent/livekit_agent_inference.pb.go +++ b/livekit/agent/livekit_agent_inference.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: agent/livekit_agent_inference.proto package agent diff --git a/livekit/agent/livekit_agent_session.pb.go b/livekit/agent/livekit_agent_session.pb.go index 47658a649..a7f3faccd 100644 --- a/livekit/agent/livekit_agent_session.pb.go +++ b/livekit/agent/livekit_agent_session.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: agent/livekit_agent_session.proto package agent diff --git a/livekit/cloud_replay.pb.go b/livekit/cloud_replay.pb.go index 9b317995b..f57c11a57 100644 --- a/livekit/cloud_replay.pb.go +++ b/livekit/cloud_replay.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: cloud_replay.proto package livekit diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go index 88afa73e0..1217609af 100644 --- a/livekit/livekit_agent.pb.go +++ b/livekit/livekit_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_agent.proto package livekit diff --git a/livekit/livekit_agent_dispatch.pb.go b/livekit/livekit_agent_dispatch.pb.go index 6a394c035..b7a4bc7fb 100644 --- a/livekit/livekit_agent_dispatch.pb.go +++ b/livekit/livekit_agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_agent_dispatch.proto package livekit diff --git a/livekit/livekit_agent_simulation.pb.go b/livekit/livekit_agent_simulation.pb.go index b68678731..6b38b18eb 100644 --- a/livekit/livekit_agent_simulation.pb.go +++ b/livekit/livekit_agent_simulation.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_agent_simulation.proto package livekit diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go index 9212a8d7d..71596ea97 100644 --- a/livekit/livekit_analytics.pb.go +++ b/livekit/livekit_analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_analytics.proto package livekit diff --git a/livekit/livekit_cloud_agent.pb.go b/livekit/livekit_cloud_agent.pb.go index dd38ec618..7060acc86 100644 --- a/livekit/livekit_cloud_agent.pb.go +++ b/livekit/livekit_cloud_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_cloud_agent.proto package livekit diff --git a/livekit/livekit_connector.pb.go b/livekit/livekit_connector.pb.go index e9edce4aa..1cfe227f8 100644 --- a/livekit/livekit_connector.pb.go +++ b/livekit/livekit_connector.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_connector.proto package livekit diff --git a/livekit/livekit_connector_twilio.pb.go b/livekit/livekit_connector_twilio.pb.go index dbef57de5..18cb8d0c8 100644 --- a/livekit/livekit_connector_twilio.pb.go +++ b/livekit/livekit_connector_twilio.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_connector_twilio.proto package livekit diff --git a/livekit/livekit_connector_whatsapp.pb.go b/livekit/livekit_connector_whatsapp.pb.go index 442a24c11..b42f502c0 100644 --- a/livekit/livekit_connector_whatsapp.pb.go +++ b/livekit/livekit_connector_whatsapp.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_connector_whatsapp.proto package livekit diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go index 245c0aaea..91a10dab0 100644 --- a/livekit/livekit_egress.pb.go +++ b/livekit/livekit_egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_egress.proto package livekit diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go index 6aeb756d0..d457d5e63 100644 --- a/livekit/livekit_ingress.pb.go +++ b/livekit/livekit_ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_ingress.proto package livekit diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go index 311bb0791..d27a15194 100644 --- a/livekit/livekit_internal.pb.go +++ b/livekit/livekit_internal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_internal.proto package livekit diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index 29332e6a9..2163d33cc 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_metrics.proto package livekit diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index 0c4fb0536..d9cb42bc1 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_models.proto package livekit diff --git a/livekit/livekit_phone_number.pb.go b/livekit/livekit_phone_number.pb.go index 37ca28e58..7b2ad1eae 100644 --- a/livekit/livekit_phone_number.pb.go +++ b/livekit/livekit_phone_number.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_phone_number.proto package livekit diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go index fc5e17525..013c26127 100644 --- a/livekit/livekit_room.pb.go +++ b/livekit/livekit_room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_room.proto package livekit diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index e32e37235..f3fae5149 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_rtc.proto package livekit diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go index 888f937a7..4704c69e8 100644 --- a/livekit/livekit_sip.pb.go +++ b/livekit/livekit_sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_sip.proto package livekit diff --git a/livekit/livekit_token_source.pb.go b/livekit/livekit_token_source.pb.go index 2241c9568..4952c9ec7 100644 --- a/livekit/livekit_token_source.pb.go +++ b/livekit/livekit_token_source.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_token_source.proto package livekit diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go index 6c9a0f5e1..09594da82 100644 --- a/livekit/livekit_webhook.pb.go +++ b/livekit/livekit_webhook.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: livekit_webhook.proto package livekit diff --git a/livekit/logger/options.pb.go b/livekit/logger/options.pb.go index 6edc2b8cc..455da6120 100644 --- a/livekit/logger/options.pb.go +++ b/livekit/logger/options.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: logger/options.proto package logger diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go index a0dd6fa8f..0ea4d2475 100644 --- a/rpc/agent.pb.go +++ b/rpc/agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/agent.proto package rpc diff --git a/rpc/agent_dispatch.pb.go b/rpc/agent_dispatch.pb.go index 47ec4b924..85a469027 100644 --- a/rpc/agent_dispatch.pb.go +++ b/rpc/agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/agent_dispatch.proto package rpc diff --git a/rpc/analytics.pb.go b/rpc/analytics.pb.go index 649c23f8a..0e3352e2a 100644 --- a/rpc/analytics.pb.go +++ b/rpc/analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/analytics.proto package rpc diff --git a/rpc/analytics_grpc.pb.go b/rpc/analytics_grpc.pb.go index 994221a48..5c8c48002 100644 --- a/rpc/analytics_grpc.pb.go +++ b/rpc/analytics_grpc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.5.1 -// - protoc v6.33.0 +// - protoc-gen-go-grpc v1.6.1 +// - protoc v4.23.4 // source: rpc/analytics.proto package rpc @@ -114,13 +114,13 @@ type AnalyticsRecorderServiceServer interface { type UnimplementedAnalyticsRecorderServiceServer struct{} func (UnimplementedAnalyticsRecorderServiceServer) IngestStats(grpc.ClientStreamingServer[livekit.AnalyticsStats, emptypb.Empty]) error { - return status.Errorf(codes.Unimplemented, "method IngestStats not implemented") + return status.Error(codes.Unimplemented, "method IngestStats not implemented") } func (UnimplementedAnalyticsRecorderServiceServer) IngestEvents(grpc.ClientStreamingServer[livekit.AnalyticsEvents, emptypb.Empty]) error { - return status.Errorf(codes.Unimplemented, "method IngestEvents not implemented") + return status.Error(codes.Unimplemented, "method IngestEvents not implemented") } func (UnimplementedAnalyticsRecorderServiceServer) IngestNodeRoomStates(grpc.ClientStreamingServer[livekit.AnalyticsNodeRooms, emptypb.Empty]) error { - return status.Errorf(codes.Unimplemented, "method IngestNodeRoomStates not implemented") + return status.Error(codes.Unimplemented, "method IngestNodeRoomStates not implemented") } func (UnimplementedAnalyticsRecorderServiceServer) mustEmbedUnimplementedAnalyticsRecorderServiceServer() { } @@ -134,7 +134,7 @@ type UnsafeAnalyticsRecorderServiceServer interface { } func RegisterAnalyticsRecorderServiceServer(s grpc.ServiceRegistrar, srv AnalyticsRecorderServiceServer) { - // If the following call pancis, it indicates UnimplementedAnalyticsRecorderServiceServer was + // If the following call panics, it indicates UnimplementedAnalyticsRecorderServiceServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go index dfba0fced..2a508d73a 100644 --- a/rpc/egress.pb.go +++ b/rpc/egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/egress.proto package rpc diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go index fe4760663..8ccc1d5c4 100644 --- a/rpc/ingress.pb.go +++ b/rpc/ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/ingress.proto package rpc diff --git a/rpc/io.pb.go b/rpc/io.pb.go index 0bd9db031..d038c33c4 100644 --- a/rpc/io.pb.go +++ b/rpc/io.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/io.proto package rpc diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go index 71e94e740..1890702a2 100644 --- a/rpc/keepalive.pb.go +++ b/rpc/keepalive.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/keepalive.proto package rpc diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go index 3d53ad385..cffcbb5eb 100644 --- a/rpc/participant.pb.go +++ b/rpc/participant.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/participant.proto package rpc diff --git a/rpc/room.pb.go b/rpc/room.pb.go index 69a8430ef..2d25c8c79 100644 --- a/rpc/room.pb.go +++ b/rpc/room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/room.proto package rpc diff --git a/rpc/roommanager.pb.go b/rpc/roommanager.pb.go index dc2219e19..54861c5a4 100644 --- a/rpc/roommanager.pb.go +++ b/rpc/roommanager.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/roommanager.proto package rpc diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go index 344eae247..b9477d103 100644 --- a/rpc/signal.pb.go +++ b/rpc/signal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/signal.proto package rpc diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go index c275b5ea1..ecfa1de69 100644 --- a/rpc/sip.pb.go +++ b/rpc/sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/sip.proto package rpc diff --git a/rpc/whip_signal.pb.go b/rpc/whip_signal.pb.go index e3ea2472c..e7a80bd45 100644 --- a/rpc/whip_signal.pb.go +++ b/rpc/whip_signal.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v6.33.0 +// protoc-gen-go v1.36.11 +// protoc v4.23.4 // source: rpc/whip_signal.proto package rpc