Chiebot-Mirror
/
xds
mirror of https://github.com/cncf/xds.git
9
0
Fork 0
Code Issues Projects Releases Wiki Activity

rules_go//proto : use go_grpc_v2 instead of go_grpc (#94)

Browse Source 
Signed-off-by: Matthieu MOREL <matthieu.morel35@gmail.com>
pull/96/head
Matthieu MOREL 10 months ago committed by GitHub
parent 7e7c9eab84
commit 555b57ec20
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 271 additions and 223 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      bazel/api_build_system.bzl
  2. 111
      go/udpa/service/orca/v1/orca.pb.go
  3. 135
      go/udpa/service/orca/v1/orca_grpc.pb.go
  4. 111
      go/xds/service/orca/v3/orca.pb.go
  5. 135
      go/xds/service/orca/v3/orca_grpc.pb.go

2
bazel/api_build_system.bzl
Unescape View File

@ -104,7 +104,7 @@ def xds_proto_package(
compilers = ["@io_bazel_rules_go//proto:go_proto", "@com_envoyproxy_protoc_gen_validate//bazel/go:pgv_plugin_go"]
if has_services:
compilers = ["@io_bazel_rules_go//proto:go_grpc", "@com_envoyproxy_protoc_gen_validate//bazel/go:pgv_plugin_go"]
compilers = ["@io_bazel_rules_go//proto:go_proto", "@io_bazel_rules_go//proto:go_grpc_v2", "@com_envoyproxy_protoc_gen_validate//bazel/go:pgv_plugin_go"]
# Because RBAC proro depends on googleapis syntax.proto and checked.proto,
# which share the same go proto library, it causes duplicative dependencies.

111
go/udpa/service/orca/v1/orca.pb.go generated
Unescape View File

@ -7,11 +7,7 @@
package v1
import (
context "context"
v1 "github.com/cncf/xds/go/udpa/data/orca/v1"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
durationpb "google.golang.org/protobuf/types/known/durationpb"
@ -184,110 +180,3 @@ func file_udpa_service_orca_v1_orca_proto_init() {
file_udpa_service_orca_v1_orca_proto_goTypes = nil
file_udpa_service_orca_v1_orca_proto_depIdxs = nil
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6
// OpenRcaServiceClient is the client API for OpenRcaService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type OpenRcaServiceClient interface {
StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error)
}
type openRcaServiceClient struct {
cc grpc.ClientConnInterface
}
func NewOpenRcaServiceClient(cc grpc.ClientConnInterface) OpenRcaServiceClient {
return &openRcaServiceClient{cc}
}
func (c *openRcaServiceClient) StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error) {
stream, err := c.cc.NewStream(ctx, &_OpenRcaService_serviceDesc.Streams[0], "/udpa.service.orca.v1.OpenRcaService/StreamCoreMetrics", opts...)
if err != nil {
return nil, err
}
x := &openRcaServiceStreamCoreMetricsClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type OpenRcaService_StreamCoreMetricsClient interface {
Recv() (*v1.OrcaLoadReport, error)
grpc.ClientStream
}
type openRcaServiceStreamCoreMetricsClient struct {
grpc.ClientStream
}
func (x *openRcaServiceStreamCoreMetricsClient) Recv() (*v1.OrcaLoadReport, error) {
m := new(v1.OrcaLoadReport)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// OpenRcaServiceServer is the server API for OpenRcaService service.
type OpenRcaServiceServer interface {
StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error
}
// UnimplementedOpenRcaServiceServer can be embedded to have forward compatible implementations.
type UnimplementedOpenRcaServiceServer struct {
}
func (*UnimplementedOpenRcaServiceServer) StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error {
return status.Errorf(codes.Unimplemented, "method StreamCoreMetrics not implemented")
}
func RegisterOpenRcaServiceServer(s *grpc.Server, srv OpenRcaServiceServer) {
s.RegisterService(&_OpenRcaService_serviceDesc, srv)
}
func _OpenRcaService_StreamCoreMetrics_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(OrcaLoadReportRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(OpenRcaServiceServer).StreamCoreMetrics(m, &openRcaServiceStreamCoreMetricsServer{stream})
}
type OpenRcaService_StreamCoreMetricsServer interface {
Send(*v1.OrcaLoadReport) error
grpc.ServerStream
}
type openRcaServiceStreamCoreMetricsServer struct {
grpc.ServerStream
}
func (x *openRcaServiceStreamCoreMetricsServer) Send(m *v1.OrcaLoadReport) error {
return x.ServerStream.SendMsg(m)
}
var _OpenRcaService_serviceDesc = grpc.ServiceDesc{
ServiceName: "udpa.service.orca.v1.OpenRcaService",
HandlerType: (*OpenRcaServiceServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
{
StreamName: "StreamCoreMetrics",
Handler: _OpenRcaService_StreamCoreMetrics_Handler,
ServerStreams: true,
},
},
Metadata: "udpa/service/orca/v1/orca.proto",
}

135
go/udpa/service/orca/v1/orca_grpc.pb.go generated
Unescape View File

@ -0,0 +1,135 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc v3.21.5
// source: udpa/service/orca/v1/orca.proto
package v1
import (
context "context"
v1 "github.com/cncf/xds/go/udpa/data/orca/v1"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// 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.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
const (
OpenRcaService_StreamCoreMetrics_FullMethodName = "/udpa.service.orca.v1.OpenRcaService/StreamCoreMetrics"
)
// OpenRcaServiceClient is the client API for OpenRcaService service.
//
// 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 OpenRcaServiceClient interface {
StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error)
}
type openRcaServiceClient struct {
cc grpc.ClientConnInterface
}
func NewOpenRcaServiceClient(cc grpc.ClientConnInterface) OpenRcaServiceClient {
return &openRcaServiceClient{cc}
}
func (c *openRcaServiceClient) StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error) {
stream, err := c.cc.NewStream(ctx, &OpenRcaService_ServiceDesc.Streams[0], OpenRcaService_StreamCoreMetrics_FullMethodName, opts...)
if err != nil {
return nil, err
}
x := &openRcaServiceStreamCoreMetricsClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type OpenRcaService_StreamCoreMetricsClient interface {
Recv() (*v1.OrcaLoadReport, error)
grpc.ClientStream
}
type openRcaServiceStreamCoreMetricsClient struct {
grpc.ClientStream
}
func (x *openRcaServiceStreamCoreMetricsClient) Recv() (*v1.OrcaLoadReport, error) {
m := new(v1.OrcaLoadReport)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// OpenRcaServiceServer is the server API for OpenRcaService service.
// All implementations should embed UnimplementedOpenRcaServiceServer
// for forward compatibility
type OpenRcaServiceServer interface {
StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error
}
// UnimplementedOpenRcaServiceServer should be embedded to have forward compatible implementations.
type UnimplementedOpenRcaServiceServer struct {
}
func (UnimplementedOpenRcaServiceServer) StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error {
return status.Errorf(codes.Unimplemented, "method StreamCoreMetrics not implemented")
}
// UnsafeOpenRcaServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to OpenRcaServiceServer will
// result in compilation errors.
type UnsafeOpenRcaServiceServer interface {
mustEmbedUnimplementedOpenRcaServiceServer()
}
func RegisterOpenRcaServiceServer(s grpc.ServiceRegistrar, srv OpenRcaServiceServer) {
s.RegisterService(&OpenRcaService_ServiceDesc, srv)
}
func _OpenRcaService_StreamCoreMetrics_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(OrcaLoadReportRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(OpenRcaServiceServer).StreamCoreMetrics(m, &openRcaServiceStreamCoreMetricsServer{stream})
}
type OpenRcaService_StreamCoreMetricsServer interface {
Send(*v1.OrcaLoadReport) error
grpc.ServerStream
}
type openRcaServiceStreamCoreMetricsServer struct {
grpc.ServerStream
}
func (x *openRcaServiceStreamCoreMetricsServer) Send(m *v1.OrcaLoadReport) error {
return x.ServerStream.SendMsg(m)
}
// OpenRcaService_ServiceDesc is the grpc.ServiceDesc for OpenRcaService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var OpenRcaService_ServiceDesc = grpc.ServiceDesc{
ServiceName: "udpa.service.orca.v1.OpenRcaService",
HandlerType: (*OpenRcaServiceServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
{
StreamName: "StreamCoreMetrics",
Handler: _OpenRcaService_StreamCoreMetrics_Handler,
ServerStreams: true,
},
},
Metadata: "udpa/service/orca/v1/orca.proto",
}

111
go/xds/service/orca/v3/orca.pb.go generated
Unescape View File

@ -7,11 +7,7 @@
package v3
import (
context "context"
v3 "github.com/cncf/xds/go/xds/data/orca/v3"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
durationpb "google.golang.org/protobuf/types/known/durationpb"
@ -184,110 +180,3 @@ func file_xds_service_orca_v3_orca_proto_init() {
file_xds_service_orca_v3_orca_proto_goTypes = nil
file_xds_service_orca_v3_orca_proto_depIdxs = nil
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6
// OpenRcaServiceClient is the client API for OpenRcaService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type OpenRcaServiceClient interface {
StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error)
}
type openRcaServiceClient struct {
cc grpc.ClientConnInterface
}
func NewOpenRcaServiceClient(cc grpc.ClientConnInterface) OpenRcaServiceClient {
return &openRcaServiceClient{cc}
}
func (c *openRcaServiceClient) StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error) {
stream, err := c.cc.NewStream(ctx, &_OpenRcaService_serviceDesc.Streams[0], "/xds.service.orca.v3.OpenRcaService/StreamCoreMetrics", opts...)
if err != nil {
return nil, err
}
x := &openRcaServiceStreamCoreMetricsClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type OpenRcaService_StreamCoreMetricsClient interface {
Recv() (*v3.OrcaLoadReport, error)
grpc.ClientStream
}
type openRcaServiceStreamCoreMetricsClient struct {
grpc.ClientStream
}
func (x *openRcaServiceStreamCoreMetricsClient) Recv() (*v3.OrcaLoadReport, error) {
m := new(v3.OrcaLoadReport)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// OpenRcaServiceServer is the server API for OpenRcaService service.
type OpenRcaServiceServer interface {
StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error
}
// UnimplementedOpenRcaServiceServer can be embedded to have forward compatible implementations.
type UnimplementedOpenRcaServiceServer struct {
}
func (*UnimplementedOpenRcaServiceServer) StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error {
return status.Errorf(codes.Unimplemented, "method StreamCoreMetrics not implemented")
}
func RegisterOpenRcaServiceServer(s *grpc.Server, srv OpenRcaServiceServer) {
s.RegisterService(&_OpenRcaService_serviceDesc, srv)
}
func _OpenRcaService_StreamCoreMetrics_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(OrcaLoadReportRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(OpenRcaServiceServer).StreamCoreMetrics(m, &openRcaServiceStreamCoreMetricsServer{stream})
}
type OpenRcaService_StreamCoreMetricsServer interface {
Send(*v3.OrcaLoadReport) error
grpc.ServerStream
}
type openRcaServiceStreamCoreMetricsServer struct {
grpc.ServerStream
}
func (x *openRcaServiceStreamCoreMetricsServer) Send(m *v3.OrcaLoadReport) error {
return x.ServerStream.SendMsg(m)
}
var _OpenRcaService_serviceDesc = grpc.ServiceDesc{
ServiceName: "xds.service.orca.v3.OpenRcaService",
HandlerType: (*OpenRcaServiceServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
{
StreamName: "StreamCoreMetrics",
Handler: _OpenRcaService_StreamCoreMetrics_Handler,
ServerStreams: true,
},
},
Metadata: "xds/service/orca/v3/orca.proto",
}

135
go/xds/service/orca/v3/orca_grpc.pb.go generated
Unescape View File

@ -0,0 +1,135 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc v3.21.5
// source: xds/service/orca/v3/orca.proto
package v3
import (
context "context"
v3 "github.com/cncf/xds/go/xds/data/orca/v3"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// 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.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
const (
OpenRcaService_StreamCoreMetrics_FullMethodName = "/xds.service.orca.v3.OpenRcaService/StreamCoreMetrics"
)
// OpenRcaServiceClient is the client API for OpenRcaService service.
//
// 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 OpenRcaServiceClient interface {
StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error)
}
type openRcaServiceClient struct {
cc grpc.ClientConnInterface
}
func NewOpenRcaServiceClient(cc grpc.ClientConnInterface) OpenRcaServiceClient {
return &openRcaServiceClient{cc}
}
func (c *openRcaServiceClient) StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, opts ...grpc.CallOption) (OpenRcaService_StreamCoreMetricsClient, error) {
stream, err := c.cc.NewStream(ctx, &OpenRcaService_ServiceDesc.Streams[0], OpenRcaService_StreamCoreMetrics_FullMethodName, opts...)
if err != nil {
return nil, err
}
x := &openRcaServiceStreamCoreMetricsClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type OpenRcaService_StreamCoreMetricsClient interface {
Recv() (*v3.OrcaLoadReport, error)
grpc.ClientStream
}
type openRcaServiceStreamCoreMetricsClient struct {
grpc.ClientStream
}
func (x *openRcaServiceStreamCoreMetricsClient) Recv() (*v3.OrcaLoadReport, error) {
m := new(v3.OrcaLoadReport)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// OpenRcaServiceServer is the server API for OpenRcaService service.
// All implementations should embed UnimplementedOpenRcaServiceServer
// for forward compatibility
type OpenRcaServiceServer interface {
StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error
}
// UnimplementedOpenRcaServiceServer should be embedded to have forward compatible implementations.
type UnimplementedOpenRcaServiceServer struct {
}
func (UnimplementedOpenRcaServiceServer) StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error {
return status.Errorf(codes.Unimplemented, "method StreamCoreMetrics not implemented")
}
// UnsafeOpenRcaServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to OpenRcaServiceServer will
// result in compilation errors.
type UnsafeOpenRcaServiceServer interface {
mustEmbedUnimplementedOpenRcaServiceServer()
}
func RegisterOpenRcaServiceServer(s grpc.ServiceRegistrar, srv OpenRcaServiceServer) {
s.RegisterService(&OpenRcaService_ServiceDesc, srv)
}
func _OpenRcaService_StreamCoreMetrics_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(OrcaLoadReportRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(OpenRcaServiceServer).StreamCoreMetrics(m, &openRcaServiceStreamCoreMetricsServer{stream})
}
type OpenRcaService_StreamCoreMetricsServer interface {
Send(*v3.OrcaLoadReport) error
grpc.ServerStream
}
type openRcaServiceStreamCoreMetricsServer struct {
grpc.ServerStream
}
func (x *openRcaServiceStreamCoreMetricsServer) Send(m *v3.OrcaLoadReport) error {
return x.ServerStream.SendMsg(m)
}
// OpenRcaService_ServiceDesc is the grpc.ServiceDesc for OpenRcaService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var OpenRcaService_ServiceDesc = grpc.ServiceDesc{
ServiceName: "xds.service.orca.v3.OpenRcaService",
HandlerType: (*OpenRcaServiceServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
{
StreamName: "StreamCoreMetrics",
Handler: _OpenRcaService_StreamCoreMetrics_Handler,
ServerStreams: true,
},
},
Metadata: "xds/service/orca/v3/orca.proto",
}
Write Preview
Loading…
Cancel
Save