Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterClientStatusDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ClientStatusDiscoveryServiceServer)
- type ClientConfig
- func (*ClientConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClientConfig) GetClientScope() string
- func (x *ClientConfig) GetGenericXdsConfigs() []*ClientConfig_GenericXdsConfig
- func (x *ClientConfig) GetNode() *v31.Node
- func (x *ClientConfig) GetXdsConfig() []*PerXdsConfigdeprecated
- func (*ClientConfig) ProtoMessage()
- func (x *ClientConfig) ProtoReflect() protoreflect.Message
- func (x *ClientConfig) Reset()
- func (x *ClientConfig) String() string
- func (m *ClientConfig) Validate() error
- func (m *ClientConfig) ValidateAll() error
- type ClientConfigMultiError
- type ClientConfigStatus
- func (ClientConfigStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ClientConfigStatus) Enum() *ClientConfigStatus
- func (ClientConfigStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClientConfigStatus) Number() protoreflect.EnumNumber
- func (x ClientConfigStatus) String() string
- func (ClientConfigStatus) Type() protoreflect.EnumType
- type ClientConfigValidationError
- func (e ClientConfigValidationError) Cause() error
- func (e ClientConfigValidationError) Error() string
- func (e ClientConfigValidationError) ErrorName() string
- func (e ClientConfigValidationError) Field() string
- func (e ClientConfigValidationError) Key() bool
- func (e ClientConfigValidationError) Reason() string
- type ClientConfig_GenericXdsConfig
- func (*ClientConfig_GenericXdsConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClientConfig_GenericXdsConfig) GetClientStatus() v32.ClientResourceStatus
- func (x *ClientConfig_GenericXdsConfig) GetConfigStatus() ConfigStatus
- func (x *ClientConfig_GenericXdsConfig) GetErrorState() *v32.UpdateFailureState
- func (x *ClientConfig_GenericXdsConfig) GetIsStaticResource() bool
- func (x *ClientConfig_GenericXdsConfig) GetLastUpdated() *timestamppb.Timestamp
- func (x *ClientConfig_GenericXdsConfig) GetName() string
- func (x *ClientConfig_GenericXdsConfig) GetTypeUrl() string
- func (x *ClientConfig_GenericXdsConfig) GetVersionInfo() string
- func (x *ClientConfig_GenericXdsConfig) GetXdsConfig() *anypb.Any
- func (*ClientConfig_GenericXdsConfig) ProtoMessage()
- func (x *ClientConfig_GenericXdsConfig) ProtoReflect() protoreflect.Message
- func (x *ClientConfig_GenericXdsConfig) Reset()
- func (x *ClientConfig_GenericXdsConfig) String() string
- func (m *ClientConfig_GenericXdsConfig) Validate() error
- func (m *ClientConfig_GenericXdsConfig) ValidateAll() error
- type ClientConfig_GenericXdsConfigMultiError
- type ClientConfig_GenericXdsConfigValidationError
- func (e ClientConfig_GenericXdsConfigValidationError) Cause() error
- func (e ClientConfig_GenericXdsConfigValidationError) Error() string
- func (e ClientConfig_GenericXdsConfigValidationError) ErrorName() string
- func (e ClientConfig_GenericXdsConfigValidationError) Field() string
- func (e ClientConfig_GenericXdsConfigValidationError) Key() bool
- func (e ClientConfig_GenericXdsConfigValidationError) Reason() string
- type ClientStatusDiscoveryServiceClient
- type ClientStatusDiscoveryServiceServer
- type ClientStatusDiscoveryService_StreamClientStatusClient
- type ClientStatusDiscoveryService_StreamClientStatusServer
- type ClientStatusRequest
- func (*ClientStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClientStatusRequest) GetExcludeResourceContents() bool
- 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
- func (m *ClientStatusRequest) ValidateAll() error
- type ClientStatusRequestMultiError
- type ClientStatusRequestValidationError
- func (e ClientStatusRequestValidationError) Cause() error
- func (e ClientStatusRequestValidationError) Error() string
- func (e ClientStatusRequestValidationError) ErrorName() string
- func (e ClientStatusRequestValidationError) Field() string
- func (e ClientStatusRequestValidationError) Key() bool
- func (e ClientStatusRequestValidationError) Reason() string
- type ClientStatusResponse
- func (*ClientStatusResponse) Descriptor() ([]byte, []int)deprecated
- 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
- func (m *ClientStatusResponse) ValidateAll() error
- type ClientStatusResponseMultiError
- type ClientStatusResponseValidationError
- func (e ClientStatusResponseValidationError) Cause() error
- func (e ClientStatusResponseValidationError) Error() string
- func (e ClientStatusResponseValidationError) ErrorName() string
- func (e ClientStatusResponseValidationError) Field() string
- func (e ClientStatusResponseValidationError) Key() bool
- func (e ClientStatusResponseValidationError) Reason() string
- type ConfigStatus
- func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ConfigStatus) Enum() *ConfigStatus
- func (ConfigStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConfigStatus) Number() protoreflect.EnumNumber
- func (x ConfigStatus) String() string
- func (ConfigStatus) Type() protoreflect.EnumType
- type PerXdsConfig
- func (*PerXdsConfig) Descriptor() ([]byte, []int)deprecated
- func (x *PerXdsConfig) GetClientStatus() ClientConfigStatusdeprecated
- 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
- func (m *PerXdsConfig) ValidateAll() error
- type PerXdsConfigMultiError
- type PerXdsConfigValidationError
- func (e PerXdsConfigValidationError) Cause() error
- func (e PerXdsConfigValidationError) Error() string
- func (e PerXdsConfigValidationError) ErrorName() string
- func (e PerXdsConfigValidationError) Field() string
- func (e PerXdsConfigValidationError) Key() bool
- func (e PerXdsConfigValidationError) Reason() string
- type PerXdsConfig_ClusterConfig
- type PerXdsConfig_EndpointConfig
- type PerXdsConfig_ListenerConfig
- type PerXdsConfig_RouteConfig
- type PerXdsConfig_ScopedRouteConfig
- type UnimplementedClientStatusDiscoveryServiceServer
- type UnsafeClientStatusDiscoveryServiceServer
Constants ¶
const ( ClientStatusDiscoveryService_StreamClientStatus_FullMethodName = "/envoy.service.status.v3.ClientStatusDiscoveryService/StreamClientStatus" ClientStatusDiscoveryService_FetchClientStatus_FullMethodName = "/envoy.service.status.v3.ClientStatusDiscoveryService/FetchClientStatus" )
Variables ¶
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 ClientStatusDiscoveryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "envoy.service.status.v3.ClientStatusDiscoveryService", HandlerType: (*ClientStatusDiscoveryServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FetchClientStatus", Handler: _ClientStatusDiscoveryService_FetchClientStatus_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamClientStatus", Handler: _ClientStatusDiscoveryService_StreamClientStatus_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "envoy/service/status/v3/csds.proto", }
ClientStatusDiscoveryService_ServiceDesc is the grpc.ServiceDesc for ClientStatusDiscoveryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_envoy_service_status_v3_csds_proto protoreflect.FileDescriptor
Functions ¶
func RegisterClientStatusDiscoveryServiceServer ¶
func RegisterClientStatusDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ClientStatusDiscoveryServiceServer)
Types ¶
type ClientConfig ¶
type ClientConfig struct { // Node for a particular client. Node *v31.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // This field is deprecated in favor of generic_xds_configs which is // much simpler and uniform in structure. // // Deprecated: Marked as deprecated in envoy/service/status/v3/csds.proto. XdsConfig []*PerXdsConfig `protobuf:"bytes,2,rep,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"` // Represents generic xDS config and the exact config structure depends on // the type URL (like Cluster if it is CDS) GenericXdsConfigs []*ClientConfig_GenericXdsConfig `protobuf:"bytes,3,rep,name=generic_xds_configs,json=genericXdsConfigs,proto3" json:"generic_xds_configs,omitempty"` // For xDS clients, the scope in which the data is used. // For example, gRPC indicates the data plane target or that the data is // associated with gRPC server(s). ClientScope string `protobuf:"bytes,4,opt,name=client_scope,json=clientScope,proto3" json:"client_scope,omitempty"` // contains filtered or unexported fields }
All xds configs for a particular client.
func (*ClientConfig) Descriptor
deprecated
func (*ClientConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
func (*ClientConfig) GetClientScope ¶ added in v0.13.0
func (x *ClientConfig) GetClientScope() string
func (*ClientConfig) GetGenericXdsConfigs ¶ added in v0.10.0
func (x *ClientConfig) GetGenericXdsConfigs() []*ClientConfig_GenericXdsConfig
func (*ClientConfig) GetNode ¶
func (x *ClientConfig) GetNode() *v31.Node
func (*ClientConfig) GetXdsConfig
deprecated
func (x *ClientConfig) GetXdsConfig() []*PerXdsConfig
Deprecated: Marked as deprecated in envoy/service/status/v3/csds.proto.
func (*ClientConfig) ProtoMessage ¶
func (*ClientConfig) ProtoMessage()
func (*ClientConfig) ProtoReflect ¶ added in v0.9.6
func (x *ClientConfig) ProtoReflect() protoreflect.Message
func (*ClientConfig) Reset ¶
func (x *ClientConfig) Reset()
func (*ClientConfig) String ¶
func (x *ClientConfig) String() string
func (*ClientConfig) Validate ¶
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, the first error encountered is returned, or nil if there are no violations.
func (*ClientConfig) ValidateAll ¶ added in v0.10.0
func (m *ClientConfig) ValidateAll() error
ValidateAll checks the field values on ClientConfig with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClientConfigMultiError, or nil if none found.
type ClientConfigMultiError ¶ added in v0.10.0
type ClientConfigMultiError []error
ClientConfigMultiError is an error wrapping multiple validation errors returned by ClientConfig.ValidateAll() if the designated constraints aren't met.
func (ClientConfigMultiError) AllErrors ¶ added in v0.10.0
func (m ClientConfigMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientConfigMultiError) Error ¶ added in v0.10.0
func (m ClientConfigMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ClientConfigStatus ¶ added in v0.9.7
type ClientConfigStatus int32
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 ¶ added in v0.9.7
func (ClientConfigStatus) Descriptor() protoreflect.EnumDescriptor
func (ClientConfigStatus) Enum ¶ added in v0.9.7
func (x ClientConfigStatus) Enum() *ClientConfigStatus
func (ClientConfigStatus) EnumDescriptor
deprecated
added in
v0.9.7
func (ClientConfigStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientConfigStatus.Descriptor instead.
func (ClientConfigStatus) Number ¶ added in v0.9.7
func (x ClientConfigStatus) Number() protoreflect.EnumNumber
func (ClientConfigStatus) String ¶ added in v0.9.7
func (x ClientConfigStatus) String() string
func (ClientConfigStatus) Type ¶ added in v0.9.7
func (ClientConfigStatus) Type() protoreflect.EnumType
type ClientConfigValidationError ¶
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 (ClientConfigValidationError) Cause ¶
func (e ClientConfigValidationError) Cause() error
Cause function returns cause value.
func (ClientConfigValidationError) Error ¶
func (e ClientConfigValidationError) Error() string
Error satisfies the builtin error interface
func (ClientConfigValidationError) ErrorName ¶
func (e ClientConfigValidationError) ErrorName() string
ErrorName returns error name.
func (ClientConfigValidationError) Field ¶
func (e ClientConfigValidationError) Field() string
Field function returns field value.
func (ClientConfigValidationError) Key ¶
func (e ClientConfigValidationError) Key() bool
Key function returns key value.
func (ClientConfigValidationError) Reason ¶
func (e ClientConfigValidationError) Reason() string
Reason function returns reason value.
type ClientConfig_GenericXdsConfig ¶ added in v0.10.0
type ClientConfig_GenericXdsConfig struct { // Type_url represents the fully qualified name of xDS resource type // like envoy.v3.Cluster, envoy.v3.ClusterLoadAssignment etc. TypeUrl string `protobuf:"bytes,1,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"` // Name of the xDS resource Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // This is the :ref:`version_info <envoy_v3_api_field_service.discovery.v3.DiscoveryResponse.version_info>` // in the last processed xDS discovery response. If there are only // static bootstrap listeners, this field will be "" VersionInfo string `protobuf:"bytes,3,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"` // The xDS resource config. Actual content depends on the type XdsConfig *anypb.Any `protobuf:"bytes,4,opt,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"` // Timestamp when the xDS resource was last updated LastUpdated *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"` // Per xDS resource config status. It is generated by management servers. // It will not be present if the CSDS server is an xDS client. ConfigStatus ConfigStatus `` /* 140-byte string literal not displayed */ // Per xDS resource status from the view of a xDS client ClientStatus v32.ClientResourceStatus `` /* 139-byte string literal not displayed */ // Set if the last update failed, cleared after the next successful // update. The *error_state* field contains the rejected version of // this particular resource along with the reason and timestamp. For // successfully updated or acknowledged resource, this field should // be empty. // [#not-implemented-hide:] ErrorState *v32.UpdateFailureState `protobuf:"bytes,8,opt,name=error_state,json=errorState,proto3" json:"error_state,omitempty"` // Is static resource is true if it is specified in the config supplied // through the file at the startup. IsStaticResource bool `protobuf:"varint,9,opt,name=is_static_resource,json=isStaticResource,proto3" json:"is_static_resource,omitempty"` // contains filtered or unexported fields }
GenericXdsConfig is used to specify the config status and the dump of any xDS resource identified by their type URL. It is the generalized version of the now deprecated ListenersConfigDump, ClustersConfigDump etc [#next-free-field: 10]
func (*ClientConfig_GenericXdsConfig) Descriptor
deprecated
added in
v0.10.0
func (*ClientConfig_GenericXdsConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfig_GenericXdsConfig.ProtoReflect.Descriptor instead.
func (*ClientConfig_GenericXdsConfig) GetClientStatus ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetClientStatus() v32.ClientResourceStatus
func (*ClientConfig_GenericXdsConfig) GetConfigStatus ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetConfigStatus() ConfigStatus
func (*ClientConfig_GenericXdsConfig) GetErrorState ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetErrorState() *v32.UpdateFailureState
func (*ClientConfig_GenericXdsConfig) GetIsStaticResource ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetIsStaticResource() bool
func (*ClientConfig_GenericXdsConfig) GetLastUpdated ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetLastUpdated() *timestamppb.Timestamp
func (*ClientConfig_GenericXdsConfig) GetName ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetName() string
func (*ClientConfig_GenericXdsConfig) GetTypeUrl ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetTypeUrl() string
func (*ClientConfig_GenericXdsConfig) GetVersionInfo ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetVersionInfo() string
func (*ClientConfig_GenericXdsConfig) GetXdsConfig ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) GetXdsConfig() *anypb.Any
func (*ClientConfig_GenericXdsConfig) ProtoMessage ¶ added in v0.10.0
func (*ClientConfig_GenericXdsConfig) ProtoMessage()
func (*ClientConfig_GenericXdsConfig) ProtoReflect ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) ProtoReflect() protoreflect.Message
func (*ClientConfig_GenericXdsConfig) Reset ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) Reset()
func (*ClientConfig_GenericXdsConfig) String ¶ added in v0.10.0
func (x *ClientConfig_GenericXdsConfig) String() string
func (*ClientConfig_GenericXdsConfig) Validate ¶ added in v0.10.0
func (m *ClientConfig_GenericXdsConfig) Validate() error
Validate checks the field values on ClientConfig_GenericXdsConfig with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ClientConfig_GenericXdsConfig) ValidateAll ¶ added in v0.10.0
func (m *ClientConfig_GenericXdsConfig) ValidateAll() error
ValidateAll checks the field values on ClientConfig_GenericXdsConfig with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClientConfig_GenericXdsConfigMultiError, or nil if none found.
type ClientConfig_GenericXdsConfigMultiError ¶ added in v0.10.0
type ClientConfig_GenericXdsConfigMultiError []error
ClientConfig_GenericXdsConfigMultiError is an error wrapping multiple validation errors returned by ClientConfig_GenericXdsConfig.ValidateAll() if the designated constraints aren't met.
func (ClientConfig_GenericXdsConfigMultiError) AllErrors ¶ added in v0.10.0
func (m ClientConfig_GenericXdsConfigMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientConfig_GenericXdsConfigMultiError) Error ¶ added in v0.10.0
func (m ClientConfig_GenericXdsConfigMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ClientConfig_GenericXdsConfigValidationError ¶ added in v0.10.0
type ClientConfig_GenericXdsConfigValidationError struct {
// contains filtered or unexported fields
}
ClientConfig_GenericXdsConfigValidationError is the validation error returned by ClientConfig_GenericXdsConfig.Validate if the designated constraints aren't met.
func (ClientConfig_GenericXdsConfigValidationError) Cause ¶ added in v0.10.0
func (e ClientConfig_GenericXdsConfigValidationError) Cause() error
Cause function returns cause value.
func (ClientConfig_GenericXdsConfigValidationError) Error ¶ added in v0.10.0
func (e ClientConfig_GenericXdsConfigValidationError) Error() string
Error satisfies the builtin error interface
func (ClientConfig_GenericXdsConfigValidationError) ErrorName ¶ added in v0.10.0
func (e ClientConfig_GenericXdsConfigValidationError) ErrorName() string
ErrorName returns error name.
func (ClientConfig_GenericXdsConfigValidationError) Field ¶ added in v0.10.0
func (e ClientConfig_GenericXdsConfigValidationError) Field() string
Field function returns field value.
func (ClientConfig_GenericXdsConfigValidationError) Key ¶ added in v0.10.0
func (e ClientConfig_GenericXdsConfigValidationError) Key() bool
Key function returns key value.
func (ClientConfig_GenericXdsConfigValidationError) Reason ¶ added in v0.10.0
func (e ClientConfig_GenericXdsConfigValidationError) Reason() string
Reason function returns reason value.
type ClientStatusDiscoveryServiceClient ¶
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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClientStatusDiscoveryServiceClient ¶
func NewClientStatusDiscoveryServiceClient(cc grpc.ClientConnInterface) ClientStatusDiscoveryServiceClient
type ClientStatusDiscoveryServiceServer ¶
type ClientStatusDiscoveryServiceServer interface { StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error) }
ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service. All implementations should embed UnimplementedClientStatusDiscoveryServiceServer for forward compatibility
type ClientStatusDiscoveryService_StreamClientStatusClient ¶
type ClientStatusDiscoveryService_StreamClientStatusClient interface { Send(*ClientStatusRequest) error Recv() (*ClientStatusResponse, error) grpc.ClientStream }
type ClientStatusDiscoveryService_StreamClientStatusServer ¶
type ClientStatusDiscoveryService_StreamClientStatusServer interface { Send(*ClientStatusResponse) error Recv() (*ClientStatusRequest, error) grpc.ServerStream }
type ClientStatusRequest ¶
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"` // If true, the server will not include the resource contents in the response // (i.e., the generic_xds_configs.xds_config field will not be populated). // [#not-implemented-hide:] ExcludeResourceContents bool `` /* 133-byte string literal not displayed */ // contains filtered or unexported fields }
Request for client status of clients identified by a list of NodeMatchers.
func (*ClientStatusRequest) Descriptor
deprecated
func (*ClientStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatusRequest.ProtoReflect.Descriptor instead.
func (*ClientStatusRequest) GetExcludeResourceContents ¶ added in v0.12.0
func (x *ClientStatusRequest) GetExcludeResourceContents() bool
func (*ClientStatusRequest) GetNode ¶ added in v0.9.7
func (x *ClientStatusRequest) GetNode() *v31.Node
func (*ClientStatusRequest) GetNodeMatchers ¶
func (x *ClientStatusRequest) GetNodeMatchers() []*v3.NodeMatcher
func (*ClientStatusRequest) ProtoMessage ¶
func (*ClientStatusRequest) ProtoMessage()
func (*ClientStatusRequest) ProtoReflect ¶ added in v0.9.6
func (x *ClientStatusRequest) ProtoReflect() protoreflect.Message
func (*ClientStatusRequest) Reset ¶
func (x *ClientStatusRequest) Reset()
func (*ClientStatusRequest) String ¶
func (x *ClientStatusRequest) String() string
func (*ClientStatusRequest) Validate ¶
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, the first error encountered is returned, or nil if there are no violations.
func (*ClientStatusRequest) ValidateAll ¶ added in v0.10.0
func (m *ClientStatusRequest) ValidateAll() error
ValidateAll checks the field values on ClientStatusRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClientStatusRequestMultiError, or nil if none found.
type ClientStatusRequestMultiError ¶ added in v0.10.0
type ClientStatusRequestMultiError []error
ClientStatusRequestMultiError is an error wrapping multiple validation errors returned by ClientStatusRequest.ValidateAll() if the designated constraints aren't met.
func (ClientStatusRequestMultiError) AllErrors ¶ added in v0.10.0
func (m ClientStatusRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientStatusRequestMultiError) Error ¶ added in v0.10.0
func (m ClientStatusRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ClientStatusRequestValidationError ¶
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 (ClientStatusRequestValidationError) Cause ¶
func (e ClientStatusRequestValidationError) Cause() error
Cause function returns cause value.
func (ClientStatusRequestValidationError) Error ¶
func (e ClientStatusRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ClientStatusRequestValidationError) ErrorName ¶
func (e ClientStatusRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ClientStatusRequestValidationError) Field ¶
func (e ClientStatusRequestValidationError) Field() string
Field function returns field value.
func (ClientStatusRequestValidationError) Key ¶
func (e ClientStatusRequestValidationError) Key() bool
Key function returns key value.
func (ClientStatusRequestValidationError) Reason ¶
func (e ClientStatusRequestValidationError) Reason() string
Reason function returns reason value.
type ClientStatusResponse ¶
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
deprecated
func (*ClientStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatusResponse.ProtoReflect.Descriptor instead.
func (*ClientStatusResponse) GetConfig ¶
func (x *ClientStatusResponse) GetConfig() []*ClientConfig
func (*ClientStatusResponse) ProtoMessage ¶
func (*ClientStatusResponse) ProtoMessage()
func (*ClientStatusResponse) ProtoReflect ¶ added in v0.9.6
func (x *ClientStatusResponse) ProtoReflect() protoreflect.Message
func (*ClientStatusResponse) Reset ¶
func (x *ClientStatusResponse) Reset()
func (*ClientStatusResponse) String ¶
func (x *ClientStatusResponse) String() string
func (*ClientStatusResponse) Validate ¶
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, the first error encountered is returned, or nil if there are no violations.
func (*ClientStatusResponse) ValidateAll ¶ added in v0.10.0
func (m *ClientStatusResponse) ValidateAll() error
ValidateAll checks the field values on ClientStatusResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClientStatusResponseMultiError, or nil if none found.
type ClientStatusResponseMultiError ¶ added in v0.10.0
type ClientStatusResponseMultiError []error
ClientStatusResponseMultiError is an error wrapping multiple validation errors returned by ClientStatusResponse.ValidateAll() if the designated constraints aren't met.
func (ClientStatusResponseMultiError) AllErrors ¶ added in v0.10.0
func (m ClientStatusResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientStatusResponseMultiError) Error ¶ added in v0.10.0
func (m ClientStatusResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ClientStatusResponseValidationError ¶
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 (ClientStatusResponseValidationError) Cause ¶
func (e ClientStatusResponseValidationError) Cause() error
Cause function returns cause value.
func (ClientStatusResponseValidationError) Error ¶
func (e ClientStatusResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ClientStatusResponseValidationError) ErrorName ¶
func (e ClientStatusResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ClientStatusResponseValidationError) Field ¶
func (e ClientStatusResponseValidationError) Field() string
Field function returns field value.
func (ClientStatusResponseValidationError) Key ¶
func (e ClientStatusResponseValidationError) Key() bool
Key function returns key value.
func (ClientStatusResponseValidationError) Reason ¶
func (e ClientStatusResponseValidationError) Reason() string
Reason function returns reason value.
type ConfigStatus ¶
type ConfigStatus int32
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 ¶ added in v0.9.6
func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
func (ConfigStatus) Enum ¶ added in v0.9.6
func (x ConfigStatus) Enum() *ConfigStatus
func (ConfigStatus) EnumDescriptor
deprecated
func (ConfigStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigStatus.Descriptor instead.
func (ConfigStatus) Number ¶ added in v0.9.6
func (x ConfigStatus) Number() protoreflect.EnumNumber
func (ConfigStatus) String ¶
func (x ConfigStatus) String() string
func (ConfigStatus) Type ¶ added in v0.9.6
func (ConfigStatus) Type() protoreflect.EnumType
type PerXdsConfig ¶
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. // // .. attention:: // // This field is deprecated. Use :ref:`ClientResourceStatus // <envoy_v3_api_enum_admin.v3.ClientResourceStatus>` for per-resource // config status instead. // // Deprecated: Marked as deprecated in envoy/service/status/v3/csds.proto. ClientStatus ClientConfigStatus `` /* 146-byte string literal not displayed */ // 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
deprecated
func (*PerXdsConfig) Descriptor() ([]byte, []int)
Deprecated: Use PerXdsConfig.ProtoReflect.Descriptor instead.
func (*PerXdsConfig) GetClientStatus
deprecated
added in
v0.9.7
func (x *PerXdsConfig) GetClientStatus() ClientConfigStatus
Deprecated: Marked as deprecated in envoy/service/status/v3/csds.proto.
func (*PerXdsConfig) GetClusterConfig ¶
func (x *PerXdsConfig) GetClusterConfig() *v32.ClustersConfigDump
func (*PerXdsConfig) GetEndpointConfig ¶ added in v0.9.6
func (x *PerXdsConfig) GetEndpointConfig() *v32.EndpointsConfigDump
func (*PerXdsConfig) GetListenerConfig ¶
func (x *PerXdsConfig) GetListenerConfig() *v32.ListenersConfigDump
func (*PerXdsConfig) GetPerXdsConfig ¶
func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig
func (*PerXdsConfig) GetRouteConfig ¶
func (x *PerXdsConfig) GetRouteConfig() *v32.RoutesConfigDump
func (*PerXdsConfig) GetScopedRouteConfig ¶
func (x *PerXdsConfig) GetScopedRouteConfig() *v32.ScopedRoutesConfigDump
func (*PerXdsConfig) GetStatus ¶
func (x *PerXdsConfig) GetStatus() ConfigStatus
func (*PerXdsConfig) ProtoMessage ¶
func (*PerXdsConfig) ProtoMessage()
func (*PerXdsConfig) ProtoReflect ¶ added in v0.9.6
func (x *PerXdsConfig) ProtoReflect() protoreflect.Message
func (*PerXdsConfig) Reset ¶
func (x *PerXdsConfig) Reset()
func (*PerXdsConfig) String ¶
func (x *PerXdsConfig) String() string
func (*PerXdsConfig) Validate ¶
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, the first error encountered is returned, or nil if there are no violations.
func (*PerXdsConfig) ValidateAll ¶ added in v0.10.0
func (m *PerXdsConfig) ValidateAll() error
ValidateAll checks the field values on PerXdsConfig with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PerXdsConfigMultiError, or nil if none found.
type PerXdsConfigMultiError ¶ added in v0.10.0
type PerXdsConfigMultiError []error
PerXdsConfigMultiError is an error wrapping multiple validation errors returned by PerXdsConfig.ValidateAll() if the designated constraints aren't met.
func (PerXdsConfigMultiError) AllErrors ¶ added in v0.10.0
func (m PerXdsConfigMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PerXdsConfigMultiError) Error ¶ added in v0.10.0
func (m PerXdsConfigMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PerXdsConfigValidationError ¶
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 (PerXdsConfigValidationError) Cause ¶
func (e PerXdsConfigValidationError) Cause() error
Cause function returns cause value.
func (PerXdsConfigValidationError) Error ¶
func (e PerXdsConfigValidationError) Error() string
Error satisfies the builtin error interface
func (PerXdsConfigValidationError) ErrorName ¶
func (e PerXdsConfigValidationError) ErrorName() string
ErrorName returns error name.
func (PerXdsConfigValidationError) Field ¶
func (e PerXdsConfigValidationError) Field() string
Field function returns field value.
func (PerXdsConfigValidationError) Key ¶
func (e PerXdsConfigValidationError) Key() bool
Key function returns key value.
func (PerXdsConfigValidationError) Reason ¶
func (e PerXdsConfigValidationError) Reason() string
Reason function returns reason value.
type PerXdsConfig_ClusterConfig ¶
type PerXdsConfig_ClusterConfig struct {
ClusterConfig *v32.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof"`
}
type PerXdsConfig_EndpointConfig ¶ added in v0.9.6
type PerXdsConfig_EndpointConfig struct {
EndpointConfig *v32.EndpointsConfigDump `protobuf:"bytes,6,opt,name=endpoint_config,json=endpointConfig,proto3,oneof"`
}
type PerXdsConfig_ListenerConfig ¶
type PerXdsConfig_ListenerConfig struct {
ListenerConfig *v32.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof"`
}
type PerXdsConfig_RouteConfig ¶
type PerXdsConfig_RouteConfig struct {
RouteConfig *v32.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"`
}
type PerXdsConfig_ScopedRouteConfig ¶
type PerXdsConfig_ScopedRouteConfig struct {
ScopedRouteConfig *v32.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof"`
}
type UnimplementedClientStatusDiscoveryServiceServer ¶
type UnimplementedClientStatusDiscoveryServiceServer struct { }
UnimplementedClientStatusDiscoveryServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus ¶
func (UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)
func (UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus ¶
func (UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
type UnsafeClientStatusDiscoveryServiceServer ¶ added in v0.13.0
type UnsafeClientStatusDiscoveryServiceServer interface {
// contains filtered or unexported methods
}
UnsafeClientStatusDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClientStatusDiscoveryServiceServer will result in compilation errors.