ratelimit

type Cfg struct {
	Type Type `json:"type" yaml:"type"`
	Cfg  any  `json:"cfg"  yaml:"cfg"`
}

type FixedRateLimiter struct {
	runner.Runner
	*FixedRateLimiterCfg
	// contains filtered or unexported fields
}

type FixedRateLimiterCfg struct {
	N     int
	Burst int
}

type HostRateLimiter struct {
	runner.Runner
	*HostRateLimiterCfg
	// contains filtered or unexported fields
}

type HostRateLimiterCfg struct {
	Nic             string `json:"nic"             validate:"required"    yaml:"nic"`
	MonitorInterval int    `json:"monitorInterval" yaml:"monitorInterval"`
	ReservePercent  int    `json:"reservePercent"  yaml:"reservePercent"`
	MinMBps         int    `json:"minMBps"         yaml:"minMBps"`
	Burst           int    `json:"burst"           yaml:"burst"`
}

type RxTxRateLimiter interface {
	runner.Runner
	plugin.Plugin
	RxWaitN(n int, timeout int) error
	TxWaitN(n int, timeout int) error
}

type SleepRateLimiter struct {
	runner.Runner
	*SleepRateLimiterCfg
}

type SleepRateLimiterCfg struct {
	Millisecond int
}

type Type string