weightadjuster

Documentation

Index

• type Proxy
  • func (p *Proxy) SetRealPlugin(plug plugin.Plugin, engine model.Engine)
• type WeightAdjuster

Types

type Proxy

type Proxy struct {
	WeightAdjuster
	// contains filtered or unexported fields
}

Proxy is a proxy for weight adjuster plugin

func (*Proxy) SetRealPlugin

func (p *Proxy) SetRealPlugin(plug plugin.Plugin, engine model.Engine)

SetRealPlugin 设置

type WeightAdjuster

type WeightAdjuster interface {
	plugin.Plugin
	// RealTimeAdjustDynamicWeight 实时上报健康状态，并判断是否需要立刻进行动态权重调整，用于流量削峰
	RealTimeAdjustDynamicWeight(model.InstanceGauge) (bool, error)
	// TimingAdjustDynamicWeight 进行动态权重调整，返回调整后的动态权重
	TimingAdjustDynamicWeight(service model.ServiceInstances) ([]*model.InstanceWeight, error)
}

WeightAdjuster 【扩展点接口】动态权重调整接口