ratelimit

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

type FixedRateLimiterCfg struct {
	N 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"`
	FixedMBps       int    `json:"fixedMBps"       yaml:"fixedMBps"`
}

type RateLimiterCfg struct {
	Cfg  interface{}     `json:"cfg"  yaml:"cfg"`
	Type RateLimiterType `json:"type" yaml:"type"`
}

type RateLimiterType string

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

type SleepRateLimiter struct {
	runner.Runner
	*SleepRateLimiterCfg
}

type SleepRateLimiterCfg struct {
	Millisecond int
}