throttle

type ContextLimitFilter struct {
	Context []string `config:"context"`
	// contains filtered or unexported fields
}

type DropFilter struct {
	param.Parameters
}

type ElasticsearchBulkRequestThrottle struct {
	Indices map[string]*config.Config `config:"indices"`
	// contains filtered or unexported fields
}

type ElasticsearchHealthCheckFilter struct {
	Elasticsearch string `config:"elasticsearch"`
	Interval      int    `config:"interval"`
}

type GenericLimiter struct {
	MaxRequests    int    `config:"max_requests"`
	BurstRequests  int    `config:"burst_requests"`
	MaxBytes       int    `config:"max_bytes"`
	BurstBytes     int    `config:"burst_bytes"`
	Interval       string `config:"interval"`
	Action         string `config:"action"`
	MaxRetryTimes  int    `config:"max_retry_times"`
	RetryDelayInMs int    `config:"retry_delay_in_ms"`
	Status         int    `config:"status"`
	Message        string `config:"message"`
	WarnMessage    bool   `config:"log_warn_message"`
	RetriedMessage string `config:"failed_retry_message"`
	// contains filtered or unexported fields
}

type MatchRules struct {
	Pattern string `config:"pattern"` //pattern
	MaxQPS  int64  `config:"max_qps"` //max_qps

	ExtractGroup string `config:"group"`
	// contains filtered or unexported fields
}

type RequestAPIKeyLimitFilter struct {
	APIKeys []string `config:"id"`
	// contains filtered or unexported fields
}

type RequestClientIPLimitFilter struct {
	IP []string `config:"ip"`
	// contains filtered or unexported fields
}

type RequestHostLimitFilter struct {
	Host []string `config:"host"`
	// contains filtered or unexported fields
}

type RequestPathLimitFilter struct {
	WarnMessage bool          `config:"log_warn_message"`
	Message     string        `config:"message"`
	Rules       []*MatchRules `config:"rules"`
}

type RequestUserLimitFilter struct {
	User []string `config:"user"`
	// contains filtered or unexported fields
}

type RetryLimiter struct {
	MaxRetryTimes int      `config:"max_retry_times"`
	SleepInterval int      `config:"retry_interval_in_ms"`
	Queue         string   `config:"queue_name"`
	TagsOnSuccess []string `config:"tag_on_success"` //hit limiter then add tag
}

type SleepFilter struct {
	SleepInMs int `config:"sleep_in_million_seconds"`
}