concurrency

Documentation

Index

• type AtomicValue
  • func (a *AtomicValue[T]) Get() T
  • func (a *AtomicValue[T]) Set(value T)
  • func (a *AtomicValue[T]) Update(fn func(T) T) T
• type BatchingChannel
  • func NewBatchingChannel[T any](capacity int, maxBatchSize int, maxWaitTime time.Duration) BatchingChannel[T]
• type BufferedConcurrentChannel
  • func NewBufferedConcurrentChannel[T any](capacity int, concurrency int) BufferedConcurrentChannel[T]
• type KeyedLimiter
  • func NewKeyedLimiter(rl rate.Limit, burst int, size int, ttl time.Duration) KeyedLimiter

Types

type AtomicValue

type AtomicValue[T any] struct {
	// contains filtered or unexported fields
}

func (*AtomicValue[T]) Get

func (a *AtomicValue[T]) Get() T

func (*AtomicValue[T]) Set

func (a *AtomicValue[T]) Set(value T)

func (*AtomicValue[T]) Update

func (a *AtomicValue[T]) Update(fn func(T) T) T

type BatchingChannel

type BatchingChannel[T any] interface {
	In() chan<- T
	Out() <-chan []T
}

func NewBatchingChannel

func NewBatchingChannel[T any](capacity int, maxBatchSize int, maxWaitTime time.Duration) BatchingChannel[T]

type BufferedConcurrentChannel

type BufferedConcurrentChannel[T any] interface {
	In() chan<- T
	Run(context.Context, func(T)) error
}

func NewBufferedConcurrentChannel

func NewBufferedConcurrentChannel[T any](capacity int, concurrency int) BufferedConcurrentChannel[T]

type KeyedLimiter

type KeyedLimiter interface {
	Allow(key string) bool
	Wait(ctx context.Context, key string) error
}

func NewKeyedLimiter

func NewKeyedLimiter(rl rate.Limit, burst int, size int, ttl time.Duration) KeyedLimiter