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) 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.8
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.7.0
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.7.0
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.7.0
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.7.0
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.7.0
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.7
func (m *LbEndpoint) GetEndpointName() string
func (*LbEndpoint) GetHealthStatus ¶
func (m *LbEndpoint) GetHealthStatus() core.HealthStatus
func (*LbEndpoint) GetHostIdentifier ¶ added in v0.6.7
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.7
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.7.0
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.7
type LbEndpoint_Endpoint struct {
Endpoint *Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3,oneof"`
}
func (*LbEndpoint_Endpoint) Equal ¶ added in v0.6.7
func (this *LbEndpoint_Endpoint) Equal(that interface{}) bool
func (*LbEndpoint_Endpoint) MarshalTo ¶ added in v0.6.7
func (m *LbEndpoint_Endpoint) MarshalTo(dAtA []byte) (int, error)
func (*LbEndpoint_Endpoint) Size ¶ added in v0.6.7
func (m *LbEndpoint_Endpoint) Size() (n int)
type LbEndpoint_EndpointName ¶ added in v0.6.7
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.7
func (this *LbEndpoint_EndpointName) Equal(that interface{}) bool
func (*LbEndpoint_EndpointName) MarshalTo ¶ added in v0.6.7
func (m *LbEndpoint_EndpointName) MarshalTo(dAtA []byte) (int, error)
func (*LbEndpoint_EndpointName) Size ¶ added in v0.6.7
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"`
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) 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.7.0
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.7.0
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.7.0
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.