cache

type CacheableFunction ¶

type CacheableFunction func(ctx context.Context, stdout io.Writer, stderr io.Writer) (result []byte, err error)

A CacheableFunction is provided with writers for any stdout/stderr they produce, along with a context which may be cancelled.

type Cacher ¶

type Cacher[T comparable] interface {
	Cache(ctx context.Context, hasher hash.Hash, wrapped CacheableFunction, versioner Version[T]) ([]byte, error)
	SetDefaultValidity(d time.Duration)
	Close()
}

type Reactive ¶

type Reactive[T comparable] func() T

func (r Reactive[_]) CancelNotifyOnChange(i int)

func (r Reactive[T]) Current() T

func (r Reactive[_]) HasCurrent() bool

func (r Reactive[T]) NotifyOnChange(onChanged chan<- T) int

type Version ¶

type Version[T comparable] interface {
	HasCurrent() bool
	Current() T // only valid if HasCurrent()
	NotifyOnChange(onChanged chan<- T) int

	// CancelNotifyOnChange deregisters the NotifyOnChange registration.
	CancelNotifyOnChange(i int)
}

Version is used to track the current value of something, receiving a push to nominated channel(s) whenever the value changes. The channel will also be pushed the current value, if there is one at the time of registration.

func CreateNullVersion() Version[string]