srate

Documentation

Index

• Variables
• func ShardMaxConcurrencyKey(shardID int, maxConcurrency int) int
• type 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(config *Config) Limiter

Variables

var DefaultConfig = Config{
	MaxConcurrency: 1,
	StartupDelay:   5,
}

Functions

func ShardMaxConcurrencyKey

func ShardMaxConcurrencyKey(shardID int, maxConcurrency int) int

Types

type Config

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

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) error
	Config() Config
	WaitBucket(ctx context.Context, shardID int) error
	UnlockBucket(shardID int)
}

func NewLimiter

func NewLimiter(config *Config) Limiter