based

type Clock interface {

	// Now returns the current time according to this Clock.
	Now() time.Time
}

type ClockFunc func() time.Time

type FuncRef[T any] func(ctx context.Context) (T, error)

type Goroutine interface {

	// Cancel signals cancellation to the goroutine.
	Cancel()

	// Join waits for goroutine to finish.
	Join(ctx context.Context) error
}

type Locker interface {

	// Lock acquires the lock.
	// It returns a new Context which should be checked for error before proceeding with the execution.
	// Context scope must be limited to holding the lock.
	// CancelFunc must not be nil and is used in defer statement to release the lock or perform other cleanup,
	// even in cases of context errors.
	//
	// Example usage:
	//  ctx, cancel := mu.Lock(ctx)
	//  defer cancel()
	//  if err := ctx.Err(); err != nil {
	//    return err
	//  }
	Lock(ctx context.Context) (context.Context, context.CancelFunc)
}

type LockerFunc func(ctx context.Context) (context.Context, context.CancelFunc)

type Lockers []Locker

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

type Ref[T any] interface {
	Get(ctx context.Context) (T, error)
}

type Unit struct{}

type WriteThroughCache[K comparable, V comparable] struct {
	// contains filtered or unexported fields
}

type WriteThroughCacheStorage[K comparable, V comparable] interface {

	// Load loads the value from storage.
	Load(ctx context.Context, key K) (V, error)

	// Update persists the value in storage.
	Update(ctx context.Context, key K, value V) error
}

type WriteThroughCacheStorageFunc[K comparable, V comparable] struct {
	LoadFn   func(ctx context.Context, key K) (V, error)
	UpdateFn func(ctx context.Context, key K, value V) error
}

type WriteThroughCached[V comparable] struct {
	// contains filtered or unexported fields
}