concurrent

Documentation

Index

• type Loader
• type Map
  • func NewMap[V any](loader Loader[V], cleaner func(v V)) Map[V]
  • func (m Map[V]) Get(id string) (V, error)
  • func (m Map[V]) Put(id string, value V)
• type Pool
  • func NewPool[T any](min uint32, createT func(release func(T)) T) *Pool[T]
  • func (p *Pool[T]) Checkout() T
  • func (p *Pool[T]) Depleted() uint64
  • func (p *Pool[T]) Len() int

Types

type Loader

type Loader[V any] func(id string) (V, error)

type Map

type Map[V any] struct {
	// contains filtered or unexported fields
}

func NewMap

func NewMap[V any](loader Loader[V], cleaner func(v V)) Map[V]

func (Map[V]) Get

func (m Map[V]) Get(id string) (V, error)

func (Map[V]) Put

func (m Map[V]) Put(id string, value V)

type Pool

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

func NewPool

func NewPool[T any](min uint32, createT func(release func(T)) T) *Pool[T]

func (*Pool[T]) Checkout

func (p *Pool[T]) Checkout() T

func (*Pool[T]) Depleted

func (p *Pool[T]) Depleted() uint64

how often the pool was empty and we had to create a buffer on the fly

func (*Pool[T]) Len

func (p *Pool[T]) Len() int