Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2026 Changes in this version + func GetRangeMany[V any](ctx context.Context, store state.Store[V], m monoid.Monoid[V], ...) ([]V, error) + func GetRange[V any](ctx context.Context, store state.Store[V], m monoid.Monoid[V], ...) (V, error) + func GetTrailingMany[V any](ctx context.Context, store state.Store[V], m monoid.Monoid[V], ...) ([]V, error) + func GetTrailing[V any](ctx context.Context, store state.Store[V], m monoid.Monoid[V], ...) (V, error) + func GetWindowMany[V any](ctx context.Context, store state.Store[V], m monoid.Monoid[V], ...) ([]V, error) + func GetWindow[V any](ctx context.Context, store state.Store[V], m monoid.Monoid[V], ...) (V, error) + func Get[V any](ctx context.Context, store state.Store[V], entity string) (V, bool, error) + func WarmupNonWindowed[V any](ctx context.Context, cache state.Cache[V], store state.Store[V], ...) (int, error) + func WarmupWindowed[V any](ctx context.Context, cache state.Cache[V], store state.Store[V], ...) (int, error) + type LambdaQuery struct + Delta state.Store[V] + Monoid monoid.Monoid[V] + View state.Store[V] + func (q LambdaQuery[V]) Get(ctx context.Context, entity string) (V, bool, error) + func (q LambdaQuery[V]) GetRange(ctx context.Context, w windowed.Config, entity string, start, end time.Time) (V, error) + func (q LambdaQuery[V]) GetWindow(ctx context.Context, w windowed.Config, entity string, duration time.Duration, ...) (V, error)
Go to main page