bond

package module

Go to main page

Versions in this module

v0

v0.1.51

Apr 19, 2024

Changes in this version

+ type TableUnsafeInserter interface

+ UnsafeInsert func(ctx context.Context, trs []T, optBatch ...Batch) error

v0.1.50

Apr 17, 2024

Changes in this version

type Batch

+ Type func() BatchType

+ type BatchType int

+ const BatchTypeReadWrite

+ const BatchTypeWriteOnly

v0.1.49

Mar 22, 2024

Changes in this version

type TableWriter

+ ReIndex func(idxs []*Index[T]) error

v0.1.48

Feb 20, 2024

Changes in this version

+ const PebbleFormatFile

+ func MigratePebbleFormatVersion(dir string, upgradeVersion uint64) error

+ func PebbleFormatVersion(dir string) (uint64, error)

v0.1.47

Feb 5, 2024

Changes in this version

type IndexOrder

+ KeyBuilder KeyBuilder

v0.1.46

Jan 3, 2024

v0.1.45

Dec 17, 2023

v0.1.44

Dec 8, 2023

Changes in this version

+ var ErrNotFound = fmt.Errorf("bond: not found")

+ type Backup interface

+ Dump func(ctx context.Context, dir string, tables []TableID, withIndex bool) error

+ Restore func(ctx context.Context, dir string, tables []TableID, withIndex bool) error

type TableGetter

+ GetPoint func(ctx context.Context, sel T, optBatch ...Batch) (T, error)

v0.1.43

May 12, 2023

Changes in this version

+ const BOND_DB_DATA_TABLE_ID

+ const BOND_DB_DATA_USER_SPACE_INDEX_ID

+ const BOND_DB_DATA_VERSION

+ const DefaultKeyBufferSize

+ const DefaultMaxConcurrentCompactions

+ const DefaultMaxWriterConcurrency

+ const DefaultNumberOfKeyBuffersInMultiKeyBuffer

+ const DefaultNumberOfPreAllocBytesArrays

+ const DefaultNumberOfPreAllocKeyBuffers

+ const DefaultNumberOfPreAllocMultiKeyBuffers

+ const DefaultNumberOfPreAllocValueBuffers

+ const DefaultScanPrefetchSize

+ const DefaultValueBufferSize

+ const NumberSequenceBitShift

+ const NumberSequenceSequenceNumberMask

+ const NumberSequenceTimestampMask

+ const PrimaryIndexID

+ const PrimaryIndexName

+ const ReindexBatchSize

+ var NoSync = WriteOptions

+ var Sync = WriteOptions

+ func ContextWithBatch(ctx context.Context, batch Batch) context.Context

+ func ContextWithSyncBatch(ctx context.Context, batch *SyncBatch) context.Context

+ func DefaultKeyComparer() *pebble.Comparer

+ func DefaultPebbleOptions() *pebble.Options

+ func FilterInitialize(ctx context.Context, filter Filter, filterStorer FilterStorer, ...) error

+ func KeyEncode(key Key, rawBuffs ...[]byte) []byte

+ func KeyEncodeRaw(tableID TableID, indexID IndexID, ...) []byte

+ func TableUpsertOnConflictReplace(_, new T) T

+ type Applier interface

+ Apply func(b Batch, opt WriteOptions) error

+ type Batch interface

+ Empty func() bool

+ ID func() uint64

+ Len func() int

+ Reset func()

+ ResetRetained func()

+ func ContextRetrieveBatch(ctx context.Context) Batch

+ type Batcher interface

+ Batch func() Batch

+ type Closer io.Closer

+ type Committer interface

+ Commit func(opt WriteOptions) error

+ OnClose func(func(b Batch))

+ OnCommit func(func(b Batch) error)

+ OnCommitted func(func(b Batch))

+ OnError func(func(b Batch, err error))

+ type DB interface

+ Backend func() *pebble.DB

+ OnClose func(func(db DB))

+ Serializer func() Serializer[any]

+ func Open(dirname string, opts *Options) (DB, error)

+ type Deleter interface

+ Delete func(key []byte, opt WriteOptions, batch ...Batch) error

+ type DeleterWithRange interface

+ DeleteRange func(start []byte, end []byte, opt WriteOptions, batch ...Batch) error

+ type Filter interface

+ Add func(ctx context.Context, key []byte)

+ Clear func(ctx context.Context, store FilterStorer) error

+ Load func(ctx context.Context, store FilterStorer) error

+ MayContain func(ctx context.Context, key []byte) bool

+ Save func(ctx context.Context, store FilterStorer) error

+ type FilterInitializable struct

+ func (f *FilterInitializable) Initialize(ctx context.Context, filterStorer FilterStorer, scanners []TableScanner[any]) error

+ func (f *FilterInitializable) MayContain(ctx context.Context, key []byte) bool

+ func (f *FilterInitializable) Save(ctx context.Context, store FilterStorer) error

+ type FilterStorer interface

+ type Getter interface

+ Get func(key []byte, batch ...Batch) (data []byte, closer io.Closer, err error)

+ type Index struct

+ IndexFilterFunction IndexFilterFunction[T]

+ IndexID IndexID

+ IndexKeyFunction IndexKeyFunction[T]

+ IndexName string

+ IndexOrderFunction IndexOrderFunction[T]

+ func NewIndex(opt IndexOptions[T]) *Index[T]

+ func (idx *Index[T]) ID() IndexID

+ func (idx *Index[T]) Intersect(ctx context.Context, table Table[T], sel Selector[T], indexes []*Index[T], ...) ([][]byte, error)

+ func (idx *Index[T]) Iter(table Table[T], selector Selector[T], optBatch ...Batch) Iterator

+ func (idx *Index[T]) Name() string

+ func (idx *Index[T]) OnDelete(table Table[T], tr T, batch Batch, buffs ...[]byte) error

+ func (idx *Index[T]) OnInsert(table Table[T], tr T, batch Batch, buffs ...[]byte) error

+ func (idx *Index[T]) OnUpdate(table Table[T], oldTr T, tr T, batch Batch, buffs ...[]byte) error

+ type IndexFilterFunction func(t T) bool

+ type IndexID uint8

+ type IndexInfo interface

+ ID func() IndexID

+ Name func() string

+ type IndexKeyFunction func(builder KeyBuilder, t T) []byte

+ type IndexOptions struct

+ IndexFilterFunc IndexFilterFunction[T]

+ IndexID IndexID

+ IndexKeyFunc IndexKeyFunction[T]

+ IndexName string

+ IndexOrderFunc IndexOrderFunction[T]

+ type IndexOrder struct

+ func IndexOrderDefault(o IndexOrder, t T) IndexOrder

+ func (o IndexOrder) Bytes() []byte

+ func (o IndexOrder) OrderBigInt(b *big.Int, bits int, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderByte(b byte, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderBytes(b []byte, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderInt16(i int16, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderInt32(i int32, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderInt64(i int64, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderUint16(i uint16, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderUint32(i uint32, orderType IndexOrderType) IndexOrder

+ func (o IndexOrder) OrderUint64(i uint64, orderType IndexOrderType) IndexOrder

+ type IndexOrderFunction func(o IndexOrder, t T) IndexOrder

+ type IndexOrderType bool

+ const IndexOrderTypeASC

+ const IndexOrderTypeDESC

+ type IterOptions struct

+ type Iterationer interface

+ Iter func(opt *IterOptions, batch ...Batch) Iterator

+ type Iterator interface

+ Close func() error

+ Error func() error

+ First func() bool

+ Key func() []byte

+ Last func() bool

+ Next func() bool

+ Prev func() bool

+ SeekGE func(key []byte) bool

+ SeekLT func(key []byte) bool

+ SeekPrefixGE func(key []byte) bool

+ Valid func() bool

+ Value func() []byte

+ type Key struct

+ Index []byte

+ IndexID IndexID

+ IndexOrder []byte

+ PrimaryKey []byte

+ TableID TableID

+ func KeyDecode(keyBytes []byte) Key

+ func (k Key) IsDataKey() bool

+ func (k Key) IsIndexKey() bool

+ func (k Key) IsKeyPrefix() bool

+ func (k Key) ToDataKey() Key

+ func (k Key) ToKeyPrefix() Key

+ type KeyBuilder struct

+ func NewKeyBuilder(buff []byte) KeyBuilder

+ func (b KeyBuilder) AddBigIntField(bi *big.Int, bits int) KeyBuilder

+ func (b KeyBuilder) AddByteField(btt byte) KeyBuilder

+ func (b KeyBuilder) AddBytesField(bs []byte) KeyBuilder

+ func (b KeyBuilder) AddInt16Field(i int16) KeyBuilder

+ func (b KeyBuilder) AddInt32Field(i int32) KeyBuilder

+ func (b KeyBuilder) AddInt64Field(i int64) KeyBuilder

+ func (b KeyBuilder) AddStringField(s string) KeyBuilder

+ func (b KeyBuilder) AddUint16Field(i uint16) KeyBuilder

+ func (b KeyBuilder) AddUint32Field(i uint32) KeyBuilder

+ func (b KeyBuilder) AddUint64Field(i uint64) KeyBuilder

+ func (b KeyBuilder) Bytes() []byte

+ type KeyBytes []byte

+ func NewUserKey(key string) KeyBytes

+ func (key KeyBytes) Index() []byte

+ func (key KeyBytes) IndexID() IndexID

+ func (key KeyBytes) IsDataKey() bool

+ func (key KeyBytes) IsIndexKey() bool

+ func (key KeyBytes) TableID() TableID

+ func (key KeyBytes) ToDataKeyBytes(rawBuffs ...[]byte) KeyBytes

+ func (key KeyBytes) ToKey() Key

+ type Lazy struct

+ GetFunc func() (T, error)

+ func (l Lazy[T]) Get() (T, error)

+ type NumberSequence struct

+ func (n *NumberSequence) Next() (uint64, error)

+ func (n *NumberSequence) SequenceNumber(ns uint64) uint64

+ func (n *NumberSequence) Timestamp(ns uint64) uint64

+ type Options struct

+ PebbleOptions *pebble.Options

+ Serializer Serializer[any]

+ func DefaultOptions() *Options

+ type OrderLessFunc func(r, r2 R) bool

+ type Query struct

+ func (q Query[T]) After(sel T) Query[T]

+ func (q Query[T]) CondFuncType() reflect.Type

+ func (q Query[T]) Execute(ctx context.Context, r *[]T, optBatch ...Batch) error

+ func (q Query[T]) Filter(cond cond.Cond[T]) Query[T]

+ func (q Query[T]) Intersects(queries ...Query[T]) Query[T]

+ func (q Query[T]) Limit(limit uint64) Query[T]

+ func (q Query[T]) Offset(offset uint64) Query[T]

+ func (q Query[T]) Order(less OrderLessFunc[T]) Query[T]

+ func (q Query[T]) Reverse() Query[T]

+ func (q Query[T]) Table() Table[T]

+ func (q Query[T]) With(idx *Index[T], selector Selector[T]) Query[T]

+ type Selector interface

+ Type func() SelectorType

+ type SelectorPoint interface

+ Point func() T

+ SetPoint func(p T)

+ func NewSelectorPoint(point T) SelectorPoint[T]

+ type SelectorPoints interface

+ Points func() []T

+ SetPoints func(p ...T)

+ func NewSelectorPoints(points ...T) SelectorPoints[T]

+ type SelectorRange interface

+ Range func() (T, T)

+ SetRange func(start, end T)

+ func NewSelectorRange(start, end T) SelectorRange[T]

+ type SelectorRanges interface

+ Ranges func() [][]T

+ SetRanges func(ranges ...[]T)

+ func NewSelectorRanges(ranges ...[]T) SelectorRanges[T]

+ type SelectorType uint8

+ const SelectorTypePoint

+ const SelectorTypePoints

+ const SelectorTypeRange

+ const SelectorTypeRanges

+ type Serializer interface

+ Deserialize func(b []byte, t T) error

+ Serialize func(t T) ([]byte, error)

+ type SerializerAnyWrapper struct

+ Serializer Serializer[any]

+ func (s *SerializerAnyWrapper[T]) Deserialize(b []byte, t T) error

+ func (s *SerializerAnyWrapper[T]) Serialize(t T) ([]byte, error)

+ type SerializerWithBuffer interface

+ SerializeFuncWithBuffer func(buff *bytes.Buffer) func(T any) ([]byte, error)

+ type SerializerWithClosable interface

+ SerializerWithCloseable func(t T) ([]byte, func(), error)

+ type Setter interface

+ Set func(key []byte, value []byte, opt WriteOptions, batch ...Batch) error

+ type SyncBatch struct

+ func ContextRetrieveSyncBatch(ctx context.Context) *SyncBatch

+ func NewSyncBatch(batch Batch) *SyncBatch

+ func (s *SyncBatch) WithSync(f func(batch Batch) error) error

+ type Table interface

+ func NewTable(opt TableOptions[T]) Table[T]

+ type TableDeleter interface

+ Delete func(ctx context.Context, trs []T, optBatch ...Batch) error

+ type TableExistChecker interface

+ Exist func(tr T, optBatch ...Batch) bool

+ type TableGetter interface

+ Get func(ctx context.Context, sel Selector[T], optBatch ...Batch) ([]T, error)

+ type TableID uint8

+ type TableInfo interface

+ EntryType func() reflect.Type

+ ID func() TableID

+ Indexes func() []IndexInfo

+ Name func() string

+ SelectorPointType func() reflect.Type

+ type TableInserter interface

+ Insert func(ctx context.Context, trs []T, optBatch ...Batch) error

+ type TableIterationer interface

+ Iter func(sel Selector[T], optBatch ...Batch) Iterator

+ type TableOptions struct

+ DB DB

+ Filter Filter

+ ScanPrefetchSize int

+ Serializer Serializer[any]

+ TableID TableID

+ TableName string

+ TablePrimaryKeyFunc TablePrimaryKeyFunc[T]

+ type TablePrimaryKeyFunc func(builder KeyBuilder, t T) []byte

+ type TableQuerier interface

+ Query func() Query[T]

+ type TableReader interface

+ DB func() DB

+ PrimaryIndex func() *Index[T]

+ PrimaryKey func(builder KeyBuilder, tr T) []byte

+ SecondaryIndexes func() []*Index[T]

+ Serializer func() Serializer[*T]

+ type TableScanner interface

+ Scan func(ctx context.Context, tr *[]T, reverse bool, optBatch ...Batch) error

+ ScanForEach func(ctx context.Context, f func(keyBytes KeyBytes, l Lazy[T]) (bool, error), ...) error

+ ScanIndex func(ctx context.Context, i *Index[T], s Selector[T], tr *[]T, reverse bool, ...) error

+ ScanIndexForEach func(ctx context.Context, idx *Index[T], s Selector[T], ...) error

+ func TableAnyScanner(scanner TableScanner[T]) TableScanner[any]

+ type TableUnsafeUpdater interface

+ UnsafeUpdate func(ctx context.Context, trs []T, oldTrs []T, optBatch ...Batch) error

+ type TableUpdater interface

+ Update func(ctx context.Context, trs []T, optBatch ...Batch) error

+ type TableUpserter interface

+ Upsert func(ctx context.Context, trs []T, onConflict func(old, new T) T, optBatch ...Batch) error

+ type TableWriter interface

+ AddIndex func(idxs []*Index[T], reIndex ...bool) error

+ type UUIDGenerator struct

+ func (n *UUIDGenerator) Next() (uuid.UUID, error)

+ type UniqueKeyGenerator interface

+ Next func() (T, error)

+ type WriteOptions struct

+ Sync bool

v0.1.42

Apr 17, 2023

v0.1.41

Apr 14, 2023

v0.1.40

Apr 11, 2023

v0.1.39

Mar 29, 2023

v0.1.38

Mar 15, 2023

v0.1.37

Mar 15, 2023

v0.1.36

Feb 5, 2023

v0.1.35

Feb 2, 2023

v0.1.34

Feb 2, 2023

v0.1.33

Feb 2, 2023

v0.1.32

Jan 31, 2023

v0.1.31

Jan 26, 2023

v0.1.30

Dec 8, 2022

v0.1.27

Dec 15, 2022

v0.1.26

Dec 14, 2022

v0.1.25

Dec 8, 2022

v0.1.24

Dec 7, 2022

v0.1.23

Dec 5, 2022

v0.1.22

Dec 5, 2022

v0.1.21

Nov 24, 2022

v0.1.20

Nov 15, 2022

v0.1.19

Nov 10, 2022

v0.1.18

Nov 9, 2022

v0.1.17

Nov 5, 2022

v0.1.16

Nov 3, 2022

v0.1.15

Oct 21, 2022

v0.1.14

Sep 27, 2022

v0.1.13

Sep 16, 2022

v0.1.12

Aug 30, 2022

v0.1.11

Aug 19, 2022

v0.1.10

Aug 15, 2022

v0.1.9

Aug 12, 2022

v0.1.8

Aug 11, 2022

v0.1.7

Aug 10, 2022

v0.1.6

Aug 9, 2022

v0.1.5

Aug 9, 2022

v0.1.4

Aug 9, 2022

v0.1.3

Aug 9, 2022

v0.1.2

Aug 3, 2022

v0.1.1

Aug 2, 2022

v0.1.0

Aug 2, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL