import "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
csds.pb.go csds.pb.validate.go
var (
ConfigStatus_name = map[int32]string{
0: "UNKNOWN",
1: "SYNCED",
2: "NOT_SENT",
3: "STALE",
4: "ERROR",
}
ConfigStatus_value = map[string]int32{
"UNKNOWN": 0,
"SYNCED": 1,
"NOT_SENT": 2,
"STALE": 3,
"ERROR": 4,
}
)Enum value maps for ConfigStatus.
var (
ClientConfigStatus_name = map[int32]string{
0: "CLIENT_UNKNOWN",
1: "CLIENT_REQUESTED",
2: "CLIENT_ACKED",
3: "CLIENT_NACKED",
}
ClientConfigStatus_value = map[string]int32{
"CLIENT_UNKNOWN": 0,
"CLIENT_REQUESTED": 1,
"CLIENT_ACKED": 2,
"CLIENT_NACKED": 3,
}
)Enum value maps for ClientConfigStatus.
var File_envoy_service_status_v3_csds_proto protoreflect.FileDescriptor
func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer)
type ClientConfig struct {
// Node for a particular client.
Node *v31.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
XdsConfig []*PerXdsConfig `protobuf:"bytes,2,rep,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"`
// contains filtered or unexported fields
}All xds configs for a particular client.
func (*ClientConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
func (x *ClientConfig) GetNode() *v31.Node
func (x *ClientConfig) GetXdsConfig() []*PerXdsConfig
func (*ClientConfig) ProtoMessage()
func (x *ClientConfig) ProtoReflect() protoreflect.Message
func (x *ClientConfig) Reset()
func (x *ClientConfig) String() string
func (m *ClientConfig) Validate() error
Validate checks the field values on ClientConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
Config status from a client-side view.
const (
// Config status is not available/unknown.
ClientConfigStatus_CLIENT_UNKNOWN ClientConfigStatus = 0
// Client requested the config but hasn't received any config from management
// server yet.
ClientConfigStatus_CLIENT_REQUESTED ClientConfigStatus = 1
// Client received the config and replied with ACK.
ClientConfigStatus_CLIENT_ACKED ClientConfigStatus = 2
// Client received the config and replied with NACK. Notably, the attached
// config dump is not the NACKed version, but the most recent accepted one. If
// no config is accepted yet, the attached config dump will be empty.
ClientConfigStatus_CLIENT_NACKED ClientConfigStatus = 3
)func (ClientConfigStatus) Descriptor() protoreflect.EnumDescriptor
func (x ClientConfigStatus) Enum() *ClientConfigStatus
func (ClientConfigStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientConfigStatus.Descriptor instead.
func (x ClientConfigStatus) Number() protoreflect.EnumNumber
func (x ClientConfigStatus) String() string
func (ClientConfigStatus) Type() protoreflect.EnumType
type ClientConfigValidationError struct {
// contains filtered or unexported fields
}ClientConfigValidationError is the validation error returned by ClientConfig.Validate if the designated constraints aren't met.
func (e ClientConfigValidationError) Cause() error
Cause function returns cause value.
func (e ClientConfigValidationError) Error() string
Error satisfies the builtin error interface
func (e ClientConfigValidationError) ErrorName() string
ErrorName returns error name.
func (e ClientConfigValidationError) Field() string
Field function returns field value.
func (e ClientConfigValidationError) Key() bool
Key function returns key value.
func (e ClientConfigValidationError) Reason() string
Reason function returns reason value.
type ClientStatusDiscoveryServiceClient interface {
StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error)
FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error)
}ClientStatusDiscoveryServiceClient is the client API for ClientStatusDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewClientStatusDiscoveryServiceClient(cc grpc.ClientConnInterface) ClientStatusDiscoveryServiceClient
type ClientStatusDiscoveryServiceServer interface {
StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)
}ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service.
type ClientStatusDiscoveryService_StreamClientStatusClient interface {
Send(*ClientStatusRequest) error
Recv() (*ClientStatusResponse, error)
grpc.ClientStream
}type ClientStatusDiscoveryService_StreamClientStatusServer interface {
Send(*ClientStatusResponse) error
Recv() (*ClientStatusRequest, error)
grpc.ServerStream
}type ClientStatusRequest struct {
// Management server can use these match criteria to identify clients.
// The match follows OR semantics.
NodeMatchers []*v3.NodeMatcher `protobuf:"bytes,1,rep,name=node_matchers,json=nodeMatchers,proto3" json:"node_matchers,omitempty"`
// The node making the csds request.
Node *v31.Node `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
// contains filtered or unexported fields
}Request for client status of clients identified by a list of NodeMatchers.
func (*ClientStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatusRequest.ProtoReflect.Descriptor instead.
func (x *ClientStatusRequest) GetNode() *v31.Node
func (x *ClientStatusRequest) GetNodeMatchers() []*v3.NodeMatcher
func (*ClientStatusRequest) ProtoMessage()
func (x *ClientStatusRequest) ProtoReflect() protoreflect.Message
func (x *ClientStatusRequest) Reset()
func (x *ClientStatusRequest) String() string
func (m *ClientStatusRequest) Validate() error
Validate checks the field values on ClientStatusRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type ClientStatusRequestValidationError struct {
// contains filtered or unexported fields
}ClientStatusRequestValidationError is the validation error returned by ClientStatusRequest.Validate if the designated constraints aren't met.
func (e ClientStatusRequestValidationError) Cause() error
Cause function returns cause value.
func (e ClientStatusRequestValidationError) Error() string
Error satisfies the builtin error interface
func (e ClientStatusRequestValidationError) ErrorName() string
ErrorName returns error name.
func (e ClientStatusRequestValidationError) Field() string
Field function returns field value.
func (e ClientStatusRequestValidationError) Key() bool
Key function returns key value.
func (e ClientStatusRequestValidationError) Reason() string
Reason function returns reason value.
type ClientStatusResponse struct {
// Client configs for the clients specified in the ClientStatusRequest.
Config []*ClientConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}func (*ClientStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatusResponse.ProtoReflect.Descriptor instead.
func (x *ClientStatusResponse) GetConfig() []*ClientConfig
func (*ClientStatusResponse) ProtoMessage()
func (x *ClientStatusResponse) ProtoReflect() protoreflect.Message
func (x *ClientStatusResponse) Reset()
func (x *ClientStatusResponse) String() string
func (m *ClientStatusResponse) Validate() error
Validate checks the field values on ClientStatusResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type ClientStatusResponseValidationError struct {
// contains filtered or unexported fields
}ClientStatusResponseValidationError is the validation error returned by ClientStatusResponse.Validate if the designated constraints aren't met.
func (e ClientStatusResponseValidationError) Cause() error
Cause function returns cause value.
func (e ClientStatusResponseValidationError) Error() string
Error satisfies the builtin error interface
func (e ClientStatusResponseValidationError) ErrorName() string
ErrorName returns error name.
func (e ClientStatusResponseValidationError) Field() string
Field function returns field value.
func (e ClientStatusResponseValidationError) Key() bool
Key function returns key value.
func (e ClientStatusResponseValidationError) Reason() string
Reason function returns reason value.
Status of a config from a management server view.
const (
// Status info is not available/unknown.
ConfigStatus_UNKNOWN ConfigStatus = 0
// Management server has sent the config to client and received ACK.
ConfigStatus_SYNCED ConfigStatus = 1
// Config is not sent.
ConfigStatus_NOT_SENT ConfigStatus = 2
// Management server has sent the config to client but hasn’t received
// ACK/NACK.
ConfigStatus_STALE ConfigStatus = 3
// Management server has sent the config to client but received NACK. The
// attached config dump will be the latest config (the rejected one), since
// it is the persisted version in the management server.
ConfigStatus_ERROR ConfigStatus = 4
)func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
func (x ConfigStatus) Enum() *ConfigStatus
func (ConfigStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigStatus.Descriptor instead.
func (x ConfigStatus) Number() protoreflect.EnumNumber
func (x ConfigStatus) String() string
func (ConfigStatus) Type() protoreflect.EnumType
type PerXdsConfig struct {
// Config status generated by management servers. Will not be present if the
// CSDS server is an xDS client.
Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v3.ConfigStatus" json:"status,omitempty"`
// Client config status is populated by xDS clients. Will not be present if
// the CSDS server is an xDS server. No matter what the client config status
// is, xDS clients should always dump the most recent accepted xDS config.
ClientStatus ClientConfigStatus `protobuf:"varint,7,opt,name=client_status,json=clientStatus,proto3,enum=envoy.service.status.v3.ClientConfigStatus" json:"client_status,omitempty"`
// Types that are assignable to PerXdsConfig:
// *PerXdsConfig_ListenerConfig
// *PerXdsConfig_ClusterConfig
// *PerXdsConfig_RouteConfig
// *PerXdsConfig_ScopedRouteConfig
// *PerXdsConfig_EndpointConfig
PerXdsConfig isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"`
// contains filtered or unexported fields
}Detailed config (per xDS) with status. [#next-free-field: 8]
func (*PerXdsConfig) Descriptor() ([]byte, []int)
Deprecated: Use PerXdsConfig.ProtoReflect.Descriptor instead.
func (x *PerXdsConfig) GetClientStatus() ClientConfigStatus
func (x *PerXdsConfig) GetClusterConfig() *v32.ClustersConfigDump
func (x *PerXdsConfig) GetEndpointConfig() *v32.EndpointsConfigDump
func (x *PerXdsConfig) GetListenerConfig() *v32.ListenersConfigDump
func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig
func (x *PerXdsConfig) GetRouteConfig() *v32.RoutesConfigDump
func (x *PerXdsConfig) GetScopedRouteConfig() *v32.ScopedRoutesConfigDump
func (x *PerXdsConfig) GetStatus() ConfigStatus
func (*PerXdsConfig) ProtoMessage()
func (x *PerXdsConfig) ProtoReflect() protoreflect.Message
func (x *PerXdsConfig) Reset()
func (x *PerXdsConfig) String() string
func (m *PerXdsConfig) Validate() error
Validate checks the field values on PerXdsConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type PerXdsConfigValidationError struct {
// contains filtered or unexported fields
}PerXdsConfigValidationError is the validation error returned by PerXdsConfig.Validate if the designated constraints aren't met.
func (e PerXdsConfigValidationError) Cause() error
Cause function returns cause value.
func (e PerXdsConfigValidationError) Error() string
Error satisfies the builtin error interface
func (e PerXdsConfigValidationError) ErrorName() string
ErrorName returns error name.
func (e PerXdsConfigValidationError) Field() string
Field function returns field value.
func (e PerXdsConfigValidationError) Key() bool
Key function returns key value.
func (e PerXdsConfigValidationError) Reason() string
Reason function returns reason value.
type PerXdsConfig_ClusterConfig struct {
ClusterConfig *v32.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof"`
}type PerXdsConfig_EndpointConfig struct {
EndpointConfig *v32.EndpointsConfigDump `protobuf:"bytes,6,opt,name=endpoint_config,json=endpointConfig,proto3,oneof"`
}type PerXdsConfig_ListenerConfig struct {
ListenerConfig *v32.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof"`
}type PerXdsConfig_RouteConfig struct {
RouteConfig *v32.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"`
}type PerXdsConfig_ScopedRouteConfig struct {
ScopedRouteConfig *v32.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof"`
}type UnimplementedClientStatusDiscoveryServiceServer struct {
}UnimplementedClientStatusDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)
func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
Package envoy_service_status_v3 imports 26 packages (graph) and is imported by 9 packages. Updated 2021-01-08. Refresh now. Tools for package owners.