typedful

Jan 3, 2024

Changes in this version

+ func AgeRangeKey(age int) string

+ type TypedAppendLog struct

+ func NewTypedAppendLog[T any](log schemaless.AppendLoger[schema.Schema]) *TypedAppendLog[T]

+ func (t *TypedAppendLog[T]) Append(b *schemaless.AppendLog[T])

+ func (t *TypedAppendLog[T]) Change(from, to schemaless.Record[T]) error

+ func (t *TypedAppendLog[T]) Close()

+ func (t *TypedAppendLog[T]) Delete(data schemaless.Record[T]) error

+ func (t *TypedAppendLog[T]) Push(x schemaless.Change[T])

+ func (t *TypedAppendLog[T]) Subscribe(ctx context.Context, fromOffset int, f func(schemaless.Change[T])) error

+ type TypedLocation struct

+ func NewTypedLocation[T any]() (*TypedLocation, error)

+ func (location *TypedLocation) WrapLocation(loc []schema.Location) ([]schema.Location, error)

+ func (location *TypedLocation) WrapLocationStr(field string) (string, error)

+ type User struct

+ Age int

+ Name string

+ type UsersCountByAge struct

+ Count int

Nov 10, 2023

Changes in this version

+ type TypedRepoWithAggregator struct

+ func NewTypedRepoWithAggregator[T, C any](store Repository[schema.Schema], aggregator func() Aggregator[T, C]) *TypedRepoWithAggregator[T, C]

+ func NewTypedRepository[A any](store schemaless.Repository[schema.Schema]) *TypedRepoWithAggregator[A, any]

+ func (r *TypedRepoWithAggregator[T, C]) FindingRecords(query FindingRecords[Record[T]]) (PageResult[Record[T]], error)

+ func (r *TypedRepoWithAggregator[T, C]) Get(recordID string, recordType RecordType) (Record[T], error)

+ func (r *TypedRepoWithAggregator[T, C]) ReindexAll()

+ func (r *TypedRepoWithAggregator[T, C]) UpdateRecords(s UpdateRecords[Record[T]]) error