...

Source file src/github.com/datawire/ambassador/v2/pkg/api/envoy/service/status/v4alpha/csds.pb.go

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

     1  // Code generated by protoc-gen-go. DO NOT EDIT.
     2  // versions:
     3  // 	protoc-gen-go v1.25.0
     4  // 	protoc        v3.14.0
     5  // source: envoy/service/status/v4alpha/csds.proto
     6  
     7  package envoy_service_status_v4alpha
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/udpa/go/udpa/annotations"
    12  	v4alpha2 "github.com/datawire/ambassador/v2/pkg/api/envoy/admin/v4alpha"
    13  	v4alpha1 "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v4alpha"
    14  	v4alpha "github.com/datawire/ambassador/v2/pkg/api/envoy/type/matcher/v4alpha"
    15  	proto "github.com/golang/protobuf/proto"
    16  	_ "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  // Status of a config from a management server view.
    39  type ConfigStatus int32
    40  
    41  const (
    42  	// Status info is not available/unknown.
    43  	ConfigStatus_UNKNOWN ConfigStatus = 0
    44  	// Management server has sent the config to client and received ACK.
    45  	ConfigStatus_SYNCED ConfigStatus = 1
    46  	// Config is not sent.
    47  	ConfigStatus_NOT_SENT ConfigStatus = 2
    48  	// Management server has sent the config to client but hasn’t received
    49  	// ACK/NACK.
    50  	ConfigStatus_STALE ConfigStatus = 3
    51  	// Management server has sent the config to client but received NACK. The
    52  	// attached config dump will be the latest config (the rejected one), since
    53  	// it is the persisted version in the management server.
    54  	ConfigStatus_ERROR ConfigStatus = 4
    55  )
    56  
    57  // Enum value maps for ConfigStatus.
    58  var (
    59  	ConfigStatus_name = map[int32]string{
    60  		0: "UNKNOWN",
    61  		1: "SYNCED",
    62  		2: "NOT_SENT",
    63  		3: "STALE",
    64  		4: "ERROR",
    65  	}
    66  	ConfigStatus_value = map[string]int32{
    67  		"UNKNOWN":  0,
    68  		"SYNCED":   1,
    69  		"NOT_SENT": 2,
    70  		"STALE":    3,
    71  		"ERROR":    4,
    72  	}
    73  )
    74  
    75  func (x ConfigStatus) Enum() *ConfigStatus {
    76  	p := new(ConfigStatus)
    77  	*p = x
    78  	return p
    79  }
    80  
    81  func (x ConfigStatus) String() string {
    82  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    83  }
    84  
    85  func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor {
    86  	return file_envoy_service_status_v4alpha_csds_proto_enumTypes[0].Descriptor()
    87  }
    88  
    89  func (ConfigStatus) Type() protoreflect.EnumType {
    90  	return &file_envoy_service_status_v4alpha_csds_proto_enumTypes[0]
    91  }
    92  
    93  func (x ConfigStatus) Number() protoreflect.EnumNumber {
    94  	return protoreflect.EnumNumber(x)
    95  }
    96  
    97  // Deprecated: Use ConfigStatus.Descriptor instead.
    98  func (ConfigStatus) EnumDescriptor() ([]byte, []int) {
    99  	return file_envoy_service_status_v4alpha_csds_proto_rawDescGZIP(), []int{0}
   100  }
   101  
   102  // Config status from a client-side view.
   103  type ClientConfigStatus int32
   104  
   105  const (
   106  	// Config status is not available/unknown.
   107  	ClientConfigStatus_CLIENT_UNKNOWN ClientConfigStatus = 0
   108  	// Client requested the config but hasn't received any config from management
   109  	// server yet.
   110  	ClientConfigStatus_CLIENT_REQUESTED ClientConfigStatus = 1
   111  	// Client received the config and replied with ACK.
   112  	ClientConfigStatus_CLIENT_ACKED ClientConfigStatus = 2
   113  	// Client received the config and replied with NACK. Notably, the attached
   114  	// config dump is not the NACKed version, but the most recent accepted one. If
   115  	// no config is accepted yet, the attached config dump will be empty.
   116  	ClientConfigStatus_CLIENT_NACKED ClientConfigStatus = 3
   117  )
   118  
   119  // Enum value maps for ClientConfigStatus.
   120  var (
   121  	ClientConfigStatus_name = map[int32]string{
   122  		0: "CLIENT_UNKNOWN",
   123  		1: "CLIENT_REQUESTED",
   124  		2: "CLIENT_ACKED",
   125  		3: "CLIENT_NACKED",
   126  	}
   127  	ClientConfigStatus_value = map[string]int32{
   128  		"CLIENT_UNKNOWN":   0,
   129  		"CLIENT_REQUESTED": 1,
   130  		"CLIENT_ACKED":     2,
   131  		"CLIENT_NACKED":    3,
   132  	}
   133  )
   134  
   135  func (x ClientConfigStatus) Enum() *ClientConfigStatus {
   136  	p := new(ClientConfigStatus)
   137  	*p = x
   138  	return p
   139  }
   140  
   141  func (x ClientConfigStatus) String() string {
   142  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   143  }
   144  
   145  func (ClientConfigStatus) Descriptor() protoreflect.EnumDescriptor {
   146  	return file_envoy_service_status_v4alpha_csds_proto_enumTypes[1].Descriptor()
   147  }
   148  
   149  func (ClientConfigStatus) Type() protoreflect.EnumType {
   150  	return &file_envoy_service_status_v4alpha_csds_proto_enumTypes[1]
   151  }
   152  
   153  func (x ClientConfigStatus) Number() protoreflect.EnumNumber {
   154  	return protoreflect.EnumNumber(x)
   155  }
   156  
   157  // Deprecated: Use ClientConfigStatus.Descriptor instead.
   158  func (ClientConfigStatus) EnumDescriptor() ([]byte, []int) {
   159  	return file_envoy_service_status_v4alpha_csds_proto_rawDescGZIP(), []int{1}
   160  }
   161  
   162  // Request for client status of clients identified by a list of NodeMatchers.
   163  type ClientStatusRequest struct {
   164  	state         protoimpl.MessageState
   165  	sizeCache     protoimpl.SizeCache
   166  	unknownFields protoimpl.UnknownFields
   167  
   168  	// Management server can use these match criteria to identify clients.
   169  	// The match follows OR semantics.
   170  	NodeMatchers []*v4alpha.NodeMatcher `protobuf:"bytes,1,rep,name=node_matchers,json=nodeMatchers,proto3" json:"node_matchers,omitempty"`
   171  	// The node making the csds request.
   172  	Node *v4alpha1.Node `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
   173  }
   174  
   175  func (x *ClientStatusRequest) Reset() {
   176  	*x = ClientStatusRequest{}
   177  	if protoimpl.UnsafeEnabled {
   178  		mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[0]
   179  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   180  		ms.StoreMessageInfo(mi)
   181  	}
   182  }
   183  
   184  func (x *ClientStatusRequest) String() string {
   185  	return protoimpl.X.MessageStringOf(x)
   186  }
   187  
   188  func (*ClientStatusRequest) ProtoMessage() {}
   189  
   190  func (x *ClientStatusRequest) ProtoReflect() protoreflect.Message {
   191  	mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[0]
   192  	if protoimpl.UnsafeEnabled && x != nil {
   193  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   194  		if ms.LoadMessageInfo() == nil {
   195  			ms.StoreMessageInfo(mi)
   196  		}
   197  		return ms
   198  	}
   199  	return mi.MessageOf(x)
   200  }
   201  
   202  // Deprecated: Use ClientStatusRequest.ProtoReflect.Descriptor instead.
   203  func (*ClientStatusRequest) Descriptor() ([]byte, []int) {
   204  	return file_envoy_service_status_v4alpha_csds_proto_rawDescGZIP(), []int{0}
   205  }
   206  
   207  func (x *ClientStatusRequest) GetNodeMatchers() []*v4alpha.NodeMatcher {
   208  	if x != nil {
   209  		return x.NodeMatchers
   210  	}
   211  	return nil
   212  }
   213  
   214  func (x *ClientStatusRequest) GetNode() *v4alpha1.Node {
   215  	if x != nil {
   216  		return x.Node
   217  	}
   218  	return nil
   219  }
   220  
   221  // Detailed config (per xDS) with status.
   222  // [#next-free-field: 8]
   223  type PerXdsConfig struct {
   224  	state         protoimpl.MessageState
   225  	sizeCache     protoimpl.SizeCache
   226  	unknownFields protoimpl.UnknownFields
   227  
   228  	// Types that are assignable to StatusConfig:
   229  	//	*PerXdsConfig_Status
   230  	//	*PerXdsConfig_ClientStatus
   231  	StatusConfig isPerXdsConfig_StatusConfig `protobuf_oneof:"status_config"`
   232  	// Types that are assignable to PerXdsConfig:
   233  	//	*PerXdsConfig_ListenerConfig
   234  	//	*PerXdsConfig_ClusterConfig
   235  	//	*PerXdsConfig_RouteConfig
   236  	//	*PerXdsConfig_ScopedRouteConfig
   237  	//	*PerXdsConfig_EndpointConfig
   238  	PerXdsConfig isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"`
   239  }
   240  
   241  func (x *PerXdsConfig) Reset() {
   242  	*x = PerXdsConfig{}
   243  	if protoimpl.UnsafeEnabled {
   244  		mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[1]
   245  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   246  		ms.StoreMessageInfo(mi)
   247  	}
   248  }
   249  
   250  func (x *PerXdsConfig) String() string {
   251  	return protoimpl.X.MessageStringOf(x)
   252  }
   253  
   254  func (*PerXdsConfig) ProtoMessage() {}
   255  
   256  func (x *PerXdsConfig) ProtoReflect() protoreflect.Message {
   257  	mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[1]
   258  	if protoimpl.UnsafeEnabled && x != nil {
   259  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   260  		if ms.LoadMessageInfo() == nil {
   261  			ms.StoreMessageInfo(mi)
   262  		}
   263  		return ms
   264  	}
   265  	return mi.MessageOf(x)
   266  }
   267  
   268  // Deprecated: Use PerXdsConfig.ProtoReflect.Descriptor instead.
   269  func (*PerXdsConfig) Descriptor() ([]byte, []int) {
   270  	return file_envoy_service_status_v4alpha_csds_proto_rawDescGZIP(), []int{1}
   271  }
   272  
   273  func (m *PerXdsConfig) GetStatusConfig() isPerXdsConfig_StatusConfig {
   274  	if m != nil {
   275  		return m.StatusConfig
   276  	}
   277  	return nil
   278  }
   279  
   280  func (x *PerXdsConfig) GetStatus() ConfigStatus {
   281  	if x, ok := x.GetStatusConfig().(*PerXdsConfig_Status); ok {
   282  		return x.Status
   283  	}
   284  	return ConfigStatus_UNKNOWN
   285  }
   286  
   287  func (x *PerXdsConfig) GetClientStatus() ClientConfigStatus {
   288  	if x, ok := x.GetStatusConfig().(*PerXdsConfig_ClientStatus); ok {
   289  		return x.ClientStatus
   290  	}
   291  	return ClientConfigStatus_CLIENT_UNKNOWN
   292  }
   293  
   294  func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig {
   295  	if m != nil {
   296  		return m.PerXdsConfig
   297  	}
   298  	return nil
   299  }
   300  
   301  func (x *PerXdsConfig) GetListenerConfig() *v4alpha2.ListenersConfigDump {
   302  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ListenerConfig); ok {
   303  		return x.ListenerConfig
   304  	}
   305  	return nil
   306  }
   307  
   308  func (x *PerXdsConfig) GetClusterConfig() *v4alpha2.ClustersConfigDump {
   309  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ClusterConfig); ok {
   310  		return x.ClusterConfig
   311  	}
   312  	return nil
   313  }
   314  
   315  func (x *PerXdsConfig) GetRouteConfig() *v4alpha2.RoutesConfigDump {
   316  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_RouteConfig); ok {
   317  		return x.RouteConfig
   318  	}
   319  	return nil
   320  }
   321  
   322  func (x *PerXdsConfig) GetScopedRouteConfig() *v4alpha2.ScopedRoutesConfigDump {
   323  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ScopedRouteConfig); ok {
   324  		return x.ScopedRouteConfig
   325  	}
   326  	return nil
   327  }
   328  
   329  func (x *PerXdsConfig) GetEndpointConfig() *v4alpha2.EndpointsConfigDump {
   330  	if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_EndpointConfig); ok {
   331  		return x.EndpointConfig
   332  	}
   333  	return nil
   334  }
   335  
   336  type isPerXdsConfig_StatusConfig interface {
   337  	isPerXdsConfig_StatusConfig()
   338  }
   339  
   340  type PerXdsConfig_Status struct {
   341  	// Config status generated by management servers. Will not be present if the
   342  	// CSDS server is an xDS client.
   343  	Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v4alpha.ConfigStatus,oneof"`
   344  }
   345  
   346  type PerXdsConfig_ClientStatus struct {
   347  	// Client config status is populated by xDS clients. Will not be present if
   348  	// the CSDS server is an xDS server. No matter what the client config status
   349  	// is, xDS clients should always dump the most recent accepted xDS config.
   350  	ClientStatus ClientConfigStatus `protobuf:"varint,7,opt,name=client_status,json=clientStatus,proto3,enum=envoy.service.status.v4alpha.ClientConfigStatus,oneof"`
   351  }
   352  
   353  func (*PerXdsConfig_Status) isPerXdsConfig_StatusConfig() {}
   354  
   355  func (*PerXdsConfig_ClientStatus) isPerXdsConfig_StatusConfig() {}
   356  
   357  type isPerXdsConfig_PerXdsConfig interface {
   358  	isPerXdsConfig_PerXdsConfig()
   359  }
   360  
   361  type PerXdsConfig_ListenerConfig struct {
   362  	ListenerConfig *v4alpha2.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof"`
   363  }
   364  
   365  type PerXdsConfig_ClusterConfig struct {
   366  	ClusterConfig *v4alpha2.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof"`
   367  }
   368  
   369  type PerXdsConfig_RouteConfig struct {
   370  	RouteConfig *v4alpha2.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"`
   371  }
   372  
   373  type PerXdsConfig_ScopedRouteConfig struct {
   374  	ScopedRouteConfig *v4alpha2.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof"`
   375  }
   376  
   377  type PerXdsConfig_EndpointConfig struct {
   378  	EndpointConfig *v4alpha2.EndpointsConfigDump `protobuf:"bytes,6,opt,name=endpoint_config,json=endpointConfig,proto3,oneof"`
   379  }
   380  
   381  func (*PerXdsConfig_ListenerConfig) isPerXdsConfig_PerXdsConfig() {}
   382  
   383  func (*PerXdsConfig_ClusterConfig) isPerXdsConfig_PerXdsConfig() {}
   384  
   385  func (*PerXdsConfig_RouteConfig) isPerXdsConfig_PerXdsConfig() {}
   386  
   387  func (*PerXdsConfig_ScopedRouteConfig) isPerXdsConfig_PerXdsConfig() {}
   388  
   389  func (*PerXdsConfig_EndpointConfig) isPerXdsConfig_PerXdsConfig() {}
   390  
   391  // All xds configs for a particular client.
   392  type ClientConfig struct {
   393  	state         protoimpl.MessageState
   394  	sizeCache     protoimpl.SizeCache
   395  	unknownFields protoimpl.UnknownFields
   396  
   397  	// Node for a particular client.
   398  	Node      *v4alpha1.Node  `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
   399  	XdsConfig []*PerXdsConfig `protobuf:"bytes,2,rep,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"`
   400  }
   401  
   402  func (x *ClientConfig) Reset() {
   403  	*x = ClientConfig{}
   404  	if protoimpl.UnsafeEnabled {
   405  		mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[2]
   406  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   407  		ms.StoreMessageInfo(mi)
   408  	}
   409  }
   410  
   411  func (x *ClientConfig) String() string {
   412  	return protoimpl.X.MessageStringOf(x)
   413  }
   414  
   415  func (*ClientConfig) ProtoMessage() {}
   416  
   417  func (x *ClientConfig) ProtoReflect() protoreflect.Message {
   418  	mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[2]
   419  	if protoimpl.UnsafeEnabled && x != nil {
   420  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   421  		if ms.LoadMessageInfo() == nil {
   422  			ms.StoreMessageInfo(mi)
   423  		}
   424  		return ms
   425  	}
   426  	return mi.MessageOf(x)
   427  }
   428  
   429  // Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
   430  func (*ClientConfig) Descriptor() ([]byte, []int) {
   431  	return file_envoy_service_status_v4alpha_csds_proto_rawDescGZIP(), []int{2}
   432  }
   433  
   434  func (x *ClientConfig) GetNode() *v4alpha1.Node {
   435  	if x != nil {
   436  		return x.Node
   437  	}
   438  	return nil
   439  }
   440  
   441  func (x *ClientConfig) GetXdsConfig() []*PerXdsConfig {
   442  	if x != nil {
   443  		return x.XdsConfig
   444  	}
   445  	return nil
   446  }
   447  
   448  type ClientStatusResponse struct {
   449  	state         protoimpl.MessageState
   450  	sizeCache     protoimpl.SizeCache
   451  	unknownFields protoimpl.UnknownFields
   452  
   453  	// Client configs for the clients specified in the ClientStatusRequest.
   454  	Config []*ClientConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"`
   455  }
   456  
   457  func (x *ClientStatusResponse) Reset() {
   458  	*x = ClientStatusResponse{}
   459  	if protoimpl.UnsafeEnabled {
   460  		mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[3]
   461  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   462  		ms.StoreMessageInfo(mi)
   463  	}
   464  }
   465  
   466  func (x *ClientStatusResponse) String() string {
   467  	return protoimpl.X.MessageStringOf(x)
   468  }
   469  
   470  func (*ClientStatusResponse) ProtoMessage() {}
   471  
   472  func (x *ClientStatusResponse) ProtoReflect() protoreflect.Message {
   473  	mi := &file_envoy_service_status_v4alpha_csds_proto_msgTypes[3]
   474  	if protoimpl.UnsafeEnabled && x != nil {
   475  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   476  		if ms.LoadMessageInfo() == nil {
   477  			ms.StoreMessageInfo(mi)
   478  		}
   479  		return ms
   480  	}
   481  	return mi.MessageOf(x)
   482  }
   483  
   484  // Deprecated: Use ClientStatusResponse.ProtoReflect.Descriptor instead.
   485  func (*ClientStatusResponse) Descriptor() ([]byte, []int) {
   486  	return file_envoy_service_status_v4alpha_csds_proto_rawDescGZIP(), []int{3}
   487  }
   488  
   489  func (x *ClientStatusResponse) GetConfig() []*ClientConfig {
   490  	if x != nil {
   491  		return x.Config
   492  	}
   493  	return nil
   494  }
   495  
   496  var File_envoy_service_status_v4alpha_csds_proto protoreflect.FileDescriptor
   497  
   498  var file_envoy_service_status_v4alpha_csds_proto_rawDesc = []byte{
   499  	0x0a, 0x27, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   500  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x63,
   501  	0x73, 0x64, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1c, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   502  	0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e,
   503  	0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x1a, 0x25, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61,
   504  	0x64, 0x6d, 0x69, 0x6e, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x63, 0x6f, 0x6e,
   505  	0x66, 0x69, 0x67, 0x5f, 0x64, 0x75, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x24,
   506  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2f, 0x63, 0x6f, 0x72,
   507  	0x65, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e, 0x70,
   508  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x25, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x74, 0x79, 0x70, 0x65,
   509  	0x2f, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61,
   510  	0x2f, 0x6e, 0x6f, 0x64, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f,
   511  	0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69,
   512  	0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   513  	0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x73, 0x74, 0x72, 0x75, 0x63,
   514  	0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e,
   515  	0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
   516  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e,
   517  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
   518  	0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xcc, 0x01, 0x0a, 0x13, 0x43, 0x6c,
   519  	0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
   520  	0x74, 0x12, 0x4c, 0x0a, 0x0d, 0x6e, 0x6f, 0x64, 0x65, 0x5f, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x65,
   521  	0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   522  	0x2e, 0x74, 0x79, 0x70, 0x65, 0x2e, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x2e, 0x76, 0x34,
   523  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65,
   524  	0x72, 0x52, 0x0c, 0x6e, 0x6f, 0x64, 0x65, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x73, 0x12,
   525  	0x33, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e,
   526  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63, 0x6f, 0x72,
   527  	0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x52, 0x04,
   528  	0x6e, 0x6f, 0x64, 0x65, 0x3a, 0x32, 0x9a, 0xc5, 0x88, 0x1e, 0x2d, 0x0a, 0x2b, 0x65, 0x6e, 0x76,
   529  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75,
   530  	0x73, 0x2e, 0x76, 0x33, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75,
   531  	0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0xa4, 0x05, 0x0a, 0x0c, 0x50, 0x65, 0x72,
   532  	0x58, 0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x44, 0x0a, 0x06, 0x73, 0x74, 0x61,
   533  	0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2a, 0x2e, 0x65, 0x6e, 0x76, 0x6f,
   534  	0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
   535  	0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x53,
   536  	0x74, 0x61, 0x74, 0x75, 0x73, 0x48, 0x00, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12,
   537  	0x57, 0x0a, 0x0d, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
   538  	0x18, 0x07, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x30, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73,
   539  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x34,
   540  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66,
   541  	0x69, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x48, 0x00, 0x52, 0x0c, 0x63, 0x6c, 0x69, 0x65,
   542  	0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x53, 0x0a, 0x0f, 0x6c, 0x69, 0x73, 0x74,
   543  	0x65, 0x6e, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28,
   544  	0x0b, 0x32, 0x28, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e,
   545  	0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72,
   546  	0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x01, 0x52, 0x0e, 0x6c,
   547  	0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x50, 0x0a,
   548  	0x0e, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18,
   549  	0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64,
   550  	0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6c, 0x75, 0x73,
   551  	0x74, 0x65, 0x72, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x01,
   552  	0x52, 0x0d, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12,
   553  	0x4a, 0x0a, 0x0c, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18,
   554  	0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64,
   555  	0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x52, 0x6f, 0x75, 0x74,
   556  	0x65, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x01, 0x52, 0x0b,
   557  	0x72, 0x6f, 0x75, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x5d, 0x0a, 0x13, 0x73,
   558  	0x63, 0x6f, 0x70, 0x65, 0x64, 0x5f, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x5f, 0x63, 0x6f, 0x6e, 0x66,
   559  	0x69, 0x67, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   560  	0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53,
   561  	0x63, 0x6f, 0x70, 0x65, 0x64, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69,
   562  	0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x01, 0x52, 0x11, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x52,
   563  	0x6f, 0x75, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x53, 0x0a, 0x0f, 0x65, 0x6e,
   564  	0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x06, 0x20,
   565  	0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64, 0x6d, 0x69,
   566  	0x6e, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69,
   567  	0x6e, 0x74, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x01, 0x52,
   568  	0x0e, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x3a,
   569  	0x2b, 0x9a, 0xc5, 0x88, 0x1e, 0x26, 0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
   570  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x2e,
   571  	0x50, 0x65, 0x72, 0x58, 0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x42, 0x0f, 0x0a, 0x0d,
   572  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x42, 0x10, 0x0a,
   573  	0x0e, 0x70, 0x65, 0x72, 0x5f, 0x78, 0x64, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22,
   574  	0xbb, 0x01, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67,
   575  	0x12, 0x33, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f,
   576  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63, 0x6f,
   577  	0x72, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x52,
   578  	0x04, 0x6e, 0x6f, 0x64, 0x65, 0x12, 0x49, 0x0a, 0x0a, 0x78, 0x64, 0x73, 0x5f, 0x63, 0x6f, 0x6e,
   579  	0x66, 0x69, 0x67, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x65, 0x6e, 0x76, 0x6f,
   580  	0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
   581  	0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x50, 0x65, 0x72, 0x58, 0x64, 0x73, 0x43,
   582  	0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x09, 0x78, 0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67,
   583  	0x3a, 0x2b, 0x9a, 0xc5, 0x88, 0x1e, 0x26, 0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73,
   584  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33,
   585  	0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x8f, 0x01,
   586  	0x0a, 0x14, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65,
   587  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x42, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67,
   588  	0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73,
   589  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x34,
   590  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66,
   591  	0x69, 0x67, 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x3a, 0x33, 0x9a, 0xc5, 0x88, 0x1e,
   592  	0x2e, 0x0a, 0x2c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   593  	0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e,
   594  	0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2a,
   595  	0x4b, 0x0a, 0x0c, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12,
   596  	0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06,
   597  	0x53, 0x59, 0x4e, 0x43, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x4e, 0x4f, 0x54, 0x5f,
   598  	0x53, 0x45, 0x4e, 0x54, 0x10, 0x02, 0x12, 0x09, 0x0a, 0x05, 0x53, 0x54, 0x41, 0x4c, 0x45, 0x10,
   599  	0x03, 0x12, 0x09, 0x0a, 0x05, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x10, 0x04, 0x2a, 0x63, 0x0a, 0x12,
   600  	0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x53, 0x74, 0x61, 0x74,
   601  	0x75, 0x73, 0x12, 0x12, 0x0a, 0x0e, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x55, 0x4e, 0x4b,
   602  	0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x14, 0x0a, 0x10, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54,
   603  	0x5f, 0x52, 0x45, 0x51, 0x55, 0x45, 0x53, 0x54, 0x45, 0x44, 0x10, 0x01, 0x12, 0x10, 0x0a, 0x0c,
   604  	0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x41, 0x43, 0x4b, 0x45, 0x44, 0x10, 0x02, 0x12, 0x11,
   605  	0x0a, 0x0d, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x4e, 0x41, 0x43, 0x4b, 0x45, 0x44, 0x10,
   606  	0x03, 0x32, 0xcd, 0x02, 0x0a, 0x1c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74,
   607  	0x75, 0x73, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x53, 0x65, 0x72, 0x76, 0x69,
   608  	0x63, 0x65, 0x12, 0x81, 0x01, 0x0a, 0x12, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x43, 0x6c, 0x69,
   609  	0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x31, 0x2e, 0x65, 0x6e, 0x76, 0x6f,
   610  	0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
   611  	0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53,
   612  	0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x65,
   613  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61,
   614  	0x74, 0x75, 0x73, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6c, 0x69, 0x65,
   615  	0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
   616  	0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0xa8, 0x01, 0x0a, 0x11, 0x46, 0x65, 0x74, 0x63, 0x68,
   617  	0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x31, 0x2e, 0x65,
   618  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61,
   619  	0x74, 0x75, 0x73, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6c, 0x69, 0x65,
   620  	0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
   621  	0x32, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
   622  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43,
   623  	0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
   624  	0x6e, 0x73, 0x65, 0x22, 0x2c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x1d, 0x22, 0x1b, 0x2f, 0x76, 0x33,
   625  	0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x3a, 0x63, 0x6c, 0x69, 0x65, 0x6e,
   626  	0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x03, 0x3a, 0x01,
   627  	0x2a, 0x42, 0x44, 0x0a, 0x2a, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f,
   628  	0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   629  	0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x42,
   630  	0x09, 0x43, 0x73, 0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba,
   631  	0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x03, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   632  }
   633  
   634  var (
   635  	file_envoy_service_status_v4alpha_csds_proto_rawDescOnce sync.Once
   636  	file_envoy_service_status_v4alpha_csds_proto_rawDescData = file_envoy_service_status_v4alpha_csds_proto_rawDesc
   637  )
   638  
   639  func file_envoy_service_status_v4alpha_csds_proto_rawDescGZIP() []byte {
   640  	file_envoy_service_status_v4alpha_csds_proto_rawDescOnce.Do(func() {
   641  		file_envoy_service_status_v4alpha_csds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_status_v4alpha_csds_proto_rawDescData)
   642  	})
   643  	return file_envoy_service_status_v4alpha_csds_proto_rawDescData
   644  }
   645  
   646  var file_envoy_service_status_v4alpha_csds_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
   647  var file_envoy_service_status_v4alpha_csds_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
   648  var file_envoy_service_status_v4alpha_csds_proto_goTypes = []interface{}{
   649  	(ConfigStatus)(0),                       // 0: envoy.service.status.v4alpha.ConfigStatus
   650  	(ClientConfigStatus)(0),                 // 1: envoy.service.status.v4alpha.ClientConfigStatus
   651  	(*ClientStatusRequest)(nil),             // 2: envoy.service.status.v4alpha.ClientStatusRequest
   652  	(*PerXdsConfig)(nil),                    // 3: envoy.service.status.v4alpha.PerXdsConfig
   653  	(*ClientConfig)(nil),                    // 4: envoy.service.status.v4alpha.ClientConfig
   654  	(*ClientStatusResponse)(nil),            // 5: envoy.service.status.v4alpha.ClientStatusResponse
   655  	(*v4alpha.NodeMatcher)(nil),             // 6: envoy.type.matcher.v4alpha.NodeMatcher
   656  	(*v4alpha1.Node)(nil),                   // 7: envoy.config.core.v4alpha.Node
   657  	(*v4alpha2.ListenersConfigDump)(nil),    // 8: envoy.admin.v4alpha.ListenersConfigDump
   658  	(*v4alpha2.ClustersConfigDump)(nil),     // 9: envoy.admin.v4alpha.ClustersConfigDump
   659  	(*v4alpha2.RoutesConfigDump)(nil),       // 10: envoy.admin.v4alpha.RoutesConfigDump
   660  	(*v4alpha2.ScopedRoutesConfigDump)(nil), // 11: envoy.admin.v4alpha.ScopedRoutesConfigDump
   661  	(*v4alpha2.EndpointsConfigDump)(nil),    // 12: envoy.admin.v4alpha.EndpointsConfigDump
   662  }
   663  var file_envoy_service_status_v4alpha_csds_proto_depIdxs = []int32{
   664  	6,  // 0: envoy.service.status.v4alpha.ClientStatusRequest.node_matchers:type_name -> envoy.type.matcher.v4alpha.NodeMatcher
   665  	7,  // 1: envoy.service.status.v4alpha.ClientStatusRequest.node:type_name -> envoy.config.core.v4alpha.Node
   666  	0,  // 2: envoy.service.status.v4alpha.PerXdsConfig.status:type_name -> envoy.service.status.v4alpha.ConfigStatus
   667  	1,  // 3: envoy.service.status.v4alpha.PerXdsConfig.client_status:type_name -> envoy.service.status.v4alpha.ClientConfigStatus
   668  	8,  // 4: envoy.service.status.v4alpha.PerXdsConfig.listener_config:type_name -> envoy.admin.v4alpha.ListenersConfigDump
   669  	9,  // 5: envoy.service.status.v4alpha.PerXdsConfig.cluster_config:type_name -> envoy.admin.v4alpha.ClustersConfigDump
   670  	10, // 6: envoy.service.status.v4alpha.PerXdsConfig.route_config:type_name -> envoy.admin.v4alpha.RoutesConfigDump
   671  	11, // 7: envoy.service.status.v4alpha.PerXdsConfig.scoped_route_config:type_name -> envoy.admin.v4alpha.ScopedRoutesConfigDump
   672  	12, // 8: envoy.service.status.v4alpha.PerXdsConfig.endpoint_config:type_name -> envoy.admin.v4alpha.EndpointsConfigDump
   673  	7,  // 9: envoy.service.status.v4alpha.ClientConfig.node:type_name -> envoy.config.core.v4alpha.Node
   674  	3,  // 10: envoy.service.status.v4alpha.ClientConfig.xds_config:type_name -> envoy.service.status.v4alpha.PerXdsConfig
   675  	4,  // 11: envoy.service.status.v4alpha.ClientStatusResponse.config:type_name -> envoy.service.status.v4alpha.ClientConfig
   676  	2,  // 12: envoy.service.status.v4alpha.ClientStatusDiscoveryService.StreamClientStatus:input_type -> envoy.service.status.v4alpha.ClientStatusRequest
   677  	2,  // 13: envoy.service.status.v4alpha.ClientStatusDiscoveryService.FetchClientStatus:input_type -> envoy.service.status.v4alpha.ClientStatusRequest
   678  	5,  // 14: envoy.service.status.v4alpha.ClientStatusDiscoveryService.StreamClientStatus:output_type -> envoy.service.status.v4alpha.ClientStatusResponse
   679  	5,  // 15: envoy.service.status.v4alpha.ClientStatusDiscoveryService.FetchClientStatus:output_type -> envoy.service.status.v4alpha.ClientStatusResponse
   680  	14, // [14:16] is the sub-list for method output_type
   681  	12, // [12:14] is the sub-list for method input_type
   682  	12, // [12:12] is the sub-list for extension type_name
   683  	12, // [12:12] is the sub-list for extension extendee
   684  	0,  // [0:12] is the sub-list for field type_name
   685  }
   686  
   687  func init() { file_envoy_service_status_v4alpha_csds_proto_init() }
   688  func file_envoy_service_status_v4alpha_csds_proto_init() {
   689  	if File_envoy_service_status_v4alpha_csds_proto != nil {
   690  		return
   691  	}
   692  	if !protoimpl.UnsafeEnabled {
   693  		file_envoy_service_status_v4alpha_csds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   694  			switch v := v.(*ClientStatusRequest); i {
   695  			case 0:
   696  				return &v.state
   697  			case 1:
   698  				return &v.sizeCache
   699  			case 2:
   700  				return &v.unknownFields
   701  			default:
   702  				return nil
   703  			}
   704  		}
   705  		file_envoy_service_status_v4alpha_csds_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   706  			switch v := v.(*PerXdsConfig); i {
   707  			case 0:
   708  				return &v.state
   709  			case 1:
   710  				return &v.sizeCache
   711  			case 2:
   712  				return &v.unknownFields
   713  			default:
   714  				return nil
   715  			}
   716  		}
   717  		file_envoy_service_status_v4alpha_csds_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   718  			switch v := v.(*ClientConfig); i {
   719  			case 0:
   720  				return &v.state
   721  			case 1:
   722  				return &v.sizeCache
   723  			case 2:
   724  				return &v.unknownFields
   725  			default:
   726  				return nil
   727  			}
   728  		}
   729  		file_envoy_service_status_v4alpha_csds_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
   730  			switch v := v.(*ClientStatusResponse); i {
   731  			case 0:
   732  				return &v.state
   733  			case 1:
   734  				return &v.sizeCache
   735  			case 2:
   736  				return &v.unknownFields
   737  			default:
   738  				return nil
   739  			}
   740  		}
   741  	}
   742  	file_envoy_service_status_v4alpha_csds_proto_msgTypes[1].OneofWrappers = []interface{}{
   743  		(*PerXdsConfig_Status)(nil),
   744  		(*PerXdsConfig_ClientStatus)(nil),
   745  		(*PerXdsConfig_ListenerConfig)(nil),
   746  		(*PerXdsConfig_ClusterConfig)(nil),
   747  		(*PerXdsConfig_RouteConfig)(nil),
   748  		(*PerXdsConfig_ScopedRouteConfig)(nil),
   749  		(*PerXdsConfig_EndpointConfig)(nil),
   750  	}
   751  	type x struct{}
   752  	out := protoimpl.TypeBuilder{
   753  		File: protoimpl.DescBuilder{
   754  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   755  			RawDescriptor: file_envoy_service_status_v4alpha_csds_proto_rawDesc,
   756  			NumEnums:      2,
   757  			NumMessages:   4,
   758  			NumExtensions: 0,
   759  			NumServices:   1,
   760  		},
   761  		GoTypes:           file_envoy_service_status_v4alpha_csds_proto_goTypes,
   762  		DependencyIndexes: file_envoy_service_status_v4alpha_csds_proto_depIdxs,
   763  		EnumInfos:         file_envoy_service_status_v4alpha_csds_proto_enumTypes,
   764  		MessageInfos:      file_envoy_service_status_v4alpha_csds_proto_msgTypes,
   765  	}.Build()
   766  	File_envoy_service_status_v4alpha_csds_proto = out.File
   767  	file_envoy_service_status_v4alpha_csds_proto_rawDesc = nil
   768  	file_envoy_service_status_v4alpha_csds_proto_goTypes = nil
   769  	file_envoy_service_status_v4alpha_csds_proto_depIdxs = nil
   770  }
   771  
   772  // Reference imports to suppress errors if they are not otherwise used.
   773  var _ context.Context
   774  var _ grpc.ClientConnInterface
   775  
   776  // This is a compile-time assertion to ensure that this generated file
   777  // is compatible with the grpc package it is being compiled against.
   778  const _ = grpc.SupportPackageIsVersion6
   779  
   780  // ClientStatusDiscoveryServiceClient is the client API for ClientStatusDiscoveryService service.
   781  //
   782  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   783  type ClientStatusDiscoveryServiceClient interface {
   784  	StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error)
   785  	FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error)
   786  }
   787  
   788  type clientStatusDiscoveryServiceClient struct {
   789  	cc grpc.ClientConnInterface
   790  }
   791  
   792  func NewClientStatusDiscoveryServiceClient(cc grpc.ClientConnInterface) ClientStatusDiscoveryServiceClient {
   793  	return &clientStatusDiscoveryServiceClient{cc}
   794  }
   795  
   796  func (c *clientStatusDiscoveryServiceClient) StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error) {
   797  	stream, err := c.cc.NewStream(ctx, &_ClientStatusDiscoveryService_serviceDesc.Streams[0], "/envoy.service.status.v4alpha.ClientStatusDiscoveryService/StreamClientStatus", opts...)
   798  	if err != nil {
   799  		return nil, err
   800  	}
   801  	x := &clientStatusDiscoveryServiceStreamClientStatusClient{stream}
   802  	return x, nil
   803  }
   804  
   805  type ClientStatusDiscoveryService_StreamClientStatusClient interface {
   806  	Send(*ClientStatusRequest) error
   807  	Recv() (*ClientStatusResponse, error)
   808  	grpc.ClientStream
   809  }
   810  
   811  type clientStatusDiscoveryServiceStreamClientStatusClient struct {
   812  	grpc.ClientStream
   813  }
   814  
   815  func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Send(m *ClientStatusRequest) error {
   816  	return x.ClientStream.SendMsg(m)
   817  }
   818  
   819  func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Recv() (*ClientStatusResponse, error) {
   820  	m := new(ClientStatusResponse)
   821  	if err := x.ClientStream.RecvMsg(m); err != nil {
   822  		return nil, err
   823  	}
   824  	return m, nil
   825  }
   826  
   827  func (c *clientStatusDiscoveryServiceClient) FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error) {
   828  	out := new(ClientStatusResponse)
   829  	err := c.cc.Invoke(ctx, "/envoy.service.status.v4alpha.ClientStatusDiscoveryService/FetchClientStatus", in, out, opts...)
   830  	if err != nil {
   831  		return nil, err
   832  	}
   833  	return out, nil
   834  }
   835  
   836  // ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service.
   837  type ClientStatusDiscoveryServiceServer interface {
   838  	StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
   839  	FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)
   840  }
   841  
   842  // UnimplementedClientStatusDiscoveryServiceServer can be embedded to have forward compatible implementations.
   843  type UnimplementedClientStatusDiscoveryServiceServer struct {
   844  }
   845  
   846  func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error {
   847  	return status.Errorf(codes.Unimplemented, "method StreamClientStatus not implemented")
   848  }
   849  func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error) {
   850  	return nil, status.Errorf(codes.Unimplemented, "method FetchClientStatus not implemented")
   851  }
   852  
   853  func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer) {
   854  	s.RegisterService(&_ClientStatusDiscoveryService_serviceDesc, srv)
   855  }
   856  
   857  func _ClientStatusDiscoveryService_StreamClientStatus_Handler(srv interface{}, stream grpc.ServerStream) error {
   858  	return srv.(ClientStatusDiscoveryServiceServer).StreamClientStatus(&clientStatusDiscoveryServiceStreamClientStatusServer{stream})
   859  }
   860  
   861  type ClientStatusDiscoveryService_StreamClientStatusServer interface {
   862  	Send(*ClientStatusResponse) error
   863  	Recv() (*ClientStatusRequest, error)
   864  	grpc.ServerStream
   865  }
   866  
   867  type clientStatusDiscoveryServiceStreamClientStatusServer struct {
   868  	grpc.ServerStream
   869  }
   870  
   871  func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Send(m *ClientStatusResponse) error {
   872  	return x.ServerStream.SendMsg(m)
   873  }
   874  
   875  func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Recv() (*ClientStatusRequest, error) {
   876  	m := new(ClientStatusRequest)
   877  	if err := x.ServerStream.RecvMsg(m); err != nil {
   878  		return nil, err
   879  	}
   880  	return m, nil
   881  }
   882  
   883  func _ClientStatusDiscoveryService_FetchClientStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   884  	in := new(ClientStatusRequest)
   885  	if err := dec(in); err != nil {
   886  		return nil, err
   887  	}
   888  	if interceptor == nil {
   889  		return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, in)
   890  	}
   891  	info := &grpc.UnaryServerInfo{
   892  		Server:     srv,
   893  		FullMethod: "/envoy.service.status.v4alpha.ClientStatusDiscoveryService/FetchClientStatus",
   894  	}
   895  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   896  		return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, req.(*ClientStatusRequest))
   897  	}
   898  	return interceptor(ctx, in, info, handler)
   899  }
   900  
   901  var _ClientStatusDiscoveryService_serviceDesc = grpc.ServiceDesc{
   902  	ServiceName: "envoy.service.status.v4alpha.ClientStatusDiscoveryService",
   903  	HandlerType: (*ClientStatusDiscoveryServiceServer)(nil),
   904  	Methods: []grpc.MethodDesc{
   905  		{
   906  			MethodName: "FetchClientStatus",
   907  			Handler:    _ClientStatusDiscoveryService_FetchClientStatus_Handler,
   908  		},
   909  	},
   910  	Streams: []grpc.StreamDesc{
   911  		{
   912  			StreamName:    "StreamClientStatus",
   913  			Handler:       _ClientStatusDiscoveryService_StreamClientStatus_Handler,
   914  			ServerStreams: true,
   915  			ClientStreams: true,
   916  		},
   917  	},
   918  	Metadata: "envoy/service/status/v4alpha/csds.proto",
   919  }
   920  

View as plain text