journal

Sep 24, 2024

Changes in this version

+ func IsConflict(err error) bool

+ func IsNotFound(err error) bool

+ type ConflictError struct

+ Journal string

+ Position Position

+ func (e ConflictError) Error() string

+ type Interval struct

+ Begin Position

+ End Position

+ func (i Interval) Contains(pos Position) bool

+ func (i Interval) IsEmpty() bool

+ func (i Interval) Len() int

+ func (i Interval) Positions() iter.Seq2[int, Position]

+ func (i Interval) String() string

type Journal

+ Name func() string

+ type RecordNotFoundError struct

+ Journal string

+ Position Position

+ func (e RecordNotFoundError) Error() string

+ type ValueNotFoundError struct

+ func (e ValueNotFoundError) Error() string

Apr 2, 2024

Changes in this version

+ func IgnoreNotFound(err error) error

type Position

+ func AppendWithConflictResolution[T any](ctx context.Context, j Journal[T], end Position, rec T, ...) (Position, error)

Mar 27, 2024

Changes in this version

+ func RangeFromSearchResult[T any](ctx context.Context, j Journal[T], begin, end Position, cmp CompareFunc[T], ...) error

Mar 17, 2024

Changes in this version

+ func ScanFromSearchResult[T, V any](ctx context.Context, j Journal[T], begin, end Position, cmp CompareFunc[T], ...) (V, error)

+ func Scan[T, V any](ctx context.Context, j Journal[T], begin Position, scan ScanFunc[T, V]) (V, error)

+ type BinaryJournal = Journal[[]byte]

+ type BinaryRangeFunc = RangeFunc[[]byte]

+ type BinaryStore = Store[[]byte]

type Position

+ func Search[T any](ctx context.Context, j Journal[T], begin, end Position, cmp CompareFunc[T]) (pos Position, rec T, err error)

+ type ScanFunc func(ctx context.Context, pos Position, rec T) (v V, ok bool, err error)

type Store

+ func NewMarshalingStore[T any](s BinaryStore, m marshaler.Marshaler[T]) Store[T]

Mar 16, 2024

Changes in this version

+ func RunBenchmarks(b *testing.B, newStore func(b *testing.B) Store)

type Position

+ const MaxPosition

Mar 11, 2024

Changes in this version

+ func IsEmpty(ctx context.Context, j Journal) (bool, error)

+ func IsFresh(ctx context.Context, j Journal) (bool, error)

type Position

+ func FirstRecord(ctx context.Context, j Journal) (Position, []byte, bool, error)

+ func LastRecord(ctx context.Context, j Journal) (Position, []byte, bool, error)

Mar 9, 2024

Changes in this version

+ type CompareFunc func(context.Context, Position, []byte) (cmp int, err error)

type Position

+ func BinarySearch(ctx context.Context, j Journal, begin, end Position, cmp CompareFunc) (pos Position, rec []byte, err error)

Mar 2, 2024

Changes in this version

type Store

+ func WithTelemetry(s Store, p trace.TracerProvider, m metric.MeterProvider, l *slog.Logger) Store

Oct 16, 2023

Changes in this version

+ var ErrConflict = errors.New("optimistic concurrency conflict")

+ var ErrNotFound = errors.New("record not found")

+ func RunTests(t *testing.T, newStore func(t *testing.T) Store)

+ type Journal interface

+ Append func(ctx context.Context, end Position, rec []byte) error

+ Bounds func(ctx context.Context) (begin, end Position, err error)

+ Close func() error

+ Get func(ctx context.Context, pos Position) (rec []byte, err error)

+ Range func(ctx context.Context, pos Position, fn RangeFunc) error

+ Truncate func(ctx context.Context, end Position) error

+ type Position uint64

+ type RangeFunc func(context.Context, Position, []byte) (ok bool, err error)

+ type Store interface

+ Open func(ctx context.Context, name string) (Journal, error)