flow_control

flow_control 流量控制组件，具备如下功能： 流量划分（非随机采样划分，保证key稳定划分） 生产者消费者模式 Demo(流量划分) // TestFlowController_Forward3 流量划分 func TestFlowController_Forward3(t *testing.T) { f := New( WithForwardRadio([]uint64{10, 10, 20}), WithEnableConsumer(false), ) for i := 0; i < 1000; i++ { tmp := i t.Logf("id: %d, group: %d", tmp, f.Forward(RandStringRunes(32))) } } Demo(生产消费者模式) // TestFlowController_Forward1 生