limiter

type BucketSnapshot struct {
	Limit float64
	Burst int
}

type GlobalDeviceLimitConfig struct {
	Enable        bool   `mapstructure:"Enable"`
	RedisNetwork  string `mapstructure:"RedisNetwork"` // tcp or unix
	RedisAddr     string `mapstructure:"RedisAddr"`    // host:port, or /path/to/unix.sock
	RedisUsername string `mapstructure:"RedisUsername"`
	RedisPassword string `mapstructure:"RedisPassword"`
	RedisDB       int    `mapstructure:"RedisDB"`
	Timeout       int    `mapstructure:"Timeout"`
	Expiry        int    `mapstructure:"Expiry"` // second
}

type InboundInfo struct {
	Tag            string
	NodeSpeedLimit uint64
	UserInfo       *sync.Map // Key: user tag (buildUserTag) -> UserInfo
	BucketHub      *sync.Map // Key: user tag -> *rate.Limiter
	UserOnlineIP   *sync.Map // Key: user tag -> *userOnlineEntry
	GlobalDevices  *globalDeviceState
	GlobalLimit    *globalLimitState
	// contains filtered or unexported fields
}

type InboundLimiterStateSnapshot struct {
	UserInfo map[string]UserInfo
	Buckets  map[string]bucketStateSnapshot
	// contains filtered or unexported fields
}

type InboundSnapshot struct {
	Tag                    string
	NodeSpeedLimit         uint64
	Users                  map[string]UserInfo
	Buckets                map[string]BucketSnapshot
	OnlineUsers            []api.OnlineUser
	GlobalDevices          map[int][]string
	GlobalDevicesUpdatedAt time.Time
	GlobalDevicesFresh     bool
	GlobalLimitEnabled     bool
	GlobalLimitClosed      bool
}

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

type LimiterSnapshot struct {
	Closed   bool
	Inbounds map[string]InboundSnapshot
}

type Reader struct {
	// contains filtered or unexported fields
}

type UserInfo struct {
	UID         int
	SpeedLimit  uint64
	DeviceLimit int
}

type Writer struct {
	// contains filtered or unexported fields
}