util

Documentation

Index

• type Remember
  • func NewRemember[T any](duration time.Duration) Remember[T]
• type UnboundedChan
  • func NewUnboundedChan[T any](interval time.Duration) UnboundedChan[T]

Types

type Remember

type Remember[T any] interface {
	// Get returns nil if nothing is remembered or it has expired
	Get() *T
	// Update sets the thing to be remembered
	Update(*T)
	// Forget clears the thing that was remembered
	Forget()
}

Remember stores an item for a period of time. It is safe to share with multiple goroutines.

func NewRemember

func NewRemember[T any](duration time.Duration) Remember[T]

NewRemember creates an implementation of Remembered with the specified duration to remember the item

type UnboundedChan

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

UnboundedChan is a channel with an unbounded buffer

func NewUnboundedChan

func NewUnboundedChan[T any](interval time.Duration) UnboundedChan[T]

NewUnboundedChan creates a new unbounded channel