The highest tagged major version is
Documentation
¶
Index ¶
- func CalculateAvgLatency()
- func FilterAvailableZoneAffinity(old []*registry.MicroServiceInstance, c []*loadbalancer.Criteria) []*registry.MicroServiceInstance
- func FilterByMetadata(old []*registry.MicroServiceInstance, c []*loadbalancer.Criteria) []*registry.MicroServiceInstance
- func SortLatency()
- type ByDuration
- type WeightedResponseStrategy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CalculateAvgLatency ¶
func CalculateAvgLatency()
CalculateAvgLatency Calculating the average latency for each instance using the statistics collected, key is addr/service/protocol
func FilterAvailableZoneAffinity ¶
func FilterAvailableZoneAffinity(old []*registry.MicroServiceInstance, c []*loadbalancer.Criteria) []*registry.MicroServiceInstance
FilterAvailableZoneAffinity is a region and zone based Select Filter which will Do the selection of instance in the same region and zone, if not Do the selection of instance in any zone in same region , if not Do the selection of instance in any zone of any region
func FilterByMetadata ¶
func FilterByMetadata(old []*registry.MicroServiceInstance, c []*loadbalancer.Criteria) []*registry.MicroServiceInstance
FilterByMetadata filter instances based meta data
Types ¶
type ByDuration ¶
type ByDuration []*loadbalancer.ProtocolStats
ByDuration is for calculating the duration
func (ByDuration) Len ¶
func (a ByDuration) Len() int
func (ByDuration) Less ¶
func (a ByDuration) Less(i, j int) bool
func (ByDuration) Swap ¶
func (a ByDuration) Swap(i, j int)
type WeightedResponseStrategy ¶
type WeightedResponseStrategy struct {
// contains filtered or unexported fields
}
WeightedResponseStrategy is a strategy plugin
func (*WeightedResponseStrategy) Pick ¶
func (r *WeightedResponseStrategy) Pick() (*registry.MicroServiceInstance, error)
Pick return instance
func (*WeightedResponseStrategy) ReceiveData ¶
func (r *WeightedResponseStrategy) ReceiveData(inv *invocation.Invocation, instances []*registry.MicroServiceInstance, serviceKey string)
ReceiveData receive data
Source Files
Click to show internal directories.
Click to hide internal directories.