limiter

type IPData struct {
	UID   int
	Tag   string
	Email string
}

type InboundInfo struct {
	Tag              string
	NodeSpeedLimit   uint64
	SubscriptionInfo *sync.Map // key: email → SubscriptionInfo
	BucketHub        *sync.Map // key: email → *rate.Limiter
	GlobalIPLimit    struct {
		// contains filtered or unexported fields
	}
}

type Limiter struct {
	InboundInfo *sync.Map
	// contains filtered or unexported fields
}

type PendingTraffic struct {
	Result   []api.SubscriptionTraffic
	Counters []pendingCounter
}

type RedisConfig struct {
	Enable   bool   `mapstructure:"Enable"`
	Network  string `mapstructure:"Network"` // tcp or unix
	Addr     string `mapstructure:"Addr"`    // host:port, or /path/to/unix.sock
	Username string `mapstructure:"Username"`
	Password string `mapstructure:"Password"`
	DB       int    `mapstructure:"DB"`
	Timeout  int    `mapstructure:"Timeout"`
}

type SubscriptionInfo struct {
	Id         int
	SpeedLimit uint64
	IPLimit    int
}

type TimeoutReader struct {
	Reader  buf.TimeoutReader
	Limiter *rate.Limiter
}

type Writer struct {
	Writer  buf.Writer
	Limiter *rate.Limiter
}