Documentation ¶
Index ¶
- Variables
- type ClusterStats
- func (*ClusterStats) Descriptor() ([]byte, []int)
- func (m *ClusterStats) GetClusterName() string
- func (m *ClusterStats) GetClusterServiceName() string
- func (m *ClusterStats) GetDroppedRequests() []*ClusterStats_DroppedRequests
- func (m *ClusterStats) GetLoadReportInterval() *types.Duration
- func (m *ClusterStats) GetTotalDroppedRequests() uint64
- func (m *ClusterStats) GetUpstreamLocalityStats() []*UpstreamLocalityStats
- func (m *ClusterStats) Marshal() (dAtA []byte, err error)
- func (m *ClusterStats) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterStats) ProtoMessage()
- func (m *ClusterStats) Reset()
- func (m *ClusterStats) Size() (n int)
- func (m *ClusterStats) String() string
- func (m *ClusterStats) Unmarshal(dAtA []byte) error
- func (m *ClusterStats) Validate() error
- func (m *ClusterStats) XXX_DiscardUnknown()
- func (m *ClusterStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterStats) XXX_Merge(src proto.Message)
- func (m *ClusterStats) XXX_Size() int
- func (m *ClusterStats) XXX_Unmarshal(b []byte) error
- type ClusterStatsValidationError
- func (e ClusterStatsValidationError) Cause() error
- func (e ClusterStatsValidationError) Error() string
- func (e ClusterStatsValidationError) ErrorName() string
- func (e ClusterStatsValidationError) Field() string
- func (e ClusterStatsValidationError) Key() bool
- func (e ClusterStatsValidationError) Reason() string
- type ClusterStats_DroppedRequests
- func (*ClusterStats_DroppedRequests) Descriptor() ([]byte, []int)
- func (m *ClusterStats_DroppedRequests) GetCategory() string
- func (m *ClusterStats_DroppedRequests) GetDroppedCount() uint64
- func (m *ClusterStats_DroppedRequests) Marshal() (dAtA []byte, err error)
- func (m *ClusterStats_DroppedRequests) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterStats_DroppedRequests) ProtoMessage()
- func (m *ClusterStats_DroppedRequests) Reset()
- func (m *ClusterStats_DroppedRequests) Size() (n int)
- func (m *ClusterStats_DroppedRequests) String() string
- func (m *ClusterStats_DroppedRequests) Unmarshal(dAtA []byte) error
- func (m *ClusterStats_DroppedRequests) Validate() error
- func (m *ClusterStats_DroppedRequests) XXX_DiscardUnknown()
- func (m *ClusterStats_DroppedRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterStats_DroppedRequests) XXX_Merge(src proto.Message)
- func (m *ClusterStats_DroppedRequests) XXX_Size() int
- func (m *ClusterStats_DroppedRequests) XXX_Unmarshal(b []byte) error
- type ClusterStats_DroppedRequestsValidationError
- func (e ClusterStats_DroppedRequestsValidationError) Cause() error
- func (e ClusterStats_DroppedRequestsValidationError) Error() string
- func (e ClusterStats_DroppedRequestsValidationError) ErrorName() string
- func (e ClusterStats_DroppedRequestsValidationError) Field() string
- func (e ClusterStats_DroppedRequestsValidationError) Key() bool
- func (e ClusterStats_DroppedRequestsValidationError) Reason() string
- type Endpoint
- func (*Endpoint) Descriptor() ([]byte, []int)
- func (this *Endpoint) Equal(that interface{}) bool
- func (m *Endpoint) GetAddress() *core.Address
- func (m *Endpoint) GetHealthCheckConfig() *Endpoint_HealthCheckConfig
- func (m *Endpoint) Marshal() (dAtA []byte, err error)
- func (m *Endpoint) MarshalTo(dAtA []byte) (int, error)
- func (*Endpoint) ProtoMessage()
- func (m *Endpoint) Reset()
- func (m *Endpoint) Size() (n int)
- func (m *Endpoint) String() string
- func (m *Endpoint) Unmarshal(dAtA []byte) error
- func (m *Endpoint) Validate() error
- func (m *Endpoint) XXX_DiscardUnknown()
- func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Endpoint) XXX_Merge(src proto.Message)
- func (m *Endpoint) XXX_Size() int
- func (m *Endpoint) XXX_Unmarshal(b []byte) error
- type EndpointLoadMetricStats
- func (*EndpointLoadMetricStats) Descriptor() ([]byte, []int)
- func (m *EndpointLoadMetricStats) GetMetricName() string
- func (m *EndpointLoadMetricStats) GetNumRequestsFinishedWithMetric() uint64
- func (m *EndpointLoadMetricStats) GetTotalMetricValue() float64
- func (m *EndpointLoadMetricStats) Marshal() (dAtA []byte, err error)
- func (m *EndpointLoadMetricStats) MarshalTo(dAtA []byte) (int, error)
- func (*EndpointLoadMetricStats) ProtoMessage()
- func (m *EndpointLoadMetricStats) Reset()
- func (m *EndpointLoadMetricStats) Size() (n int)
- func (m *EndpointLoadMetricStats) String() string
- func (m *EndpointLoadMetricStats) Unmarshal(dAtA []byte) error
- func (m *EndpointLoadMetricStats) Validate() error
- func (m *EndpointLoadMetricStats) XXX_DiscardUnknown()
- func (m *EndpointLoadMetricStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EndpointLoadMetricStats) XXX_Merge(src proto.Message)
- func (m *EndpointLoadMetricStats) XXX_Size() int
- func (m *EndpointLoadMetricStats) XXX_Unmarshal(b []byte) error
- type EndpointLoadMetricStatsValidationError
- func (e EndpointLoadMetricStatsValidationError) Cause() error
- func (e EndpointLoadMetricStatsValidationError) Error() string
- func (e EndpointLoadMetricStatsValidationError) ErrorName() string
- func (e EndpointLoadMetricStatsValidationError) Field() string
- func (e EndpointLoadMetricStatsValidationError) Key() bool
- func (e EndpointLoadMetricStatsValidationError) Reason() string
- type EndpointValidationError
- type Endpoint_HealthCheckConfig
- func (*Endpoint_HealthCheckConfig) Descriptor() ([]byte, []int)
- func (this *Endpoint_HealthCheckConfig) Equal(that interface{}) bool
- func (m *Endpoint_HealthCheckConfig) GetPortValue() uint32
- func (m *Endpoint_HealthCheckConfig) Marshal() (dAtA []byte, err error)
- func (m *Endpoint_HealthCheckConfig) MarshalTo(dAtA []byte) (int, error)
- func (*Endpoint_HealthCheckConfig) ProtoMessage()
- func (m *Endpoint_HealthCheckConfig) Reset()
- func (m *Endpoint_HealthCheckConfig) Size() (n int)
- func (m *Endpoint_HealthCheckConfig) String() string
- func (m *Endpoint_HealthCheckConfig) Unmarshal(dAtA []byte) error
- func (m *Endpoint_HealthCheckConfig) Validate() error
- func (m *Endpoint_HealthCheckConfig) XXX_DiscardUnknown()
- func (m *Endpoint_HealthCheckConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Endpoint_HealthCheckConfig) XXX_Merge(src proto.Message)
- func (m *Endpoint_HealthCheckConfig) XXX_Size() int
- func (m *Endpoint_HealthCheckConfig) XXX_Unmarshal(b []byte) error
- type Endpoint_HealthCheckConfigValidationError
- func (e Endpoint_HealthCheckConfigValidationError) Cause() error
- func (e Endpoint_HealthCheckConfigValidationError) Error() string
- func (e Endpoint_HealthCheckConfigValidationError) ErrorName() string
- func (e Endpoint_HealthCheckConfigValidationError) Field() string
- func (e Endpoint_HealthCheckConfigValidationError) Key() bool
- func (e Endpoint_HealthCheckConfigValidationError) Reason() string
- type LbEndpoint
- func (*LbEndpoint) Descriptor() ([]byte, []int)
- func (this *LbEndpoint) Equal(that interface{}) bool
- func (m *LbEndpoint) GetEndpoint() *Endpoint
- func (m *LbEndpoint) GetEndpointName() string
- func (m *LbEndpoint) GetHealthStatus() core.HealthStatus
- func (m *LbEndpoint) GetHostIdentifier() isLbEndpoint_HostIdentifier
- func (m *LbEndpoint) GetLoadBalancingWeight() *types.UInt32Value
- func (m *LbEndpoint) GetMetadata() *core.Metadata
- func (m *LbEndpoint) Marshal() (dAtA []byte, err error)
- func (m *LbEndpoint) MarshalTo(dAtA []byte) (int, error)
- func (*LbEndpoint) ProtoMessage()
- func (m *LbEndpoint) Reset()
- func (m *LbEndpoint) Size() (n int)
- func (m *LbEndpoint) String() string
- func (m *LbEndpoint) Unmarshal(dAtA []byte) error
- func (m *LbEndpoint) Validate() error
- func (m *LbEndpoint) XXX_DiscardUnknown()
- func (m *LbEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LbEndpoint) XXX_Merge(src proto.Message)
- func (*LbEndpoint) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *LbEndpoint) XXX_Size() int
- func (m *LbEndpoint) XXX_Unmarshal(b []byte) error
- type LbEndpointValidationError
- type LbEndpoint_Endpoint
- type LbEndpoint_EndpointName
- type LocalityLbEndpoints
- func (*LocalityLbEndpoints) Descriptor() ([]byte, []int)
- func (this *LocalityLbEndpoints) Equal(that interface{}) bool
- func (m *LocalityLbEndpoints) GetLbEndpoints() []LbEndpoint
- func (m *LocalityLbEndpoints) GetLoadBalancingWeight() *types.UInt32Value
- func (m *LocalityLbEndpoints) GetLocality() *core.Locality
- func (m *LocalityLbEndpoints) GetPriority() uint32
- func (m *LocalityLbEndpoints) GetProximity() *types.UInt32Value
- func (m *LocalityLbEndpoints) Marshal() (dAtA []byte, err error)
- func (m *LocalityLbEndpoints) MarshalTo(dAtA []byte) (int, error)
- func (*LocalityLbEndpoints) ProtoMessage()
- func (m *LocalityLbEndpoints) Reset()
- func (m *LocalityLbEndpoints) Size() (n int)
- func (m *LocalityLbEndpoints) String() string
- func (m *LocalityLbEndpoints) Unmarshal(dAtA []byte) error
- func (m *LocalityLbEndpoints) Validate() error
- func (m *LocalityLbEndpoints) XXX_DiscardUnknown()
- func (m *LocalityLbEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LocalityLbEndpoints) XXX_Merge(src proto.Message)
- func (m *LocalityLbEndpoints) XXX_Size() int
- func (m *LocalityLbEndpoints) XXX_Unmarshal(b []byte) error
- type LocalityLbEndpointsValidationError
- func (e LocalityLbEndpointsValidationError) Cause() error
- func (e LocalityLbEndpointsValidationError) Error() string
- func (e LocalityLbEndpointsValidationError) ErrorName() string
- func (e LocalityLbEndpointsValidationError) Field() string
- func (e LocalityLbEndpointsValidationError) Key() bool
- func (e LocalityLbEndpointsValidationError) Reason() string
- type UpstreamEndpointStats
- func (*UpstreamEndpointStats) Descriptor() ([]byte, []int)
- func (m *UpstreamEndpointStats) GetAddress() *core.Address
- func (m *UpstreamEndpointStats) GetLoadMetricStats() []*EndpointLoadMetricStats
- func (m *UpstreamEndpointStats) GetMetadata() *types.Struct
- func (m *UpstreamEndpointStats) GetTotalErrorRequests() uint64
- func (m *UpstreamEndpointStats) GetTotalRequestsInProgress() uint64
- func (m *UpstreamEndpointStats) GetTotalSuccessfulRequests() uint64
- func (m *UpstreamEndpointStats) Marshal() (dAtA []byte, err error)
- func (m *UpstreamEndpointStats) MarshalTo(dAtA []byte) (int, error)
- func (*UpstreamEndpointStats) ProtoMessage()
- func (m *UpstreamEndpointStats) Reset()
- func (m *UpstreamEndpointStats) Size() (n int)
- func (m *UpstreamEndpointStats) String() string
- func (m *UpstreamEndpointStats) Unmarshal(dAtA []byte) error
- func (m *UpstreamEndpointStats) Validate() error
- func (m *UpstreamEndpointStats) XXX_DiscardUnknown()
- func (m *UpstreamEndpointStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpstreamEndpointStats) XXX_Merge(src proto.Message)
- func (m *UpstreamEndpointStats) XXX_Size() int
- func (m *UpstreamEndpointStats) XXX_Unmarshal(b []byte) error
- type UpstreamEndpointStatsValidationError
- func (e UpstreamEndpointStatsValidationError) Cause() error
- func (e UpstreamEndpointStatsValidationError) Error() string
- func (e UpstreamEndpointStatsValidationError) ErrorName() string
- func (e UpstreamEndpointStatsValidationError) Field() string
- func (e UpstreamEndpointStatsValidationError) Key() bool
- func (e UpstreamEndpointStatsValidationError) Reason() string
- type UpstreamLocalityStats
- func (*UpstreamLocalityStats) Descriptor() ([]byte, []int)
- func (m *UpstreamLocalityStats) GetLoadMetricStats() []*EndpointLoadMetricStats
- func (m *UpstreamLocalityStats) GetLocality() *core.Locality
- func (m *UpstreamLocalityStats) GetPriority() uint32
- func (m *UpstreamLocalityStats) GetTotalErrorRequests() uint64
- func (m *UpstreamLocalityStats) GetTotalRequestsInProgress() uint64
- func (m *UpstreamLocalityStats) GetTotalSuccessfulRequests() uint64
- func (m *UpstreamLocalityStats) GetUpstreamEndpointStats() []*UpstreamEndpointStats
- func (m *UpstreamLocalityStats) Marshal() (dAtA []byte, err error)
- func (m *UpstreamLocalityStats) MarshalTo(dAtA []byte) (int, error)
- func (*UpstreamLocalityStats) ProtoMessage()
- func (m *UpstreamLocalityStats) Reset()
- func (m *UpstreamLocalityStats) Size() (n int)
- func (m *UpstreamLocalityStats) String() string
- func (m *UpstreamLocalityStats) Unmarshal(dAtA []byte) error
- func (m *UpstreamLocalityStats) Validate() error
- func (m *UpstreamLocalityStats) XXX_DiscardUnknown()
- func (m *UpstreamLocalityStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpstreamLocalityStats) XXX_Merge(src proto.Message)
- func (m *UpstreamLocalityStats) XXX_Size() int
- func (m *UpstreamLocalityStats) XXX_Unmarshal(b []byte) error
- type UpstreamLocalityStatsValidationError
- func (e UpstreamLocalityStatsValidationError) Cause() error
- func (e UpstreamLocalityStatsValidationError) Error() string
- func (e UpstreamLocalityStatsValidationError) ErrorName() string
- func (e UpstreamLocalityStatsValidationError) Field() string
- func (e UpstreamLocalityStatsValidationError) Key() bool
- func (e UpstreamLocalityStatsValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthEndpoint = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEndpoint = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthLoadReport = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowLoadReport = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type ClusterStats ¶
type ClusterStats struct { // The name of the cluster. ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` // The eds_cluster_config service_name of the cluster. // It's possible that two clusters send the same service_name to EDS, // in that case, the management server is supposed to do aggregation on the load reports. ClusterServiceName string `protobuf:"bytes,6,opt,name=cluster_service_name,json=clusterServiceName,proto3" json:"cluster_service_name,omitempty"` // Need at least one. UpstreamLocalityStats []*UpstreamLocalityStats `` /* 126-byte string literal not displayed */ // Cluster-level stats such as total_successful_requests may be computed by // summing upstream_locality_stats. In addition, below there are additional // cluster-wide stats. The following total_requests equality holds at the // cluster-level: // // .. code-block:: none // // sum_locality(total_successful_requests) + sum_locality(total_requests_in_progress) + // sum_locality(total_error_requests) + total_dropped_requests` // // The total number of dropped requests. This covers requests // deliberately dropped by the drop_overload policy and circuit breaking. TotalDroppedRequests uint64 `protobuf:"varint,3,opt,name=total_dropped_requests,json=totalDroppedRequests,proto3" json:"total_dropped_requests,omitempty"` // Information about deliberately dropped requests for each category specified // in the DropOverload policy. DroppedRequests []*ClusterStats_DroppedRequests `protobuf:"bytes,5,rep,name=dropped_requests,json=droppedRequests,proto3" json:"dropped_requests,omitempty"` // Period over which the actual load report occurred. This will be guaranteed to include every // request reported. Due to system load and delays between the *LoadStatsRequest* sent from Envoy // and the *LoadStatsResponse* message sent from the management server, this may be longer than // the requested load reporting interval in the *LoadStatsResponse*. LoadReportInterval *types.Duration `protobuf:"bytes,4,opt,name=load_report_interval,json=loadReportInterval,proto3" json:"load_report_interval,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Per cluster load stats. Envoy reports these stats a management server in a :ref:`LoadStatsRequest<envoy_api_msg_load_stats.LoadStatsRequest>` [#not-implemented-hide:] Not configuration. TBD how to doc proto APIs. Next ID: 7
func (*ClusterStats) Descriptor ¶
func (*ClusterStats) Descriptor() ([]byte, []int)
func (*ClusterStats) GetClusterName ¶
func (m *ClusterStats) GetClusterName() string
func (*ClusterStats) GetClusterServiceName ¶ added in v0.6.10
func (m *ClusterStats) GetClusterServiceName() string
func (*ClusterStats) GetDroppedRequests ¶
func (m *ClusterStats) GetDroppedRequests() []*ClusterStats_DroppedRequests
func (*ClusterStats) GetLoadReportInterval ¶
func (m *ClusterStats) GetLoadReportInterval() *types.Duration
func (*ClusterStats) GetTotalDroppedRequests ¶
func (m *ClusterStats) GetTotalDroppedRequests() uint64
func (*ClusterStats) GetUpstreamLocalityStats ¶
func (m *ClusterStats) GetUpstreamLocalityStats() []*UpstreamLocalityStats
func (*ClusterStats) Marshal ¶
func (m *ClusterStats) Marshal() (dAtA []byte, err error)
func (*ClusterStats) ProtoMessage ¶
func (*ClusterStats) ProtoMessage()
func (*ClusterStats) Reset ¶
func (m *ClusterStats) Reset()
func (*ClusterStats) Size ¶
func (m *ClusterStats) Size() (n int)
func (*ClusterStats) String ¶
func (m *ClusterStats) String() string
func (*ClusterStats) Unmarshal ¶
func (m *ClusterStats) Unmarshal(dAtA []byte) error
func (*ClusterStats) Validate ¶
func (m *ClusterStats) Validate() error
Validate checks the field values on ClusterStats with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*ClusterStats) XXX_DiscardUnknown ¶
func (m *ClusterStats) XXX_DiscardUnknown()
func (*ClusterStats) XXX_Marshal ¶
func (m *ClusterStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterStats) XXX_Merge ¶
func (m *ClusterStats) XXX_Merge(src proto.Message)
func (*ClusterStats) XXX_Size ¶
func (m *ClusterStats) XXX_Size() int
func (*ClusterStats) XXX_Unmarshal ¶
func (m *ClusterStats) XXX_Unmarshal(b []byte) error
type ClusterStatsValidationError ¶
type ClusterStatsValidationError struct {
// contains filtered or unexported fields
}
ClusterStatsValidationError is the validation error returned by ClusterStats.Validate if the designated constraints aren't met.
func (ClusterStatsValidationError) Cause ¶
func (e ClusterStatsValidationError) Cause() error
Cause function returns cause value.
func (ClusterStatsValidationError) Error ¶
func (e ClusterStatsValidationError) Error() string
Error satisfies the builtin error interface
func (ClusterStatsValidationError) ErrorName ¶ added in v0.6.100
func (e ClusterStatsValidationError) ErrorName() string
ErrorName returns error name.
func (ClusterStatsValidationError) Field ¶
func (e ClusterStatsValidationError) Field() string
Field function returns field value.
func (ClusterStatsValidationError) Key ¶
func (e ClusterStatsValidationError) Key() bool
Key function returns key value.
func (ClusterStatsValidationError) Reason ¶
func (e ClusterStatsValidationError) Reason() string
Reason function returns reason value.
type ClusterStats_DroppedRequests ¶
type ClusterStats_DroppedRequests struct { // Identifier for the policy specifying the drop. Category string `protobuf:"bytes,1,opt,name=category,proto3" json:"category,omitempty"` // Total number of deliberately dropped requests for the category. DroppedCount uint64 `protobuf:"varint,2,opt,name=dropped_count,json=droppedCount,proto3" json:"dropped_count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterStats_DroppedRequests) Descriptor ¶
func (*ClusterStats_DroppedRequests) Descriptor() ([]byte, []int)
func (*ClusterStats_DroppedRequests) GetCategory ¶
func (m *ClusterStats_DroppedRequests) GetCategory() string
func (*ClusterStats_DroppedRequests) GetDroppedCount ¶
func (m *ClusterStats_DroppedRequests) GetDroppedCount() uint64
func (*ClusterStats_DroppedRequests) Marshal ¶
func (m *ClusterStats_DroppedRequests) Marshal() (dAtA []byte, err error)
func (*ClusterStats_DroppedRequests) MarshalTo ¶
func (m *ClusterStats_DroppedRequests) MarshalTo(dAtA []byte) (int, error)
func (*ClusterStats_DroppedRequests) ProtoMessage ¶
func (*ClusterStats_DroppedRequests) ProtoMessage()
func (*ClusterStats_DroppedRequests) Reset ¶
func (m *ClusterStats_DroppedRequests) Reset()
func (*ClusterStats_DroppedRequests) Size ¶
func (m *ClusterStats_DroppedRequests) Size() (n int)
func (*ClusterStats_DroppedRequests) String ¶
func (m *ClusterStats_DroppedRequests) String() string
func (*ClusterStats_DroppedRequests) Unmarshal ¶
func (m *ClusterStats_DroppedRequests) Unmarshal(dAtA []byte) error
func (*ClusterStats_DroppedRequests) Validate ¶
func (m *ClusterStats_DroppedRequests) Validate() error
Validate checks the field values on ClusterStats_DroppedRequests with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*ClusterStats_DroppedRequests) XXX_DiscardUnknown ¶
func (m *ClusterStats_DroppedRequests) XXX_DiscardUnknown()
func (*ClusterStats_DroppedRequests) XXX_Marshal ¶
func (m *ClusterStats_DroppedRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterStats_DroppedRequests) XXX_Merge ¶
func (m *ClusterStats_DroppedRequests) XXX_Merge(src proto.Message)
func (*ClusterStats_DroppedRequests) XXX_Size ¶
func (m *ClusterStats_DroppedRequests) XXX_Size() int
func (*ClusterStats_DroppedRequests) XXX_Unmarshal ¶
func (m *ClusterStats_DroppedRequests) XXX_Unmarshal(b []byte) error
type ClusterStats_DroppedRequestsValidationError ¶
type ClusterStats_DroppedRequestsValidationError struct {
// contains filtered or unexported fields
}
ClusterStats_DroppedRequestsValidationError is the validation error returned by ClusterStats_DroppedRequests.Validate if the designated constraints aren't met.
func (ClusterStats_DroppedRequestsValidationError) Cause ¶
func (e ClusterStats_DroppedRequestsValidationError) Cause() error
Cause function returns cause value.
func (ClusterStats_DroppedRequestsValidationError) Error ¶
func (e ClusterStats_DroppedRequestsValidationError) Error() string
Error satisfies the builtin error interface
func (ClusterStats_DroppedRequestsValidationError) ErrorName ¶ added in v0.6.100
func (e ClusterStats_DroppedRequestsValidationError) ErrorName() string
ErrorName returns error name.
func (ClusterStats_DroppedRequestsValidationError) Field ¶
func (e ClusterStats_DroppedRequestsValidationError) Field() string
Field function returns field value.
func (ClusterStats_DroppedRequestsValidationError) Key ¶
func (e ClusterStats_DroppedRequestsValidationError) Key() bool
Key function returns key value.
func (ClusterStats_DroppedRequestsValidationError) Reason ¶
func (e ClusterStats_DroppedRequestsValidationError) Reason() string
Reason function returns reason value.
type Endpoint ¶
type Endpoint struct { // The upstream host address. // // .. attention:: // // The form of host address depends on the given cluster type. For STATIC or EDS, // it is expected to be a direct IP address (or something resolvable by the // specified :ref:`resolver <envoy_api_field_core.SocketAddress.resolver_name>` // in the Address). For LOGICAL or STRICT DNS, it is expected to be hostname, // and will be resolved via DNS. Address *core.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // The optional health check configuration is used as configuration for the // health checker to contact the health checked host. // // .. attention:: // // This takes into effect only for upstream clusters with // :ref:`active health checking <arch_overview_health_checking>` enabled. HealthCheckConfig *Endpoint_HealthCheckConfig `protobuf:"bytes,2,opt,name=health_check_config,json=healthCheckConfig,proto3" json:"health_check_config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Upstream host identifier.
func (*Endpoint) Descriptor ¶
func (*Endpoint) GetAddress ¶
func (*Endpoint) GetHealthCheckConfig ¶
func (m *Endpoint) GetHealthCheckConfig() *Endpoint_HealthCheckConfig
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) Validate ¶
Validate checks the field values on Endpoint with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Endpoint) XXX_DiscardUnknown ¶
func (m *Endpoint) XXX_DiscardUnknown()
func (*Endpoint) XXX_Marshal ¶
func (*Endpoint) XXX_Unmarshal ¶
type EndpointLoadMetricStats ¶
type EndpointLoadMetricStats struct { // Name of the metric; may be empty. MetricName string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"` // Number of calls that finished and included this metric. NumRequestsFinishedWithMetric uint64 `` /* 155-byte string literal not displayed */ // Sum of metric values across all calls that finished with this metric for // load_reporting_interval. TotalMetricValue float64 `protobuf:"fixed64,3,opt,name=total_metric_value,json=totalMetricValue,proto3" json:"total_metric_value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:] Not configuration. TBD how to doc proto APIs.
func (*EndpointLoadMetricStats) Descriptor ¶
func (*EndpointLoadMetricStats) Descriptor() ([]byte, []int)
func (*EndpointLoadMetricStats) GetMetricName ¶
func (m *EndpointLoadMetricStats) GetMetricName() string
func (*EndpointLoadMetricStats) GetNumRequestsFinishedWithMetric ¶
func (m *EndpointLoadMetricStats) GetNumRequestsFinishedWithMetric() uint64
func (*EndpointLoadMetricStats) GetTotalMetricValue ¶
func (m *EndpointLoadMetricStats) GetTotalMetricValue() float64
func (*EndpointLoadMetricStats) Marshal ¶
func (m *EndpointLoadMetricStats) Marshal() (dAtA []byte, err error)
func (*EndpointLoadMetricStats) MarshalTo ¶
func (m *EndpointLoadMetricStats) MarshalTo(dAtA []byte) (int, error)
func (*EndpointLoadMetricStats) ProtoMessage ¶
func (*EndpointLoadMetricStats) ProtoMessage()
func (*EndpointLoadMetricStats) Reset ¶
func (m *EndpointLoadMetricStats) Reset()
func (*EndpointLoadMetricStats) Size ¶
func (m *EndpointLoadMetricStats) Size() (n int)
func (*EndpointLoadMetricStats) String ¶
func (m *EndpointLoadMetricStats) String() string
func (*EndpointLoadMetricStats) Unmarshal ¶
func (m *EndpointLoadMetricStats) Unmarshal(dAtA []byte) error
func (*EndpointLoadMetricStats) Validate ¶
func (m *EndpointLoadMetricStats) Validate() error
Validate checks the field values on EndpointLoadMetricStats with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*EndpointLoadMetricStats) XXX_DiscardUnknown ¶
func (m *EndpointLoadMetricStats) XXX_DiscardUnknown()
func (*EndpointLoadMetricStats) XXX_Marshal ¶
func (m *EndpointLoadMetricStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EndpointLoadMetricStats) XXX_Merge ¶
func (m *EndpointLoadMetricStats) XXX_Merge(src proto.Message)
func (*EndpointLoadMetricStats) XXX_Size ¶
func (m *EndpointLoadMetricStats) XXX_Size() int
func (*EndpointLoadMetricStats) XXX_Unmarshal ¶
func (m *EndpointLoadMetricStats) XXX_Unmarshal(b []byte) error
type EndpointLoadMetricStatsValidationError ¶
type EndpointLoadMetricStatsValidationError struct {
// contains filtered or unexported fields
}
EndpointLoadMetricStatsValidationError is the validation error returned by EndpointLoadMetricStats.Validate if the designated constraints aren't met.
func (EndpointLoadMetricStatsValidationError) Cause ¶
func (e EndpointLoadMetricStatsValidationError) Cause() error
Cause function returns cause value.
func (EndpointLoadMetricStatsValidationError) Error ¶
func (e EndpointLoadMetricStatsValidationError) Error() string
Error satisfies the builtin error interface
func (EndpointLoadMetricStatsValidationError) ErrorName ¶ added in v0.6.100
func (e EndpointLoadMetricStatsValidationError) ErrorName() string
ErrorName returns error name.
func (EndpointLoadMetricStatsValidationError) Field ¶
func (e EndpointLoadMetricStatsValidationError) Field() string
Field function returns field value.
func (EndpointLoadMetricStatsValidationError) Key ¶
func (e EndpointLoadMetricStatsValidationError) Key() bool
Key function returns key value.
func (EndpointLoadMetricStatsValidationError) Reason ¶
func (e EndpointLoadMetricStatsValidationError) Reason() string
Reason function returns reason value.
type EndpointValidationError ¶
type EndpointValidationError struct {
// contains filtered or unexported fields
}
EndpointValidationError is the validation error returned by Endpoint.Validate if the designated constraints aren't met.
func (EndpointValidationError) Cause ¶
func (e EndpointValidationError) Cause() error
Cause function returns cause value.
func (EndpointValidationError) Error ¶
func (e EndpointValidationError) Error() string
Error satisfies the builtin error interface
func (EndpointValidationError) ErrorName ¶ added in v0.6.100
func (e EndpointValidationError) ErrorName() string
ErrorName returns error name.
func (EndpointValidationError) Field ¶
func (e EndpointValidationError) Field() string
Field function returns field value.
func (EndpointValidationError) Key ¶
func (e EndpointValidationError) Key() bool
Key function returns key value.
func (EndpointValidationError) Reason ¶
func (e EndpointValidationError) Reason() string
Reason function returns reason value.
type Endpoint_HealthCheckConfig ¶
type Endpoint_HealthCheckConfig struct { // Optional alternative health check port value. // // By default the health check address port of an upstream host is the same // as the host's serving address port. This provides an alternative health // check port. Setting this with a non-zero value allows an upstream host // to have different health check address port. PortValue uint32 `protobuf:"varint,1,opt,name=port_value,json=portValue,proto3" json:"port_value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The optional health check configuration.
func (*Endpoint_HealthCheckConfig) Descriptor ¶
func (*Endpoint_HealthCheckConfig) Descriptor() ([]byte, []int)
func (*Endpoint_HealthCheckConfig) Equal ¶
func (this *Endpoint_HealthCheckConfig) Equal(that interface{}) bool
func (*Endpoint_HealthCheckConfig) GetPortValue ¶
func (m *Endpoint_HealthCheckConfig) GetPortValue() uint32
func (*Endpoint_HealthCheckConfig) Marshal ¶
func (m *Endpoint_HealthCheckConfig) Marshal() (dAtA []byte, err error)
func (*Endpoint_HealthCheckConfig) MarshalTo ¶
func (m *Endpoint_HealthCheckConfig) MarshalTo(dAtA []byte) (int, error)
func (*Endpoint_HealthCheckConfig) ProtoMessage ¶
func (*Endpoint_HealthCheckConfig) ProtoMessage()
func (*Endpoint_HealthCheckConfig) Reset ¶
func (m *Endpoint_HealthCheckConfig) Reset()
func (*Endpoint_HealthCheckConfig) Size ¶
func (m *Endpoint_HealthCheckConfig) Size() (n int)
func (*Endpoint_HealthCheckConfig) String ¶
func (m *Endpoint_HealthCheckConfig) String() string
func (*Endpoint_HealthCheckConfig) Unmarshal ¶
func (m *Endpoint_HealthCheckConfig) Unmarshal(dAtA []byte) error
func (*Endpoint_HealthCheckConfig) Validate ¶
func (m *Endpoint_HealthCheckConfig) Validate() error
Validate checks the field values on Endpoint_HealthCheckConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Endpoint_HealthCheckConfig) XXX_DiscardUnknown ¶
func (m *Endpoint_HealthCheckConfig) XXX_DiscardUnknown()
func (*Endpoint_HealthCheckConfig) XXX_Marshal ¶
func (m *Endpoint_HealthCheckConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Endpoint_HealthCheckConfig) XXX_Merge ¶
func (m *Endpoint_HealthCheckConfig) XXX_Merge(src proto.Message)
func (*Endpoint_HealthCheckConfig) XXX_Size ¶
func (m *Endpoint_HealthCheckConfig) XXX_Size() int
func (*Endpoint_HealthCheckConfig) XXX_Unmarshal ¶
func (m *Endpoint_HealthCheckConfig) XXX_Unmarshal(b []byte) error
type Endpoint_HealthCheckConfigValidationError ¶
type Endpoint_HealthCheckConfigValidationError struct {
// contains filtered or unexported fields
}
Endpoint_HealthCheckConfigValidationError is the validation error returned by Endpoint_HealthCheckConfig.Validate if the designated constraints aren't met.
func (Endpoint_HealthCheckConfigValidationError) Cause ¶
func (e Endpoint_HealthCheckConfigValidationError) Cause() error
Cause function returns cause value.
func (Endpoint_HealthCheckConfigValidationError) Error ¶
func (e Endpoint_HealthCheckConfigValidationError) Error() string
Error satisfies the builtin error interface
func (Endpoint_HealthCheckConfigValidationError) ErrorName ¶ added in v0.6.100
func (e Endpoint_HealthCheckConfigValidationError) ErrorName() string
ErrorName returns error name.
func (Endpoint_HealthCheckConfigValidationError) Field ¶
func (e Endpoint_HealthCheckConfigValidationError) Field() string
Field function returns field value.
func (Endpoint_HealthCheckConfigValidationError) Key ¶
func (e Endpoint_HealthCheckConfigValidationError) Key() bool
Key function returns key value.
func (Endpoint_HealthCheckConfigValidationError) Reason ¶
func (e Endpoint_HealthCheckConfigValidationError) Reason() string
Reason function returns reason value.
type LbEndpoint ¶
type LbEndpoint struct { // Upstream host identifier or a named reference. // // Types that are valid to be assigned to HostIdentifier: // *LbEndpoint_Endpoint // *LbEndpoint_EndpointName HostIdentifier isLbEndpoint_HostIdentifier `protobuf_oneof:"host_identifier"` // Optional health status when known and supplied by EDS server. HealthStatus core.HealthStatus `` /* 134-byte string literal not displayed */ // The endpoint metadata specifies values that may be used by the load // balancer to select endpoints in a cluster for a given request. The filter // name should be specified as *envoy.lb*. An example boolean key-value pair // is *canary*, providing the optional canary status of the upstream host. // This may be matched against in a route's // :ref:`RouteAction <envoy_api_msg_route.RouteAction>` metadata_match field // to subset the endpoints considered in cluster load balancing. Metadata *core.Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // The optional load balancing weight of the upstream host, in the range 1 - // 128. Envoy uses the load balancing weight in some of the built in load // balancers. The load balancing weight for an endpoint is divided by the sum // of the weights of all endpoints in the endpoint's locality to produce a // percentage of traffic for the endpoint. This percentage is then further // weighted by the endpoint's locality's load balancing weight from // LocalityLbEndpoints. If unspecified, each host is presumed to have equal // weight in a locality. // // .. attention:: // // The limit of 128 is somewhat arbitrary, but is applied due to performance // concerns with the current implementation and can be removed when // `this issue <https://github.com/envoyproxy/envoy/issues/1285>`_ is fixed. LoadBalancingWeight *types.UInt32Value `protobuf:"bytes,4,opt,name=load_balancing_weight,json=loadBalancingWeight,proto3" json:"load_balancing_weight,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
An Endpoint that Envoy can route traffic to.
func (*LbEndpoint) Descriptor ¶
func (*LbEndpoint) Descriptor() ([]byte, []int)
func (*LbEndpoint) Equal ¶
func (this *LbEndpoint) Equal(that interface{}) bool
func (*LbEndpoint) GetEndpoint ¶
func (m *LbEndpoint) GetEndpoint() *Endpoint
func (*LbEndpoint) GetEndpointName ¶ added in v0.6.10
func (m *LbEndpoint) GetEndpointName() string
func (*LbEndpoint) GetHealthStatus ¶
func (m *LbEndpoint) GetHealthStatus() core.HealthStatus
func (*LbEndpoint) GetHostIdentifier ¶ added in v0.6.10
func (m *LbEndpoint) GetHostIdentifier() isLbEndpoint_HostIdentifier
func (*LbEndpoint) GetLoadBalancingWeight ¶
func (m *LbEndpoint) GetLoadBalancingWeight() *types.UInt32Value
func (*LbEndpoint) GetMetadata ¶
func (m *LbEndpoint) GetMetadata() *core.Metadata
func (*LbEndpoint) Marshal ¶
func (m *LbEndpoint) Marshal() (dAtA []byte, err error)
func (*LbEndpoint) ProtoMessage ¶
func (*LbEndpoint) ProtoMessage()
func (*LbEndpoint) Reset ¶
func (m *LbEndpoint) Reset()
func (*LbEndpoint) Size ¶
func (m *LbEndpoint) Size() (n int)
func (*LbEndpoint) String ¶
func (m *LbEndpoint) String() string
func (*LbEndpoint) Unmarshal ¶
func (m *LbEndpoint) Unmarshal(dAtA []byte) error
func (*LbEndpoint) Validate ¶
func (m *LbEndpoint) Validate() error
Validate checks the field values on LbEndpoint with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*LbEndpoint) XXX_DiscardUnknown ¶
func (m *LbEndpoint) XXX_DiscardUnknown()
func (*LbEndpoint) XXX_Marshal ¶
func (m *LbEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LbEndpoint) XXX_Merge ¶
func (m *LbEndpoint) XXX_Merge(src proto.Message)
func (*LbEndpoint) XXX_OneofFuncs ¶ added in v0.6.10
func (*LbEndpoint) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*LbEndpoint) XXX_Size ¶
func (m *LbEndpoint) XXX_Size() int
func (*LbEndpoint) XXX_Unmarshal ¶
func (m *LbEndpoint) XXX_Unmarshal(b []byte) error
type LbEndpointValidationError ¶
type LbEndpointValidationError struct {
// contains filtered or unexported fields
}
LbEndpointValidationError is the validation error returned by LbEndpoint.Validate if the designated constraints aren't met.
func (LbEndpointValidationError) Cause ¶
func (e LbEndpointValidationError) Cause() error
Cause function returns cause value.
func (LbEndpointValidationError) Error ¶
func (e LbEndpointValidationError) Error() string
Error satisfies the builtin error interface
func (LbEndpointValidationError) ErrorName ¶ added in v0.6.100
func (e LbEndpointValidationError) ErrorName() string
ErrorName returns error name.
func (LbEndpointValidationError) Field ¶
func (e LbEndpointValidationError) Field() string
Field function returns field value.
func (LbEndpointValidationError) Key ¶
func (e LbEndpointValidationError) Key() bool
Key function returns key value.
func (LbEndpointValidationError) Reason ¶
func (e LbEndpointValidationError) Reason() string
Reason function returns reason value.
type LbEndpoint_Endpoint ¶ added in v0.6.10
type LbEndpoint_Endpoint struct {
Endpoint *Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3,oneof"`
}
func (*LbEndpoint_Endpoint) Equal ¶ added in v0.6.10
func (this *LbEndpoint_Endpoint) Equal(that interface{}) bool
func (*LbEndpoint_Endpoint) MarshalTo ¶ added in v0.6.10
func (m *LbEndpoint_Endpoint) MarshalTo(dAtA []byte) (int, error)
func (*LbEndpoint_Endpoint) Size ¶ added in v0.6.10
func (m *LbEndpoint_Endpoint) Size() (n int)
type LbEndpoint_EndpointName ¶ added in v0.6.10
type LbEndpoint_EndpointName struct {
EndpointName string `protobuf:"bytes,5,opt,name=endpoint_name,json=endpointName,proto3,oneof"`
}
func (*LbEndpoint_EndpointName) Equal ¶ added in v0.6.10
func (this *LbEndpoint_EndpointName) Equal(that interface{}) bool
func (*LbEndpoint_EndpointName) MarshalTo ¶ added in v0.6.10
func (m *LbEndpoint_EndpointName) MarshalTo(dAtA []byte) (int, error)
func (*LbEndpoint_EndpointName) Size ¶ added in v0.6.10
func (m *LbEndpoint_EndpointName) Size() (n int)
type LocalityLbEndpoints ¶
type LocalityLbEndpoints struct { // Identifies location of where the upstream hosts run. Locality *core.Locality `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"` // The group of endpoints belonging to the locality specified. LbEndpoints []LbEndpoint `protobuf:"bytes,2,rep,name=lb_endpoints,json=lbEndpoints,proto3" json:"lb_endpoints"` // Optional: Per priority/region/zone/sub_zone weight - range 1-128. The load // balancing weight for a locality is divided by the sum of the weights of all // localities at the same priority level to produce the effective percentage // of traffic for the locality. // // Locality weights are only considered when :ref:`locality weighted load // balancing <arch_overview_load_balancing_locality_weighted_lb>` is // configured. These weights are ignored otherwise. If no weights are // specified when locality weighted load balancing is enabled, the locality is // assigned no load. // // .. attention:: // // The limit of 128 is somewhat arbitrary, but is applied due to performance // concerns with the current implementation and can be removed when // `this issue <https://github.com/envoyproxy/envoy/issues/1285>`_ is fixed. LoadBalancingWeight *types.UInt32Value `protobuf:"bytes,3,opt,name=load_balancing_weight,json=loadBalancingWeight,proto3" json:"load_balancing_weight,omitempty"` // Optional: the priority for this LocalityLbEndpoints. If unspecified this will // default to the highest priority (0). // // Under usual circumstances, Envoy will only select endpoints for the highest // priority (0). In the event all endpoints for a particular priority are // unavailable/unhealthy, Envoy will fail over to selecting endpoints for the // next highest priority group. // // Priorities should range from 0 (highest) to N (lowest) without skipping. Priority uint32 `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"` // Optional: Per locality proximity value which indicates how close this // locality is from the source locality. This value only provides ordering // information (lower the value, closer it is to the source locality). // This will be consumed by load balancing schemes that need proximity order // to determine where to route the requests. // [#not-implemented-hide:] Proximity *types.UInt32Value `protobuf:"bytes,6,opt,name=proximity,proto3" json:"proximity,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A group of endpoints belonging to a Locality. One can have multiple LocalityLbEndpoints for a locality, but this is generally only done if the different groups need to have different load balancing weights or different priorities.
func (*LocalityLbEndpoints) Descriptor ¶
func (*LocalityLbEndpoints) Descriptor() ([]byte, []int)
func (*LocalityLbEndpoints) Equal ¶
func (this *LocalityLbEndpoints) Equal(that interface{}) bool
func (*LocalityLbEndpoints) GetLbEndpoints ¶
func (m *LocalityLbEndpoints) GetLbEndpoints() []LbEndpoint
func (*LocalityLbEndpoints) GetLoadBalancingWeight ¶
func (m *LocalityLbEndpoints) GetLoadBalancingWeight() *types.UInt32Value
func (*LocalityLbEndpoints) GetLocality ¶
func (m *LocalityLbEndpoints) GetLocality() *core.Locality
func (*LocalityLbEndpoints) GetPriority ¶
func (m *LocalityLbEndpoints) GetPriority() uint32
func (*LocalityLbEndpoints) GetProximity ¶ added in v0.6.100
func (m *LocalityLbEndpoints) GetProximity() *types.UInt32Value
func (*LocalityLbEndpoints) Marshal ¶
func (m *LocalityLbEndpoints) Marshal() (dAtA []byte, err error)
func (*LocalityLbEndpoints) MarshalTo ¶
func (m *LocalityLbEndpoints) MarshalTo(dAtA []byte) (int, error)
func (*LocalityLbEndpoints) ProtoMessage ¶
func (*LocalityLbEndpoints) ProtoMessage()
func (*LocalityLbEndpoints) Reset ¶
func (m *LocalityLbEndpoints) Reset()
func (*LocalityLbEndpoints) Size ¶
func (m *LocalityLbEndpoints) Size() (n int)
func (*LocalityLbEndpoints) String ¶
func (m *LocalityLbEndpoints) String() string
func (*LocalityLbEndpoints) Unmarshal ¶
func (m *LocalityLbEndpoints) Unmarshal(dAtA []byte) error
func (*LocalityLbEndpoints) Validate ¶
func (m *LocalityLbEndpoints) Validate() error
Validate checks the field values on LocalityLbEndpoints with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*LocalityLbEndpoints) XXX_DiscardUnknown ¶
func (m *LocalityLbEndpoints) XXX_DiscardUnknown()
func (*LocalityLbEndpoints) XXX_Marshal ¶
func (m *LocalityLbEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LocalityLbEndpoints) XXX_Merge ¶
func (m *LocalityLbEndpoints) XXX_Merge(src proto.Message)
func (*LocalityLbEndpoints) XXX_Size ¶
func (m *LocalityLbEndpoints) XXX_Size() int
func (*LocalityLbEndpoints) XXX_Unmarshal ¶
func (m *LocalityLbEndpoints) XXX_Unmarshal(b []byte) error
type LocalityLbEndpointsValidationError ¶
type LocalityLbEndpointsValidationError struct {
// contains filtered or unexported fields
}
LocalityLbEndpointsValidationError is the validation error returned by LocalityLbEndpoints.Validate if the designated constraints aren't met.
func (LocalityLbEndpointsValidationError) Cause ¶
func (e LocalityLbEndpointsValidationError) Cause() error
Cause function returns cause value.
func (LocalityLbEndpointsValidationError) Error ¶
func (e LocalityLbEndpointsValidationError) Error() string
Error satisfies the builtin error interface
func (LocalityLbEndpointsValidationError) ErrorName ¶ added in v0.6.100
func (e LocalityLbEndpointsValidationError) ErrorName() string
ErrorName returns error name.
func (LocalityLbEndpointsValidationError) Field ¶
func (e LocalityLbEndpointsValidationError) Field() string
Field function returns field value.
func (LocalityLbEndpointsValidationError) Key ¶
func (e LocalityLbEndpointsValidationError) Key() bool
Key function returns key value.
func (LocalityLbEndpointsValidationError) Reason ¶
func (e LocalityLbEndpointsValidationError) Reason() string
Reason function returns reason value.
type UpstreamEndpointStats ¶
type UpstreamEndpointStats struct { // Upstream host address. Address *core.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // Opaque and implementation dependent metadata of the // endpoint. Envoy will pass this directly to the management server. Metadata *types.Struct `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"` // The total number of requests successfully completed by the endpoint. A // single HTTP or gRPC request or stream is counted as one request. A TCP // connection is also treated as one request. There is no explicit // total_requests field below for an endpoint, but it may be inferred from: // // .. code-block:: none // // total_requests = total_successful_requests + total_requests_in_progress + // total_error_requests // // The total number of requests successfully completed by the endpoints in the // locality. These include non-5xx responses for HTTP, where errors // originate at the client and the endpoint responded successfully. For gRPC, // the grpc-status values are those not covered by total_error_requests below. TotalSuccessfulRequests uint64 `` /* 133-byte string literal not displayed */ // The total number of unfinished requests for this endpoint. TotalRequestsInProgress uint64 `` /* 135-byte string literal not displayed */ // The total number of requests that failed due to errors at the endpoint. // For HTTP these are responses with 5xx status codes and for gRPC the // grpc-status values: // // - DeadlineExceeded // - Unimplemented // - Internal // - Unavailable // - Unknown // - DataLoss TotalErrorRequests uint64 `protobuf:"varint,4,opt,name=total_error_requests,json=totalErrorRequests,proto3" json:"total_error_requests,omitempty"` // Stats for multi-dimensional load balancing. LoadMetricStats []*EndpointLoadMetricStats `protobuf:"bytes,5,rep,name=load_metric_stats,json=loadMetricStats,proto3" json:"load_metric_stats,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpstreamEndpointStats) Descriptor ¶
func (*UpstreamEndpointStats) Descriptor() ([]byte, []int)
func (*UpstreamEndpointStats) GetAddress ¶
func (m *UpstreamEndpointStats) GetAddress() *core.Address
func (*UpstreamEndpointStats) GetLoadMetricStats ¶
func (m *UpstreamEndpointStats) GetLoadMetricStats() []*EndpointLoadMetricStats
func (*UpstreamEndpointStats) GetMetadata ¶ added in v0.6.4
func (m *UpstreamEndpointStats) GetMetadata() *types.Struct
func (*UpstreamEndpointStats) GetTotalErrorRequests ¶
func (m *UpstreamEndpointStats) GetTotalErrorRequests() uint64
func (*UpstreamEndpointStats) GetTotalRequestsInProgress ¶
func (m *UpstreamEndpointStats) GetTotalRequestsInProgress() uint64
func (*UpstreamEndpointStats) GetTotalSuccessfulRequests ¶
func (m *UpstreamEndpointStats) GetTotalSuccessfulRequests() uint64
func (*UpstreamEndpointStats) Marshal ¶
func (m *UpstreamEndpointStats) Marshal() (dAtA []byte, err error)
func (*UpstreamEndpointStats) MarshalTo ¶
func (m *UpstreamEndpointStats) MarshalTo(dAtA []byte) (int, error)
func (*UpstreamEndpointStats) ProtoMessage ¶
func (*UpstreamEndpointStats) ProtoMessage()
func (*UpstreamEndpointStats) Reset ¶
func (m *UpstreamEndpointStats) Reset()
func (*UpstreamEndpointStats) Size ¶
func (m *UpstreamEndpointStats) Size() (n int)
func (*UpstreamEndpointStats) String ¶
func (m *UpstreamEndpointStats) String() string
func (*UpstreamEndpointStats) Unmarshal ¶
func (m *UpstreamEndpointStats) Unmarshal(dAtA []byte) error
func (*UpstreamEndpointStats) Validate ¶
func (m *UpstreamEndpointStats) Validate() error
Validate checks the field values on UpstreamEndpointStats with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*UpstreamEndpointStats) XXX_DiscardUnknown ¶
func (m *UpstreamEndpointStats) XXX_DiscardUnknown()
func (*UpstreamEndpointStats) XXX_Marshal ¶
func (m *UpstreamEndpointStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpstreamEndpointStats) XXX_Merge ¶
func (m *UpstreamEndpointStats) XXX_Merge(src proto.Message)
func (*UpstreamEndpointStats) XXX_Size ¶
func (m *UpstreamEndpointStats) XXX_Size() int
func (*UpstreamEndpointStats) XXX_Unmarshal ¶
func (m *UpstreamEndpointStats) XXX_Unmarshal(b []byte) error
type UpstreamEndpointStatsValidationError ¶
type UpstreamEndpointStatsValidationError struct {
// contains filtered or unexported fields
}
UpstreamEndpointStatsValidationError is the validation error returned by UpstreamEndpointStats.Validate if the designated constraints aren't met.
func (UpstreamEndpointStatsValidationError) Cause ¶
func (e UpstreamEndpointStatsValidationError) Cause() error
Cause function returns cause value.
func (UpstreamEndpointStatsValidationError) Error ¶
func (e UpstreamEndpointStatsValidationError) Error() string
Error satisfies the builtin error interface
func (UpstreamEndpointStatsValidationError) ErrorName ¶ added in v0.6.100
func (e UpstreamEndpointStatsValidationError) ErrorName() string
ErrorName returns error name.
func (UpstreamEndpointStatsValidationError) Field ¶
func (e UpstreamEndpointStatsValidationError) Field() string
Field function returns field value.
func (UpstreamEndpointStatsValidationError) Key ¶
func (e UpstreamEndpointStatsValidationError) Key() bool
Key function returns key value.
func (UpstreamEndpointStatsValidationError) Reason ¶
func (e UpstreamEndpointStatsValidationError) Reason() string
Reason function returns reason value.
type UpstreamLocalityStats ¶
type UpstreamLocalityStats struct { // Name of zone, region and optionally endpoint group these metrics were // collected from. Zone and region names could be empty if unknown. Locality *core.Locality `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"` // The total number of requests sent by this Envoy since the last report. This // information is aggregated over all the upstream Endpoints. total_requests // can be inferred from: // // .. code-block:: none // // total_requests = total_successful_requests + total_requests_in_progress + // total_error_requests // // The total number of requests successfully completed by the endpoints in the // locality. TotalSuccessfulRequests uint64 `` /* 133-byte string literal not displayed */ // The total number of unfinished requests TotalRequestsInProgress uint64 `` /* 135-byte string literal not displayed */ // The total number of requests that failed due to errors at the endpoint, // aggregated over all endpoints in the locality. TotalErrorRequests uint64 `protobuf:"varint,4,opt,name=total_error_requests,json=totalErrorRequests,proto3" json:"total_error_requests,omitempty"` // Stats for multi-dimensional load balancing. LoadMetricStats []*EndpointLoadMetricStats `protobuf:"bytes,5,rep,name=load_metric_stats,json=loadMetricStats,proto3" json:"load_metric_stats,omitempty"` // Endpoint granularity stats information for this locality. This information // is populated if the Server requests it by setting // :ref:`LoadStatsResponse.report_endpoint_granularity<envoy_api_field_load_stats.LoadStatsResponse.report_endpoint_granularity>`. UpstreamEndpointStats []*UpstreamEndpointStats `` /* 126-byte string literal not displayed */ // [#not-implemented-hide:] The priority of the endpoint group these metrics // were collected from. Priority uint32 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
These are stats Envoy reports to GLB every so often. Report frequency is defined by :ref:`LoadStatsResponse.load_reporting_interval<envoy_api_field_load_stats.LoadStatsResponse.load_reporting_interval>`. Stats per upstream region/zone and optionally per subzone. [#not-implemented-hide:] Not configuration. TBD how to doc proto APIs.
func (*UpstreamLocalityStats) Descriptor ¶
func (*UpstreamLocalityStats) Descriptor() ([]byte, []int)
func (*UpstreamLocalityStats) GetLoadMetricStats ¶
func (m *UpstreamLocalityStats) GetLoadMetricStats() []*EndpointLoadMetricStats
func (*UpstreamLocalityStats) GetLocality ¶
func (m *UpstreamLocalityStats) GetLocality() *core.Locality
func (*UpstreamLocalityStats) GetPriority ¶
func (m *UpstreamLocalityStats) GetPriority() uint32
func (*UpstreamLocalityStats) GetTotalErrorRequests ¶
func (m *UpstreamLocalityStats) GetTotalErrorRequests() uint64
func (*UpstreamLocalityStats) GetTotalRequestsInProgress ¶
func (m *UpstreamLocalityStats) GetTotalRequestsInProgress() uint64
func (*UpstreamLocalityStats) GetTotalSuccessfulRequests ¶
func (m *UpstreamLocalityStats) GetTotalSuccessfulRequests() uint64
func (*UpstreamLocalityStats) GetUpstreamEndpointStats ¶
func (m *UpstreamLocalityStats) GetUpstreamEndpointStats() []*UpstreamEndpointStats
func (*UpstreamLocalityStats) Marshal ¶
func (m *UpstreamLocalityStats) Marshal() (dAtA []byte, err error)
func (*UpstreamLocalityStats) MarshalTo ¶
func (m *UpstreamLocalityStats) MarshalTo(dAtA []byte) (int, error)
func (*UpstreamLocalityStats) ProtoMessage ¶
func (*UpstreamLocalityStats) ProtoMessage()
func (*UpstreamLocalityStats) Reset ¶
func (m *UpstreamLocalityStats) Reset()
func (*UpstreamLocalityStats) Size ¶
func (m *UpstreamLocalityStats) Size() (n int)
func (*UpstreamLocalityStats) String ¶
func (m *UpstreamLocalityStats) String() string
func (*UpstreamLocalityStats) Unmarshal ¶
func (m *UpstreamLocalityStats) Unmarshal(dAtA []byte) error
func (*UpstreamLocalityStats) Validate ¶
func (m *UpstreamLocalityStats) Validate() error
Validate checks the field values on UpstreamLocalityStats with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*UpstreamLocalityStats) XXX_DiscardUnknown ¶
func (m *UpstreamLocalityStats) XXX_DiscardUnknown()
func (*UpstreamLocalityStats) XXX_Marshal ¶
func (m *UpstreamLocalityStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpstreamLocalityStats) XXX_Merge ¶
func (m *UpstreamLocalityStats) XXX_Merge(src proto.Message)
func (*UpstreamLocalityStats) XXX_Size ¶
func (m *UpstreamLocalityStats) XXX_Size() int
func (*UpstreamLocalityStats) XXX_Unmarshal ¶
func (m *UpstreamLocalityStats) XXX_Unmarshal(b []byte) error
type UpstreamLocalityStatsValidationError ¶
type UpstreamLocalityStatsValidationError struct {
// contains filtered or unexported fields
}
UpstreamLocalityStatsValidationError is the validation error returned by UpstreamLocalityStats.Validate if the designated constraints aren't met.
func (UpstreamLocalityStatsValidationError) Cause ¶
func (e UpstreamLocalityStatsValidationError) Cause() error
Cause function returns cause value.
func (UpstreamLocalityStatsValidationError) Error ¶
func (e UpstreamLocalityStatsValidationError) Error() string
Error satisfies the builtin error interface
func (UpstreamLocalityStatsValidationError) ErrorName ¶ added in v0.6.100
func (e UpstreamLocalityStatsValidationError) ErrorName() string
ErrorName returns error name.
func (UpstreamLocalityStatsValidationError) Field ¶
func (e UpstreamLocalityStatsValidationError) Field() string
Field function returns field value.
func (UpstreamLocalityStatsValidationError) Key ¶
func (e UpstreamLocalityStatsValidationError) Key() bool
Key function returns key value.
func (UpstreamLocalityStatsValidationError) Reason ¶
func (e UpstreamLocalityStatsValidationError) Reason() string
Reason function returns reason value.