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"              yaml:"nic"               validate:"required"`
	MonitorInterval int    `json:"monitorInterval"  yaml:"monitorInterval"   validate:"required"`
	MaxPercent      int    `json:"maxPercent"       yaml:"maxPercent"        validate:"gte=0,lte=100"`
	MaxMBps         int    `json:"maxMBps"          yaml:"maxMBps"`
	MinMBps         int    `json:"minMBps"          yaml:"minMBps"           validate:"gte=0"`
}

type RxTxRateLimiter interface {
	runner.Runner
	plugin.Plugin
	RxWaitN(ctx context.Context, n int, timeout time.Duration) error
	TxWaitN(ctx context.Context, n int, timeout time.Duration) error
}

type SleepRateLimiter struct {
	runner.Runner
	*SleepRateLimiterCfg
}

type SleepRateLimiterCfg struct {
	Microsecond int
}

type Type string