limiter

type CounterService interface {
	Increment(ctx context.Context, key string, n uint32, ttl int64, syncRate int) (uint32, error)
	IncrementOnStorage(ctx context.Context, key string, n uint32, ttl int64) (uint32, error)
	Get(ctx context.Context, key string) (uint32, error)
	GetFromStorage(ctx context.Context, key string) (uint32, error)
}

type DescriptorLabel struct {
	Key   string `yaml:"key"`
	Value string `yaml:"value"`
}

type DomainRules struct {
	Domain string  `yaml:"domain"`
	Rules  []*Rule `yaml:"rules"`
}

type Limit struct {
	Requests uint32 `yaml:"requests"`
	Unit     string `yaml:"unit"`
}

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

type Rule struct {
	Name      string            `yaml:"name"`
	Labels    []DescriptorLabel `yaml:"labels"`
	Limit     Limit             `yaml:"limit"`
	SyncRate  int               `yaml:"syncRate"`
	InnerRank int
}

type RulesConfig struct {
	Domains []*DomainRules `yaml:"domains"`
}

type RulesService interface {
	GetRatelimitRule(domain string, requestDescriptor *rl.RateLimitDescriptor) (*Rule, error)
}