Versions in this module Expand all Collapse all v0 v0.6.3 Nov 12, 2018 v0.6.2 Nov 6, 2018 v0.6.1 Oct 15, 2018 v0.6.0 Sep 25, 2018 v0.5.0 Aug 14, 2018 Changes in this version + var ErrIntOverflowEndpoint = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowLoadReport = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEndpoint = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthLoadReport = fmt.Errorf("proto: negative length found during unmarshaling") + type ClusterStats struct + ClusterName string + DroppedRequests []*ClusterStats_DroppedRequests + LoadReportInterval *types.Duration + TotalDroppedRequests uint64 + UpstreamLocalityStats []*UpstreamLocalityStats + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterStats) Descriptor() ([]byte, []int) + func (*ClusterStats) ProtoMessage() + func (dst *ClusterStats) XXX_Merge(src proto.Message) + func (m *ClusterStats) GetClusterName() 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 (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_Size() int + func (m *ClusterStats) XXX_Unmarshal(b []byte) error + type ClusterStatsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e ClusterStatsValidationError) Error() string + type ClusterStats_DroppedRequests struct + Category string + DroppedCount uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterStats_DroppedRequests) Descriptor() ([]byte, []int) + func (*ClusterStats_DroppedRequests) ProtoMessage() + func (dst *ClusterStats_DroppedRequests) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *ClusterStats_DroppedRequests) XXX_Unmarshal(b []byte) error + type ClusterStats_DroppedRequestsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e ClusterStats_DroppedRequestsValidationError) Error() string + type Endpoint struct + Address *core.Address + HealthCheckConfig *Endpoint_HealthCheckConfig + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Endpoint) Descriptor() ([]byte, []int) + func (*Endpoint) ProtoMessage() + func (dst *Endpoint) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *Endpoint) XXX_Unmarshal(b []byte) error + func (this *Endpoint) Equal(that interface{}) bool + type EndpointLoadMetricStats struct + MetricName string + NumRequestsFinishedWithMetric uint64 + TotalMetricValue float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointLoadMetricStats) Descriptor() ([]byte, []int) + func (*EndpointLoadMetricStats) ProtoMessage() + func (dst *EndpointLoadMetricStats) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *EndpointLoadMetricStats) XXX_Unmarshal(b []byte) error + type EndpointLoadMetricStatsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e EndpointLoadMetricStatsValidationError) Error() string + type EndpointValidationError struct + Cause error + Field string + Key bool + Reason string + func (e EndpointValidationError) Error() string + type Endpoint_HealthCheckConfig struct + PortValue uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Endpoint_HealthCheckConfig) Descriptor() ([]byte, []int) + func (*Endpoint_HealthCheckConfig) ProtoMessage() + func (dst *Endpoint_HealthCheckConfig) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *Endpoint_HealthCheckConfig) XXX_Unmarshal(b []byte) error + func (this *Endpoint_HealthCheckConfig) Equal(that interface{}) bool + type Endpoint_HealthCheckConfigValidationError struct + Cause error + Field string + Key bool + Reason string + func (e Endpoint_HealthCheckConfigValidationError) Error() string + type LbEndpoint struct + Endpoint *Endpoint + HealthStatus core.HealthStatus + LoadBalancingWeight *types.UInt32Value + Metadata *core.Metadata + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LbEndpoint) Descriptor() ([]byte, []int) + func (*LbEndpoint) ProtoMessage() + func (dst *LbEndpoint) XXX_Merge(src proto.Message) + func (m *LbEndpoint) GetEndpoint() *Endpoint + func (m *LbEndpoint) GetHealthStatus() core.HealthStatus + 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 (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_Size() int + func (m *LbEndpoint) XXX_Unmarshal(b []byte) error + func (this *LbEndpoint) Equal(that interface{}) bool + type LbEndpointValidationError struct + Cause error + Field string + Key bool + Reason string + func (e LbEndpointValidationError) Error() string + type LocalityLbEndpoints struct + LbEndpoints []LbEndpoint + LoadBalancingWeight *types.UInt32Value + Locality *core.Locality + Priority uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LocalityLbEndpoints) Descriptor() ([]byte, []int) + func (*LocalityLbEndpoints) ProtoMessage() + func (dst *LocalityLbEndpoints) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *LocalityLbEndpoints) XXX_Unmarshal(b []byte) error + func (this *LocalityLbEndpoints) Equal(that interface{}) bool + type LocalityLbEndpointsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e LocalityLbEndpointsValidationError) Error() string + type UpstreamEndpointStats struct + Address *core.Address + LoadMetricStats []*EndpointLoadMetricStats + TotalErrorRequests uint64 + TotalRequestsInProgress uint64 + TotalSuccessfulRequests uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpstreamEndpointStats) Descriptor() ([]byte, []int) + func (*UpstreamEndpointStats) ProtoMessage() + func (dst *UpstreamEndpointStats) XXX_Merge(src proto.Message) + func (m *UpstreamEndpointStats) GetAddress() *core.Address + func (m *UpstreamEndpointStats) GetLoadMetricStats() []*EndpointLoadMetricStats + 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 (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_Size() int + func (m *UpstreamEndpointStats) XXX_Unmarshal(b []byte) error + type UpstreamEndpointStatsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e UpstreamEndpointStatsValidationError) Error() string + type UpstreamLocalityStats struct + LoadMetricStats []*EndpointLoadMetricStats + Locality *core.Locality + Priority uint32 + TotalErrorRequests uint64 + TotalRequestsInProgress uint64 + TotalSuccessfulRequests uint64 + UpstreamEndpointStats []*UpstreamEndpointStats + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpstreamLocalityStats) Descriptor() ([]byte, []int) + func (*UpstreamLocalityStats) ProtoMessage() + func (dst *UpstreamLocalityStats) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *UpstreamLocalityStats) XXX_Unmarshal(b []byte) error + type UpstreamLocalityStatsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e UpstreamLocalityStatsValidationError) Error() string