Source file src/github.com/emissary-ingress/emissary/v3/pkg/api/envoy/service/status/v2/csds.pb.go

Documentation: github.com/emissary-ingress/emissary/v3/pkg/api/envoy/service/status/v2

     1  // Code generated by protoc-gen-go. DO NOT EDIT.
     2  // versions:
     3  // 	protoc-gen-go v1.28.1
     4  // 	protoc        v3.21.12
     5  // source: envoy/service/status/v2/csds.proto
     6  
     7  package statusv2
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/xds/go/udpa/annotations"
    12  	v2alpha "github.com/emissary-ingress/emissary/v3/pkg/api/envoy/admin/v2alpha"
    13  	core "github.com/emissary-ingress/emissary/v3/pkg/api/envoy/api/v2/core"
    14  	matcher "github.com/emissary-ingress/emissary/v3/pkg/api/envoy/type/matcher"
    15  	_ "google.golang.org/genproto/googleapis/api/annotations"
    16  	grpc "google.golang.org/grpc"
    17  	codes "google.golang.org/grpc/codes"
    18  	status "google.golang.org/grpc/status"
    19  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    20  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    21  	reflect "reflect"
    22  	sync "sync"
    23  )
    24  
    25  const (
    26  	// Verify that this generated code is sufficiently up-to-date.
    27  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    28  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    29  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    30  )
    31  
    32  // Status of a config.
    33  type ConfigStatus int32
    34  
    35  const (
    36  	// Status info is not available/unknown.
    37  	ConfigStatus_UNKNOWN ConfigStatus = 0
    38  	// Management server has sent the config to client and received ACK.
    39  	ConfigStatus_SYNCED ConfigStatus = 1
    40  	// Config is not sent.
    41  	ConfigStatus_NOT_SENT ConfigStatus = 2
    42  	// Management server has sent the config to client but hasn’t received
    43  	// ACK/NACK.
    44  	ConfigStatus_STALE ConfigStatus = 3
    45  	// Management server has sent the config to client but received NACK.
    46  	ConfigStatus_ERROR ConfigStatus = 4
    47  )
    48  
    49  // Enum value maps for ConfigStatus.
    50  var (
    51  	ConfigStatus_name = map[int32]string{
    52  		0: "UNKNOWN",
    53  		1: "SYNCED",
    54  		2: "NOT_SENT",
    55  		3: "STALE",
    56  		4: "ERROR",
    57  	}
    58  	ConfigStatus_value = map[string]int32{
    59  		"UNKNOWN":  0,
    60  		"SYNCED":   1,
    61  		"NOT_SENT": 2,
    62  		"STALE":    3,
    63  		"ERROR":    4,
    64  	}
    65  )
    66  
    67  func (x ConfigStatus) Enum() *ConfigStatus {
    68  	p := new(ConfigStatus)
    69  	*p = x
    70  	return p
    71  }
    72  
    73  func (x ConfigStatus) String() string {
    74  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    75  }
    76  
    77  func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor {
    78  	return file_envoy_service_status_v2_csds_proto_enumTypes[0].Descriptor()
    79  }
    80  
    81  func (ConfigStatus) Type() protoreflect.EnumType {
    82  	return &file_envoy_service_status_v2_csds_proto_enumTypes[0]
    83  }
    84  
    85  func (x ConfigStatus) Number() protoreflect.EnumNumber {
    86  	return protoreflect.EnumNumber(x)
    87  }
    88  
    89  // Deprecated: Use ConfigStatus.Descriptor instead.
    90  func (ConfigStatus) EnumDescriptor() ([]byte, []int) {
    91  	return file_envoy_service_status_v2_csds_proto_rawDescGZIP(), []int{0}
    92  }
    93  
    94  // Request for client status of clients identified by a list of NodeMatchers.
    95  type ClientStatusRequest struct {
    96  	state         protoimpl.MessageState
    97  	sizeCache     protoimpl.SizeCache
    98  	unknownFields protoimpl.UnknownFields
    99  
   100  	// Management server can use these match criteria to identify clients.
   101  	// The match follows OR semantics.
   102  	NodeMatchers []*matcher.NodeMatcher `protobuf:"bytes,1,rep,name=node_matchers,json=nodeMatchers,proto3" json:"node_matchers,omitempty"`
   103  }
   104  
   105  func (x *ClientStatusRequest) Reset() {
   106  	*x = ClientStatusRequest{}
   107  	if protoimpl.UnsafeEnabled {
   108  		mi := &file_envoy_service_status_v2_csds_proto_msgTypes[0]
   109  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   110  		ms.StoreMessageInfo(mi)
   111  	}
   112  }
   113  
   114  func (x *ClientStatusRequest) String() string {
   115  	return protoimpl.X.MessageStringOf(x)
   116  }
   117  
   118  func (*ClientStatusRequest) ProtoMessage() {}
   119  
   120  func (x *ClientStatusRequest) ProtoReflect() protoreflect.Message {
   121  	mi := &file_envoy_service_status_v2_csds_proto_msgTypes[0]
   122  	if protoimpl.UnsafeEnabled && x != nil {
   123  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   124  		if ms.LoadMessageInfo() == nil {
   125  			ms.StoreMessageInfo(mi)
   126  		}
   127  		return ms
   128  	}
   129  	return mi.MessageOf(x)
   130  }
   131  
   132  // Deprecated: Use ClientStatusRequest.ProtoReflect.Descriptor instead.
   133  func (*ClientStatusRequest) Descriptor() ([]byte, []int) {
   134  	return file_envoy_service_status_v2_csds_proto_rawDescGZIP(), []int{0}
   135  }
   136  
   137  func (x *ClientStatusRequest) GetNodeMatchers() []*matcher.NodeMatcher {
   138  	if x != nil {
   139  		return x.NodeMatchers
   140  	}
   141  	return nil
   142  }
   143  
   144  // Detailed config (per xDS) with status.
   145  // [#next-free-field: 6]
   146  type PerXdsConfig struct {
   147  	state         protoimpl.MessageState
   148  	sizeCache     protoimpl.SizeCache
   149  	unknownFields protoimpl.UnknownFields
   150  
   151  	Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v2.ConfigStatus" json:"status,omitempty"`
   152  	// Types that are assignable to PerXdsConfig:
   153  	//	*PerXdsConfig_ListenerConfig
   154  	//	*PerXdsConfig_ClusterConfig
   155  	//	*PerXdsConfig_RouteConfig
   156  	//	*PerXdsConfig_ScopedRouteConfig
   157  	PerXdsConfig isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"`
   158  }
   159  
   160  func (x *PerXdsConfig) Reset() {
   161  	*x = PerXdsConfig{}
   162  	if protoimpl.UnsafeEnabled {
   163  		mi := &file_envoy_service_status_v2_csds_proto_msgTypes[1]
   164  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   165  		ms.StoreMessageInfo(mi)
   166  	}
   167  }
   168  
   169  func (x *PerXdsConfig) String() string {
   170  	return protoimpl.X.MessageStringOf(x)
   171  }
   172  
   173  func (*PerXdsConfig) ProtoMessage() {}
   174  
   175  func (x *PerXdsConfig) ProtoReflect() protoreflect.Message {
   176  	mi := &file_envoy_service_status_v2_csds_proto_msgTypes[1]
   177  	if protoimpl.UnsafeEnabled && x != nil {
   178  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   179  		if ms.LoadMessageInfo() == nil {
   180  			ms.StoreMessageInfo(mi)
   181  		}
   182  		return ms
   183  	}
   184  	return mi.MessageOf(x)
   185  }
   186  
   187  // Deprecated: Use PerXdsConfig.ProtoReflect.Descriptor instead.
   188  func (*PerXdsConfig) Descriptor() ([]byte, []int) {
   189  	return file_envoy_service_status_v2_csds_proto_rawDescGZIP(), []int{1}
   190  }
   191  
   192  func (x *PerXdsConfig) GetStatus() ConfigStatus {
   193  	if x != nil {
   194  		return x.Status
   195  	}
   196  	return ConfigStatus_UNKNOWN
   197  }
   198  
   199  func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig {
   200  	if m != nil {
   201  		return m.PerXdsConfig
   202  	}
   203  	return nil
   204  }
   205  
   206  func (x *PerXdsConfig) GetListenerConfig() *v2alpha.ListenersConfigDump {
   207  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ListenerConfig); ok {
   208  		return x.ListenerConfig
   209  	}
   210  	return nil
   211  }
   212  
   213  func (x *PerXdsConfig) GetClusterConfig() *v2alpha.ClustersConfigDump {
   214  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ClusterConfig); ok {
   215  		return x.ClusterConfig
   216  	}
   217  	return nil
   218  }
   219  
   220  func (x *PerXdsConfig) GetRouteConfig() *v2alpha.RoutesConfigDump {
   221  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_RouteConfig); ok {
   222  		return x.RouteConfig
   223  	}
   224  	return nil
   225  }
   226  
   227  func (x *PerXdsConfig) GetScopedRouteConfig() *v2alpha.ScopedRoutesConfigDump {
   228  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ScopedRouteConfig); ok {
   229  		return x.ScopedRouteConfig
   230  	}
   231  	return nil
   232  }
   233  
   234  type isPerXdsConfig_PerXdsConfig interface {
   235  	isPerXdsConfig_PerXdsConfig()
   236  }
   237  
   238  type PerXdsConfig_ListenerConfig struct {
   239  	ListenerConfig *v2alpha.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof"`
   240  }
   241  
   242  type PerXdsConfig_ClusterConfig struct {
   243  	ClusterConfig *v2alpha.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof"`
   244  }
   245  
   246  type PerXdsConfig_RouteConfig struct {
   247  	RouteConfig *v2alpha.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"`
   248  }
   249  
   250  type PerXdsConfig_ScopedRouteConfig struct {
   251  	ScopedRouteConfig *v2alpha.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof"`
   252  }
   253  
   254  func (*PerXdsConfig_ListenerConfig) isPerXdsConfig_PerXdsConfig() {}
   255  
   256  func (*PerXdsConfig_ClusterConfig) isPerXdsConfig_PerXdsConfig() {}
   257  
   258  func (*PerXdsConfig_RouteConfig) isPerXdsConfig_PerXdsConfig() {}
   259  
   260  func (*PerXdsConfig_ScopedRouteConfig) isPerXdsConfig_PerXdsConfig() {}
   261  
   262  // All xds configs for a particular client.
   263  type ClientConfig struct {
   264  	state         protoimpl.MessageState
   265  	sizeCache     protoimpl.SizeCache
   266  	unknownFields protoimpl.UnknownFields
   267  
   268  	// Node for a particular client.
   269  	Node      *core.Node      `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
   270  	XdsConfig []*PerXdsConfig `protobuf:"bytes,2,rep,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"`
   271  }
   272  
   273  func (x *ClientConfig) Reset() {
   274  	*x = ClientConfig{}
   275  	if protoimpl.UnsafeEnabled {
   276  		mi := &file_envoy_service_status_v2_csds_proto_msgTypes[2]
   277  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   278  		ms.StoreMessageInfo(mi)
   279  	}
   280  }
   281  
   282  func (x *ClientConfig) String() string {
   283  	return protoimpl.X.MessageStringOf(x)
   284  }
   285  
   286  func (*ClientConfig) ProtoMessage() {}
   287  
   288  func (x *ClientConfig) ProtoReflect() protoreflect.Message {
   289  	mi := &file_envoy_service_status_v2_csds_proto_msgTypes[2]
   290  	if protoimpl.UnsafeEnabled && x != nil {
   291  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   292  		if ms.LoadMessageInfo() == nil {
   293  			ms.StoreMessageInfo(mi)
   294  		}
   295  		return ms
   296  	}
   297  	return mi.MessageOf(x)
   298  }
   299  
   300  // Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
   301  func (*ClientConfig) Descriptor() ([]byte, []int) {
   302  	return file_envoy_service_status_v2_csds_proto_rawDescGZIP(), []int{2}
   303  }
   304  
   305  func (x *ClientConfig) GetNode() *core.Node {
   306  	if x != nil {
   307  		return x.Node
   308  	}
   309  	return nil
   310  }
   311  
   312  func (x *ClientConfig) GetXdsConfig() []*PerXdsConfig {
   313  	if x != nil {
   314  		return x.XdsConfig
   315  	}
   316  	return nil
   317  }
   318  
   319  type ClientStatusResponse struct {
   320  	state         protoimpl.MessageState
   321  	sizeCache     protoimpl.SizeCache
   322  	unknownFields protoimpl.UnknownFields
   323  
   324  	// Client configs for the clients specified in the ClientStatusRequest.
   325  	Config []*ClientConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"`
   326  }
   327  
   328  func (x *ClientStatusResponse) Reset() {
   329  	*x = ClientStatusResponse{}
   330  	if protoimpl.UnsafeEnabled {
   331  		mi := &file_envoy_service_status_v2_csds_proto_msgTypes[3]
   332  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   333  		ms.StoreMessageInfo(mi)
   334  	}
   335  }
   336  
   337  func (x *ClientStatusResponse) String() string {
   338  	return protoimpl.X.MessageStringOf(x)
   339  }
   340  
   341  func (*ClientStatusResponse) ProtoMessage() {}
   342  
   343  func (x *ClientStatusResponse) ProtoReflect() protoreflect.Message {
   344  	mi := &file_envoy_service_status_v2_csds_proto_msgTypes[3]
   345  	if protoimpl.UnsafeEnabled && x != nil {
   346  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   347  		if ms.LoadMessageInfo() == nil {
   348  			ms.StoreMessageInfo(mi)
   349  		}
   350  		return ms
   351  	}
   352  	return mi.MessageOf(x)
   353  }
   354  
   355  // Deprecated: Use ClientStatusResponse.ProtoReflect.Descriptor instead.
   356  func (*ClientStatusResponse) Descriptor() ([]byte, []int) {
   357  	return file_envoy_service_status_v2_csds_proto_rawDescGZIP(), []int{3}
   358  }
   359  
   360  func (x *ClientStatusResponse) GetConfig() []*ClientConfig {
   361  	if x != nil {
   362  		return x.Config
   363  	}
   364  	return nil
   365  }
   366  
   367  var File_envoy_service_status_v2_csds_proto protoreflect.FileDescriptor
   368  
   369  var file_envoy_service_status_v2_csds_proto_rawDesc = []byte{
   370  	0x0a, 0x22, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   371  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2f, 0x76, 0x32, 0x2f, 0x63, 0x73, 0x64, 0x73, 0x2e, 0x70,
   372  	0x72, 0x6f, 0x74, 0x6f, 0x12, 0x17, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
   373  	0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x1a, 0x25, 0x65,
   374  	0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70,
   375  	0x68, 0x61, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x5f, 0x64, 0x75, 0x6d, 0x70, 0x2e, 0x70,
   376  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f,
   377  	0x76, 0x32, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e, 0x70, 0x72, 0x6f,
   378  	0x74, 0x6f, 0x1a, 0x1d, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x2f, 0x6d,
   379  	0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x2f, 0x6e, 0x6f, 0x64, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
   380  	0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e,
   381  	0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
   382  	0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e,
   383  	0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x5b,
   384  	0x0a, 0x13, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65,
   385  	0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x0d, 0x6e, 0x6f, 0x64, 0x65, 0x5f, 0x6d, 0x61,
   386  	0x74, 0x63, 0x68, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x65,
   387  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x74, 0x79, 0x70, 0x65, 0x2e, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x65,
   388  	0x72, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x52, 0x0c, 0x6e,
   389  	0x6f, 0x64, 0x65, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x73, 0x22, 0xb1, 0x03, 0x0a, 0x0c,
   390  	0x50, 0x65, 0x72, 0x58, 0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x3d, 0x0a, 0x06,
   391  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x25, 0x2e, 0x65,
   392  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61,
   393  	0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x53, 0x74, 0x61,
   394  	0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x53, 0x0a, 0x0f, 0x6c,
   395  	0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02,
   396  	0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64, 0x6d,
   397  	0x69, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x65,
   398  	0x6e, 0x65, 0x72, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x00,
   399  	0x52, 0x0e, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67,
   400  	0x12, 0x50, 0x0a, 0x0e, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x6e, 0x66,
   401  	0x69, 0x67, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   402  	0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43,
   403  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d,
   404  	0x70, 0x48, 0x00, 0x52, 0x0d, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66,
   405  	0x69, 0x67, 0x12, 0x4a, 0x0a, 0x0c, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x5f, 0x63, 0x6f, 0x6e, 0x66,
   406  	0x69, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   407  	0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x52,
   408  	0x6f, 0x75, 0x74, 0x65, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48,
   409  	0x00, 0x52, 0x0b, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x5d,
   410  	0x0a, 0x13, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x5f, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x5f, 0x63,
   411  	0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x65, 0x6e,
   412  	0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68,
   413  	0x61, 0x2e, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x43, 0x6f,
   414  	0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x00, 0x52, 0x11, 0x73, 0x63, 0x6f, 0x70,
   415  	0x65, 0x64, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x42, 0x10, 0x0a,
   416  	0x0e, 0x70, 0x65, 0x72, 0x5f, 0x78, 0x64, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22,
   417  	0x81, 0x01, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67,
   418  	0x12, 0x2b, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17,
   419  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x63, 0x6f,
   420  	0x72, 0x65, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x52, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x12, 0x44, 0x0a,
   421  	0x0a, 0x78, 0x64, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02, 0x20, 0x03, 0x28,
   422  	0x0b, 0x32, 0x25, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
   423  	0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x50, 0x65, 0x72, 0x58,
   424  	0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x09, 0x78, 0x64, 0x73, 0x43, 0x6f, 0x6e,
   425  	0x66, 0x69, 0x67, 0x22, 0x55, 0x0a, 0x14, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61,
   426  	0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3d, 0x0a, 0x06, 0x63,
   427  	0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x65, 0x6e,
   428  	0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74,
   429  	0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66,
   430  	0x69, 0x67, 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2a, 0x4b, 0x0a, 0x0c, 0x43, 0x6f,
   431  	0x6e, 0x66, 0x69, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e,
   432  	0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x53, 0x59, 0x4e, 0x43, 0x45,
   433  	0x44, 0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x4e, 0x4f, 0x54, 0x5f, 0x53, 0x45, 0x4e, 0x54, 0x10,
   434  	0x02, 0x12, 0x09, 0x0a, 0x05, 0x53, 0x54, 0x41, 0x4c, 0x45, 0x10, 0x03, 0x12, 0x09, 0x0a, 0x05,
   435  	0x45, 0x52, 0x52, 0x4f, 0x52, 0x10, 0x04, 0x32, 0xb8, 0x02, 0x0a, 0x1c, 0x43, 0x6c, 0x69, 0x65,
   436  	0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   437  	0x79, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x77, 0x0a, 0x12, 0x53, 0x74, 0x72, 0x65,
   438  	0x61, 0x6d, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x2c,
   439  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73,
   440  	0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53,
   441  	0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65,
   442  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61,
   443  	0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61,
   444  	0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30,
   445  	0x01, 0x12, 0x9e, 0x01, 0x0a, 0x11, 0x46, 0x65, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x69, 0x65, 0x6e,
   446  	0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   447  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76,
   448  	0x32, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65,
   449  	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
   450  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e,
   451  	0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70,
   452  	0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x1d, 0x22, 0x1b, 0x2f, 0x76,
   453  	0x32, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x3a, 0x63, 0x6c, 0x69, 0x65,
   454  	0x6e, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x03, 0x3a,
   455  	0x01, 0x2a, 0x42, 0x88, 0x01, 0x0a, 0x25, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70,
   456  	0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
   457  	0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x42, 0x09, 0x43, 0x73,
   458  	0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x47, 0x67, 0x69, 0x74, 0x68, 0x75,
   459  	0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79,
   460  	0x2f, 0x67, 0x6f, 0x2d, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x2d, 0x70, 0x6c, 0x61, 0x6e,
   461  	0x65, 0x2f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   462  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2f, 0x76, 0x32, 0x3b, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
   463  	0x76, 0x32, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x01, 0x62, 0x06, 0x70,
   464  	0x72, 0x6f, 0x74, 0x6f, 0x33,
   465  }
   466  
   467  var (
   468  	file_envoy_service_status_v2_csds_proto_rawDescOnce sync.Once
   469  	file_envoy_service_status_v2_csds_proto_rawDescData = file_envoy_service_status_v2_csds_proto_rawDesc
   470  )
   471  
   472  func file_envoy_service_status_v2_csds_proto_rawDescGZIP() []byte {
   473  	file_envoy_service_status_v2_csds_proto_rawDescOnce.Do(func() {
   474  		file_envoy_service_status_v2_csds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_status_v2_csds_proto_rawDescData)
   475  	})
   476  	return file_envoy_service_status_v2_csds_proto_rawDescData
   477  }
   478  
   479  var file_envoy_service_status_v2_csds_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
   480  var file_envoy_service_status_v2_csds_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
   481  var file_envoy_service_status_v2_csds_proto_goTypes = []interface{}{
   482  	(ConfigStatus)(0),                      // 0: envoy.service.status.v2.ConfigStatus
   483  	(*ClientStatusRequest)(nil),            // 1: envoy.service.status.v2.ClientStatusRequest
   484  	(*PerXdsConfig)(nil),                   // 2: envoy.service.status.v2.PerXdsConfig
   485  	(*ClientConfig)(nil),                   // 3: envoy.service.status.v2.ClientConfig
   486  	(*ClientStatusResponse)(nil),           // 4: envoy.service.status.v2.ClientStatusResponse
   487  	(*matcher.NodeMatcher)(nil),            // 5: envoy.type.matcher.NodeMatcher
   488  	(*v2alpha.ListenersConfigDump)(nil),    // 6: envoy.admin.v2alpha.ListenersConfigDump
   489  	(*v2alpha.ClustersConfigDump)(nil),     // 7: envoy.admin.v2alpha.ClustersConfigDump
   490  	(*v2alpha.RoutesConfigDump)(nil),       // 8: envoy.admin.v2alpha.RoutesConfigDump
   491  	(*v2alpha.ScopedRoutesConfigDump)(nil), // 9: envoy.admin.v2alpha.ScopedRoutesConfigDump
   492  	(*core.Node)(nil),                      // 10: envoy.api.v2.core.Node
   493  }
   494  var file_envoy_service_status_v2_csds_proto_depIdxs = []int32{
   495  	5,  // 0: envoy.service.status.v2.ClientStatusRequest.node_matchers:type_name -> envoy.type.matcher.NodeMatcher
   496  	0,  // 1: envoy.service.status.v2.PerXdsConfig.status:type_name -> envoy.service.status.v2.ConfigStatus
   497  	6,  // 2: envoy.service.status.v2.PerXdsConfig.listener_config:type_name -> envoy.admin.v2alpha.ListenersConfigDump
   498  	7,  // 3: envoy.service.status.v2.PerXdsConfig.cluster_config:type_name -> envoy.admin.v2alpha.ClustersConfigDump
   499  	8,  // 4: envoy.service.status.v2.PerXdsConfig.route_config:type_name -> envoy.admin.v2alpha.RoutesConfigDump
   500  	9,  // 5: envoy.service.status.v2.PerXdsConfig.scoped_route_config:type_name -> envoy.admin.v2alpha.ScopedRoutesConfigDump
   501  	10, // 6: envoy.service.status.v2.ClientConfig.node:type_name -> envoy.api.v2.core.Node
   502  	2,  // 7: envoy.service.status.v2.ClientConfig.xds_config:type_name -> envoy.service.status.v2.PerXdsConfig
   503  	3,  // 8: envoy.service.status.v2.ClientStatusResponse.config:type_name -> envoy.service.status.v2.ClientConfig
   504  	1,  // 9: envoy.service.status.v2.ClientStatusDiscoveryService.StreamClientStatus:input_type -> envoy.service.status.v2.ClientStatusRequest
   505  	1,  // 10: envoy.service.status.v2.ClientStatusDiscoveryService.FetchClientStatus:input_type -> envoy.service.status.v2.ClientStatusRequest
   506  	4,  // 11: envoy.service.status.v2.ClientStatusDiscoveryService.StreamClientStatus:output_type -> envoy.service.status.v2.ClientStatusResponse
   507  	4,  // 12: envoy.service.status.v2.ClientStatusDiscoveryService.FetchClientStatus:output_type -> envoy.service.status.v2.ClientStatusResponse
   508  	11, // [11:13] is the sub-list for method output_type
   509  	9,  // [9:11] is the sub-list for method input_type
   510  	9,  // [9:9] is the sub-list for extension type_name
   511  	9,  // [9:9] is the sub-list for extension extendee
   512  	0,  // [0:9] is the sub-list for field type_name
   513  }
   514  
   515  func init() { file_envoy_service_status_v2_csds_proto_init() }
   516  func file_envoy_service_status_v2_csds_proto_init() {
   517  	if File_envoy_service_status_v2_csds_proto != nil {
   518  		return
   519  	}
   520  	if !protoimpl.UnsafeEnabled {
   521  		file_envoy_service_status_v2_csds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   522  			switch v := v.(*ClientStatusRequest); i {
   523  			case 0:
   524  				return &v.state
   525  			case 1:
   526  				return &v.sizeCache
   527  			case 2:
   528  				return &v.unknownFields
   529  			default:
   530  				return nil
   531  			}
   532  		}
   533  		file_envoy_service_status_v2_csds_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   534  			switch v := v.(*PerXdsConfig); i {
   535  			case 0:
   536  				return &v.state
   537  			case 1:
   538  				return &v.sizeCache
   539  			case 2:
   540  				return &v.unknownFields
   541  			default:
   542  				return nil
   543  			}
   544  		}
   545  		file_envoy_service_status_v2_csds_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   546  			switch v := v.(*ClientConfig); i {
   547  			case 0:
   548  				return &v.state
   549  			case 1:
   550  				return &v.sizeCache
   551  			case 2:
   552  				return &v.unknownFields
   553  			default:
   554  				return nil
   555  			}
   556  		}
   557  		file_envoy_service_status_v2_csds_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
   558  			switch v := v.(*ClientStatusResponse); i {
   559  			case 0:
   560  				return &v.state
   561  			case 1:
   562  				return &v.sizeCache
   563  			case 2:
   564  				return &v.unknownFields
   565  			default:
   566  				return nil
   567  			}
   568  		}
   569  	}
   570  	file_envoy_service_status_v2_csds_proto_msgTypes[1].OneofWrappers = []interface{}{
   571  		(*PerXdsConfig_ListenerConfig)(nil),
   572  		(*PerXdsConfig_ClusterConfig)(nil),
   573  		(*PerXdsConfig_RouteConfig)(nil),
   574  		(*PerXdsConfig_ScopedRouteConfig)(nil),
   575  	}
   576  	type x struct{}
   577  	out := protoimpl.TypeBuilder{
   578  		File: protoimpl.DescBuilder{
   579  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   580  			RawDescriptor: file_envoy_service_status_v2_csds_proto_rawDesc,
   581  			NumEnums:      1,
   582  			NumMessages:   4,
   583  			NumExtensions: 0,
   584  			NumServices:   1,
   585  		},
   586  		GoTypes:           file_envoy_service_status_v2_csds_proto_goTypes,
   587  		DependencyIndexes: file_envoy_service_status_v2_csds_proto_depIdxs,
   588  		EnumInfos:         file_envoy_service_status_v2_csds_proto_enumTypes,
   589  		MessageInfos:      file_envoy_service_status_v2_csds_proto_msgTypes,
   590  	}.Build()
   591  	File_envoy_service_status_v2_csds_proto = out.File
   592  	file_envoy_service_status_v2_csds_proto_rawDesc = nil
   593  	file_envoy_service_status_v2_csds_proto_goTypes = nil
   594  	file_envoy_service_status_v2_csds_proto_depIdxs = nil
   595  }
   596  
   597  // Reference imports to suppress errors if they are not otherwise used.
   598  var _ context.Context
   599  var _ grpc.ClientConnInterface
   600  
   601  // This is a compile-time assertion to ensure that this generated file
   602  // is compatible with the grpc package it is being compiled against.
   603  const _ = grpc.SupportPackageIsVersion6
   604  
   605  // ClientStatusDiscoveryServiceClient is the client API for ClientStatusDiscoveryService service.
   606  //
   607  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   608  type ClientStatusDiscoveryServiceClient interface {
   609  	StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error)
   610  	FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error)
   611  }
   612  
   613  type clientStatusDiscoveryServiceClient struct {
   614  	cc grpc.ClientConnInterface
   615  }
   616  
   617  func NewClientStatusDiscoveryServiceClient(cc grpc.ClientConnInterface) ClientStatusDiscoveryServiceClient {
   618  	return &clientStatusDiscoveryServiceClient{cc}
   619  }
   620  
   621  func (c *clientStatusDiscoveryServiceClient) StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error) {
   622  	stream, err := c.cc.NewStream(ctx, &_ClientStatusDiscoveryService_serviceDesc.Streams[0], "/envoy.service.status.v2.ClientStatusDiscoveryService/StreamClientStatus", opts...)
   623  	if err != nil {
   624  		return nil, err
   625  	}
   626  	x := &clientStatusDiscoveryServiceStreamClientStatusClient{stream}
   627  	return x, nil
   628  }
   629  
   630  type ClientStatusDiscoveryService_StreamClientStatusClient interface {
   631  	Send(*ClientStatusRequest) error
   632  	Recv() (*ClientStatusResponse, error)
   633  	grpc.ClientStream
   634  }
   635  
   636  type clientStatusDiscoveryServiceStreamClientStatusClient struct {
   637  	grpc.ClientStream
   638  }
   639  
   640  func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Send(m *ClientStatusRequest) error {
   641  	return x.ClientStream.SendMsg(m)
   642  }
   643  
   644  func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Recv() (*ClientStatusResponse, error) {
   645  	m := new(ClientStatusResponse)
   646  	if err := x.ClientStream.RecvMsg(m); err != nil {
   647  		return nil, err
   648  	}
   649  	return m, nil
   650  }
   651  
   652  func (c *clientStatusDiscoveryServiceClient) FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error) {
   653  	out := new(ClientStatusResponse)
   654  	err := c.cc.Invoke(ctx, "/envoy.service.status.v2.ClientStatusDiscoveryService/FetchClientStatus", in, out, opts...)
   655  	if err != nil {
   656  		return nil, err
   657  	}
   658  	return out, nil
   659  }
   660  
   661  // ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service.
   662  type ClientStatusDiscoveryServiceServer interface {
   663  	StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
   664  	FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)
   665  }
   666  
   667  // UnimplementedClientStatusDiscoveryServiceServer can be embedded to have forward compatible implementations.
   668  type UnimplementedClientStatusDiscoveryServiceServer struct {
   669  }
   670  
   671  func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error {
   672  	return status.Errorf(codes.Unimplemented, "method StreamClientStatus not implemented")
   673  }
   674  func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error) {
   675  	return nil, status.Errorf(codes.Unimplemented, "method FetchClientStatus not implemented")
   676  }
   677  
   678  func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer) {
   679  	s.RegisterService(&_ClientStatusDiscoveryService_serviceDesc, srv)
   680  }
   681  
   682  func _ClientStatusDiscoveryService_StreamClientStatus_Handler(srv interface{}, stream grpc.ServerStream) error {
   683  	return srv.(ClientStatusDiscoveryServiceServer).StreamClientStatus(&clientStatusDiscoveryServiceStreamClientStatusServer{stream})
   684  }
   685  
   686  type ClientStatusDiscoveryService_StreamClientStatusServer interface {
   687  	Send(*ClientStatusResponse) error
   688  	Recv() (*ClientStatusRequest, error)
   689  	grpc.ServerStream
   690  }
   691  
   692  type clientStatusDiscoveryServiceStreamClientStatusServer struct {
   693  	grpc.ServerStream
   694  }
   695  
   696  func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Send(m *ClientStatusResponse) error {
   697  	return x.ServerStream.SendMsg(m)
   698  }
   699  
   700  func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Recv() (*ClientStatusRequest, error) {
   701  	m := new(ClientStatusRequest)
   702  	if err := x.ServerStream.RecvMsg(m); err != nil {
   703  		return nil, err
   704  	}
   705  	return m, nil
   706  }
   707  
   708  func _ClientStatusDiscoveryService_FetchClientStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   709  	in := new(ClientStatusRequest)
   710  	if err := dec(in); err != nil {
   711  		return nil, err
   712  	}
   713  	if interceptor == nil {
   714  		return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, in)
   715  	}
   716  	info := &grpc.UnaryServerInfo{
   717  		Server:     srv,
   718  		FullMethod: "/envoy.service.status.v2.ClientStatusDiscoveryService/FetchClientStatus",
   719  	}
   720  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   721  		return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, req.(*ClientStatusRequest))
   722  	}
   723  	return interceptor(ctx, in, info, handler)
   724  }
   725  
   726  var _ClientStatusDiscoveryService_serviceDesc = grpc.ServiceDesc{
   727  	ServiceName: "envoy.service.status.v2.ClientStatusDiscoveryService",
   728  	HandlerType: (*ClientStatusDiscoveryServiceServer)(nil),
   729  	Methods: []grpc.MethodDesc{
   730  		{
   731  			MethodName: "FetchClientStatus",
   732  			Handler:    _ClientStatusDiscoveryService_FetchClientStatus_Handler,
   733  		},
   734  	},
   735  	Streams: []grpc.StreamDesc{
   736  		{
   737  			StreamName:    "StreamClientStatus",
   738  			Handler:       _ClientStatusDiscoveryService_StreamClientStatus_Handler,
   739  			ServerStreams: true,
   740  			ClientStreams: true,
   741  		},
   742  	},
   743  	Metadata: "envoy/service/status/v2/csds.proto",
   744  }
   745  

View as plain text