distlimiter

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

type Options struct {
	Id               string
	TotalQPS         uint32
	HeartbeatSeconds uint32
	Limiter          RateLimiter
	Remote           RemoteStore
	RedisAddr        string
	RedisKey         string
}

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

type RateLimiter interface {
	Wait(context.Context, bool) error
	SetLimit(uint32)
}

type RemoteStore interface {
	Send(now time.Time, entry string) error
	Pull(min time.Time, max time.Time) ([]string, error)
	Clear(util time.Time) error
}