ads.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/discovery/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/discovery/v3/ads.proto
     6  
     7  package envoy_service_discovery_v3
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/udpa/go/udpa/annotations"
    12  	proto "github.com/golang/protobuf/proto"
    13  	grpc "google.golang.org/grpc"
    14  	codes "google.golang.org/grpc/codes"
    15  	status "google.golang.org/grpc/status"
    16  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    17  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    18  	reflect "reflect"
    19  	sync "sync"
    20  )
    21  
    22  const (
    23  	// Verify that this generated code is sufficiently up-to-date.
    24  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    25  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    26  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    27  )
    28  
    29  // This is a compile-time assertion that a sufficiently up-to-date version
    30  // of the legacy proto package is being used.
    31  const _ = proto.ProtoPackageIsVersion4
    32  
    33  // [#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing
    34  // services: https://github.com/google/protobuf/issues/4221
    35  type AdsDummy struct {
    36  	state         protoimpl.MessageState
    37  	sizeCache     protoimpl.SizeCache
    38  	unknownFields protoimpl.UnknownFields
    39  }
    40  
    41  func (x *AdsDummy) Reset() {
    42  	*x = AdsDummy{}
    43  	if protoimpl.UnsafeEnabled {
    44  		mi := &file_envoy_service_discovery_v3_ads_proto_msgTypes[0]
    45  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    46  		ms.StoreMessageInfo(mi)
    47  	}
    48  }
    49  
    50  func (x *AdsDummy) String() string {
    51  	return protoimpl.X.MessageStringOf(x)
    52  }
    53  
    54  func (*AdsDummy) ProtoMessage() {}
    55  
    56  func (x *AdsDummy) ProtoReflect() protoreflect.Message {
    57  	mi := &file_envoy_service_discovery_v3_ads_proto_msgTypes[0]
    58  	if protoimpl.UnsafeEnabled && x != nil {
    59  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    60  		if ms.LoadMessageInfo() == nil {
    61  			ms.StoreMessageInfo(mi)
    62  		}
    63  		return ms
    64  	}
    65  	return mi.MessageOf(x)
    66  }
    67  
    68  // Deprecated: Use AdsDummy.ProtoReflect.Descriptor instead.
    69  func (*AdsDummy) Descriptor() ([]byte, []int) {
    70  	return file_envoy_service_discovery_v3_ads_proto_rawDescGZIP(), []int{0}
    71  }
    72  
    73  var File_envoy_service_discovery_v3_ads_proto protoreflect.FileDescriptor
    74  
    75  var file_envoy_service_discovery_v3_ads_proto_rawDesc = []byte{
    76  	0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
    77  	0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x33, 0x2f, 0x61, 0x64, 0x73,
    78  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
    79  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e,
    80  	0x76, 0x33, 0x1a, 0x2a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
    81  	0x65, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x33, 0x2f, 0x64,
    82  	0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d,
    83  	0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
    84  	0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75,
    85  	0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
    86  	0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
    87  	0x22, 0x36, 0x0a, 0x08, 0x41, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x3a, 0x2a, 0x9a, 0xc5,
    88  	0x88, 0x1e, 0x25, 0x0a, 0x23, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
    89  	0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x2e,
    90  	0x41, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xa6, 0x02, 0x0a, 0x1a, 0x41, 0x67, 0x67,
    91  	0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
    92  	0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x7e, 0x0a, 0x19, 0x53, 0x74, 0x72, 0x65, 0x61,
    93  	0x6d, 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x52, 0x65, 0x73, 0x6f, 0x75,
    94  	0x72, 0x63, 0x65, 0x73, 0x12, 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
    95  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76,
    96  	0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65,
    97  	0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
    98  	0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e,
    99  	0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
   100  	0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x87, 0x01, 0x0a, 0x18, 0x44, 0x65, 0x6c, 0x74,
   101  	0x61, 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x52, 0x65, 0x73, 0x6f, 0x75,
   102  	0x72, 0x63, 0x65, 0x73, 0x12, 0x31, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
   103  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76,
   104  	0x33, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
   105  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   106  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   107  	0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76,
   108  	0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30,
   109  	0x01, 0x42, 0x41, 0x0a, 0x28, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f,
   110  	0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   111  	0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x42, 0x08, 0x41,
   112  	0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1,
   113  	0x06, 0x02, 0x10, 0x02, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   114  }
   115  
   116  var (
   117  	file_envoy_service_discovery_v3_ads_proto_rawDescOnce sync.Once
   118  	file_envoy_service_discovery_v3_ads_proto_rawDescData = file_envoy_service_discovery_v3_ads_proto_rawDesc
   119  )
   120  
   121  func file_envoy_service_discovery_v3_ads_proto_rawDescGZIP() []byte {
   122  	file_envoy_service_discovery_v3_ads_proto_rawDescOnce.Do(func() {
   123  		file_envoy_service_discovery_v3_ads_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_discovery_v3_ads_proto_rawDescData)
   124  	})
   125  	return file_envoy_service_discovery_v3_ads_proto_rawDescData
   126  }
   127  
   128  var file_envoy_service_discovery_v3_ads_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
   129  var file_envoy_service_discovery_v3_ads_proto_goTypes = []interface{}{
   130  	(*AdsDummy)(nil),               // 0: envoy.service.discovery.v3.AdsDummy
   131  	(*DiscoveryRequest)(nil),       // 1: envoy.service.discovery.v3.DiscoveryRequest
   132  	(*DeltaDiscoveryRequest)(nil),  // 2: envoy.service.discovery.v3.DeltaDiscoveryRequest
   133  	(*DiscoveryResponse)(nil),      // 3: envoy.service.discovery.v3.DiscoveryResponse
   134  	(*DeltaDiscoveryResponse)(nil), // 4: envoy.service.discovery.v3.DeltaDiscoveryResponse
   135  }
   136  var file_envoy_service_discovery_v3_ads_proto_depIdxs = []int32{
   137  	1, // 0: envoy.service.discovery.v3.AggregatedDiscoveryService.StreamAggregatedResources:input_type -> envoy.service.discovery.v3.DiscoveryRequest
   138  	2, // 1: envoy.service.discovery.v3.AggregatedDiscoveryService.DeltaAggregatedResources:input_type -> envoy.service.discovery.v3.DeltaDiscoveryRequest
   139  	3, // 2: envoy.service.discovery.v3.AggregatedDiscoveryService.StreamAggregatedResources:output_type -> envoy.service.discovery.v3.DiscoveryResponse
   140  	4, // 3: envoy.service.discovery.v3.AggregatedDiscoveryService.DeltaAggregatedResources:output_type -> envoy.service.discovery.v3.DeltaDiscoveryResponse
   141  	2, // [2:4] is the sub-list for method output_type
   142  	0, // [0:2] is the sub-list for method input_type
   143  	0, // [0:0] is the sub-list for extension type_name
   144  	0, // [0:0] is the sub-list for extension extendee
   145  	0, // [0:0] is the sub-list for field type_name
   146  }
   147  
   148  func init() { file_envoy_service_discovery_v3_ads_proto_init() }
   149  func file_envoy_service_discovery_v3_ads_proto_init() {
   150  	if File_envoy_service_discovery_v3_ads_proto != nil {
   151  		return
   152  	}
   153  	file_envoy_service_discovery_v3_discovery_proto_init()
   154  	if !protoimpl.UnsafeEnabled {
   155  		file_envoy_service_discovery_v3_ads_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   156  			switch v := v.(*AdsDummy); i {
   157  			case 0:
   158  				return &v.state
   159  			case 1:
   160  				return &v.sizeCache
   161  			case 2:
   162  				return &v.unknownFields
   163  			default:
   164  				return nil
   165  			}
   166  		}
   167  	}
   168  	type x struct{}
   169  	out := protoimpl.TypeBuilder{
   170  		File: protoimpl.DescBuilder{
   171  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   172  			RawDescriptor: file_envoy_service_discovery_v3_ads_proto_rawDesc,
   173  			NumEnums:      0,
   174  			NumMessages:   1,
   175  			NumExtensions: 0,
   176  			NumServices:   1,
   177  		},
   178  		GoTypes:           file_envoy_service_discovery_v3_ads_proto_goTypes,
   179  		DependencyIndexes: file_envoy_service_discovery_v3_ads_proto_depIdxs,
   180  		MessageInfos:      file_envoy_service_discovery_v3_ads_proto_msgTypes,
   181  	}.Build()
   182  	File_envoy_service_discovery_v3_ads_proto = out.File
   183  	file_envoy_service_discovery_v3_ads_proto_rawDesc = nil
   184  	file_envoy_service_discovery_v3_ads_proto_goTypes = nil
   185  	file_envoy_service_discovery_v3_ads_proto_depIdxs = nil
   186  }
   187  
   188  // Reference imports to suppress errors if they are not otherwise used.
   189  var _ context.Context
   190  var _ grpc.ClientConnInterface
   191  
   192  // This is a compile-time assertion to ensure that this generated file
   193  // is compatible with the grpc package it is being compiled against.
   194  const _ = grpc.SupportPackageIsVersion6
   195  
   196  // AggregatedDiscoveryServiceClient is the client API for AggregatedDiscoveryService service.
   197  //
   198  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   199  type AggregatedDiscoveryServiceClient interface {
   200  	// This is a gRPC-only API.
   201  	StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error)
   202  	DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error)
   203  }
   204  
   205  type aggregatedDiscoveryServiceClient struct {
   206  	cc grpc.ClientConnInterface
   207  }
   208  
   209  func NewAggregatedDiscoveryServiceClient(cc grpc.ClientConnInterface) AggregatedDiscoveryServiceClient {
   210  	return &aggregatedDiscoveryServiceClient{cc}
   211  }
   212  
   213  func (c *aggregatedDiscoveryServiceClient) StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) {
   214  	stream, err := c.cc.NewStream(ctx, &_AggregatedDiscoveryService_serviceDesc.Streams[0], "/envoy.service.discovery.v3.AggregatedDiscoveryService/StreamAggregatedResources", opts...)
   215  	if err != nil {
   216  		return nil, err
   217  	}
   218  	x := &aggregatedDiscoveryServiceStreamAggregatedResourcesClient{stream}
   219  	return x, nil
   220  }
   221  
   222  type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface {
   223  	Send(*DiscoveryRequest) error
   224  	Recv() (*DiscoveryResponse, error)
   225  	grpc.ClientStream
   226  }
   227  
   228  type aggregatedDiscoveryServiceStreamAggregatedResourcesClient struct {
   229  	grpc.ClientStream
   230  }
   231  
   232  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesClient) Send(m *DiscoveryRequest) error {
   233  	return x.ClientStream.SendMsg(m)
   234  }
   235  
   236  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesClient) Recv() (*DiscoveryResponse, error) {
   237  	m := new(DiscoveryResponse)
   238  	if err := x.ClientStream.RecvMsg(m); err != nil {
   239  		return nil, err
   240  	}
   241  	return m, nil
   242  }
   243  
   244  func (c *aggregatedDiscoveryServiceClient) DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error) {
   245  	stream, err := c.cc.NewStream(ctx, &_AggregatedDiscoveryService_serviceDesc.Streams[1], "/envoy.service.discovery.v3.AggregatedDiscoveryService/DeltaAggregatedResources", opts...)
   246  	if err != nil {
   247  		return nil, err
   248  	}
   249  	x := &aggregatedDiscoveryServiceDeltaAggregatedResourcesClient{stream}
   250  	return x, nil
   251  }
   252  
   253  type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface {
   254  	Send(*DeltaDiscoveryRequest) error
   255  	Recv() (*DeltaDiscoveryResponse, error)
   256  	grpc.ClientStream
   257  }
   258  
   259  type aggregatedDiscoveryServiceDeltaAggregatedResourcesClient struct {
   260  	grpc.ClientStream
   261  }
   262  
   263  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesClient) Send(m *DeltaDiscoveryRequest) error {
   264  	return x.ClientStream.SendMsg(m)
   265  }
   266  
   267  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesClient) Recv() (*DeltaDiscoveryResponse, error) {
   268  	m := new(DeltaDiscoveryResponse)
   269  	if err := x.ClientStream.RecvMsg(m); err != nil {
   270  		return nil, err
   271  	}
   272  	return m, nil
   273  }
   274  
   275  // AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service.
   276  type AggregatedDiscoveryServiceServer interface {
   277  	// This is a gRPC-only API.
   278  	StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
   279  	DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
   280  }
   281  
   282  // UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations.
   283  type UnimplementedAggregatedDiscoveryServiceServer struct {
   284  }
   285  
   286  func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error {
   287  	return status.Errorf(codes.Unimplemented, "method StreamAggregatedResources not implemented")
   288  }
   289  func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error {
   290  	return status.Errorf(codes.Unimplemented, "method DeltaAggregatedResources not implemented")
   291  }
   292  
   293  func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer) {
   294  	s.RegisterService(&_AggregatedDiscoveryService_serviceDesc, srv)
   295  }
   296  
   297  func _AggregatedDiscoveryService_StreamAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error {
   298  	return srv.(AggregatedDiscoveryServiceServer).StreamAggregatedResources(&aggregatedDiscoveryServiceStreamAggregatedResourcesServer{stream})
   299  }
   300  
   301  type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface {
   302  	Send(*DiscoveryResponse) error
   303  	Recv() (*DiscoveryRequest, error)
   304  	grpc.ServerStream
   305  }
   306  
   307  type aggregatedDiscoveryServiceStreamAggregatedResourcesServer struct {
   308  	grpc.ServerStream
   309  }
   310  
   311  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesServer) Send(m *DiscoveryResponse) error {
   312  	return x.ServerStream.SendMsg(m)
   313  }
   314  
   315  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesServer) Recv() (*DiscoveryRequest, error) {
   316  	m := new(DiscoveryRequest)
   317  	if err := x.ServerStream.RecvMsg(m); err != nil {
   318  		return nil, err
   319  	}
   320  	return m, nil
   321  }
   322  
   323  func _AggregatedDiscoveryService_DeltaAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error {
   324  	return srv.(AggregatedDiscoveryServiceServer).DeltaAggregatedResources(&aggregatedDiscoveryServiceDeltaAggregatedResourcesServer{stream})
   325  }
   326  
   327  type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface {
   328  	Send(*DeltaDiscoveryResponse) error
   329  	Recv() (*DeltaDiscoveryRequest, error)
   330  	grpc.ServerStream
   331  }
   332  
   333  type aggregatedDiscoveryServiceDeltaAggregatedResourcesServer struct {
   334  	grpc.ServerStream
   335  }
   336  
   337  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesServer) Send(m *DeltaDiscoveryResponse) error {
   338  	return x.ServerStream.SendMsg(m)
   339  }
   340  
   341  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesServer) Recv() (*DeltaDiscoveryRequest, error) {
   342  	m := new(DeltaDiscoveryRequest)
   343  	if err := x.ServerStream.RecvMsg(m); err != nil {
   344  		return nil, err
   345  	}
   346  	return m, nil
   347  }
   348  
   349  var _AggregatedDiscoveryService_serviceDesc = grpc.ServiceDesc{
   350  	ServiceName: "envoy.service.discovery.v3.AggregatedDiscoveryService",
   351  	HandlerType: (*AggregatedDiscoveryServiceServer)(nil),
   352  	Methods:     []grpc.MethodDesc{},
   353  	Streams: []grpc.StreamDesc{
   354  		{
   355  			StreamName:    "StreamAggregatedResources",
   356  			Handler:       _AggregatedDiscoveryService_StreamAggregatedResources_Handler,
   357  			ServerStreams: true,
   358  			ClientStreams: true,
   359  		},
   360  		{
   361  			StreamName:    "DeltaAggregatedResources",
   362  			Handler:       _AggregatedDiscoveryService_DeltaAggregatedResources_Handler,
   363  			ServerStreams: true,
   364  			ClientStreams: true,
   365  		},
   366  	},
   367  	Metadata: "envoy/service/discovery/v3/ads.proto",
   368  }
   369
View as plain text