ads.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/discovery/v4alpha

     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/v4alpha/ads.proto
     6  
     7  package envoy_service_discovery_v4alpha
     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_v4alpha_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_v4alpha_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_v4alpha_ads_proto_rawDescGZIP(), []int{0}
    71  }
    72  
    73  var File_envoy_service_discovery_v4alpha_ads_proto protoreflect.FileDescriptor
    74  
    75  var file_envoy_service_discovery_v4alpha_ads_proto_rawDesc = []byte{
    76  	0x0a, 0x29, 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, 0x34, 0x61, 0x6c, 0x70, 0x68,
    78  	0x61, 0x2f, 0x61, 0x64, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1f, 0x65, 0x6e, 0x76,
    79  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f,
    80  	0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x1a, 0x2f, 0x65, 0x6e,
    81  	0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x64, 0x69, 0x73, 0x63,
    82  	0x6f, 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x64, 0x69,
    83  	0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75,
    84  	0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
    85  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64,
    86  	0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76,
    87  	0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22,
    88  	0x36, 0x0a, 0x08, 0x41, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x3a, 0x2a, 0x9a, 0xc5, 0x88,
    89  	0x1e, 0x25, 0x0a, 0x23, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
    90  	0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x41,
    91  	0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xbb, 0x02, 0x0a, 0x1a, 0x41, 0x67, 0x67, 0x72,
    92  	0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x53,
    93  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x88, 0x01, 0x0a, 0x19, 0x53, 0x74, 0x72, 0x65, 0x61,
    94  	0x6d, 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x52, 0x65, 0x73, 0x6f, 0x75,
    95  	0x72, 0x63, 0x65, 0x73, 0x12, 0x31, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
    96  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76,
    97  	0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
    98  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
    99  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   100  	0x79, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76,
   101  	0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30,
   102  	0x01, 0x12, 0x91, 0x01, 0x0a, 0x18, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x41, 0x67, 0x67, 0x72, 0x65,
   103  	0x67, 0x61, 0x74, 0x65, 0x64, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, 0x36,
   104  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64,
   105  	0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61,
   106  	0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52,
   107  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x37, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73,
   108  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
   109  	0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69,
   110  	0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
   111  	0x00, 0x28, 0x01, 0x30, 0x01, 0x42, 0x46, 0x0a, 0x2d, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f,
   112  	0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
   113  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76,
   114  	0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x42, 0x08, 0x41, 0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f,
   115  	0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x03, 0x62, 0x06, 0x70,
   116  	0x72, 0x6f, 0x74, 0x6f, 0x33,
   117  }
   118  
   119  var (
   120  	file_envoy_service_discovery_v4alpha_ads_proto_rawDescOnce sync.Once
   121  	file_envoy_service_discovery_v4alpha_ads_proto_rawDescData = file_envoy_service_discovery_v4alpha_ads_proto_rawDesc
   122  )
   123  
   124  func file_envoy_service_discovery_v4alpha_ads_proto_rawDescGZIP() []byte {
   125  	file_envoy_service_discovery_v4alpha_ads_proto_rawDescOnce.Do(func() {
   126  		file_envoy_service_discovery_v4alpha_ads_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_discovery_v4alpha_ads_proto_rawDescData)
   127  	})
   128  	return file_envoy_service_discovery_v4alpha_ads_proto_rawDescData
   129  }
   130  
   131  var file_envoy_service_discovery_v4alpha_ads_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
   132  var file_envoy_service_discovery_v4alpha_ads_proto_goTypes = []interface{}{
   133  	(*AdsDummy)(nil),               // 0: envoy.service.discovery.v4alpha.AdsDummy
   134  	(*DiscoveryRequest)(nil),       // 1: envoy.service.discovery.v4alpha.DiscoveryRequest
   135  	(*DeltaDiscoveryRequest)(nil),  // 2: envoy.service.discovery.v4alpha.DeltaDiscoveryRequest
   136  	(*DiscoveryResponse)(nil),      // 3: envoy.service.discovery.v4alpha.DiscoveryResponse
   137  	(*DeltaDiscoveryResponse)(nil), // 4: envoy.service.discovery.v4alpha.DeltaDiscoveryResponse
   138  }
   139  var file_envoy_service_discovery_v4alpha_ads_proto_depIdxs = []int32{
   140  	1, // 0: envoy.service.discovery.v4alpha.AggregatedDiscoveryService.StreamAggregatedResources:input_type -> envoy.service.discovery.v4alpha.DiscoveryRequest
   141  	2, // 1: envoy.service.discovery.v4alpha.AggregatedDiscoveryService.DeltaAggregatedResources:input_type -> envoy.service.discovery.v4alpha.DeltaDiscoveryRequest
   142  	3, // 2: envoy.service.discovery.v4alpha.AggregatedDiscoveryService.StreamAggregatedResources:output_type -> envoy.service.discovery.v4alpha.DiscoveryResponse
   143  	4, // 3: envoy.service.discovery.v4alpha.AggregatedDiscoveryService.DeltaAggregatedResources:output_type -> envoy.service.discovery.v4alpha.DeltaDiscoveryResponse
   144  	2, // [2:4] is the sub-list for method output_type
   145  	0, // [0:2] is the sub-list for method input_type
   146  	0, // [0:0] is the sub-list for extension type_name
   147  	0, // [0:0] is the sub-list for extension extendee
   148  	0, // [0:0] is the sub-list for field type_name
   149  }
   150  
   151  func init() { file_envoy_service_discovery_v4alpha_ads_proto_init() }
   152  func file_envoy_service_discovery_v4alpha_ads_proto_init() {
   153  	if File_envoy_service_discovery_v4alpha_ads_proto != nil {
   154  		return
   155  	}
   156  	file_envoy_service_discovery_v4alpha_discovery_proto_init()
   157  	if !protoimpl.UnsafeEnabled {
   158  		file_envoy_service_discovery_v4alpha_ads_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   159  			switch v := v.(*AdsDummy); i {
   160  			case 0:
   161  				return &v.state
   162  			case 1:
   163  				return &v.sizeCache
   164  			case 2:
   165  				return &v.unknownFields
   166  			default:
   167  				return nil
   168  			}
   169  		}
   170  	}
   171  	type x struct{}
   172  	out := protoimpl.TypeBuilder{
   173  		File: protoimpl.DescBuilder{
   174  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   175  			RawDescriptor: file_envoy_service_discovery_v4alpha_ads_proto_rawDesc,
   176  			NumEnums:      0,
   177  			NumMessages:   1,
   178  			NumExtensions: 0,
   179  			NumServices:   1,
   180  		},
   181  		GoTypes:           file_envoy_service_discovery_v4alpha_ads_proto_goTypes,
   182  		DependencyIndexes: file_envoy_service_discovery_v4alpha_ads_proto_depIdxs,
   183  		MessageInfos:      file_envoy_service_discovery_v4alpha_ads_proto_msgTypes,
   184  	}.Build()
   185  	File_envoy_service_discovery_v4alpha_ads_proto = out.File
   186  	file_envoy_service_discovery_v4alpha_ads_proto_rawDesc = nil
   187  	file_envoy_service_discovery_v4alpha_ads_proto_goTypes = nil
   188  	file_envoy_service_discovery_v4alpha_ads_proto_depIdxs = nil
   189  }
   190  
   191  // Reference imports to suppress errors if they are not otherwise used.
   192  var _ context.Context
   193  var _ grpc.ClientConnInterface
   194  
   195  // This is a compile-time assertion to ensure that this generated file
   196  // is compatible with the grpc package it is being compiled against.
   197  const _ = grpc.SupportPackageIsVersion6
   198  
   199  // AggregatedDiscoveryServiceClient is the client API for AggregatedDiscoveryService service.
   200  //
   201  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   202  type AggregatedDiscoveryServiceClient interface {
   203  	// This is a gRPC-only API.
   204  	StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error)
   205  	DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error)
   206  }
   207  
   208  type aggregatedDiscoveryServiceClient struct {
   209  	cc grpc.ClientConnInterface
   210  }
   211  
   212  func NewAggregatedDiscoveryServiceClient(cc grpc.ClientConnInterface) AggregatedDiscoveryServiceClient {
   213  	return &aggregatedDiscoveryServiceClient{cc}
   214  }
   215  
   216  func (c *aggregatedDiscoveryServiceClient) StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) {
   217  	stream, err := c.cc.NewStream(ctx, &_AggregatedDiscoveryService_serviceDesc.Streams[0], "/envoy.service.discovery.v4alpha.AggregatedDiscoveryService/StreamAggregatedResources", opts...)
   218  	if err != nil {
   219  		return nil, err
   220  	}
   221  	x := &aggregatedDiscoveryServiceStreamAggregatedResourcesClient{stream}
   222  	return x, nil
   223  }
   224  
   225  type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface {
   226  	Send(*DiscoveryRequest) error
   227  	Recv() (*DiscoveryResponse, error)
   228  	grpc.ClientStream
   229  }
   230  
   231  type aggregatedDiscoveryServiceStreamAggregatedResourcesClient struct {
   232  	grpc.ClientStream
   233  }
   234  
   235  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesClient) Send(m *DiscoveryRequest) error {
   236  	return x.ClientStream.SendMsg(m)
   237  }
   238  
   239  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesClient) Recv() (*DiscoveryResponse, error) {
   240  	m := new(DiscoveryResponse)
   241  	if err := x.ClientStream.RecvMsg(m); err != nil {
   242  		return nil, err
   243  	}
   244  	return m, nil
   245  }
   246  
   247  func (c *aggregatedDiscoveryServiceClient) DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error) {
   248  	stream, err := c.cc.NewStream(ctx, &_AggregatedDiscoveryService_serviceDesc.Streams[1], "/envoy.service.discovery.v4alpha.AggregatedDiscoveryService/DeltaAggregatedResources", opts...)
   249  	if err != nil {
   250  		return nil, err
   251  	}
   252  	x := &aggregatedDiscoveryServiceDeltaAggregatedResourcesClient{stream}
   253  	return x, nil
   254  }
   255  
   256  type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface {
   257  	Send(*DeltaDiscoveryRequest) error
   258  	Recv() (*DeltaDiscoveryResponse, error)
   259  	grpc.ClientStream
   260  }
   261  
   262  type aggregatedDiscoveryServiceDeltaAggregatedResourcesClient struct {
   263  	grpc.ClientStream
   264  }
   265  
   266  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesClient) Send(m *DeltaDiscoveryRequest) error {
   267  	return x.ClientStream.SendMsg(m)
   268  }
   269  
   270  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesClient) Recv() (*DeltaDiscoveryResponse, error) {
   271  	m := new(DeltaDiscoveryResponse)
   272  	if err := x.ClientStream.RecvMsg(m); err != nil {
   273  		return nil, err
   274  	}
   275  	return m, nil
   276  }
   277  
   278  // AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service.
   279  type AggregatedDiscoveryServiceServer interface {
   280  	// This is a gRPC-only API.
   281  	StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
   282  	DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
   283  }
   284  
   285  // UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations.
   286  type UnimplementedAggregatedDiscoveryServiceServer struct {
   287  }
   288  
   289  func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error {
   290  	return status.Errorf(codes.Unimplemented, "method StreamAggregatedResources not implemented")
   291  }
   292  func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error {
   293  	return status.Errorf(codes.Unimplemented, "method DeltaAggregatedResources not implemented")
   294  }
   295  
   296  func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer) {
   297  	s.RegisterService(&_AggregatedDiscoveryService_serviceDesc, srv)
   298  }
   299  
   300  func _AggregatedDiscoveryService_StreamAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error {
   301  	return srv.(AggregatedDiscoveryServiceServer).StreamAggregatedResources(&aggregatedDiscoveryServiceStreamAggregatedResourcesServer{stream})
   302  }
   303  
   304  type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface {
   305  	Send(*DiscoveryResponse) error
   306  	Recv() (*DiscoveryRequest, error)
   307  	grpc.ServerStream
   308  }
   309  
   310  type aggregatedDiscoveryServiceStreamAggregatedResourcesServer struct {
   311  	grpc.ServerStream
   312  }
   313  
   314  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesServer) Send(m *DiscoveryResponse) error {
   315  	return x.ServerStream.SendMsg(m)
   316  }
   317  
   318  func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesServer) Recv() (*DiscoveryRequest, error) {
   319  	m := new(DiscoveryRequest)
   320  	if err := x.ServerStream.RecvMsg(m); err != nil {
   321  		return nil, err
   322  	}
   323  	return m, nil
   324  }
   325  
   326  func _AggregatedDiscoveryService_DeltaAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error {
   327  	return srv.(AggregatedDiscoveryServiceServer).DeltaAggregatedResources(&aggregatedDiscoveryServiceDeltaAggregatedResourcesServer{stream})
   328  }
   329  
   330  type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface {
   331  	Send(*DeltaDiscoveryResponse) error
   332  	Recv() (*DeltaDiscoveryRequest, error)
   333  	grpc.ServerStream
   334  }
   335  
   336  type aggregatedDiscoveryServiceDeltaAggregatedResourcesServer struct {
   337  	grpc.ServerStream
   338  }
   339  
   340  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesServer) Send(m *DeltaDiscoveryResponse) error {
   341  	return x.ServerStream.SendMsg(m)
   342  }
   343  
   344  func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesServer) Recv() (*DeltaDiscoveryRequest, error) {
   345  	m := new(DeltaDiscoveryRequest)
   346  	if err := x.ServerStream.RecvMsg(m); err != nil {
   347  		return nil, err
   348  	}
   349  	return m, nil
   350  }
   351  
   352  var _AggregatedDiscoveryService_serviceDesc = grpc.ServiceDesc{
   353  	ServiceName: "envoy.service.discovery.v4alpha.AggregatedDiscoveryService",
   354  	HandlerType: (*AggregatedDiscoveryServiceServer)(nil),
   355  	Methods:     []grpc.MethodDesc{},
   356  	Streams: []grpc.StreamDesc{
   357  		{
   358  			StreamName:    "StreamAggregatedResources",
   359  			Handler:       _AggregatedDiscoveryService_StreamAggregatedResources_Handler,
   360  			ServerStreams: true,
   361  			ClientStreams: true,
   362  		},
   363  		{
   364  			StreamName:    "DeltaAggregatedResources",
   365  			Handler:       _AggregatedDiscoveryService_DeltaAggregatedResources_Handler,
   366  			ServerStreams: true,
   367  			ClientStreams: true,
   368  		},
   369  	},
   370  	Metadata: "envoy/service/discovery/v4alpha/ads.proto",
   371  }
   372
View as plain text