memorycontrol

Documentation

Index

• type Idempotency
  • func NewIdempotency() *Idempotency
  • func (i *Idempotency) Done(ctx context.Context, key string) (bool, error)
  • func (i *Idempotency) MarkDone(ctx context.Context, key string, ttl time.Duration) error
• type Locker
  • func NewLocker() *Locker
  • func (l *Locker) Lock(ctx context.Context, key string, ttl time.Duration) (func(context.Context) error, bool, error)
• type RateLimiter
  • func NewRateLimiter() *RateLimiter
  • func (l *RateLimiter) Allow(ctx context.Context, key string, limit int, window time.Duration) (bool, time.Duration, error)

Types

type Idempotency

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

func NewIdempotency

func NewIdempotency() *Idempotency

func (*Idempotency) Done

func (i *Idempotency) Done(ctx context.Context, key string) (bool, error)

func (*Idempotency) MarkDone

func (i *Idempotency) MarkDone(ctx context.Context, key string, ttl time.Duration) error

type Locker

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

func NewLocker

func NewLocker() *Locker

func (*Locker) Lock

func (l *Locker) Lock(ctx context.Context, key string, ttl time.Duration) (func(context.Context) error, bool, error)

type RateLimiter

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

func NewRateLimiter

func NewRateLimiter() *RateLimiter

func (*RateLimiter) Allow

func (l *RateLimiter) Allow(ctx context.Context, key string, limit int, window time.Duration) (bool, time.Duration, error)