TODO: add rate in policy level

app/policy/config.go

@@ -27,7 +27,7 @@ func defaultPolicy() *Policy {
 		Buffer: &Policy_Buffer{
 			Connection: p.Buffer.PerConnection,
 		},
-		Rate: &p.Rate,
+		Rate: p.Rate,
 	}
 }
 
@@ -44,6 +44,9 @@ func (p *Policy_Timeout) overrideWith(another *Policy_Timeout) {
 	if another.DownlinkOnly != nil {
 		p.DownlinkOnly = &Second{Value: another.DownlinkOnly.Value}
 	}
+	if another.Rate != 0 {
+		p.Rate = another.Rate
+	}
 }
 
 func (p *Policy) overrideWith(another *Policy) {
@@ -59,7 +62,7 @@ func (p *Policy) overrideWith(another *Policy) {
 			Connection: another.Buffer.Connection,
 		}
 	}
-	if another.Rate != nil {
+	if another.Rate != 0 {
 		p.Rate = another.Rate
 	}
 }
@@ -81,8 +84,8 @@ func (p *Policy) ToCorePolicy() policy.Session {
 	if p.Buffer != nil {
 		cp.Buffer.PerConnection = p.Buffer.Connection
 	}
-	if p.Rate != nil {
-		cp.Rate = *p.Rate
+	if p.Rate != 0 {
+		cp.Rate = p.Rate
 	}
 	return cp
 }

features/policy/default.go

@@ -18,6 +18,9 @@ func (DefaultManager) ForLevel(level uint32) Session {
 	if level == 1 {
 		p.Timeouts.ConnectionIdle = time.Second * 600
 	}
+	if level == 100 {
+		p.Rate = 100
+	}
 	return p
 }
 

features/policy/policy.go

@@ -27,6 +27,8 @@ type Stats struct {
 	UserUplink bool
 	// Whether or not to enable stat counter for user downlink traffic.
 	UserDownlink bool
+
+	Rate uint64
 }
 
 // Buffer contains settings for internal buffer.

infra/conf/policy.go

@@ -49,7 +49,7 @@ func (t *Policy) Build() (*policy.Policy, error) {
 	}
 
 	if t.Rate != nil {
-		config.Rate = t.Rate
+		p.Rate = *t.Rate
 	}
 
 	return p, nil