diff --git a/.changeset/beige-impalas-judge.md b/.changeset/beige-impalas-judge.md new file mode 100644 index 000000000..d724fcf2c --- /dev/null +++ b/.changeset/beige-impalas-judge.md @@ -0,0 +1,5 @@ +--- +"@livekit/protocol": patch +--- + +update psrpc diff --git a/go.mod b/go.mod index 298323f93..25fa18de8 100644 --- a/go.mod +++ b/go.mod @@ -15,7 +15,7 @@ require ( github.com/jxskiss/base62 v1.1.0 github.com/lithammer/shortuuid/v4 v4.2.0 github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731 - github.com/livekit/psrpc v0.6.1-0.20250726180611-3915e005e741 + github.com/livekit/psrpc v0.7.0 github.com/mackerelio/go-osstat v0.2.5 github.com/maxbrunsfeld/counterfeiter/v6 v6.11.1 github.com/pion/logging v0.2.4 diff --git a/go.sum b/go.sum index 047f67f40..a884cfd09 100644 --- a/go.sum +++ b/go.sum @@ -93,8 +93,8 @@ github.com/lithammer/shortuuid/v4 v4.2.0 h1:LMFOzVB3996a7b8aBuEXxqOBflbfPQAiVzkI github.com/lithammer/shortuuid/v4 v4.2.0/go.mod h1:D5noHZ2oFw/YaKCfGy0YxyE7M0wMbezmMjPdhyEFe6Y= github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731 h1:9x+U2HGLrSw5ATTo469PQPkqzdoU7be46ryiCDO3boc= github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731/go.mod h1:Rs3MhFwutWhGwmY1VQsygw28z5bWcnEYmS1OG9OxjOQ= -github.com/livekit/psrpc v0.6.1-0.20250726180611-3915e005e741 h1:KKL1u94l6dF9u4cBwnnfozk27GH1txWy2SlvkfgmzoY= -github.com/livekit/psrpc v0.6.1-0.20250726180611-3915e005e741/go.mod h1:AuDC5uOoEjQJEc69v4Li3t77Ocz0e0NdjQEuFfO+vfk= +github.com/livekit/psrpc v0.7.0 h1:rtfqfjYN06WJYloE/S0nmkJ/Y04x4pxLQLe8kQ4FVHU= +github.com/livekit/psrpc v0.7.0/go.mod h1:AuDC5uOoEjQJEc69v4Li3t77Ocz0e0NdjQEuFfO+vfk= github.com/mackerelio/go-osstat v0.2.5 h1:+MqTbZUhoIt4m8qzkVoXUJg1EuifwlAJSk4Yl2GXh+o= github.com/mackerelio/go-osstat v0.2.5/go.mod h1:atxwWF+POUZcdtR1wnsUcQxTytoHG4uhl2AKKzrOajY= github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= diff --git a/infra/link.pb.go b/infra/link.pb.go index 40e1c24cb..f636bb3a6 100644 --- a/infra/link.pb.go +++ b/infra/link.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: infra/link.proto diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go index 205de50bd..77a264d2e 100644 --- a/livekit/livekit_agent.pb.go +++ b/livekit/livekit_agent.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_agent.proto diff --git a/livekit/livekit_agent_dispatch.pb.go b/livekit/livekit_agent_dispatch.pb.go index e4ec23b56..147c54bbe 100644 --- a/livekit/livekit_agent_dispatch.pb.go +++ b/livekit/livekit_agent_dispatch.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_agent_dispatch.proto diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go index b988e5cc1..7031d1921 100644 --- a/livekit/livekit_analytics.pb.go +++ b/livekit/livekit_analytics.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_analytics.proto diff --git a/livekit/livekit_cloud_agent.pb.go b/livekit/livekit_cloud_agent.pb.go index 7ae5e53c1..ede8db9ec 100644 --- a/livekit/livekit_cloud_agent.pb.go +++ b/livekit/livekit_cloud_agent.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_cloud_agent.proto diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go index 82947f286..a09910513 100644 --- a/livekit/livekit_egress.pb.go +++ b/livekit/livekit_egress.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_egress.proto diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go index 0a12d0c30..1605a6822 100644 --- a/livekit/livekit_ingress.pb.go +++ b/livekit/livekit_ingress.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_ingress.proto diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go index 048210dc8..0cad406f1 100644 --- a/livekit/livekit_internal.pb.go +++ b/livekit/livekit_internal.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_internal.proto diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index a84fa761d..98f9cc115 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_metrics.proto diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index f2fe71155..26e7d95a3 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_models.proto diff --git a/livekit/livekit_phone_number.pb.go b/livekit/livekit_phone_number.pb.go index 50b3fcabd..b8a58b2e0 100644 --- a/livekit/livekit_phone_number.pb.go +++ b/livekit/livekit_phone_number.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_phone_number.proto diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go index 76e56a6ce..ff2860275 100644 --- a/livekit/livekit_room.pb.go +++ b/livekit/livekit_room.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_room.proto diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index 6c19398ef..c90b16eee 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_rtc.proto diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go index 41f557d83..08f83a03d 100644 --- a/livekit/livekit_sip.pb.go +++ b/livekit/livekit_sip.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_sip.proto diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go index 02c479aad..f5b87fead 100644 --- a/livekit/livekit_webhook.pb.go +++ b/livekit/livekit_webhook.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: livekit_webhook.proto diff --git a/replay/cloud_replay.pb.go b/replay/cloud_replay.pb.go index 81f435f82..90717043e 100644 --- a/replay/cloud_replay.pb.go +++ b/replay/cloud_replay.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: cloud_replay.proto diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go index aea574ef5..5dc973385 100644 --- a/rpc/agent.pb.go +++ b/rpc/agent.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/agent.proto diff --git a/rpc/agent.psrpc.go b/rpc/agent.psrpc.go index 365996bd0..838346c58 100644 --- a/rpc/agent.psrpc.go +++ b/rpc/agent.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/agent.proto package rpc @@ -16,7 +16,7 @@ import ( import google_protobuf "google.golang.org/protobuf/types/known/emptypb" import livekit2 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ============================== // AgentInternal Client Interface @@ -180,6 +180,31 @@ func (s *agentInternalServer) Kill() { s.rpc.Close(true) } +// ================================== +// AgentInternal Unimplemented Server +// ================================== + +type UnimplementedAgentInternalServer struct{} + +func (UnimplementedAgentInternalServer) CheckEnabled(context.Context, *CheckEnabledRequest) (*CheckEnabledResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentInternalServer) JobRequest(context.Context, *livekit2.Job) (*JobRequestResponse, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedAgentInternalServer) JobRequestAffinity(context.Context, *livekit2.Job) float32 { + return -1 +} + +func (UnimplementedAgentInternalServer) JobTerminate(context.Context, *JobTerminateRequest) (*JobTerminateResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentInternalServer) WorkerRegistered(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor0 = []byte{ // 566 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x53, 0xdf, 0x8e, 0xd2, 0x4e, diff --git a/rpc/agent_dispatch.pb.go b/rpc/agent_dispatch.pb.go index 13028ff37..88a3a9134 100644 --- a/rpc/agent_dispatch.pb.go +++ b/rpc/agent_dispatch.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/agent_dispatch.proto diff --git a/rpc/agent_dispatch.psrpc.go b/rpc/agent_dispatch.psrpc.go index 8f2b4ea0e..c28eb3cd1 100644 --- a/rpc/agent_dispatch.psrpc.go +++ b/rpc/agent_dispatch.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/agent_dispatch.proto package rpc @@ -15,7 +15,7 @@ import ( ) import livekit3 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ====================================== // AgentDispatchInternal Client Interface @@ -186,6 +186,24 @@ func (s *agentDispatchInternalServer[RoomTopicType]) Kill() { s.rpc.Close(true) } +// ========================================== +// AgentDispatchInternal Unimplemented Server +// ========================================== + +type UnimplementedAgentDispatchInternalServer struct{} + +func (UnimplementedAgentDispatchInternalServer) CreateDispatch(context.Context, *livekit3.AgentDispatch) (*livekit3.AgentDispatch, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentDispatchInternalServer) DeleteDispatch(context.Context, *livekit3.DeleteAgentDispatchRequest) (*livekit3.AgentDispatch, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentDispatchInternalServer) ListDispatch(context.Context, *livekit3.ListAgentDispatchRequest) (*livekit3.ListAgentDispatchResponse, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor1 = []byte{ // 228 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x28, 0x2a, 0x48, 0xd6, diff --git a/rpc/analytics.pb.go b/rpc/analytics.pb.go index 8e97f206a..306fffa89 100644 --- a/rpc/analytics.pb.go +++ b/rpc/analytics.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/analytics.proto diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go index a1b382858..06662bb3a 100644 --- a/rpc/egress.pb.go +++ b/rpc/egress.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/egress.proto diff --git a/rpc/egress.psrpc.go b/rpc/egress.psrpc.go index fa1a43f94..907980c8e 100644 --- a/rpc/egress.psrpc.go +++ b/rpc/egress.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/egress.proto package rpc @@ -15,7 +15,7 @@ import ( ) import livekit4 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // =============================== // EgressInternal Client Interface @@ -149,6 +149,23 @@ func (s *egressInternalServer) Kill() { s.rpc.Close(true) } +// =================================== +// EgressInternal Unimplemented Server +// =================================== + +type UnimplementedEgressInternalServer struct{} + +func (UnimplementedEgressInternalServer) StartEgress(context.Context, *StartEgressRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedEgressInternalServer) StartEgressAffinity(context.Context, *StartEgressRequest) float32 { + return -1 +} + +func (UnimplementedEgressInternalServer) ListActiveEgress(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error) { + return nil, psrpc.ErrUnimplemented +} + // ============================== // EgressHandler Client Interface // ============================== @@ -280,6 +297,20 @@ func (s *egressHandlerServer) Kill() { s.rpc.Close(true) } +// ================================== +// EgressHandler Unimplemented Server +// ================================== + +type UnimplementedEgressHandlerServer struct{} + +func (UnimplementedEgressHandlerServer) UpdateStream(context.Context, *livekit4.UpdateStreamRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedEgressHandlerServer) StopEgress(context.Context, *livekit4.StopEgressRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor2 = []byte{ // 544 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x93, 0xd1, 0x4e, 0xdb, 0x3e, diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go index 776dd2cad..f42584535 100644 --- a/rpc/ingress.pb.go +++ b/rpc/ingress.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/ingress.proto diff --git a/rpc/ingress.psrpc.go b/rpc/ingress.psrpc.go index ef84589ad..cffe43a86 100644 --- a/rpc/ingress.psrpc.go +++ b/rpc/ingress.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/ingress.proto package rpc @@ -16,7 +16,7 @@ import ( import google_protobuf "google.golang.org/protobuf/types/known/emptypb" import livekit5 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ================================ // IngressInternal Client Interface @@ -167,6 +167,27 @@ func (s *ingressInternalServer) Kill() { s.rpc.Close(true) } +// ==================================== +// IngressInternal Unimplemented Server +// ==================================== + +type UnimplementedIngressInternalServer struct{} + +func (UnimplementedIngressInternalServer) StartIngress(context.Context, *StartIngressRequest) (*livekit5.IngressInfo, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedIngressInternalServer) StartIngressAffinity(context.Context, *StartIngressRequest) float32 { + return -1 +} + +func (UnimplementedIngressInternalServer) ListActiveIngress(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressInternalServer) KillIngressSession(context.Context, *KillIngressSessionRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + // =============================== // IngressHandler Client Interface // =============================== @@ -358,6 +379,32 @@ func (s *ingressHandlerServer) Kill() { s.rpc.Close(true) } +// =================================== +// IngressHandler Unimplemented Server +// =================================== + +type UnimplementedIngressHandlerServer struct{} + +func (UnimplementedIngressHandlerServer) UpdateIngress(context.Context, *livekit5.UpdateIngressRequest) (*livekit5.IngressState, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) DeleteIngress(context.Context, *livekit5.DeleteIngressRequest) (*livekit5.IngressState, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) DeleteWHIPResource(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) ICERestartWHIPResource(context.Context, *ICERestartWHIPResourceRequest) (*ICERestartWHIPResourceResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) WHIPRTCConnectionNotify(context.Context, *WHIPRTCConnectionNotifyRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor3 = []byte{ // 863 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0xdd, 0x4e, 0xe3, 0x46, diff --git a/rpc/io.pb.go b/rpc/io.pb.go index bfed9dae2..2271746ba 100644 --- a/rpc/io.pb.go +++ b/rpc/io.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/io.proto diff --git a/rpc/io.psrpc.go b/rpc/io.psrpc.go index c8d637f4c..4972b9c60 100644 --- a/rpc/io.psrpc.go +++ b/rpc/io.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/io.proto package rpc @@ -17,7 +17,7 @@ import google_protobuf "google.golang.org/protobuf/types/known/emptypb" import livekit4 "github.com/livekit/protocol/livekit" import livekit5 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ======================= // IOInfo Client Interface @@ -309,6 +309,60 @@ func (s *iOInfoServer) Kill() { s.rpc.Close(true) } +// =========================== +// IOInfo Unimplemented Server +// =========================== + +type UnimplementedIOInfoServer struct{} + +func (UnimplementedIOInfoServer) CreateEgress(context.Context, *livekit4.EgressInfo) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateEgress(context.Context, *livekit4.EgressInfo) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) GetEgress(context.Context, *GetEgressRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) ListEgress(context.Context, *livekit4.ListEgressRequest) (*livekit4.ListEgressResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateMetrics(context.Context, *UpdateMetricsRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) CreateIngress(context.Context, *livekit5.IngressInfo) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) GetIngressInfo(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateIngressState(context.Context, *UpdateIngressStateRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) GetSIPTrunkAuthentication(context.Context, *GetSIPTrunkAuthenticationRequest) (*GetSIPTrunkAuthenticationResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) EvaluateSIPDispatchRules(context.Context, *EvaluateSIPDispatchRulesRequest) (*EvaluateSIPDispatchRulesResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateSIPCallState(context.Context, *UpdateSIPCallStateRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) RecordCallContext(context.Context, *RecordCallContextRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor4 = []byte{ // 1743 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x18, 0xdd, 0x56, 0x1b, 0xc7, diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go index 4325587ce..761edd1b8 100644 --- a/rpc/keepalive.pb.go +++ b/rpc/keepalive.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/keepalive.proto diff --git a/rpc/keepalive.psrpc.go b/rpc/keepalive.psrpc.go index 36e69d21a..a67dc376e 100644 --- a/rpc/keepalive.psrpc.go +++ b/rpc/keepalive.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/keepalive.proto package rpc @@ -14,7 +14,7 @@ import ( "github.com/livekit/psrpc/version" ) -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ========================== // Keepalive Client Interface @@ -121,6 +121,16 @@ func (s *keepaliveServer[NodeIDTopicType]) Kill() { s.rpc.Close(true) } +// ============================== +// Keepalive Unimplemented Server +// ============================== + +type UnimplementedKeepaliveServer struct{} + +func (UnimplementedKeepaliveServer) Ping(context.Context, *KeepalivePing) (*KeepalivePing, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor5 = []byte{ // 178 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x2e, 0x2a, 0x48, 0xd6, diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go index d6cabcf3e..34cc5d20f 100644 --- a/rpc/participant.pb.go +++ b/rpc/participant.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/participant.proto diff --git a/rpc/participant.psrpc.go b/rpc/participant.psrpc.go index 989637cdf..16c7683fa 100644 --- a/rpc/participant.psrpc.go +++ b/rpc/participant.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/participant.proto package rpc @@ -16,7 +16,7 @@ import ( import livekit1 "github.com/livekit/protocol/livekit" import livekit6 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ============================ // Participant Client Interface @@ -250,6 +250,36 @@ func (s *participantServer[ParticipantTopicType]) Kill() { s.rpc.Close(true) } +// ================================ +// Participant Unimplemented Server +// ================================ + +type UnimplementedParticipantServer struct{} + +func (UnimplementedParticipantServer) RemoveParticipant(context.Context, *livekit6.RoomParticipantIdentity) (*livekit6.RemoveParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) MutePublishedTrack(context.Context, *livekit6.MuteRoomTrackRequest) (*livekit6.MuteRoomTrackResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) UpdateParticipant(context.Context, *livekit6.UpdateParticipantRequest) (*livekit1.ParticipantInfo, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) UpdateSubscriptions(context.Context, *livekit6.UpdateSubscriptionsRequest) (*livekit6.UpdateSubscriptionsResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) ForwardParticipant(context.Context, *livekit6.ForwardParticipantRequest) (*livekit6.ForwardParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) MoveParticipant(context.Context, *livekit6.MoveParticipantRequest) (*livekit6.MoveParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor6 = []byte{ // 337 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x53, 0x4f, 0x4b, 0xfb, 0x40, diff --git a/rpc/room.pb.go b/rpc/room.pb.go index df41b8b8f..6454b489c 100644 --- a/rpc/room.pb.go +++ b/rpc/room.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/room.proto diff --git a/rpc/room.psrpc.go b/rpc/room.psrpc.go index a29ef514d..73621bcc7 100644 --- a/rpc/room.psrpc.go +++ b/rpc/room.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/room.proto package rpc @@ -16,7 +16,7 @@ import ( import livekit1 "github.com/livekit/protocol/livekit" import livekit6 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ===================== // Room Client Interface @@ -187,6 +187,24 @@ func (s *roomServer[RoomTopicType]) Kill() { s.rpc.Close(true) } +// ========================= +// Room Unimplemented Server +// ========================= + +type UnimplementedRoomServer struct{} + +func (UnimplementedRoomServer) DeleteRoom(context.Context, *livekit6.DeleteRoomRequest) (*livekit6.DeleteRoomResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedRoomServer) SendData(context.Context, *livekit6.SendDataRequest) (*livekit6.SendDataResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedRoomServer) UpdateRoomMetadata(context.Context, *livekit6.UpdateRoomMetadataRequest) (*livekit1.Room, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor7 = []byte{ // 230 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x2b, 0x2a, 0x48, 0xd6, diff --git a/rpc/roommanager.pb.go b/rpc/roommanager.pb.go index a447b0bf3..6424aba6b 100644 --- a/rpc/roommanager.pb.go +++ b/rpc/roommanager.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/roommanager.proto diff --git a/rpc/roommanager.psrpc.go b/rpc/roommanager.psrpc.go index 4b532cbc5..31b6cb7e0 100644 --- a/rpc/roommanager.psrpc.go +++ b/rpc/roommanager.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/roommanager.proto package rpc @@ -16,7 +16,7 @@ import ( import livekit1 "github.com/livekit/protocol/livekit" import livekit6 "github.com/livekit/protocol/livekit" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ============================ // RoomManager Client Interface @@ -145,6 +145,16 @@ func (s *roomManagerServer[NodeIdTopicType]) Kill() { s.rpc.Close(true) } +// ================================ +// RoomManager Unimplemented Server +// ================================ + +type UnimplementedRoomManagerServer struct{} + +func (UnimplementedRoomManagerServer) CreateRoom(context.Context, *livekit6.CreateRoomRequest) (*livekit1.Room, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor8 = []byte{ // 185 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x44, 0xcd, 0x4d, 0x0a, 0xc2, 0x30, diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go index 65f9bf05d..18564147e 100644 --- a/rpc/signal.pb.go +++ b/rpc/signal.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/signal.proto diff --git a/rpc/signal.psrpc.go b/rpc/signal.psrpc.go index 36e7c0aee..a2d80b7d0 100644 --- a/rpc/signal.psrpc.go +++ b/rpc/signal.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/signal.proto package rpc @@ -14,7 +14,7 @@ import ( "github.com/livekit/psrpc/version" ) -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ======================= // Signal Client Interface @@ -143,6 +143,16 @@ func (s *signalServer[NodeIdTopicType]) Kill() { s.rpc.Close(true) } +// =========================== +// Signal Unimplemented Server +// =========================== + +type UnimplementedSignalServer struct{} + +func (UnimplementedSignalServer) RelaySignal(psrpc.ServerStream[*RelaySignalResponse, *RelaySignalRequest]) error { + return psrpc.ErrUnimplemented +} + var psrpcFileDescriptor9 = []byte{ // 313 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x91, 0x4f, 0x4e, 0xf3, 0x30, diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go index d48be7de3..264cb6880 100644 --- a/rpc/sip.pb.go +++ b/rpc/sip.pb.go @@ -14,7 +14,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/sip.proto diff --git a/rpc/sip.psrpc.go b/rpc/sip.psrpc.go index b7c64249c..e864ee941 100644 --- a/rpc/sip.psrpc.go +++ b/rpc/sip.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/sip.proto package rpc @@ -15,7 +15,7 @@ import ( ) import google_protobuf "google.golang.org/protobuf/types/known/emptypb" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ============================ // SIPInternal Client Interface @@ -149,6 +149,23 @@ func (s *sIPInternalServer) Kill() { s.rpc.Close(true) } +// ================================ +// SIPInternal Unimplemented Server +// ================================ + +type UnimplementedSIPInternalServer struct{} + +func (UnimplementedSIPInternalServer) CreateSIPParticipant(context.Context, *InternalCreateSIPParticipantRequest) (*InternalCreateSIPParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedSIPInternalServer) CreateSIPParticipantAffinity(context.Context, *InternalCreateSIPParticipantRequest) float32 { + return -1 +} + +func (UnimplementedSIPInternalServer) TransferSIPParticipant(context.Context, *InternalTransferSIPParticipantRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor11 = []byte{ // 1013 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xcd, 0x72, 0xdb, 0x36, diff --git a/rpc/whip_signal.pb.go b/rpc/whip_signal.pb.go index ced3c1e53..47dc35763 100644 --- a/rpc/whip_signal.pb.go +++ b/rpc/whip_signal.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 +// protoc-gen-go v1.36.9 // protoc v4.23.4 // source: rpc/whip_signal.proto diff --git a/rpc/whip_signal.psrpc.go b/rpc/whip_signal.psrpc.go index 181197924..170c15b59 100644 --- a/rpc/whip_signal.psrpc.go +++ b/rpc/whip_signal.psrpc.go @@ -1,4 +1,4 @@ -// Code generated by protoc-gen-psrpc v0.6.0, DO NOT EDIT. +// Code generated by protoc-gen-psrpc v0.7.0, DO NOT EDIT. // source: rpc/whip_signal.proto package rpc @@ -15,7 +15,7 @@ import ( ) import google_protobuf "google.golang.org/protobuf/types/known/emptypb" -var _ = version.PsrpcVersion_0_6 +var _ = version.PsrpcVersion_0_7 // ===================== // WHIP Client Interface @@ -144,6 +144,16 @@ func (s *wHIPServer[TopicTopicType]) Kill() { s.rpc.Close(true) } +// ========================= +// WHIP Unimplemented Server +// ========================= + +type UnimplementedWHIPServer struct{} + +func (UnimplementedWHIPServer) Create(context.Context, *WHIPCreateRequest) (*WHIPCreateResponse, error) { + return nil, psrpc.ErrUnimplemented +} + // ================================ // WHIPParticipant Client Interface // ================================ @@ -313,6 +323,24 @@ func (s *wHIPParticipantServer[TopicTopicType]) Kill() { s.rpc.Close(true) } +// ==================================== +// WHIPParticipant Unimplemented Server +// ==================================== + +type UnimplementedWHIPParticipantServer struct{} + +func (UnimplementedWHIPParticipantServer) ICETrickle(context.Context, *WHIPParticipantICETrickleRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedWHIPParticipantServer) ICERestart(context.Context, *WHIPParticipantICERestartRequest) (*WHIPParticipantICERestartResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedWHIPParticipantServer) DeleteSession(context.Context, *WHIPParticipantDeleteSessionRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor10 = []byte{ // 726 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x55, 0x5f, 0x4f, 0x1b, 0x39,