cycle

Documentation

Index

• type Cache
  • func NewCache[T any](log *logp.Logger) *Cache[T]
  • func (c *Cache[T]) GetValue(ctx context.Context, cycle Metadata, fetch func(context.Context) (T, error)) (T, error)
• type Metadata

Types

type Cache

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

Cache is a thread-safe generic struct that you can use to cache values for the current cycle. On a new cycle, determined by cycle metadata, the callback function is called and a new value is initialized. If the callback fails and an old value exists, it is re-used.

func NewCache

func NewCache[T any](log *logp.Logger) *Cache[T]

func (*Cache[T]) GetValue

func (c *Cache[T]) GetValue(ctx context.Context, cycle Metadata, fetch func(context.Context) (T, error)) (T, error)

type Metadata

type Metadata struct {
	Sequence int64
}