srds.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/route/v3

     1  // Code generated by protoc-gen-go. DO NOT EDIT.
     2  // versions:
     3  // 	protoc-gen-go v1.25.0
     4  // 	protoc        v3.14.0
     5  // source: envoy/service/route/v3/srds.proto
     6  
     7  package envoy_service_route_v3
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/udpa/go/udpa/annotations"
    12  	_ "github.com/datawire/ambassador/v2/pkg/api/envoy/annotations"
    13  	v3 "github.com/datawire/ambassador/v2/pkg/api/envoy/service/discovery/v3"
    14  	proto "github.com/golang/protobuf/proto"
    15  	_ "google.golang.org/genproto/googleapis/api/annotations"
    16  	grpc "google.golang.org/grpc"
    17  	codes "google.golang.org/grpc/codes"
    18  	status "google.golang.org/grpc/status"
    19  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    20  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    21  	reflect "reflect"
    22  	sync "sync"
    23  )
    24  
    25  const (
    26  	// Verify that this generated code is sufficiently up-to-date.
    27  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    28  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    29  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    30  )
    31  
    32  // This is a compile-time assertion that a sufficiently up-to-date version
    33  // of the legacy proto package is being used.
    34  const _ = proto.ProtoPackageIsVersion4
    35  
    36  // [#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing
    37  // services: https://github.com/google/protobuf/issues/4221 and protoxform to upgrade the file.
    38  type SrdsDummy struct {
    39  	state         protoimpl.MessageState
    40  	sizeCache     protoimpl.SizeCache
    41  	unknownFields protoimpl.UnknownFields
    42  }
    43  
    44  func (x *SrdsDummy) Reset() {
    45  	*x = SrdsDummy{}
    46  	if protoimpl.UnsafeEnabled {
    47  		mi := &file_envoy_service_route_v3_srds_proto_msgTypes[0]
    48  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    49  		ms.StoreMessageInfo(mi)
    50  	}
    51  }
    52  
    53  func (x *SrdsDummy) String() string {
    54  	return protoimpl.X.MessageStringOf(x)
    55  }
    56  
    57  func (*SrdsDummy) ProtoMessage() {}
    58  
    59  func (x *SrdsDummy) ProtoReflect() protoreflect.Message {
    60  	mi := &file_envoy_service_route_v3_srds_proto_msgTypes[0]
    61  	if protoimpl.UnsafeEnabled && x != nil {
    62  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    63  		if ms.LoadMessageInfo() == nil {
    64  			ms.StoreMessageInfo(mi)
    65  		}
    66  		return ms
    67  	}
    68  	return mi.MessageOf(x)
    69  }
    70  
    71  // Deprecated: Use SrdsDummy.ProtoReflect.Descriptor instead.
    72  func (*SrdsDummy) Descriptor() ([]byte, []int) {
    73  	return file_envoy_service_route_v3_srds_proto_rawDescGZIP(), []int{0}
    74  }
    75  
    76  var File_envoy_service_route_v3_srds_proto protoreflect.FileDescriptor
    77  
    78  var file_envoy_service_route_v3_srds_proto_rawDesc = []byte{
    79  	0x0a, 0x21, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
    80  	0x72, 0x6f, 0x75, 0x74, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x73, 0x72, 0x64, 0x73, 0x2e, 0x70, 0x72,
    81  	0x6f, 0x74, 0x6f, 0x12, 0x16, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
    82  	0x63, 0x65, 0x2e, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x2e, 0x76, 0x33, 0x1a, 0x2a, 0x65, 0x6e, 0x76,
    83  	0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f,
    84  	0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x33, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
    85  	0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
    86  	0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e,
    87  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x6e, 0x6e,
    88  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63,
    89  	0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e,
    90  	0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
    91  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e,
    92  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
    93  	0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x2a, 0x0a, 0x09, 0x53, 0x72, 0x64,
    94  	0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x3a, 0x1d, 0x9a, 0xc5, 0x88, 0x1e, 0x18, 0x0a, 0x16, 0x65,
    95  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x72, 0x64, 0x73,
    96  	0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xf3, 0x03, 0x0a, 0x1c, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x64,
    97  	0x52, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x53,
    98  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x77, 0x0a, 0x12, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
    99  	0x53, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x12, 0x2c, 0x2e, 0x65,
   100  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73,
   101  	0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76,
   102  	0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76,
   103  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f,
   104  	0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   105  	0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12,
   106  	0x80, 0x01, 0x0a, 0x11, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x52,
   107  	0x6f, 0x75, 0x74, 0x65, 0x73, 0x12, 0x31, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
   108  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e,
   109  	0x76, 0x33, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   110  	0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   111  	0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65,
   112  	0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f,
   113  	0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01,
   114  	0x30, 0x01, 0x12, 0x9e, 0x01, 0x0a, 0x11, 0x46, 0x65, 0x74, 0x63, 0x68, 0x53, 0x63, 0x6f, 0x70,
   115  	0x65, 0x64, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x12, 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   116  	0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65,
   117  	0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52,
   118  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73,
   119  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
   120  	0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73,
   121  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x1d, 0x22, 0x1b, 0x2f,
   122  	0x76, 0x33, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x3a, 0x73, 0x63, 0x6f,
   123  	0x70, 0x65, 0x64, 0x2d, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x03,
   124  	0x3a, 0x01, 0x2a, 0x1a, 0x36, 0x8a, 0xa4, 0x96, 0xf3, 0x07, 0x30, 0x0a, 0x2e, 0x65, 0x6e, 0x76,
   125  	0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x2e,
   126  	0x76, 0x33, 0x2e, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x43, 0x6f,
   127  	0x6e, 0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x3e, 0x0a, 0x24, 0x69,
   128  	0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76,
   129  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x72, 0x6f, 0x75, 0x74, 0x65,
   130  	0x2e, 0x76, 0x33, 0x42, 0x09, 0x53, 0x72, 0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01,
   131  	0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x02, 0x62, 0x06, 0x70, 0x72, 0x6f,
   132  	0x74, 0x6f, 0x33,
   133  }
   134  
   135  var (
   136  	file_envoy_service_route_v3_srds_proto_rawDescOnce sync.Once
   137  	file_envoy_service_route_v3_srds_proto_rawDescData = file_envoy_service_route_v3_srds_proto_rawDesc
   138  )
   139  
   140  func file_envoy_service_route_v3_srds_proto_rawDescGZIP() []byte {
   141  	file_envoy_service_route_v3_srds_proto_rawDescOnce.Do(func() {
   142  		file_envoy_service_route_v3_srds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_route_v3_srds_proto_rawDescData)
   143  	})
   144  	return file_envoy_service_route_v3_srds_proto_rawDescData
   145  }
   146  
   147  var file_envoy_service_route_v3_srds_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
   148  var file_envoy_service_route_v3_srds_proto_goTypes = []interface{}{
   149  	(*SrdsDummy)(nil),                 // 0: envoy.service.route.v3.SrdsDummy
   150  	(*v3.DiscoveryRequest)(nil),       // 1: envoy.service.discovery.v3.DiscoveryRequest
   151  	(*v3.DeltaDiscoveryRequest)(nil),  // 2: envoy.service.discovery.v3.DeltaDiscoveryRequest
   152  	(*v3.DiscoveryResponse)(nil),      // 3: envoy.service.discovery.v3.DiscoveryResponse
   153  	(*v3.DeltaDiscoveryResponse)(nil), // 4: envoy.service.discovery.v3.DeltaDiscoveryResponse
   154  }
   155  var file_envoy_service_route_v3_srds_proto_depIdxs = []int32{
   156  	1, // 0: envoy.service.route.v3.ScopedRoutesDiscoveryService.StreamScopedRoutes:input_type -> envoy.service.discovery.v3.DiscoveryRequest
   157  	2, // 1: envoy.service.route.v3.ScopedRoutesDiscoveryService.DeltaScopedRoutes:input_type -> envoy.service.discovery.v3.DeltaDiscoveryRequest
   158  	1, // 2: envoy.service.route.v3.ScopedRoutesDiscoveryService.FetchScopedRoutes:input_type -> envoy.service.discovery.v3.DiscoveryRequest
   159  	3, // 3: envoy.service.route.v3.ScopedRoutesDiscoveryService.StreamScopedRoutes:output_type -> envoy.service.discovery.v3.DiscoveryResponse
   160  	4, // 4: envoy.service.route.v3.ScopedRoutesDiscoveryService.DeltaScopedRoutes:output_type -> envoy.service.discovery.v3.DeltaDiscoveryResponse
   161  	3, // 5: envoy.service.route.v3.ScopedRoutesDiscoveryService.FetchScopedRoutes:output_type -> envoy.service.discovery.v3.DiscoveryResponse
   162  	3, // [3:6] is the sub-list for method output_type
   163  	0, // [0:3] is the sub-list for method input_type
   164  	0, // [0:0] is the sub-list for extension type_name
   165  	0, // [0:0] is the sub-list for extension extendee
   166  	0, // [0:0] is the sub-list for field type_name
   167  }
   168  
   169  func init() { file_envoy_service_route_v3_srds_proto_init() }
   170  func file_envoy_service_route_v3_srds_proto_init() {
   171  	if File_envoy_service_route_v3_srds_proto != nil {
   172  		return
   173  	}
   174  	if !protoimpl.UnsafeEnabled {
   175  		file_envoy_service_route_v3_srds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   176  			switch v := v.(*SrdsDummy); i {
   177  			case 0:
   178  				return &v.state
   179  			case 1:
   180  				return &v.sizeCache
   181  			case 2:
   182  				return &v.unknownFields
   183  			default:
   184  				return nil
   185  			}
   186  		}
   187  	}
   188  	type x struct{}
   189  	out := protoimpl.TypeBuilder{
   190  		File: protoimpl.DescBuilder{
   191  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   192  			RawDescriptor: file_envoy_service_route_v3_srds_proto_rawDesc,
   193  			NumEnums:      0,
   194  			NumMessages:   1,
   195  			NumExtensions: 0,
   196  			NumServices:   1,
   197  		},
   198  		GoTypes:           file_envoy_service_route_v3_srds_proto_goTypes,
   199  		DependencyIndexes: file_envoy_service_route_v3_srds_proto_depIdxs,
   200  		MessageInfos:      file_envoy_service_route_v3_srds_proto_msgTypes,
   201  	}.Build()
   202  	File_envoy_service_route_v3_srds_proto = out.File
   203  	file_envoy_service_route_v3_srds_proto_rawDesc = nil
   204  	file_envoy_service_route_v3_srds_proto_goTypes = nil
   205  	file_envoy_service_route_v3_srds_proto_depIdxs = nil
   206  }
   207  
   208  // Reference imports to suppress errors if they are not otherwise used.
   209  var _ context.Context
   210  var _ grpc.ClientConnInterface
   211  
   212  // This is a compile-time assertion to ensure that this generated file
   213  // is compatible with the grpc package it is being compiled against.
   214  const _ = grpc.SupportPackageIsVersion6
   215  
   216  // ScopedRoutesDiscoveryServiceClient is the client API for ScopedRoutesDiscoveryService service.
   217  //
   218  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   219  type ScopedRoutesDiscoveryServiceClient interface {
   220  	StreamScopedRoutes(ctx context.Context, opts ...grpc.CallOption) (ScopedRoutesDiscoveryService_StreamScopedRoutesClient, error)
   221  	DeltaScopedRoutes(ctx context.Context, opts ...grpc.CallOption) (ScopedRoutesDiscoveryService_DeltaScopedRoutesClient, error)
   222  	FetchScopedRoutes(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error)
   223  }
   224  
   225  type scopedRoutesDiscoveryServiceClient struct {
   226  	cc grpc.ClientConnInterface
   227  }
   228  
   229  func NewScopedRoutesDiscoveryServiceClient(cc grpc.ClientConnInterface) ScopedRoutesDiscoveryServiceClient {
   230  	return &scopedRoutesDiscoveryServiceClient{cc}
   231  }
   232  
   233  func (c *scopedRoutesDiscoveryServiceClient) StreamScopedRoutes(ctx context.Context, opts ...grpc.CallOption) (ScopedRoutesDiscoveryService_StreamScopedRoutesClient, error) {
   234  	stream, err := c.cc.NewStream(ctx, &_ScopedRoutesDiscoveryService_serviceDesc.Streams[0], "/envoy.service.route.v3.ScopedRoutesDiscoveryService/StreamScopedRoutes", opts...)
   235  	if err != nil {
   236  		return nil, err
   237  	}
   238  	x := &scopedRoutesDiscoveryServiceStreamScopedRoutesClient{stream}
   239  	return x, nil
   240  }
   241  
   242  type ScopedRoutesDiscoveryService_StreamScopedRoutesClient interface {
   243  	Send(*v3.DiscoveryRequest) error
   244  	Recv() (*v3.DiscoveryResponse, error)
   245  	grpc.ClientStream
   246  }
   247  
   248  type scopedRoutesDiscoveryServiceStreamScopedRoutesClient struct {
   249  	grpc.ClientStream
   250  }
   251  
   252  func (x *scopedRoutesDiscoveryServiceStreamScopedRoutesClient) Send(m *v3.DiscoveryRequest) error {
   253  	return x.ClientStream.SendMsg(m)
   254  }
   255  
   256  func (x *scopedRoutesDiscoveryServiceStreamScopedRoutesClient) Recv() (*v3.DiscoveryResponse, error) {
   257  	m := new(v3.DiscoveryResponse)
   258  	if err := x.ClientStream.RecvMsg(m); err != nil {
   259  		return nil, err
   260  	}
   261  	return m, nil
   262  }
   263  
   264  func (c *scopedRoutesDiscoveryServiceClient) DeltaScopedRoutes(ctx context.Context, opts ...grpc.CallOption) (ScopedRoutesDiscoveryService_DeltaScopedRoutesClient, error) {
   265  	stream, err := c.cc.NewStream(ctx, &_ScopedRoutesDiscoveryService_serviceDesc.Streams[1], "/envoy.service.route.v3.ScopedRoutesDiscoveryService/DeltaScopedRoutes", opts...)
   266  	if err != nil {
   267  		return nil, err
   268  	}
   269  	x := &scopedRoutesDiscoveryServiceDeltaScopedRoutesClient{stream}
   270  	return x, nil
   271  }
   272  
   273  type ScopedRoutesDiscoveryService_DeltaScopedRoutesClient interface {
   274  	Send(*v3.DeltaDiscoveryRequest) error
   275  	Recv() (*v3.DeltaDiscoveryResponse, error)
   276  	grpc.ClientStream
   277  }
   278  
   279  type scopedRoutesDiscoveryServiceDeltaScopedRoutesClient struct {
   280  	grpc.ClientStream
   281  }
   282  
   283  func (x *scopedRoutesDiscoveryServiceDeltaScopedRoutesClient) Send(m *v3.DeltaDiscoveryRequest) error {
   284  	return x.ClientStream.SendMsg(m)
   285  }
   286  
   287  func (x *scopedRoutesDiscoveryServiceDeltaScopedRoutesClient) Recv() (*v3.DeltaDiscoveryResponse, error) {
   288  	m := new(v3.DeltaDiscoveryResponse)
   289  	if err := x.ClientStream.RecvMsg(m); err != nil {
   290  		return nil, err
   291  	}
   292  	return m, nil
   293  }
   294  
   295  func (c *scopedRoutesDiscoveryServiceClient) FetchScopedRoutes(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error) {
   296  	out := new(v3.DiscoveryResponse)
   297  	err := c.cc.Invoke(ctx, "/envoy.service.route.v3.ScopedRoutesDiscoveryService/FetchScopedRoutes", in, out, opts...)
   298  	if err != nil {
   299  		return nil, err
   300  	}
   301  	return out, nil
   302  }
   303  
   304  // ScopedRoutesDiscoveryServiceServer is the server API for ScopedRoutesDiscoveryService service.
   305  type ScopedRoutesDiscoveryServiceServer interface {
   306  	StreamScopedRoutes(ScopedRoutesDiscoveryService_StreamScopedRoutesServer) error
   307  	DeltaScopedRoutes(ScopedRoutesDiscoveryService_DeltaScopedRoutesServer) error
   308  	FetchScopedRoutes(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
   309  }
   310  
   311  // UnimplementedScopedRoutesDiscoveryServiceServer can be embedded to have forward compatible implementations.
   312  type UnimplementedScopedRoutesDiscoveryServiceServer struct {
   313  }
   314  
   315  func (*UnimplementedScopedRoutesDiscoveryServiceServer) StreamScopedRoutes(ScopedRoutesDiscoveryService_StreamScopedRoutesServer) error {
   316  	return status.Errorf(codes.Unimplemented, "method StreamScopedRoutes not implemented")
   317  }
   318  func (*UnimplementedScopedRoutesDiscoveryServiceServer) DeltaScopedRoutes(ScopedRoutesDiscoveryService_DeltaScopedRoutesServer) error {
   319  	return status.Errorf(codes.Unimplemented, "method DeltaScopedRoutes not implemented")
   320  }
   321  func (*UnimplementedScopedRoutesDiscoveryServiceServer) FetchScopedRoutes(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error) {
   322  	return nil, status.Errorf(codes.Unimplemented, "method FetchScopedRoutes not implemented")
   323  }
   324  
   325  func RegisterScopedRoutesDiscoveryServiceServer(s *grpc.Server, srv ScopedRoutesDiscoveryServiceServer) {
   326  	s.RegisterService(&_ScopedRoutesDiscoveryService_serviceDesc, srv)
   327  }
   328  
   329  func _ScopedRoutesDiscoveryService_StreamScopedRoutes_Handler(srv interface{}, stream grpc.ServerStream) error {
   330  	return srv.(ScopedRoutesDiscoveryServiceServer).StreamScopedRoutes(&scopedRoutesDiscoveryServiceStreamScopedRoutesServer{stream})
   331  }
   332  
   333  type ScopedRoutesDiscoveryService_StreamScopedRoutesServer interface {
   334  	Send(*v3.DiscoveryResponse) error
   335  	Recv() (*v3.DiscoveryRequest, error)
   336  	grpc.ServerStream
   337  }
   338  
   339  type scopedRoutesDiscoveryServiceStreamScopedRoutesServer struct {
   340  	grpc.ServerStream
   341  }
   342  
   343  func (x *scopedRoutesDiscoveryServiceStreamScopedRoutesServer) Send(m *v3.DiscoveryResponse) error {
   344  	return x.ServerStream.SendMsg(m)
   345  }
   346  
   347  func (x *scopedRoutesDiscoveryServiceStreamScopedRoutesServer) Recv() (*v3.DiscoveryRequest, error) {
   348  	m := new(v3.DiscoveryRequest)
   349  	if err := x.ServerStream.RecvMsg(m); err != nil {
   350  		return nil, err
   351  	}
   352  	return m, nil
   353  }
   354  
   355  func _ScopedRoutesDiscoveryService_DeltaScopedRoutes_Handler(srv interface{}, stream grpc.ServerStream) error {
   356  	return srv.(ScopedRoutesDiscoveryServiceServer).DeltaScopedRoutes(&scopedRoutesDiscoveryServiceDeltaScopedRoutesServer{stream})
   357  }
   358  
   359  type ScopedRoutesDiscoveryService_DeltaScopedRoutesServer interface {
   360  	Send(*v3.DeltaDiscoveryResponse) error
   361  	Recv() (*v3.DeltaDiscoveryRequest, error)
   362  	grpc.ServerStream
   363  }
   364  
   365  type scopedRoutesDiscoveryServiceDeltaScopedRoutesServer struct {
   366  	grpc.ServerStream
   367  }
   368  
   369  func (x *scopedRoutesDiscoveryServiceDeltaScopedRoutesServer) Send(m *v3.DeltaDiscoveryResponse) error {
   370  	return x.ServerStream.SendMsg(m)
   371  }
   372  
   373  func (x *scopedRoutesDiscoveryServiceDeltaScopedRoutesServer) Recv() (*v3.DeltaDiscoveryRequest, error) {
   374  	m := new(v3.DeltaDiscoveryRequest)
   375  	if err := x.ServerStream.RecvMsg(m); err != nil {
   376  		return nil, err
   377  	}
   378  	return m, nil
   379  }
   380  
   381  func _ScopedRoutesDiscoveryService_FetchScopedRoutes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   382  	in := new(v3.DiscoveryRequest)
   383  	if err := dec(in); err != nil {
   384  		return nil, err
   385  	}
   386  	if interceptor == nil {
   387  		return srv.(ScopedRoutesDiscoveryServiceServer).FetchScopedRoutes(ctx, in)
   388  	}
   389  	info := &grpc.UnaryServerInfo{
   390  		Server:     srv,
   391  		FullMethod: "/envoy.service.route.v3.ScopedRoutesDiscoveryService/FetchScopedRoutes",
   392  	}
   393  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   394  		return srv.(ScopedRoutesDiscoveryServiceServer).FetchScopedRoutes(ctx, req.(*v3.DiscoveryRequest))
   395  	}
   396  	return interceptor(ctx, in, info, handler)
   397  }
   398  
   399  var _ScopedRoutesDiscoveryService_serviceDesc = grpc.ServiceDesc{
   400  	ServiceName: "envoy.service.route.v3.ScopedRoutesDiscoveryService",
   401  	HandlerType: (*ScopedRoutesDiscoveryServiceServer)(nil),
   402  	Methods: []grpc.MethodDesc{
   403  		{
   404  			MethodName: "FetchScopedRoutes",
   405  			Handler:    _ScopedRoutesDiscoveryService_FetchScopedRoutes_Handler,
   406  		},
   407  	},
   408  	Streams: []grpc.StreamDesc{
   409  		{
   410  			StreamName:    "StreamScopedRoutes",
   411  			Handler:       _ScopedRoutesDiscoveryService_StreamScopedRoutes_Handler,
   412  			ServerStreams: true,
   413  			ClientStreams: true,
   414  		},
   415  		{
   416  			StreamName:    "DeltaScopedRoutes",
   417  			Handler:       _ScopedRoutesDiscoveryService_DeltaScopedRoutes_Handler,
   418  			ServerStreams: true,
   419  			ClientStreams: true,
   420  		},
   421  	},
   422  	Metadata: "envoy/service/route/v3/srds.proto",
   423  }
   424
View as plain text