Documentation ¶
Index ¶
- Variables
- func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer)
- type ClientConfig
- func (*ClientConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClientConfig) GetNode() *core.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
- func (m *ClientConfig) ValidateAll() error
- type ClientConfigMultiError
- 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 ClientStatusDiscoveryServiceClient
- type ClientStatusDiscoveryServiceServer
- type ClientStatusDiscoveryService_StreamClientStatusClient
- type ClientStatusDiscoveryService_StreamClientStatusServer
- type ClientStatusRequest
- func (*ClientStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClientStatusRequest) GetNodeMatchers() []*matcher.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) GetClusterConfig() *v2alpha.ClustersConfigDump
- func (x *PerXdsConfig) GetListenerConfig() *v2alpha.ListenersConfigDump
- func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig
- func (x *PerXdsConfig) GetRouteConfig() *v2alpha.RoutesConfigDump
- func (x *PerXdsConfig) GetScopedRouteConfig() *v2alpha.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_ListenerConfig
- type PerXdsConfig_RouteConfig
- type PerXdsConfig_ScopedRouteConfig
- type UnimplementedClientStatusDiscoveryServiceServer
Constants ¶
This section is empty.
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 File_envoy_service_status_v2_csds_proto protoreflect.FileDescriptor
Functions ¶
func RegisterClientStatusDiscoveryServiceServer ¶
func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer)
Types ¶
type ClientConfig ¶
type ClientConfig struct { // Node for a particular client. Node *core.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
deprecated
func (*ClientConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
func (*ClientConfig) GetNode ¶
func (x *ClientConfig) GetNode() *core.Node
func (*ClientConfig) GetXdsConfig ¶
func (x *ClientConfig) GetXdsConfig() []*PerXdsConfig
func (*ClientConfig) ProtoMessage ¶
func (*ClientConfig) ProtoMessage()
func (*ClientConfig) ProtoReflect ¶
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 ¶
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 ¶
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 ¶
func (m ClientConfigMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientConfigMultiError) Error ¶
func (m ClientConfigMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
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 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://godoc.org/google.golang.org/grpc#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.
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 []*matcher.NodeMatcher `protobuf:"bytes,1,rep,name=node_matchers,json=nodeMatchers,proto3" json:"node_matchers,omitempty"` // 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) GetNodeMatchers ¶
func (x *ClientStatusRequest) GetNodeMatchers() []*matcher.NodeMatcher
func (*ClientStatusRequest) ProtoMessage ¶
func (*ClientStatusRequest) ProtoMessage()
func (*ClientStatusRequest) ProtoReflect ¶
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 ¶
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 ¶
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 ¶
func (m ClientStatusRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientStatusRequestMultiError) Error ¶
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 ¶
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 ¶
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 ¶
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 ¶
func (m ClientStatusResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientStatusResponseMultiError) Error ¶
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.
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. ConfigStatus_ERROR ConfigStatus = 4 )
func (ConfigStatus) Descriptor ¶
func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
func (ConfigStatus) Enum ¶
func (x ConfigStatus) Enum() *ConfigStatus
func (ConfigStatus) EnumDescriptor
deprecated
func (ConfigStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigStatus.Descriptor instead.
func (ConfigStatus) Number ¶
func (x ConfigStatus) Number() protoreflect.EnumNumber
func (ConfigStatus) String ¶
func (x ConfigStatus) String() string
func (ConfigStatus) Type ¶
func (ConfigStatus) Type() protoreflect.EnumType
type PerXdsConfig ¶
type PerXdsConfig struct { Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v2.ConfigStatus" json:"status,omitempty"` // Types that are assignable to PerXdsConfig: // *PerXdsConfig_ListenerConfig // *PerXdsConfig_ClusterConfig // *PerXdsConfig_RouteConfig // *PerXdsConfig_ScopedRouteConfig PerXdsConfig isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"` // contains filtered or unexported fields }
Detailed config (per xDS) with status. [#next-free-field: 6]
func (*PerXdsConfig) Descriptor
deprecated
func (*PerXdsConfig) Descriptor() ([]byte, []int)
Deprecated: Use PerXdsConfig.ProtoReflect.Descriptor instead.
func (*PerXdsConfig) GetClusterConfig ¶
func (x *PerXdsConfig) GetClusterConfig() *v2alpha.ClustersConfigDump
func (*PerXdsConfig) GetListenerConfig ¶
func (x *PerXdsConfig) GetListenerConfig() *v2alpha.ListenersConfigDump
func (*PerXdsConfig) GetPerXdsConfig ¶
func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig
func (*PerXdsConfig) GetRouteConfig ¶
func (x *PerXdsConfig) GetRouteConfig() *v2alpha.RoutesConfigDump
func (*PerXdsConfig) GetScopedRouteConfig ¶
func (x *PerXdsConfig) GetScopedRouteConfig() *v2alpha.ScopedRoutesConfigDump
func (*PerXdsConfig) GetStatus ¶
func (x *PerXdsConfig) GetStatus() ConfigStatus
func (*PerXdsConfig) ProtoMessage ¶
func (*PerXdsConfig) ProtoMessage()
func (*PerXdsConfig) ProtoReflect ¶
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 ¶
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 ¶
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 ¶
func (m PerXdsConfigMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PerXdsConfigMultiError) Error ¶
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 *v2alpha.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof"`
}
type PerXdsConfig_ListenerConfig ¶
type PerXdsConfig_ListenerConfig struct {
ListenerConfig *v2alpha.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof"`
}
type PerXdsConfig_RouteConfig ¶
type PerXdsConfig_RouteConfig struct {
RouteConfig *v2alpha.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"`
}
type PerXdsConfig_ScopedRouteConfig ¶
type PerXdsConfig_ScopedRouteConfig struct {
ScopedRouteConfig *v2alpha.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof"`
}
type UnimplementedClientStatusDiscoveryServiceServer ¶
type UnimplementedClientStatusDiscoveryServiceServer struct { }
UnimplementedClientStatusDiscoveryServiceServer can 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