memoryprojection

Nov 23, 2025

Changes in this version

type Projection

+ func (p *Projection[T, H]) Reset(context.Context, dogma.ProjectionResetScope) error

Sep 18, 2025

Changes in this version

type Projection

+ func (p *Projection[T, H]) CheckpointOffset(_ context.Context, id string) (uint64, error)

Jul 10, 2024

Changes in this version

+ func Query[T, R any, H MessageHandler[T]](p *Projection[T, H], q func(T) R) R

+ type MessageHandler interface

+ Compact func(v T, s dogma.ProjectionCompactScope) T

+ Configure func(c dogma.ProjectionConfigurer)

+ HandleEvent func(v T, s dogma.ProjectionEventScope, m dogma.Message) (T, error)

+ type NoCompactBehavior struct

+ func (NoCompactBehavior[T]) Compact(v T, _ dogma.ProjectionCompactScope) T

+ type Projection struct

+ Handler H

+ func (p *Projection[T, H]) CloseResource(ctx context.Context, r []byte) error

+ func (p *Projection[T, H]) Compact(_ context.Context, s dogma.ProjectionCompactScope) error

+ func (p *Projection[T, H]) Configure(c dogma.ProjectionConfigurer)

+ func (p *Projection[T, H]) DeleteResource(_ context.Context, r []byte) error

+ func (p *Projection[T, H]) HandleEvent(_ context.Context, r, c, n []byte, s dogma.ProjectionEventScope, ...) (bool, error)

+ func (p *Projection[T, H]) ResourceRepository(context.Context) (resource.Repository, error)

+ func (p *Projection[T, H]) ResourceVersion(_ context.Context, r []byte) ([]byte, error)

+ func (p *Projection[T, H]) StoreResourceVersion(_ context.Context, r, v []byte) error

+ func (p *Projection[T, H]) TimeoutHint(dogma.Message) time.Duration

+ func (p *Projection[T, H]) UpdateResourceVersion(_ context.Context, r, c, n []byte) (bool, error)