Source file src/github.com/datawire/ambassador/v2/pkg/api/envoy/service/route/v3/rds.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/rds.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  	_ "github.com/envoyproxy/protoc-gen-validate/validate"
    15  	proto "github.com/golang/protobuf/proto"
    16  	_ "github.com/golang/protobuf/ptypes/wrappers"
    17  	_ "google.golang.org/genproto/googleapis/api/annotations"
    18  	grpc "google.golang.org/grpc"
    19  	codes "google.golang.org/grpc/codes"
    20  	status "google.golang.org/grpc/status"
    21  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    22  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    23  	reflect "reflect"
    24  	sync "sync"
    25  )
    26  
    27  const (
    28  	// Verify that this generated code is sufficiently up-to-date.
    29  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    30  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    31  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    32  )
    33  
    34  // This is a compile-time assertion that a sufficiently up-to-date version
    35  // of the legacy proto package is being used.
    36  const _ = proto.ProtoPackageIsVersion4
    37  
    38  // [#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing
    39  // services: https://github.com/google/protobuf/issues/4221 and protoxform to upgrade the file.
    40  type RdsDummy struct {
    41  	state         protoimpl.MessageState
    42  	sizeCache     protoimpl.SizeCache
    43  	unknownFields protoimpl.UnknownFields
    44  }
    45  
    46  func (x *RdsDummy) Reset() {
    47  	*x = RdsDummy{}
    48  	if protoimpl.UnsafeEnabled {
    49  		mi := &file_envoy_service_route_v3_rds_proto_msgTypes[0]
    50  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    51  		ms.StoreMessageInfo(mi)
    52  	}
    53  }
    54  
    55  func (x *RdsDummy) String() string {
    56  	return protoimpl.X.MessageStringOf(x)
    57  }
    58  
    59  func (*RdsDummy) ProtoMessage() {}
    60  
    61  func (x *RdsDummy) ProtoReflect() protoreflect.Message {
    62  	mi := &file_envoy_service_route_v3_rds_proto_msgTypes[0]
    63  	if protoimpl.UnsafeEnabled && x != nil {
    64  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    65  		if ms.LoadMessageInfo() == nil {
    66  			ms.StoreMessageInfo(mi)
    67  		}
    68  		return ms
    69  	}
    70  	return mi.MessageOf(x)
    71  }
    72  
    73  // Deprecated: Use RdsDummy.ProtoReflect.Descriptor instead.
    74  func (*RdsDummy) Descriptor() ([]byte, []int) {
    75  	return file_envoy_service_route_v3_rds_proto_rawDescGZIP(), []int{0}
    76  }
    77  
    78  var File_envoy_service_route_v3_rds_proto protoreflect.FileDescriptor
    79  
    80  var file_envoy_service_route_v3_rds_proto_rawDesc = []byte{
    81  	0x0a, 0x20, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
    82  	0x72, 0x6f, 0x75, 0x74, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x72, 0x64, 0x73, 0x2e, 0x70, 0x72, 0x6f,
    83  	0x74, 0x6f, 0x12, 0x16, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
    84  	0x65, 0x2e, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x2e, 0x76, 0x33, 0x1a, 0x2a, 0x65, 0x6e, 0x76, 0x6f,
    85  	0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76,
    86  	0x65, 0x72, 0x79, 0x2f, 0x76, 0x33, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
    87  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61,
    88  	0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70,
    89  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f,
    90  	0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x77, 0x72, 0x61, 0x70, 0x70, 0x65, 0x72, 0x73, 0x2e, 0x70,
    91  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x6e, 0x6e, 0x6f,
    92  	0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65,
    93  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e,
    94  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e,
    95  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f,
    96  	0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x69,
    97  	0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61,
    98  	0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
    99  	0x6f, 0x22, 0x28, 0x0a, 0x08, 0x52, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x3a, 0x1c, 0x9a,
   100  	0xc5, 0x88, 0x1e, 0x17, 0x0a, 0x15, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e,
   101  	0x76, 0x32, 0x2e, 0x52, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xcc, 0x03, 0x0a, 0x15,
   102  	0x52, 0x6f, 0x75, 0x74, 0x65, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x53, 0x65,
   103  	0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x71, 0x0a, 0x0c, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
   104  	0x6f, 0x75, 0x74, 0x65, 0x73, 0x12, 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
   105  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e,
   106  	0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75,
   107  	0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
   108  	0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33,
   109  	0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
   110  	0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x7a, 0x0a, 0x0b, 0x44, 0x65, 0x6c, 0x74,
   111  	0x61, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x12, 0x31, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   112  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   113  	0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76,
   114  	0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x65, 0x6e, 0x76,
   115  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f,
   116  	0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73,
   117  	0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00,
   118  	0x28, 0x01, 0x30, 0x01, 0x12, 0x91, 0x01, 0x0a, 0x0b, 0x46, 0x65, 0x74, 0x63, 0x68, 0x52, 0x6f,
   119  	0x75, 0x74, 0x65, 0x73, 0x12, 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
   120  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76,
   121  	0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65,
   122  	0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
   123  	0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e,
   124  	0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
   125  	0x65, 0x22, 0x25, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x16, 0x22, 0x14, 0x2f, 0x76, 0x33, 0x2f, 0x64,
   126  	0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x3a, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x82,
   127  	0xd3, 0xe4, 0x93, 0x02, 0x03, 0x3a, 0x01, 0x2a, 0x1a, 0x30, 0x8a, 0xa4, 0x96, 0xf3, 0x07, 0x2a,
   128  	0x0a, 0x28, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x72,
   129  	0x6f, 0x75, 0x74, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x43, 0x6f, 0x6e,
   130  	0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x32, 0xcb, 0x01, 0x0a, 0x1b, 0x56,
   131  	0x69, 0x72, 0x74, 0x75, 0x61, 0x6c, 0x48, 0x6f, 0x73, 0x74, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76,
   132  	0x65, 0x72, 0x79, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x80, 0x01, 0x0a, 0x11, 0x44,
   133  	0x65, 0x6c, 0x74, 0x61, 0x56, 0x69, 0x72, 0x74, 0x75, 0x61, 0x6c, 0x48, 0x6f, 0x73, 0x74, 0x73,
   134  	0x12, 0x31, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   135  	0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x65,
   136  	0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75,
   137  	0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
   138  	0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33,
   139  	0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52,
   140  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x1a, 0x29, 0x8a,
   141  	0xa4, 0x96, 0xf3, 0x07, 0x23, 0x0a, 0x21, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e,
   142  	0x66, 0x69, 0x67, 0x2e, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x56, 0x69, 0x72,
   143  	0x74, 0x75, 0x61, 0x6c, 0x48, 0x6f, 0x73, 0x74, 0x42, 0x3d, 0x0a, 0x24, 0x69, 0x6f, 0x2e, 0x65,
   144  	0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   145  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x2e, 0x76, 0x33,
   146  	0x42, 0x08, 0x52, 0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba,
   147  	0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x02, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   148  }
   149  
   150  var (
   151  	file_envoy_service_route_v3_rds_proto_rawDescOnce sync.Once
   152  	file_envoy_service_route_v3_rds_proto_rawDescData = file_envoy_service_route_v3_rds_proto_rawDesc
   153  )
   154  
   155  func file_envoy_service_route_v3_rds_proto_rawDescGZIP() []byte {
   156  	file_envoy_service_route_v3_rds_proto_rawDescOnce.Do(func() {
   157  		file_envoy_service_route_v3_rds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_route_v3_rds_proto_rawDescData)
   158  	})
   159  	return file_envoy_service_route_v3_rds_proto_rawDescData
   160  }
   161  
   162  var file_envoy_service_route_v3_rds_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
   163  var file_envoy_service_route_v3_rds_proto_goTypes = []interface{}{
   164  	(*RdsDummy)(nil),                  // 0: envoy.service.route.v3.RdsDummy
   165  	(*v3.DiscoveryRequest)(nil),       // 1: envoy.service.discovery.v3.DiscoveryRequest
   166  	(*v3.DeltaDiscoveryRequest)(nil),  // 2: envoy.service.discovery.v3.DeltaDiscoveryRequest
   167  	(*v3.DiscoveryResponse)(nil),      // 3: envoy.service.discovery.v3.DiscoveryResponse
   168  	(*v3.DeltaDiscoveryResponse)(nil), // 4: envoy.service.discovery.v3.DeltaDiscoveryResponse
   169  }
   170  var file_envoy_service_route_v3_rds_proto_depIdxs = []int32{
   171  	1, // 0: envoy.service.route.v3.RouteDiscoveryService.StreamRoutes:input_type -> envoy.service.discovery.v3.DiscoveryRequest
   172  	2, // 1: envoy.service.route.v3.RouteDiscoveryService.DeltaRoutes:input_type -> envoy.service.discovery.v3.DeltaDiscoveryRequest
   173  	1, // 2: envoy.service.route.v3.RouteDiscoveryService.FetchRoutes:input_type -> envoy.service.discovery.v3.DiscoveryRequest
   174  	2, // 3: envoy.service.route.v3.VirtualHostDiscoveryService.DeltaVirtualHosts:input_type -> envoy.service.discovery.v3.DeltaDiscoveryRequest
   175  	3, // 4: envoy.service.route.v3.RouteDiscoveryService.StreamRoutes:output_type -> envoy.service.discovery.v3.DiscoveryResponse
   176  	4, // 5: envoy.service.route.v3.RouteDiscoveryService.DeltaRoutes:output_type -> envoy.service.discovery.v3.DeltaDiscoveryResponse
   177  	3, // 6: envoy.service.route.v3.RouteDiscoveryService.FetchRoutes:output_type -> envoy.service.discovery.v3.DiscoveryResponse
   178  	4, // 7: envoy.service.route.v3.VirtualHostDiscoveryService.DeltaVirtualHosts:output_type -> envoy.service.discovery.v3.DeltaDiscoveryResponse
   179  	4, // [4:8] is the sub-list for method output_type
   180  	0, // [0:4] is the sub-list for method input_type
   181  	0, // [0:0] is the sub-list for extension type_name
   182  	0, // [0:0] is the sub-list for extension extendee
   183  	0, // [0:0] is the sub-list for field type_name
   184  }
   185  
   186  func init() { file_envoy_service_route_v3_rds_proto_init() }
   187  func file_envoy_service_route_v3_rds_proto_init() {
   188  	if File_envoy_service_route_v3_rds_proto != nil {
   189  		return
   190  	}
   191  	if !protoimpl.UnsafeEnabled {
   192  		file_envoy_service_route_v3_rds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   193  			switch v := v.(*RdsDummy); i {
   194  			case 0:
   195  				return &v.state
   196  			case 1:
   197  				return &v.sizeCache
   198  			case 2:
   199  				return &v.unknownFields
   200  			default:
   201  				return nil
   202  			}
   203  		}
   204  	}
   205  	type x struct{}
   206  	out := protoimpl.TypeBuilder{
   207  		File: protoimpl.DescBuilder{
   208  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   209  			RawDescriptor: file_envoy_service_route_v3_rds_proto_rawDesc,
   210  			NumEnums:      0,
   211  			NumMessages:   1,
   212  			NumExtensions: 0,
   213  			NumServices:   2,
   214  		},
   215  		GoTypes:           file_envoy_service_route_v3_rds_proto_goTypes,
   216  		DependencyIndexes: file_envoy_service_route_v3_rds_proto_depIdxs,
   217  		MessageInfos:      file_envoy_service_route_v3_rds_proto_msgTypes,
   218  	}.Build()
   219  	File_envoy_service_route_v3_rds_proto = out.File
   220  	file_envoy_service_route_v3_rds_proto_rawDesc = nil
   221  	file_envoy_service_route_v3_rds_proto_goTypes = nil
   222  	file_envoy_service_route_v3_rds_proto_depIdxs = nil
   223  }
   224  
   225  // Reference imports to suppress errors if they are not otherwise used.
   226  var _ context.Context
   227  var _ grpc.ClientConnInterface
   228  
   229  // This is a compile-time assertion to ensure that this generated file
   230  // is compatible with the grpc package it is being compiled against.
   231  const _ = grpc.SupportPackageIsVersion6
   232  
   233  // RouteDiscoveryServiceClient is the client API for RouteDiscoveryService service.
   234  //
   235  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   236  type RouteDiscoveryServiceClient interface {
   237  	StreamRoutes(ctx context.Context, opts ...grpc.CallOption) (RouteDiscoveryService_StreamRoutesClient, error)
   238  	DeltaRoutes(ctx context.Context, opts ...grpc.CallOption) (RouteDiscoveryService_DeltaRoutesClient, error)
   239  	FetchRoutes(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error)
   240  }
   241  
   242  type routeDiscoveryServiceClient struct {
   243  	cc grpc.ClientConnInterface
   244  }
   245  
   246  func NewRouteDiscoveryServiceClient(cc grpc.ClientConnInterface) RouteDiscoveryServiceClient {
   247  	return &routeDiscoveryServiceClient{cc}
   248  }
   249  
   250  func (c *routeDiscoveryServiceClient) StreamRoutes(ctx context.Context, opts ...grpc.CallOption) (RouteDiscoveryService_StreamRoutesClient, error) {
   251  	stream, err := c.cc.NewStream(ctx, &_RouteDiscoveryService_serviceDesc.Streams[0], "/envoy.service.route.v3.RouteDiscoveryService/StreamRoutes", opts...)
   252  	if err != nil {
   253  		return nil, err
   254  	}
   255  	x := &routeDiscoveryServiceStreamRoutesClient{stream}
   256  	return x, nil
   257  }
   258  
   259  type RouteDiscoveryService_StreamRoutesClient interface {
   260  	Send(*v3.DiscoveryRequest) error
   261  	Recv() (*v3.DiscoveryResponse, error)
   262  	grpc.ClientStream
   263  }
   264  
   265  type routeDiscoveryServiceStreamRoutesClient struct {
   266  	grpc.ClientStream
   267  }
   268  
   269  func (x *routeDiscoveryServiceStreamRoutesClient) Send(m *v3.DiscoveryRequest) error {
   270  	return x.ClientStream.SendMsg(m)
   271  }
   272  
   273  func (x *routeDiscoveryServiceStreamRoutesClient) Recv() (*v3.DiscoveryResponse, error) {
   274  	m := new(v3.DiscoveryResponse)
   275  	if err := x.ClientStream.RecvMsg(m); err != nil {
   276  		return nil, err
   277  	}
   278  	return m, nil
   279  }
   280  
   281  func (c *routeDiscoveryServiceClient) DeltaRoutes(ctx context.Context, opts ...grpc.CallOption) (RouteDiscoveryService_DeltaRoutesClient, error) {
   282  	stream, err := c.cc.NewStream(ctx, &_RouteDiscoveryService_serviceDesc.Streams[1], "/envoy.service.route.v3.RouteDiscoveryService/DeltaRoutes", opts...)
   283  	if err != nil {
   284  		return nil, err
   285  	}
   286  	x := &routeDiscoveryServiceDeltaRoutesClient{stream}
   287  	return x, nil
   288  }
   289  
   290  type RouteDiscoveryService_DeltaRoutesClient interface {
   291  	Send(*v3.DeltaDiscoveryRequest) error
   292  	Recv() (*v3.DeltaDiscoveryResponse, error)
   293  	grpc.ClientStream
   294  }
   295  
   296  type routeDiscoveryServiceDeltaRoutesClient struct {
   297  	grpc.ClientStream
   298  }
   299  
   300  func (x *routeDiscoveryServiceDeltaRoutesClient) Send(m *v3.DeltaDiscoveryRequest) error {
   301  	return x.ClientStream.SendMsg(m)
   302  }
   303  
   304  func (x *routeDiscoveryServiceDeltaRoutesClient) Recv() (*v3.DeltaDiscoveryResponse, error) {
   305  	m := new(v3.DeltaDiscoveryResponse)
   306  	if err := x.ClientStream.RecvMsg(m); err != nil {
   307  		return nil, err
   308  	}
   309  	return m, nil
   310  }
   311  
   312  func (c *routeDiscoveryServiceClient) FetchRoutes(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error) {
   313  	out := new(v3.DiscoveryResponse)
   314  	err := c.cc.Invoke(ctx, "/envoy.service.route.v3.RouteDiscoveryService/FetchRoutes", in, out, opts...)
   315  	if err != nil {
   316  		return nil, err
   317  	}
   318  	return out, nil
   319  }
   320  
   321  // RouteDiscoveryServiceServer is the server API for RouteDiscoveryService service.
   322  type RouteDiscoveryServiceServer interface {
   323  	StreamRoutes(RouteDiscoveryService_StreamRoutesServer) error
   324  	DeltaRoutes(RouteDiscoveryService_DeltaRoutesServer) error
   325  	FetchRoutes(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
   326  }
   327  
   328  // UnimplementedRouteDiscoveryServiceServer can be embedded to have forward compatible implementations.
   329  type UnimplementedRouteDiscoveryServiceServer struct {
   330  }
   331  
   332  func (*UnimplementedRouteDiscoveryServiceServer) StreamRoutes(RouteDiscoveryService_StreamRoutesServer) error {
   333  	return status.Errorf(codes.Unimplemented, "method StreamRoutes not implemented")
   334  }
   335  func (*UnimplementedRouteDiscoveryServiceServer) DeltaRoutes(RouteDiscoveryService_DeltaRoutesServer) error {
   336  	return status.Errorf(codes.Unimplemented, "method DeltaRoutes not implemented")
   337  }
   338  func (*UnimplementedRouteDiscoveryServiceServer) FetchRoutes(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error) {
   339  	return nil, status.Errorf(codes.Unimplemented, "method FetchRoutes not implemented")
   340  }
   341  
   342  func RegisterRouteDiscoveryServiceServer(s *grpc.Server, srv RouteDiscoveryServiceServer) {
   343  	s.RegisterService(&_RouteDiscoveryService_serviceDesc, srv)
   344  }
   345  
   346  func _RouteDiscoveryService_StreamRoutes_Handler(srv interface{}, stream grpc.ServerStream) error {
   347  	return srv.(RouteDiscoveryServiceServer).StreamRoutes(&routeDiscoveryServiceStreamRoutesServer{stream})
   348  }
   349  
   350  type RouteDiscoveryService_StreamRoutesServer interface {
   351  	Send(*v3.DiscoveryResponse) error
   352  	Recv() (*v3.DiscoveryRequest, error)
   353  	grpc.ServerStream
   354  }
   355  
   356  type routeDiscoveryServiceStreamRoutesServer struct {
   357  	grpc.ServerStream
   358  }
   359  
   360  func (x *routeDiscoveryServiceStreamRoutesServer) Send(m *v3.DiscoveryResponse) error {
   361  	return x.ServerStream.SendMsg(m)
   362  }
   363  
   364  func (x *routeDiscoveryServiceStreamRoutesServer) Recv() (*v3.DiscoveryRequest, error) {
   365  	m := new(v3.DiscoveryRequest)
   366  	if err := x.ServerStream.RecvMsg(m); err != nil {
   367  		return nil, err
   368  	}
   369  	return m, nil
   370  }
   371  
   372  func _RouteDiscoveryService_DeltaRoutes_Handler(srv interface{}, stream grpc.ServerStream) error {
   373  	return srv.(RouteDiscoveryServiceServer).DeltaRoutes(&routeDiscoveryServiceDeltaRoutesServer{stream})
   374  }
   375  
   376  type RouteDiscoveryService_DeltaRoutesServer interface {
   377  	Send(*v3.DeltaDiscoveryResponse) error
   378  	Recv() (*v3.DeltaDiscoveryRequest, error)
   379  	grpc.ServerStream
   380  }
   381  
   382  type routeDiscoveryServiceDeltaRoutesServer struct {
   383  	grpc.ServerStream
   384  }
   385  
   386  func (x *routeDiscoveryServiceDeltaRoutesServer) Send(m *v3.DeltaDiscoveryResponse) error {
   387  	return x.ServerStream.SendMsg(m)
   388  }
   389  
   390  func (x *routeDiscoveryServiceDeltaRoutesServer) Recv() (*v3.DeltaDiscoveryRequest, error) {
   391  	m := new(v3.DeltaDiscoveryRequest)
   392  	if err := x.ServerStream.RecvMsg(m); err != nil {
   393  		return nil, err
   394  	}
   395  	return m, nil
   396  }
   397  
   398  func _RouteDiscoveryService_FetchRoutes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   399  	in := new(v3.DiscoveryRequest)
   400  	if err := dec(in); err != nil {
   401  		return nil, err
   402  	}
   403  	if interceptor == nil {
   404  		return srv.(RouteDiscoveryServiceServer).FetchRoutes(ctx, in)
   405  	}
   406  	info := &grpc.UnaryServerInfo{
   407  		Server:     srv,
   408  		FullMethod: "/envoy.service.route.v3.RouteDiscoveryService/FetchRoutes",
   409  	}
   410  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   411  		return srv.(RouteDiscoveryServiceServer).FetchRoutes(ctx, req.(*v3.DiscoveryRequest))
   412  	}
   413  	return interceptor(ctx, in, info, handler)
   414  }
   415  
   416  var _RouteDiscoveryService_serviceDesc = grpc.ServiceDesc{
   417  	ServiceName: "envoy.service.route.v3.RouteDiscoveryService",
   418  	HandlerType: (*RouteDiscoveryServiceServer)(nil),
   419  	Methods: []grpc.MethodDesc{
   420  		{
   421  			MethodName: "FetchRoutes",
   422  			Handler:    _RouteDiscoveryService_FetchRoutes_Handler,
   423  		},
   424  	},
   425  	Streams: []grpc.StreamDesc{
   426  		{
   427  			StreamName:    "StreamRoutes",
   428  			Handler:       _RouteDiscoveryService_StreamRoutes_Handler,
   429  			ServerStreams: true,
   430  			ClientStreams: true,
   431  		},
   432  		{
   433  			StreamName:    "DeltaRoutes",
   434  			Handler:       _RouteDiscoveryService_DeltaRoutes_Handler,
   435  			ServerStreams: true,
   436  			ClientStreams: true,
   437  		},
   438  	},
   439  	Metadata: "envoy/service/route/v3/rds.proto",
   440  }
   441  
   442  // VirtualHostDiscoveryServiceClient is the client API for VirtualHostDiscoveryService service.
   443  //
   444  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   445  type VirtualHostDiscoveryServiceClient interface {
   446  	DeltaVirtualHosts(ctx context.Context, opts ...grpc.CallOption) (VirtualHostDiscoveryService_DeltaVirtualHostsClient, error)
   447  }
   448  
   449  type virtualHostDiscoveryServiceClient struct {
   450  	cc grpc.ClientConnInterface
   451  }
   452  
   453  func NewVirtualHostDiscoveryServiceClient(cc grpc.ClientConnInterface) VirtualHostDiscoveryServiceClient {
   454  	return &virtualHostDiscoveryServiceClient{cc}
   455  }
   456  
   457  func (c *virtualHostDiscoveryServiceClient) DeltaVirtualHosts(ctx context.Context, opts ...grpc.CallOption) (VirtualHostDiscoveryService_DeltaVirtualHostsClient, error) {
   458  	stream, err := c.cc.NewStream(ctx, &_VirtualHostDiscoveryService_serviceDesc.Streams[0], "/envoy.service.route.v3.VirtualHostDiscoveryService/DeltaVirtualHosts", opts...)
   459  	if err != nil {
   460  		return nil, err
   461  	}
   462  	x := &virtualHostDiscoveryServiceDeltaVirtualHostsClient{stream}
   463  	return x, nil
   464  }
   465  
   466  type VirtualHostDiscoveryService_DeltaVirtualHostsClient interface {
   467  	Send(*v3.DeltaDiscoveryRequest) error
   468  	Recv() (*v3.DeltaDiscoveryResponse, error)
   469  	grpc.ClientStream
   470  }
   471  
   472  type virtualHostDiscoveryServiceDeltaVirtualHostsClient struct {
   473  	grpc.ClientStream
   474  }
   475  
   476  func (x *virtualHostDiscoveryServiceDeltaVirtualHostsClient) Send(m *v3.DeltaDiscoveryRequest) error {
   477  	return x.ClientStream.SendMsg(m)
   478  }
   479  
   480  func (x *virtualHostDiscoveryServiceDeltaVirtualHostsClient) Recv() (*v3.DeltaDiscoveryResponse, error) {
   481  	m := new(v3.DeltaDiscoveryResponse)
   482  	if err := x.ClientStream.RecvMsg(m); err != nil {
   483  		return nil, err
   484  	}
   485  	return m, nil
   486  }
   487  
   488  // VirtualHostDiscoveryServiceServer is the server API for VirtualHostDiscoveryService service.
   489  type VirtualHostDiscoveryServiceServer interface {
   490  	DeltaVirtualHosts(VirtualHostDiscoveryService_DeltaVirtualHostsServer) error
   491  }
   492  
   493  // UnimplementedVirtualHostDiscoveryServiceServer can be embedded to have forward compatible implementations.
   494  type UnimplementedVirtualHostDiscoveryServiceServer struct {
   495  }
   496  
   497  func (*UnimplementedVirtualHostDiscoveryServiceServer) DeltaVirtualHosts(VirtualHostDiscoveryService_DeltaVirtualHostsServer) error {
   498  	return status.Errorf(codes.Unimplemented, "method DeltaVirtualHosts not implemented")
   499  }
   500  
   501  func RegisterVirtualHostDiscoveryServiceServer(s *grpc.Server, srv VirtualHostDiscoveryServiceServer) {
   502  	s.RegisterService(&_VirtualHostDiscoveryService_serviceDesc, srv)
   503  }
   504  
   505  func _VirtualHostDiscoveryService_DeltaVirtualHosts_Handler(srv interface{}, stream grpc.ServerStream) error {
   506  	return srv.(VirtualHostDiscoveryServiceServer).DeltaVirtualHosts(&virtualHostDiscoveryServiceDeltaVirtualHostsServer{stream})
   507  }
   508  
   509  type VirtualHostDiscoveryService_DeltaVirtualHostsServer interface {
   510  	Send(*v3.DeltaDiscoveryResponse) error
   511  	Recv() (*v3.DeltaDiscoveryRequest, error)
   512  	grpc.ServerStream
   513  }
   514  
   515  type virtualHostDiscoveryServiceDeltaVirtualHostsServer struct {
   516  	grpc.ServerStream
   517  }
   518  
   519  func (x *virtualHostDiscoveryServiceDeltaVirtualHostsServer) Send(m *v3.DeltaDiscoveryResponse) error {
   520  	return x.ServerStream.SendMsg(m)
   521  }
   522  
   523  func (x *virtualHostDiscoveryServiceDeltaVirtualHostsServer) Recv() (*v3.DeltaDiscoveryRequest, error) {
   524  	m := new(v3.DeltaDiscoveryRequest)
   525  	if err := x.ServerStream.RecvMsg(m); err != nil {
   526  		return nil, err
   527  	}
   528  	return m, nil
   529  }
   530  
   531  var _VirtualHostDiscoveryService_serviceDesc = grpc.ServiceDesc{
   532  	ServiceName: "envoy.service.route.v3.VirtualHostDiscoveryService",
   533  	HandlerType: (*VirtualHostDiscoveryServiceServer)(nil),
   534  	Methods:     []grpc.MethodDesc{},
   535  	Streams: []grpc.StreamDesc{
   536  		{
   537  			StreamName:    "DeltaVirtualHosts",
   538  			Handler:       _VirtualHostDiscoveryService_DeltaVirtualHosts_Handler,
   539  			ServerStreams: true,
   540  			ClientStreams: true,
   541  		},
   542  	},
   543  	Metadata: "envoy/service/route/v3/rds.proto",
   544  }
   545  

View as plain text