services

Jul 1, 2026

Changes in this version

type DatabaseProvider

+ func (p *DatabaseProvider) GetValue(ctx context.Context, key string) (any, error)

type InMemoryProvider

+ func (p *InMemoryProvider) GetValue(ctx context.Context, key string) (any, error)

type SecondaryStorageProvider

+ func (p *SecondaryStorageProvider) GetValue(ctx context.Context, key string) (any, error)

May 18, 2026

Changes in this version

+ func NewRateLimiterService(provider types.RateLimitProvider) rootservices.RateLimiterService

+ type DatabaseProvider struct

+ func NewDatabaseProvider(db bun.IDB) (*DatabaseProvider, error)

+ func NewDatabaseProviderWithConfig(db bun.IDB, config types.DatabaseStorageConfig) (*DatabaseProvider, error)

+ func (p *DatabaseProvider) CheckAndIncrement(ctx context.Context, key string, window time.Duration, maxRequests int) (bool, int, time.Time, error)

+ func (p *DatabaseProvider) Close() error

+ func (p *DatabaseProvider) DeleteRule(ctx context.Context, key string) error

+ func (p *DatabaseProvider) GetName() string

+ func (p *DatabaseProvider) GetRule(ctx context.Context, key string) (time.Duration, int, bool, error)

+ func (p *DatabaseProvider) SetRule(ctx context.Context, key string, window time.Duration, maxRequests int) error

+ type InMemoryProvider struct

+ func NewInMemoryProvider() *InMemoryProvider

+ func NewInMemoryProviderWithConfig(config types.MemoryStorageConfig) *InMemoryProvider

+ func (p *InMemoryProvider) CheckAndIncrement(ctx context.Context, key string, window time.Duration, maxRequests int) (bool, int, time.Time, error)

+ func (p *InMemoryProvider) Close() error

+ func (p *InMemoryProvider) DeleteRule(_ context.Context, key string) error

+ func (p *InMemoryProvider) GetName() string

+ func (p *InMemoryProvider) GetRule(_ context.Context, key string) (time.Duration, int, bool, error)

+ func (p *InMemoryProvider) SetRule(_ context.Context, key string, window time.Duration, maxRequests int) error

+ type RateLimiterService interface

+ CheckAndIncrement func(ctx context.Context, key string, window time.Duration, maxRequests int) (bool, int, time.Time, error)

+ DeleteRule func(ctx context.Context, key string) error

+ GetRule func(ctx context.Context, key string) (window time.Duration, maxRequests int, found bool, err error)

+ SetRule func(ctx context.Context, key string, window time.Duration, maxRequests int) error

+ type SecondaryStorageProvider struct

+ func NewSecondaryStorageProvider(name string, storage models.SecondaryStorage) *SecondaryStorageProvider

+ func (p *SecondaryStorageProvider) CheckAndIncrement(ctx context.Context, key string, window time.Duration, maxRequests int) (bool, int, time.Time, error)

+ func (p *SecondaryStorageProvider) Close() error

+ func (p *SecondaryStorageProvider) DeleteRule(ctx context.Context, key string) error

+ func (p *SecondaryStorageProvider) GetName() string

+ func (p *SecondaryStorageProvider) GetRule(ctx context.Context, key string) (time.Duration, int, bool, error)

+ func (p *SecondaryStorageProvider) SetRule(ctx context.Context, key string, window time.Duration, maxRequests int) error