srate

Documentation

Index

• func ShardMaxConcurrencyKey(shardID int, maxConcurrency int) int
• type Config
  • func DefaultConfig() *Config
  • func (c *Config) Apply(opts []ConfigOpt)
• type ConfigOpt
  • func WithLogger(logger log.Logger) ConfigOpt
  • func WithMaxConcurrency(maxConcurrency int) ConfigOpt
  • func WithStartupDelay(startupDelay int) ConfigOpt
• type Limiter
  • func NewLimiter(opts ...ConfigOpt) Limiter

Functions

func ShardMaxConcurrencyKey

func ShardMaxConcurrencyKey(shardID int, maxConcurrency int) int

Types

type Config

type Config struct {
	Logger         log.Logger
	MaxConcurrency int
	StartupDelay   int
}

func DefaultConfig

func DefaultConfig() *Config

func (*Config) Apply

func (c *Config) Apply(opts []ConfigOpt)

type ConfigOpt

type ConfigOpt func(config *Config)

func WithLogger

func WithLogger(logger log.Logger) ConfigOpt

func WithMaxConcurrency

func WithMaxConcurrency(maxConcurrency int) ConfigOpt

func WithStartupDelay

func WithStartupDelay(startupDelay int) ConfigOpt

type Limiter

type Limiter interface {
	Logger() log.Logger
	Close(ctx context.Context)

	WaitBucket(ctx context.Context, shardID int) error
	UnlockBucket(shardID int)
}

func NewLimiter

func NewLimiter(opts ...ConfigOpt) Limiter