diff --git a/.bingo/Variables.mk b/.bingo/Variables.mk index 2af2ea9ff..1d179a2df 100644 --- a/.bingo/Variables.mk +++ b/.bingo/Variables.mk @@ -35,9 +35,9 @@ $(GORELEASER): $(BINGO_DIR)/goreleaser.mod @echo "(re)installing $(GOBIN)/goreleaser-v1.26.2" @cd $(BINGO_DIR) && GOWORK=off $(GO) build -mod=mod -modfile=goreleaser.mod -o=$(GOBIN)/goreleaser-v1.26.2 "github.com/goreleaser/goreleaser" -PROTOC_GEN_GO_GRPC := $(GOBIN)/protoc-gen-go-grpc-v1.5.1 +PROTOC_GEN_GO_GRPC := $(GOBIN)/protoc-gen-go-grpc-v1.3.0 $(PROTOC_GEN_GO_GRPC): $(BINGO_DIR)/protoc-gen-go-grpc.mod @# Install binary/ries using Go 1.14+ build command. This is using bwplotka/bingo-controlled, separate go module with pinned dependencies. - @echo "(re)installing $(GOBIN)/protoc-gen-go-grpc-v1.5.1" - @cd $(BINGO_DIR) && GOWORK=off $(GO) build -mod=mod -modfile=protoc-gen-go-grpc.mod -o=$(GOBIN)/protoc-gen-go-grpc-v1.5.1 "google.golang.org/grpc/cmd/protoc-gen-go-grpc" + @echo "(re)installing $(GOBIN)/protoc-gen-go-grpc-v1.3.0" + @cd $(BINGO_DIR) && GOWORK=off $(GO) build -mod=mod -modfile=protoc-gen-go-grpc.mod -o=$(GOBIN)/protoc-gen-go-grpc-v1.3.0 "google.golang.org/grpc/cmd/protoc-gen-go-grpc" diff --git a/.bingo/protoc-gen-go-grpc.mod b/.bingo/protoc-gen-go-grpc.mod index 6d0d141a4..51b100833 100644 --- a/.bingo/protoc-gen-go-grpc.mod +++ b/.bingo/protoc-gen-go-grpc.mod @@ -2,4 +2,4 @@ module _ // Auto generated by https://github.com/bwplotka/bingo. DO NOT EDIT go 1.22.2 -require google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.5.1 +require google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.3.0 diff --git a/.bingo/variables.env b/.bingo/variables.env index 1d0ecefd3..8b1c16cdf 100644 --- a/.bingo/variables.env +++ b/.bingo/variables.env @@ -14,5 +14,5 @@ GINKGO="${GOBIN}/ginkgo-v2.22.2" GORELEASER="${GOBIN}/goreleaser-v1.26.2" -PROTOC_GEN_GO_GRPC="${GOBIN}/protoc-gen-go-grpc-v1.5.1" +PROTOC_GEN_GO_GRPC="${GOBIN}/protoc-gen-go-grpc-v1.3.0" diff --git a/pkg/api/registry_grpc.pb.go b/pkg/api/registry_grpc.pb.go index 6cbe685f8..b5a62b3df 100644 --- a/pkg/api/registry_grpc.pb.go +++ b/pkg/api/registry_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.5.1 +// - protoc-gen-go-grpc v1.3.0 // - protoc v5.27.0 // source: registry.proto @@ -15,8 +15,8 @@ import ( // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.64.0 or later. -const _ = grpc.SupportPackageIsVersion9 +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 const ( Registry_ListPackages_FullMethodName = "/api.Registry/ListPackages" @@ -35,17 +35,17 @@ const ( // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type RegistryClient interface { - ListPackages(ctx context.Context, in *ListPackageRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[PackageName], error) + ListPackages(ctx context.Context, in *ListPackageRequest, opts ...grpc.CallOption) (Registry_ListPackagesClient, error) GetPackage(ctx context.Context, in *GetPackageRequest, opts ...grpc.CallOption) (*Package, error) GetBundle(ctx context.Context, in *GetBundleRequest, opts ...grpc.CallOption) (*Bundle, error) // Deprecated: Do not use. GetBundleForChannel(ctx context.Context, in *GetBundleInChannelRequest, opts ...grpc.CallOption) (*Bundle, error) - GetChannelEntriesThatReplace(ctx context.Context, in *GetAllReplacementsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChannelEntry], error) + GetChannelEntriesThatReplace(ctx context.Context, in *GetAllReplacementsRequest, opts ...grpc.CallOption) (Registry_GetChannelEntriesThatReplaceClient, error) GetBundleThatReplaces(ctx context.Context, in *GetReplacementRequest, opts ...grpc.CallOption) (*Bundle, error) - GetChannelEntriesThatProvide(ctx context.Context, in *GetAllProvidersRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChannelEntry], error) - GetLatestChannelEntriesThatProvide(ctx context.Context, in *GetLatestProvidersRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChannelEntry], error) + GetChannelEntriesThatProvide(ctx context.Context, in *GetAllProvidersRequest, opts ...grpc.CallOption) (Registry_GetChannelEntriesThatProvideClient, error) + GetLatestChannelEntriesThatProvide(ctx context.Context, in *GetLatestProvidersRequest, opts ...grpc.CallOption) (Registry_GetLatestChannelEntriesThatProvideClient, error) GetDefaultBundleThatProvides(ctx context.Context, in *GetDefaultProviderRequest, opts ...grpc.CallOption) (*Bundle, error) - ListBundles(ctx context.Context, in *ListBundlesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Bundle], error) + ListBundles(ctx context.Context, in *ListBundlesRequest, opts ...grpc.CallOption) (Registry_ListBundlesClient, error) } type registryClient struct { @@ -56,13 +56,12 @@ func NewRegistryClient(cc grpc.ClientConnInterface) RegistryClient { return ®istryClient{cc} } -func (c *registryClient) ListPackages(ctx context.Context, in *ListPackageRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[PackageName], error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[0], Registry_ListPackages_FullMethodName, cOpts...) +func (c *registryClient) ListPackages(ctx context.Context, in *ListPackageRequest, opts ...grpc.CallOption) (Registry_ListPackagesClient, error) { + stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[0], Registry_ListPackages_FullMethodName, opts...) if err != nil { return nil, err } - x := &grpc.GenericClientStream[ListPackageRequest, PackageName]{ClientStream: stream} + x := ®istryListPackagesClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -72,13 +71,26 @@ func (c *registryClient) ListPackages(ctx context.Context, in *ListPackageReques return x, nil } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_ListPackagesClient = grpc.ServerStreamingClient[PackageName] +type Registry_ListPackagesClient interface { + Recv() (*PackageName, error) + grpc.ClientStream +} + +type registryListPackagesClient struct { + grpc.ClientStream +} + +func (x *registryListPackagesClient) Recv() (*PackageName, error) { + m := new(PackageName) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} func (c *registryClient) GetPackage(ctx context.Context, in *GetPackageRequest, opts ...grpc.CallOption) (*Package, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Package) - err := c.cc.Invoke(ctx, Registry_GetPackage_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Registry_GetPackage_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -86,9 +98,8 @@ func (c *registryClient) GetPackage(ctx context.Context, in *GetPackageRequest, } func (c *registryClient) GetBundle(ctx context.Context, in *GetBundleRequest, opts ...grpc.CallOption) (*Bundle, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Bundle) - err := c.cc.Invoke(ctx, Registry_GetBundle_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Registry_GetBundle_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -97,22 +108,20 @@ func (c *registryClient) GetBundle(ctx context.Context, in *GetBundleRequest, op // Deprecated: Do not use. func (c *registryClient) GetBundleForChannel(ctx context.Context, in *GetBundleInChannelRequest, opts ...grpc.CallOption) (*Bundle, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Bundle) - err := c.cc.Invoke(ctx, Registry_GetBundleForChannel_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Registry_GetBundleForChannel_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } -func (c *registryClient) GetChannelEntriesThatReplace(ctx context.Context, in *GetAllReplacementsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChannelEntry], error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[1], Registry_GetChannelEntriesThatReplace_FullMethodName, cOpts...) +func (c *registryClient) GetChannelEntriesThatReplace(ctx context.Context, in *GetAllReplacementsRequest, opts ...grpc.CallOption) (Registry_GetChannelEntriesThatReplaceClient, error) { + stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[1], Registry_GetChannelEntriesThatReplace_FullMethodName, opts...) if err != nil { return nil, err } - x := &grpc.GenericClientStream[GetAllReplacementsRequest, ChannelEntry]{ClientStream: stream} + x := ®istryGetChannelEntriesThatReplaceClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -122,26 +131,38 @@ func (c *registryClient) GetChannelEntriesThatReplace(ctx context.Context, in *G return x, nil } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_GetChannelEntriesThatReplaceClient = grpc.ServerStreamingClient[ChannelEntry] +type Registry_GetChannelEntriesThatReplaceClient interface { + Recv() (*ChannelEntry, error) + grpc.ClientStream +} + +type registryGetChannelEntriesThatReplaceClient struct { + grpc.ClientStream +} + +func (x *registryGetChannelEntriesThatReplaceClient) Recv() (*ChannelEntry, error) { + m := new(ChannelEntry) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} func (c *registryClient) GetBundleThatReplaces(ctx context.Context, in *GetReplacementRequest, opts ...grpc.CallOption) (*Bundle, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Bundle) - err := c.cc.Invoke(ctx, Registry_GetBundleThatReplaces_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Registry_GetBundleThatReplaces_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } -func (c *registryClient) GetChannelEntriesThatProvide(ctx context.Context, in *GetAllProvidersRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChannelEntry], error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[2], Registry_GetChannelEntriesThatProvide_FullMethodName, cOpts...) +func (c *registryClient) GetChannelEntriesThatProvide(ctx context.Context, in *GetAllProvidersRequest, opts ...grpc.CallOption) (Registry_GetChannelEntriesThatProvideClient, error) { + stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[2], Registry_GetChannelEntriesThatProvide_FullMethodName, opts...) if err != nil { return nil, err } - x := &grpc.GenericClientStream[GetAllProvidersRequest, ChannelEntry]{ClientStream: stream} + x := ®istryGetChannelEntriesThatProvideClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -151,16 +172,29 @@ func (c *registryClient) GetChannelEntriesThatProvide(ctx context.Context, in *G return x, nil } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_GetChannelEntriesThatProvideClient = grpc.ServerStreamingClient[ChannelEntry] +type Registry_GetChannelEntriesThatProvideClient interface { + Recv() (*ChannelEntry, error) + grpc.ClientStream +} + +type registryGetChannelEntriesThatProvideClient struct { + grpc.ClientStream +} + +func (x *registryGetChannelEntriesThatProvideClient) Recv() (*ChannelEntry, error) { + m := new(ChannelEntry) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} -func (c *registryClient) GetLatestChannelEntriesThatProvide(ctx context.Context, in *GetLatestProvidersRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChannelEntry], error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[3], Registry_GetLatestChannelEntriesThatProvide_FullMethodName, cOpts...) +func (c *registryClient) GetLatestChannelEntriesThatProvide(ctx context.Context, in *GetLatestProvidersRequest, opts ...grpc.CallOption) (Registry_GetLatestChannelEntriesThatProvideClient, error) { + stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[3], Registry_GetLatestChannelEntriesThatProvide_FullMethodName, opts...) if err != nil { return nil, err } - x := &grpc.GenericClientStream[GetLatestProvidersRequest, ChannelEntry]{ClientStream: stream} + x := ®istryGetLatestChannelEntriesThatProvideClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -170,26 +204,38 @@ func (c *registryClient) GetLatestChannelEntriesThatProvide(ctx context.Context, return x, nil } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_GetLatestChannelEntriesThatProvideClient = grpc.ServerStreamingClient[ChannelEntry] +type Registry_GetLatestChannelEntriesThatProvideClient interface { + Recv() (*ChannelEntry, error) + grpc.ClientStream +} + +type registryGetLatestChannelEntriesThatProvideClient struct { + grpc.ClientStream +} + +func (x *registryGetLatestChannelEntriesThatProvideClient) Recv() (*ChannelEntry, error) { + m := new(ChannelEntry) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} func (c *registryClient) GetDefaultBundleThatProvides(ctx context.Context, in *GetDefaultProviderRequest, opts ...grpc.CallOption) (*Bundle, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Bundle) - err := c.cc.Invoke(ctx, Registry_GetDefaultBundleThatProvides_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Registry_GetDefaultBundleThatProvides_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } -func (c *registryClient) ListBundles(ctx context.Context, in *ListBundlesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Bundle], error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[4], Registry_ListBundles_FullMethodName, cOpts...) +func (c *registryClient) ListBundles(ctx context.Context, in *ListBundlesRequest, opts ...grpc.CallOption) (Registry_ListBundlesClient, error) { + stream, err := c.cc.NewStream(ctx, &Registry_ServiceDesc.Streams[4], Registry_ListBundles_FullMethodName, opts...) if err != nil { return nil, err } - x := &grpc.GenericClientStream[ListBundlesRequest, Bundle]{ClientStream: stream} + x := ®istryListBundlesClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -199,35 +245,46 @@ func (c *registryClient) ListBundles(ctx context.Context, in *ListBundlesRequest return x, nil } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_ListBundlesClient = grpc.ServerStreamingClient[Bundle] +type Registry_ListBundlesClient interface { + Recv() (*Bundle, error) + grpc.ClientStream +} + +type registryListBundlesClient struct { + grpc.ClientStream +} + +func (x *registryListBundlesClient) Recv() (*Bundle, error) { + m := new(Bundle) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} // RegistryServer is the server API for Registry service. // All implementations must embed UnimplementedRegistryServer -// for forward compatibility. +// for forward compatibility type RegistryServer interface { - ListPackages(*ListPackageRequest, grpc.ServerStreamingServer[PackageName]) error + ListPackages(*ListPackageRequest, Registry_ListPackagesServer) error GetPackage(context.Context, *GetPackageRequest) (*Package, error) GetBundle(context.Context, *GetBundleRequest) (*Bundle, error) // Deprecated: Do not use. GetBundleForChannel(context.Context, *GetBundleInChannelRequest) (*Bundle, error) - GetChannelEntriesThatReplace(*GetAllReplacementsRequest, grpc.ServerStreamingServer[ChannelEntry]) error + GetChannelEntriesThatReplace(*GetAllReplacementsRequest, Registry_GetChannelEntriesThatReplaceServer) error GetBundleThatReplaces(context.Context, *GetReplacementRequest) (*Bundle, error) - GetChannelEntriesThatProvide(*GetAllProvidersRequest, grpc.ServerStreamingServer[ChannelEntry]) error - GetLatestChannelEntriesThatProvide(*GetLatestProvidersRequest, grpc.ServerStreamingServer[ChannelEntry]) error + GetChannelEntriesThatProvide(*GetAllProvidersRequest, Registry_GetChannelEntriesThatProvideServer) error + GetLatestChannelEntriesThatProvide(*GetLatestProvidersRequest, Registry_GetLatestChannelEntriesThatProvideServer) error GetDefaultBundleThatProvides(context.Context, *GetDefaultProviderRequest) (*Bundle, error) - ListBundles(*ListBundlesRequest, grpc.ServerStreamingServer[Bundle]) error + ListBundles(*ListBundlesRequest, Registry_ListBundlesServer) error mustEmbedUnimplementedRegistryServer() } -// UnimplementedRegistryServer must be embedded to have -// forward compatible implementations. -// -// NOTE: this should be embedded by value instead of pointer to avoid a nil -// pointer dereference when methods are called. -type UnimplementedRegistryServer struct{} +// UnimplementedRegistryServer must be embedded to have forward compatible implementations. +type UnimplementedRegistryServer struct { +} -func (UnimplementedRegistryServer) ListPackages(*ListPackageRequest, grpc.ServerStreamingServer[PackageName]) error { +func (UnimplementedRegistryServer) ListPackages(*ListPackageRequest, Registry_ListPackagesServer) error { return status.Errorf(codes.Unimplemented, "method ListPackages not implemented") } func (UnimplementedRegistryServer) GetPackage(context.Context, *GetPackageRequest) (*Package, error) { @@ -239,26 +296,25 @@ func (UnimplementedRegistryServer) GetBundle(context.Context, *GetBundleRequest) func (UnimplementedRegistryServer) GetBundleForChannel(context.Context, *GetBundleInChannelRequest) (*Bundle, error) { return nil, status.Errorf(codes.Unimplemented, "method GetBundleForChannel not implemented") } -func (UnimplementedRegistryServer) GetChannelEntriesThatReplace(*GetAllReplacementsRequest, grpc.ServerStreamingServer[ChannelEntry]) error { +func (UnimplementedRegistryServer) GetChannelEntriesThatReplace(*GetAllReplacementsRequest, Registry_GetChannelEntriesThatReplaceServer) error { return status.Errorf(codes.Unimplemented, "method GetChannelEntriesThatReplace not implemented") } func (UnimplementedRegistryServer) GetBundleThatReplaces(context.Context, *GetReplacementRequest) (*Bundle, error) { return nil, status.Errorf(codes.Unimplemented, "method GetBundleThatReplaces not implemented") } -func (UnimplementedRegistryServer) GetChannelEntriesThatProvide(*GetAllProvidersRequest, grpc.ServerStreamingServer[ChannelEntry]) error { +func (UnimplementedRegistryServer) GetChannelEntriesThatProvide(*GetAllProvidersRequest, Registry_GetChannelEntriesThatProvideServer) error { return status.Errorf(codes.Unimplemented, "method GetChannelEntriesThatProvide not implemented") } -func (UnimplementedRegistryServer) GetLatestChannelEntriesThatProvide(*GetLatestProvidersRequest, grpc.ServerStreamingServer[ChannelEntry]) error { +func (UnimplementedRegistryServer) GetLatestChannelEntriesThatProvide(*GetLatestProvidersRequest, Registry_GetLatestChannelEntriesThatProvideServer) error { return status.Errorf(codes.Unimplemented, "method GetLatestChannelEntriesThatProvide not implemented") } func (UnimplementedRegistryServer) GetDefaultBundleThatProvides(context.Context, *GetDefaultProviderRequest) (*Bundle, error) { return nil, status.Errorf(codes.Unimplemented, "method GetDefaultBundleThatProvides not implemented") } -func (UnimplementedRegistryServer) ListBundles(*ListBundlesRequest, grpc.ServerStreamingServer[Bundle]) error { +func (UnimplementedRegistryServer) ListBundles(*ListBundlesRequest, Registry_ListBundlesServer) error { return status.Errorf(codes.Unimplemented, "method ListBundles not implemented") } func (UnimplementedRegistryServer) mustEmbedUnimplementedRegistryServer() {} -func (UnimplementedRegistryServer) testEmbeddedByValue() {} // UnsafeRegistryServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to RegistryServer will @@ -268,13 +324,6 @@ type UnsafeRegistryServer interface { } func RegisterRegistryServer(s grpc.ServiceRegistrar, srv RegistryServer) { - // If the following call pancis, it indicates UnimplementedRegistryServer 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. - if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { - t.testEmbeddedByValue() - } s.RegisterService(&Registry_ServiceDesc, srv) } @@ -283,11 +332,21 @@ func _Registry_ListPackages_Handler(srv interface{}, stream grpc.ServerStream) e if err := stream.RecvMsg(m); err != nil { return err } - return srv.(RegistryServer).ListPackages(m, &grpc.GenericServerStream[ListPackageRequest, PackageName]{ServerStream: stream}) + return srv.(RegistryServer).ListPackages(m, ®istryListPackagesServer{stream}) +} + +type Registry_ListPackagesServer interface { + Send(*PackageName) error + grpc.ServerStream } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_ListPackagesServer = grpc.ServerStreamingServer[PackageName] +type registryListPackagesServer struct { + grpc.ServerStream +} + +func (x *registryListPackagesServer) Send(m *PackageName) error { + return x.ServerStream.SendMsg(m) +} func _Registry_GetPackage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetPackageRequest) @@ -348,11 +407,21 @@ func _Registry_GetChannelEntriesThatReplace_Handler(srv interface{}, stream grpc if err := stream.RecvMsg(m); err != nil { return err } - return srv.(RegistryServer).GetChannelEntriesThatReplace(m, &grpc.GenericServerStream[GetAllReplacementsRequest, ChannelEntry]{ServerStream: stream}) + return srv.(RegistryServer).GetChannelEntriesThatReplace(m, ®istryGetChannelEntriesThatReplaceServer{stream}) +} + +type Registry_GetChannelEntriesThatReplaceServer interface { + Send(*ChannelEntry) error + grpc.ServerStream +} + +type registryGetChannelEntriesThatReplaceServer struct { + grpc.ServerStream } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_GetChannelEntriesThatReplaceServer = grpc.ServerStreamingServer[ChannelEntry] +func (x *registryGetChannelEntriesThatReplaceServer) Send(m *ChannelEntry) error { + return x.ServerStream.SendMsg(m) +} func _Registry_GetBundleThatReplaces_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetReplacementRequest) @@ -377,22 +446,42 @@ func _Registry_GetChannelEntriesThatProvide_Handler(srv interface{}, stream grpc if err := stream.RecvMsg(m); err != nil { return err } - return srv.(RegistryServer).GetChannelEntriesThatProvide(m, &grpc.GenericServerStream[GetAllProvidersRequest, ChannelEntry]{ServerStream: stream}) + return srv.(RegistryServer).GetChannelEntriesThatProvide(m, ®istryGetChannelEntriesThatProvideServer{stream}) } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_GetChannelEntriesThatProvideServer = grpc.ServerStreamingServer[ChannelEntry] +type Registry_GetChannelEntriesThatProvideServer interface { + Send(*ChannelEntry) error + grpc.ServerStream +} + +type registryGetChannelEntriesThatProvideServer struct { + grpc.ServerStream +} + +func (x *registryGetChannelEntriesThatProvideServer) Send(m *ChannelEntry) error { + return x.ServerStream.SendMsg(m) +} func _Registry_GetLatestChannelEntriesThatProvide_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(GetLatestProvidersRequest) if err := stream.RecvMsg(m); err != nil { return err } - return srv.(RegistryServer).GetLatestChannelEntriesThatProvide(m, &grpc.GenericServerStream[GetLatestProvidersRequest, ChannelEntry]{ServerStream: stream}) + return srv.(RegistryServer).GetLatestChannelEntriesThatProvide(m, ®istryGetLatestChannelEntriesThatProvideServer{stream}) +} + +type Registry_GetLatestChannelEntriesThatProvideServer interface { + Send(*ChannelEntry) error + grpc.ServerStream } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_GetLatestChannelEntriesThatProvideServer = grpc.ServerStreamingServer[ChannelEntry] +type registryGetLatestChannelEntriesThatProvideServer struct { + grpc.ServerStream +} + +func (x *registryGetLatestChannelEntriesThatProvideServer) Send(m *ChannelEntry) error { + return x.ServerStream.SendMsg(m) +} func _Registry_GetDefaultBundleThatProvides_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetDefaultProviderRequest) @@ -417,11 +506,21 @@ func _Registry_ListBundles_Handler(srv interface{}, stream grpc.ServerStream) er if err := stream.RecvMsg(m); err != nil { return err } - return srv.(RegistryServer).ListBundles(m, &grpc.GenericServerStream[ListBundlesRequest, Bundle]{ServerStream: stream}) + return srv.(RegistryServer).ListBundles(m, ®istryListBundlesServer{stream}) +} + +type Registry_ListBundlesServer interface { + Send(*Bundle) error + grpc.ServerStream } -// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. -type Registry_ListBundlesServer = grpc.ServerStreamingServer[Bundle] +type registryListBundlesServer struct { + grpc.ServerStream +} + +func (x *registryListBundlesServer) Send(m *Bundle) error { + return x.ServerStream.SendMsg(m) +} // Registry_ServiceDesc is the grpc.ServiceDesc for Registry service. // It's only intended for direct use with grpc.RegisterService,