rtds.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/runtime/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/runtime/v3/rtds.proto
     6  
     7  package envoy_service_runtime_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  	_struct "github.com/golang/protobuf/ptypes/struct"
    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
    40  type RtdsDummy struct {
    41  	state         protoimpl.MessageState
    42  	sizeCache     protoimpl.SizeCache
    43  	unknownFields protoimpl.UnknownFields
    44  }
    45  
    46  func (x *RtdsDummy) Reset() {
    47  	*x = RtdsDummy{}
    48  	if protoimpl.UnsafeEnabled {
    49  		mi := &file_envoy_service_runtime_v3_rtds_proto_msgTypes[0]
    50  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    51  		ms.StoreMessageInfo(mi)
    52  	}
    53  }
    54  
    55  func (x *RtdsDummy) String() string {
    56  	return protoimpl.X.MessageStringOf(x)
    57  }
    58  
    59  func (*RtdsDummy) ProtoMessage() {}
    60  
    61  func (x *RtdsDummy) ProtoReflect() protoreflect.Message {
    62  	mi := &file_envoy_service_runtime_v3_rtds_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 RtdsDummy.ProtoReflect.Descriptor instead.
    74  func (*RtdsDummy) Descriptor() ([]byte, []int) {
    75  	return file_envoy_service_runtime_v3_rtds_proto_rawDescGZIP(), []int{0}
    76  }
    77  
    78  // RTDS resource type. This describes a layer in the runtime virtual filesystem.
    79  type Runtime struct {
    80  	state         protoimpl.MessageState
    81  	sizeCache     protoimpl.SizeCache
    82  	unknownFields protoimpl.UnknownFields
    83  
    84  	// Runtime resource name. This makes the Runtime a self-describing xDS
    85  	// resource.
    86  	Name  string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    87  	Layer *_struct.Struct `protobuf:"bytes,2,opt,name=layer,proto3" json:"layer,omitempty"`
    88  }
    89  
    90  func (x *Runtime) Reset() {
    91  	*x = Runtime{}
    92  	if protoimpl.UnsafeEnabled {
    93  		mi := &file_envoy_service_runtime_v3_rtds_proto_msgTypes[1]
    94  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    95  		ms.StoreMessageInfo(mi)
    96  	}
    97  }
    98  
    99  func (x *Runtime) String() string {
   100  	return protoimpl.X.MessageStringOf(x)
   101  }
   102  
   103  func (*Runtime) ProtoMessage() {}
   104  
   105  func (x *Runtime) ProtoReflect() protoreflect.Message {
   106  	mi := &file_envoy_service_runtime_v3_rtds_proto_msgTypes[1]
   107  	if protoimpl.UnsafeEnabled && x != nil {
   108  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   109  		if ms.LoadMessageInfo() == nil {
   110  			ms.StoreMessageInfo(mi)
   111  		}
   112  		return ms
   113  	}
   114  	return mi.MessageOf(x)
   115  }
   116  
   117  // Deprecated: Use Runtime.ProtoReflect.Descriptor instead.
   118  func (*Runtime) Descriptor() ([]byte, []int) {
   119  	return file_envoy_service_runtime_v3_rtds_proto_rawDescGZIP(), []int{1}
   120  }
   121  
   122  func (x *Runtime) GetName() string {
   123  	if x != nil {
   124  		return x.Name
   125  	}
   126  	return ""
   127  }
   128  
   129  func (x *Runtime) GetLayer() *_struct.Struct {
   130  	if x != nil {
   131  		return x.Layer
   132  	}
   133  	return nil
   134  }
   135  
   136  var File_envoy_service_runtime_v3_rtds_proto protoreflect.FileDescriptor
   137  
   138  var file_envoy_service_runtime_v3_rtds_proto_rawDesc = []byte{
   139  	0x0a, 0x23, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   140  	0x72, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x72, 0x74, 0x64, 0x73, 0x2e,
   141  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x18, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
   142  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x72, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x33, 0x1a,
   143  	0x2a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x64,
   144  	0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x33, 0x2f, 0x64, 0x69, 0x73, 0x63,
   145  	0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f,
   146  	0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69,
   147  	0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   148  	0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x73, 0x74, 0x72, 0x75, 0x63,
   149  	0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61,
   150  	0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75,
   151  	0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f,
   152  	0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74,
   153  	0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61,
   154  	0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73, 0x69,
   155  	0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76, 0x61, 0x6c,
   156  	0x69, 0x64, 0x61, 0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2e, 0x70,
   157  	0x72, 0x6f, 0x74, 0x6f, 0x22, 0x38, 0x0a, 0x09, 0x52, 0x74, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d,
   158  	0x79, 0x3a, 0x2b, 0x9a, 0xc5, 0x88, 0x1e, 0x26, 0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   159  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   160  	0x79, 0x2e, 0x76, 0x32, 0x2e, 0x52, 0x74, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x22, 0x80,
   161  	0x01, 0x0a, 0x07, 0x52, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x1b, 0x0a, 0x04, 0x6e, 0x61,
   162  	0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10,
   163  	0x01, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x2d, 0x0a, 0x05, 0x6c, 0x61, 0x79, 0x65, 0x72,
   164  	0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
   165  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x52,
   166  	0x05, 0x6c, 0x61, 0x79, 0x65, 0x72, 0x3a, 0x29, 0x9a, 0xc5, 0x88, 0x1e, 0x24, 0x0a, 0x22, 0x65,
   167  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73,
   168  	0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x2e, 0x52, 0x75, 0x6e, 0x74, 0x69, 0x6d,
   169  	0x65, 0x32, 0xca, 0x03, 0x0a, 0x17, 0x52, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x44, 0x69, 0x73,
   170  	0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x72, 0x0a,
   171  	0x0d, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x2c,
   172  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64,
   173  	0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63,
   174  	0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65,
   175  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73,
   176  	0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76,
   177  	0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30,
   178  	0x01, 0x12, 0x7b, 0x0a, 0x0c, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x52, 0x75, 0x6e, 0x74, 0x69, 0x6d,
   179  	0x65, 0x12, 0x31, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
   180  	0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44,
   181  	0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71,
   182  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
   183  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76,
   184  	0x33, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
   185  	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x93,
   186  	0x01, 0x0a, 0x0c, 0x46, 0x65, 0x74, 0x63, 0x68, 0x52, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x12,
   187  	0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
   188  	0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73,
   189  	0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e,
   190  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69,
   191  	0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x33, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f,
   192  	0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x26, 0x82, 0xd3,
   193  	0xe4, 0x93, 0x02, 0x17, 0x22, 0x15, 0x2f, 0x76, 0x33, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76,
   194  	0x65, 0x72, 0x79, 0x3a, 0x72, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02,
   195  	0x03, 0x3a, 0x01, 0x2a, 0x1a, 0x28, 0x8a, 0xa4, 0x96, 0xf3, 0x07, 0x22, 0x0a, 0x20, 0x65, 0x6e,
   196  	0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x72, 0x75, 0x6e, 0x74,
   197  	0x69, 0x6d, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x52, 0x75, 0x6e, 0x74, 0x69, 0x6d, 0x65, 0x42, 0x40,
   198  	0x0a, 0x26, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e,
   199  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x72, 0x75,
   200  	0x6e, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x33, 0x42, 0x09, 0x52, 0x74, 0x64, 0x73, 0x50, 0x72,
   201  	0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x02,
   202  	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   203  }
   204  
   205  var (
   206  	file_envoy_service_runtime_v3_rtds_proto_rawDescOnce sync.Once
   207  	file_envoy_service_runtime_v3_rtds_proto_rawDescData = file_envoy_service_runtime_v3_rtds_proto_rawDesc
   208  )
   209  
   210  func file_envoy_service_runtime_v3_rtds_proto_rawDescGZIP() []byte {
   211  	file_envoy_service_runtime_v3_rtds_proto_rawDescOnce.Do(func() {
   212  		file_envoy_service_runtime_v3_rtds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_runtime_v3_rtds_proto_rawDescData)
   213  	})
   214  	return file_envoy_service_runtime_v3_rtds_proto_rawDescData
   215  }
   216  
   217  var file_envoy_service_runtime_v3_rtds_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
   218  var file_envoy_service_runtime_v3_rtds_proto_goTypes = []interface{}{
   219  	(*RtdsDummy)(nil),                 // 0: envoy.service.runtime.v3.RtdsDummy
   220  	(*Runtime)(nil),                   // 1: envoy.service.runtime.v3.Runtime
   221  	(*_struct.Struct)(nil),            // 2: google.protobuf.Struct
   222  	(*v3.DiscoveryRequest)(nil),       // 3: envoy.service.discovery.v3.DiscoveryRequest
   223  	(*v3.DeltaDiscoveryRequest)(nil),  // 4: envoy.service.discovery.v3.DeltaDiscoveryRequest
   224  	(*v3.DiscoveryResponse)(nil),      // 5: envoy.service.discovery.v3.DiscoveryResponse
   225  	(*v3.DeltaDiscoveryResponse)(nil), // 6: envoy.service.discovery.v3.DeltaDiscoveryResponse
   226  }
   227  var file_envoy_service_runtime_v3_rtds_proto_depIdxs = []int32{
   228  	2, // 0: envoy.service.runtime.v3.Runtime.layer:type_name -> google.protobuf.Struct
   229  	3, // 1: envoy.service.runtime.v3.RuntimeDiscoveryService.StreamRuntime:input_type -> envoy.service.discovery.v3.DiscoveryRequest
   230  	4, // 2: envoy.service.runtime.v3.RuntimeDiscoveryService.DeltaRuntime:input_type -> envoy.service.discovery.v3.DeltaDiscoveryRequest
   231  	3, // 3: envoy.service.runtime.v3.RuntimeDiscoveryService.FetchRuntime:input_type -> envoy.service.discovery.v3.DiscoveryRequest
   232  	5, // 4: envoy.service.runtime.v3.RuntimeDiscoveryService.StreamRuntime:output_type -> envoy.service.discovery.v3.DiscoveryResponse
   233  	6, // 5: envoy.service.runtime.v3.RuntimeDiscoveryService.DeltaRuntime:output_type -> envoy.service.discovery.v3.DeltaDiscoveryResponse
   234  	5, // 6: envoy.service.runtime.v3.RuntimeDiscoveryService.FetchRuntime:output_type -> envoy.service.discovery.v3.DiscoveryResponse
   235  	4, // [4:7] is the sub-list for method output_type
   236  	1, // [1:4] is the sub-list for method input_type
   237  	1, // [1:1] is the sub-list for extension type_name
   238  	1, // [1:1] is the sub-list for extension extendee
   239  	0, // [0:1] is the sub-list for field type_name
   240  }
   241  
   242  func init() { file_envoy_service_runtime_v3_rtds_proto_init() }
   243  func file_envoy_service_runtime_v3_rtds_proto_init() {
   244  	if File_envoy_service_runtime_v3_rtds_proto != nil {
   245  		return
   246  	}
   247  	if !protoimpl.UnsafeEnabled {
   248  		file_envoy_service_runtime_v3_rtds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   249  			switch v := v.(*RtdsDummy); i {
   250  			case 0:
   251  				return &v.state
   252  			case 1:
   253  				return &v.sizeCache
   254  			case 2:
   255  				return &v.unknownFields
   256  			default:
   257  				return nil
   258  			}
   259  		}
   260  		file_envoy_service_runtime_v3_rtds_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   261  			switch v := v.(*Runtime); i {
   262  			case 0:
   263  				return &v.state
   264  			case 1:
   265  				return &v.sizeCache
   266  			case 2:
   267  				return &v.unknownFields
   268  			default:
   269  				return nil
   270  			}
   271  		}
   272  	}
   273  	type x struct{}
   274  	out := protoimpl.TypeBuilder{
   275  		File: protoimpl.DescBuilder{
   276  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   277  			RawDescriptor: file_envoy_service_runtime_v3_rtds_proto_rawDesc,
   278  			NumEnums:      0,
   279  			NumMessages:   2,
   280  			NumExtensions: 0,
   281  			NumServices:   1,
   282  		},
   283  		GoTypes:           file_envoy_service_runtime_v3_rtds_proto_goTypes,
   284  		DependencyIndexes: file_envoy_service_runtime_v3_rtds_proto_depIdxs,
   285  		MessageInfos:      file_envoy_service_runtime_v3_rtds_proto_msgTypes,
   286  	}.Build()
   287  	File_envoy_service_runtime_v3_rtds_proto = out.File
   288  	file_envoy_service_runtime_v3_rtds_proto_rawDesc = nil
   289  	file_envoy_service_runtime_v3_rtds_proto_goTypes = nil
   290  	file_envoy_service_runtime_v3_rtds_proto_depIdxs = nil
   291  }
   292  
   293  // Reference imports to suppress errors if they are not otherwise used.
   294  var _ context.Context
   295  var _ grpc.ClientConnInterface
   296  
   297  // This is a compile-time assertion to ensure that this generated file
   298  // is compatible with the grpc package it is being compiled against.
   299  const _ = grpc.SupportPackageIsVersion6
   300  
   301  // RuntimeDiscoveryServiceClient is the client API for RuntimeDiscoveryService service.
   302  //
   303  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   304  type RuntimeDiscoveryServiceClient interface {
   305  	StreamRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_StreamRuntimeClient, error)
   306  	DeltaRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_DeltaRuntimeClient, error)
   307  	FetchRuntime(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error)
   308  }
   309  
   310  type runtimeDiscoveryServiceClient struct {
   311  	cc grpc.ClientConnInterface
   312  }
   313  
   314  func NewRuntimeDiscoveryServiceClient(cc grpc.ClientConnInterface) RuntimeDiscoveryServiceClient {
   315  	return &runtimeDiscoveryServiceClient{cc}
   316  }
   317  
   318  func (c *runtimeDiscoveryServiceClient) StreamRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_StreamRuntimeClient, error) {
   319  	stream, err := c.cc.NewStream(ctx, &_RuntimeDiscoveryService_serviceDesc.Streams[0], "/envoy.service.runtime.v3.RuntimeDiscoveryService/StreamRuntime", opts...)
   320  	if err != nil {
   321  		return nil, err
   322  	}
   323  	x := &runtimeDiscoveryServiceStreamRuntimeClient{stream}
   324  	return x, nil
   325  }
   326  
   327  type RuntimeDiscoveryService_StreamRuntimeClient interface {
   328  	Send(*v3.DiscoveryRequest) error
   329  	Recv() (*v3.DiscoveryResponse, error)
   330  	grpc.ClientStream
   331  }
   332  
   333  type runtimeDiscoveryServiceStreamRuntimeClient struct {
   334  	grpc.ClientStream
   335  }
   336  
   337  func (x *runtimeDiscoveryServiceStreamRuntimeClient) Send(m *v3.DiscoveryRequest) error {
   338  	return x.ClientStream.SendMsg(m)
   339  }
   340  
   341  func (x *runtimeDiscoveryServiceStreamRuntimeClient) Recv() (*v3.DiscoveryResponse, error) {
   342  	m := new(v3.DiscoveryResponse)
   343  	if err := x.ClientStream.RecvMsg(m); err != nil {
   344  		return nil, err
   345  	}
   346  	return m, nil
   347  }
   348  
   349  func (c *runtimeDiscoveryServiceClient) DeltaRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_DeltaRuntimeClient, error) {
   350  	stream, err := c.cc.NewStream(ctx, &_RuntimeDiscoveryService_serviceDesc.Streams[1], "/envoy.service.runtime.v3.RuntimeDiscoveryService/DeltaRuntime", opts...)
   351  	if err != nil {
   352  		return nil, err
   353  	}
   354  	x := &runtimeDiscoveryServiceDeltaRuntimeClient{stream}
   355  	return x, nil
   356  }
   357  
   358  type RuntimeDiscoveryService_DeltaRuntimeClient interface {
   359  	Send(*v3.DeltaDiscoveryRequest) error
   360  	Recv() (*v3.DeltaDiscoveryResponse, error)
   361  	grpc.ClientStream
   362  }
   363  
   364  type runtimeDiscoveryServiceDeltaRuntimeClient struct {
   365  	grpc.ClientStream
   366  }
   367  
   368  func (x *runtimeDiscoveryServiceDeltaRuntimeClient) Send(m *v3.DeltaDiscoveryRequest) error {
   369  	return x.ClientStream.SendMsg(m)
   370  }
   371  
   372  func (x *runtimeDiscoveryServiceDeltaRuntimeClient) Recv() (*v3.DeltaDiscoveryResponse, error) {
   373  	m := new(v3.DeltaDiscoveryResponse)
   374  	if err := x.ClientStream.RecvMsg(m); err != nil {
   375  		return nil, err
   376  	}
   377  	return m, nil
   378  }
   379  
   380  func (c *runtimeDiscoveryServiceClient) FetchRuntime(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error) {
   381  	out := new(v3.DiscoveryResponse)
   382  	err := c.cc.Invoke(ctx, "/envoy.service.runtime.v3.RuntimeDiscoveryService/FetchRuntime", in, out, opts...)
   383  	if err != nil {
   384  		return nil, err
   385  	}
   386  	return out, nil
   387  }
   388  
   389  // RuntimeDiscoveryServiceServer is the server API for RuntimeDiscoveryService service.
   390  type RuntimeDiscoveryServiceServer interface {
   391  	StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error
   392  	DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error
   393  	FetchRuntime(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
   394  }
   395  
   396  // UnimplementedRuntimeDiscoveryServiceServer can be embedded to have forward compatible implementations.
   397  type UnimplementedRuntimeDiscoveryServiceServer struct {
   398  }
   399  
   400  func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error {
   401  	return status.Errorf(codes.Unimplemented, "method StreamRuntime not implemented")
   402  }
   403  func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error {
   404  	return status.Errorf(codes.Unimplemented, "method DeltaRuntime not implemented")
   405  }
   406  func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error) {
   407  	return nil, status.Errorf(codes.Unimplemented, "method FetchRuntime not implemented")
   408  }
   409  
   410  func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer) {
   411  	s.RegisterService(&_RuntimeDiscoveryService_serviceDesc, srv)
   412  }
   413  
   414  func _RuntimeDiscoveryService_StreamRuntime_Handler(srv interface{}, stream grpc.ServerStream) error {
   415  	return srv.(RuntimeDiscoveryServiceServer).StreamRuntime(&runtimeDiscoveryServiceStreamRuntimeServer{stream})
   416  }
   417  
   418  type RuntimeDiscoveryService_StreamRuntimeServer interface {
   419  	Send(*v3.DiscoveryResponse) error
   420  	Recv() (*v3.DiscoveryRequest, error)
   421  	grpc.ServerStream
   422  }
   423  
   424  type runtimeDiscoveryServiceStreamRuntimeServer struct {
   425  	grpc.ServerStream
   426  }
   427  
   428  func (x *runtimeDiscoveryServiceStreamRuntimeServer) Send(m *v3.DiscoveryResponse) error {
   429  	return x.ServerStream.SendMsg(m)
   430  }
   431  
   432  func (x *runtimeDiscoveryServiceStreamRuntimeServer) Recv() (*v3.DiscoveryRequest, error) {
   433  	m := new(v3.DiscoveryRequest)
   434  	if err := x.ServerStream.RecvMsg(m); err != nil {
   435  		return nil, err
   436  	}
   437  	return m, nil
   438  }
   439  
   440  func _RuntimeDiscoveryService_DeltaRuntime_Handler(srv interface{}, stream grpc.ServerStream) error {
   441  	return srv.(RuntimeDiscoveryServiceServer).DeltaRuntime(&runtimeDiscoveryServiceDeltaRuntimeServer{stream})
   442  }
   443  
   444  type RuntimeDiscoveryService_DeltaRuntimeServer interface {
   445  	Send(*v3.DeltaDiscoveryResponse) error
   446  	Recv() (*v3.DeltaDiscoveryRequest, error)
   447  	grpc.ServerStream
   448  }
   449  
   450  type runtimeDiscoveryServiceDeltaRuntimeServer struct {
   451  	grpc.ServerStream
   452  }
   453  
   454  func (x *runtimeDiscoveryServiceDeltaRuntimeServer) Send(m *v3.DeltaDiscoveryResponse) error {
   455  	return x.ServerStream.SendMsg(m)
   456  }
   457  
   458  func (x *runtimeDiscoveryServiceDeltaRuntimeServer) Recv() (*v3.DeltaDiscoveryRequest, error) {
   459  	m := new(v3.DeltaDiscoveryRequest)
   460  	if err := x.ServerStream.RecvMsg(m); err != nil {
   461  		return nil, err
   462  	}
   463  	return m, nil
   464  }
   465  
   466  func _RuntimeDiscoveryService_FetchRuntime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   467  	in := new(v3.DiscoveryRequest)
   468  	if err := dec(in); err != nil {
   469  		return nil, err
   470  	}
   471  	if interceptor == nil {
   472  		return srv.(RuntimeDiscoveryServiceServer).FetchRuntime(ctx, in)
   473  	}
   474  	info := &grpc.UnaryServerInfo{
   475  		Server:     srv,
   476  		FullMethod: "/envoy.service.runtime.v3.RuntimeDiscoveryService/FetchRuntime",
   477  	}
   478  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   479  		return srv.(RuntimeDiscoveryServiceServer).FetchRuntime(ctx, req.(*v3.DiscoveryRequest))
   480  	}
   481  	return interceptor(ctx, in, info, handler)
   482  }
   483  
   484  var _RuntimeDiscoveryService_serviceDesc = grpc.ServiceDesc{
   485  	ServiceName: "envoy.service.runtime.v3.RuntimeDiscoveryService",
   486  	HandlerType: (*RuntimeDiscoveryServiceServer)(nil),
   487  	Methods: []grpc.MethodDesc{
   488  		{
   489  			MethodName: "FetchRuntime",
   490  			Handler:    _RuntimeDiscoveryService_FetchRuntime_Handler,
   491  		},
   492  	},
   493  	Streams: []grpc.StreamDesc{
   494  		{
   495  			StreamName:    "StreamRuntime",
   496  			Handler:       _RuntimeDiscoveryService_StreamRuntime_Handler,
   497  			ServerStreams: true,
   498  			ClientStreams: true,
   499  		},
   500  		{
   501  			StreamName:    "DeltaRuntime",
   502  			Handler:       _RuntimeDiscoveryService_DeltaRuntime_Handler,
   503  			ServerStreams: true,
   504  			ClientStreams: true,
   505  		},
   506  	},
   507  	Metadata: "envoy/service/runtime/v3/rtds.proto",
   508  }
   509
View as plain text