Versions in this module Expand all Collapse all v0 v0.1.0 Aug 26, 2026 Changes in this version + const AllTimeLeaderboardType + const CollateFuncICU + const CollateFuncJRE + const CollateStrengthPrimary + const CollateStrengthSecondary + const CollateStrengthTertiary + const DefaultCollectScannedBytesLimit + const DefaultCollectTimeLimit + const DefaultMaterializationLimit + const DefaultTextTokenizerName + const FunctionNameBitmapValue + const FunctionNameCardinality + const FunctionNameCount + const FunctionNameCountDistinct + const FunctionNameCountNotNull + const FunctionNameCountUpdates + const FunctionNameMax + const FunctionNameMaxEver + const FunctionNameMin + const FunctionNameMinEver + const FunctionNameRank + const FunctionNameRankForScore + const FunctionNameScoreForRank + const FunctionNameScoreForRankElseSkip + const FunctionNameScoreForTimeWindowRank + const FunctionNameScoreForTimeWindowRankElseSkip + const FunctionNameSum + const FunctionNameTimeWindowCount + const FunctionNameTimeWindowRank + const FunctionNameTimeWindowRankAndEntry + const FunctionNameTimeWindowRankForScore + const FunctionNameVersion + const GlobalMinVersion + const GlobalVersionBytes + const GroupCountCompanionSuffix + const IndexBuildSpaceKey + const IndexKey + const IndexOptionAllowedForQuery + const IndexOptionBitmapValueEntrySize + const IndexOptionClearWhenZero + const IndexOptionHNSWEfConstruction + const IndexOptionHNSWEfRepair + const IndexOptionHNSWM + const IndexOptionHNSWMMax + const IndexOptionHNSWMMax0 + const IndexOptionHNSWMaintainStatsProbability + const IndexOptionHNSWMaxNumConcurrentDeleteFromLayer + const IndexOptionHNSWMaxNumConcurrentNeighborhoodFetches + const IndexOptionHNSWMaxNumConcurrentNodeFetches + const IndexOptionHNSWRaBitQNumExBits + const IndexOptionHNSWSampleVectorStatsProbability + const IndexOptionHNSWStatsThreshold + const IndexOptionHNSWUseInlining + const IndexOptionHNSWUseRaBitQ + const IndexOptionPermutedSize + const IndexOptionRTreeMaxM + const IndexOptionRTreeMinM + const IndexOptionRTreeSplitS + const IndexOptionRTreeStorage + const IndexOptionRTreeStoreHilbertValues + const IndexOptionRTreeUseNodeSlotIndex + const IndexOptionRankCountDuplicates + const IndexOptionRankHashFunction + const IndexOptionRankNLevels + const IndexOptionReplacedByPrefix + const IndexOptionSPFreshAlpha + const IndexOptionSPFreshBuildAssignCells + const IndexOptionSPFreshCellMax + const IndexOptionSPFreshCellTarget + const IndexOptionSPFreshCooldownSec + const IndexOptionSPFreshKn + const IndexOptionSPFreshLmax + const IndexOptionSPFreshLminRatio + const IndexOptionSPFreshMetric + const IndexOptionSPFreshNumDimensions + const IndexOptionSPFreshRaBitQNumExBits + const IndexOptionSPFreshReplication + const IndexOptionSPFreshSidecar + const IndexOptionTextAddAggressiveConflictRanges + const IndexOptionTextOmitPositions + const IndexOptionTextTokenizerName + const IndexOptionTextTokenizerVersion + const IndexOptionUnique + const IndexOptionVectorExtendCandidates + const IndexOptionVectorKeepPrunedConnections + const IndexOptionVectorMetric + const IndexOptionVectorNumDimensions + const IndexRangeSpaceKey + const IndexSecondarySpaceKey + const IndexSlidingWindowSpaceKey + const IndexStateSpaceKey + const IndexTypeBitmapValue + const IndexTypeCount + const IndexTypeCountNotNull + const IndexTypeCountUpdates + const IndexTypeMaxEver + const IndexTypeMaxEverLong + const IndexTypeMaxEverTuple + const IndexTypeMaxEverVersion + const IndexTypeMinEver + const IndexTypeMinEverLong + const IndexTypeMinEverTuple + const IndexTypeMultidimensional + const IndexTypePermutedMax + const IndexTypePermutedMin + const IndexTypeRank + const IndexTypeSum + const IndexTypeText + const IndexTypeTimeWindowLeaderboard + const IndexTypeValue + const IndexTypeVector + const IndexTypeVectorSPFresh + const IndexTypeVersion + const IndexUniquenessViolationsKey + const IsolationLevelSerializable + const IsolationLevelSnapshot + const LocalVersionBytes + const MaxRecordContextTagLen + const MaxRecordContextTags + const OrderFuncAscNullsFirst + const OrderFuncAscNullsLast + const OrderFuncDescNullsFirst + const OrderFuncDescNullsLast + const RecordCountKey + const RecordKey + const RecordVersionKey + const SerializableIsolation + const SnapshotIsolation + const StatisticsFormatVersion + const StoreInfoKey + const VersionBytes + var CountBytesRead = Event + var CountBytesWritten = Event + var CountDeleteIndexKey = Event + var CountDeleteIndexKeyBytes = Event + var CountDeleteIndexValueBytes = Event + var CountDeleteRecordKey = Event + var CountDeleteRecordKeyBytes = Event + var CountLoadIndexKey = Event + var CountLoadIndexKeyBytes = Event + var CountLoadIndexValueBytes = Event + var CountReads = Event + var CountSPFreshCSplitDefers = Event + var CountSPFreshCSplits = Event + var CountSPFreshCappedPostingReads = Event + var CountSPFreshEntriesScanned = Event + var CountSPFreshFilteredTruncated = Event + var CountSPFreshForwardFollows = Event + var CountSPFreshInsertFenceReads = Event + var CountSPFreshInsertReplicas = Event + var CountSPFreshLeaseSkips = Event + var CountSPFreshMerges = Event + var CountSPFreshNPAs = Event + var CountSPFreshPhase2Reached = Event + var CountSPFreshPostingsProbed = Event + var CountSPFreshPostingsPruned = Event + var CountSPFreshReadPathSplitFiles = Event + var CountSPFreshRefineConverged = Event + var CountSPFreshRefineMoves = Event + var CountSPFreshRerankReads = Event + var CountSPFreshSplits = Event + var CountSPFreshStaleRouteRetry = Event + var CountSPFreshStarvationWiden = Event + var CountSPFreshStreamWiden = Event + var CountSPFreshTaskErrors = Event + var CountSPFreshZombieCleans = Event + var CountSWDeleteUntracked = Event + var CountSWEvictedRecordMissing = Event + var CountSWItemAddedToEntriesOnly = Event + var CountSWItemAddedToWindowFilling = Event + var CountSWItemPromotedFromOverflow = Event + var CountSWOverflowEntryDeleted = Event + var CountSWPartitionCleared = Event + var CountSWPartitionEmptied = Event + var CountSWPreemptiveDeleteWriteOnly = Event + var CountSWPromotedRecordMissing = Event + var CountSWWindowEntryDeleted = Event + var CountSWWindowShrunkNoOverflow = Event + var CountSaveIndexKey = Event + var CountSaveIndexKeyBytes = Event + var CountSaveIndexValueBytes = Event + var CountSaveRecordKey = Event + var CountSaveRecordKeyBytes = Event + var CountSaveRecordValueBytes = Event + var CountWrites = Event + var EventCommit = Event + var EventDeleteRecord = Event + var EventGetReadVersion = Event + var EventLoadRecord = Event + var EventOpenStore = Event + var EventRebuildIndex = Event + var EventSPFreshInsert = Event + var EventSPFreshSearch = Event + var EventSWBoundaryRescanAfterDelete = Event + var EventSWBoundaryRescanAfterEvict = Event + var EventSWDelegateDelete = Event + var EventSWDelegateInsert = Event + var EventSWEvictAndReplace = Event + var EventSWReElectFromOverflow = Event + var EventSaveRecord = Event + var EventScanIndex = Event + var EventScanRecords = Event + var OrderAscNullsFirst = OrderDirection + var OrderAscNullsLast = OrderDirection + var OrderDescNullsFirst = OrderDirection + var OrderDescNullsLast = OrderDirection + var SizeSWWindowCount = Event + var TupleRangeAll = TupleRange + func AbsolutizeFieldTypeNames(fd *descriptorpb.FileDescriptorProto) + func AsListWithContinuation[T any](ctx context.Context, cursor RecordCursor[T]) ([]T, []byte, error) + func AsList[T any](ctx context.Context, cursor RecordCursor[T]) ([]T, error) + func BuildSPFreshIndex(ctx context.Context, db *FDBDatabase, ...) error + func CheckValidProtoBufCompliantName(name string) error + func CleanupAllHeartbeats(tx fdb.WritableTransaction, storeSubspace subspace.Subspace, index *Index) + func ClearStatistics(ctx context.Context, db *FDBDatabase, stats StatisticsSubspace, ...) error + func DecodeOnceIfReversible(stored string) string + func DeleteStore(ctx *FDBRecordContext, ss subspace.Subspace) error + func Filter2[T any](seq iter.Seq2[T, error], predicate func(T) bool) iter.Seq2[T, error] + func Filter[T any](seq iter.Seq[T], predicate func(T) bool) iter.Seq[T] + func FindRegisteredMessageType(fullName protoreflect.FullName) protoreflect.MessageType + func First[T any](ctx context.Context, cursor RecordCursor[T]) (*T, error) + func ForEach[T any](ctx context.Context, cursor RecordCursor[T], fn func(T) error) error + func GetCount[T any](ctx context.Context, cursor RecordCursor[T]) (int, error) + func GroupCountCompanionName(ownerIndexName string) string + func GroupingSignature(g *GroupingKeyExpression) []byte + func IsGroupCountCompanionFor(idx *Index, groupingSignature, predicateSignature []byte, ...) bool + func IsPermutedMinIndex(idx *Index) bool + func IsRecordTypeExpression(expr KeyExpression) bool + func KeyExpressionHasRecordTypePrefix(expr KeyExpression) bool + func Limit[T any](seq iter.Seq[T], n int) iter.Seq[T] + func LiteralToProtoValue(v any) (*gen.Value, error) + func LoadIndexStates(tx fdb.ReadTransaction, ss subspace.Subspace) (map[string]IndexState, error) + func MBRToTuple(m MBR) tuple.Tuple + func Map[T, R any](seq iter.Seq[T], fn func(T) R) iter.Seq[R] + func NeedsGroupCountCompanion(idx *Index) bool + func NewHNSWGraph(storage *hnswStorage, config HNSWConfig) *hnswGraph + func PermutedMinIgnoringNulls(ctx context.Context, scan OrdinaryIndexScanFunc, indexName string, ...) (tuple.Tuple, error) + func PredicateSignature(idx *Index) []byte + func ReadHeartbeats(tx fdb.ReadTransaction, storeSubspace subspace.Subspace, index *Index) ([]*gen.IndexBuildHeartbeat, []string, error) + func ReadStatisticsAtWithRefusal(ctx context.Context, db *FDBDatabase, stats StatisticsSubspace, ...) (StoreStatistics, StatisticsReadRefusal, int64, error) + func RebalanceSPFreshIndex(ctx context.Context, db *FDBDatabase, ...) (int, error) + func Reduce[T any, R any](ctx context.Context, cursor RecordCursor[T], initial R, fn func(R, T) R) (R, error) + func RefineSPFreshIndex(ctx context.Context, db *FDBDatabase, ...) (int, bool, error) + func RefineSPFreshIndexAll(ctx context.Context, db *FDBDatabase, ...) (int, error) + func RegisterFunction(name string, evaluator FunctionEvaluator) + func RunSPFreshMaintenance(ctx context.Context, db *FDBDatabase, opts SPFreshMaintenanceOptions) error + func SPFreshAuditTrail(fineID int64) []string + func SPFreshDebugIntegrity(rtx *FDBRecordContext, store *FDBRecordStore, indexName string, sample int) string + func SPFreshDebugTopology(rtx *FDBRecordContext, store *FDBRecordStore, indexName string) string + func SPFreshDisableAudit() + func SPFreshEnableAudit() + func SPFreshHasPendingMaintenance(ctx context.Context, db *FDBDatabase, ...) (bool, error) + func SafeDecoderOver(decoded, verbatim []string) func(string) string + func SamePredicateSignature(a, b []byte) bool + func Seq2[T any](cursor RecordCursor[T], ctx context.Context) iter.Seq2[T, error] + func SerializeVector(vec []float64) []byte + func ToProtoBufCompliantName(name string) (string, error) + func ToUserIdentifier(protoIdentifier string) string + func TranslatePrimaryKeyToValues(pk KeyExpression, normalizeName func(string) string, flowedType values.Type) []values.Value + func ValidateEvolution(oldMetaData, newMetaData *RecordMetaData) error + func ValidateHNSWConfig(c HNSWConfig) error + func ValidateRTreeConfig(config RTreeConfig) error + func ValidateSPFreshConfig(c SPFreshConfig) error + func ValidateTags(tags []string) ([]string, error) + func ValidateTokenizerVersion(t TextTokenizer, version int) error + func WriteRecordMetaData(meta *RecordMetaData, w io.Writer) error + type AggregateFunctionNotSupportedError struct + Function string + Operand string + func (e *AggregateFunctionNotSupportedError) Error() string + type BackendCapabilityError struct + Op string + func (e *BackendCapabilityError) Error() string + type BunchedEntry struct + Key K + Value V + type BunchedMap struct + func NewBunchedMap(bunchSize int) *BunchedMap + func NewInstrumentedBunchedMap(bunchSize int, timer *StoreTimer) *BunchedMap + func (m *BunchedMap) Compact(tx fdb.WritableTransaction, ss subspace.Subspace, keyLimit int, ...) ([]byte, error) + func (m *BunchedMap) ContainsKey(tx fdb.WritableTransaction, ss subspace.Subspace, key tuple.Tuple) (bool, error) + func (m *BunchedMap) Get(tx fdb.WritableTransaction, ss subspace.Subspace, key tuple.Tuple) ([]int, bool, error) + func (m *BunchedMap) Put(tx fdb.WritableTransaction, ss subspace.Subspace, key tuple.Tuple, value []int) ([]int, bool, error) + func (m *BunchedMap) Remove(tx fdb.WritableTransaction, ss subspace.Subspace, key tuple.Tuple) ([]int, bool, error) + func (m *BunchedMap) Scan(tx fdb.ReadTransaction, ss subspace.Subspace, continuation []byte, limit int, ...) *BunchedMapIterator + func (m *BunchedMap) VerifyIntegrity(tx fdb.ReadTransaction, ss subspace.Subspace) error + type BunchedMapException struct + Message string + func (e *BunchedMapException) Error() string + type BunchedMapIterator struct + func (it *BunchedMapIterator) Err() error + func (it *BunchedMapIterator) GetContinuation() []byte + func (it *BunchedMapIterator) HasNext() bool + func (it *BunchedMapIterator) Next() *bunchedEntry + type BunchedMapMultiIterator struct + func NewBunchedMapMultiIterator(tx fdb.ReadTransaction, parentSubspace subspace.Subspace, ...) *BunchedMapMultiIterator + func NewBunchedMapMultiIteratorWithCallback(tx fdb.ReadTransaction, parentSubspace subspace.Subspace, ...) *BunchedMapMultiIterator + func (it *BunchedMapMultiIterator) Cancel() + func (it *BunchedMapMultiIterator) Err() error + func (it *BunchedMapMultiIterator) GetContinuation() []byte + func (it *BunchedMapMultiIterator) HasNext() bool + func (it *BunchedMapMultiIterator) Next() *BunchedMapScanEntry + type BunchedMapScanEntry struct + Key tuple.Tuple + Subspace subspace.Subspace + SubspaceTag tuple.Tuple + Value []int + type BunchedSerializationError struct + Data []byte + Message string + func (e *BunchedSerializationError) Error() string + type BunchedSerializer interface + CanAppend func() bool + DeserializeEntries func(key K, data []byte) ([]BunchedEntry[K, V], error) + DeserializeKey func(data []byte, offset, length int) (K, error) + DeserializeKeys func(key K, data []byte) ([]K, error) + SerializeEntries func(entries []BunchedEntry[K, V]) ([]byte, error) + SerializeEntry func(key K, value V) ([]byte, error) + SerializeKey func(key K) []byte + type BytesContinuation struct + func NewBytesContinuation(b []byte) *BytesContinuation + func (c *BytesContinuation) IsEnd() bool + func (c *BytesContinuation) ToBytes() ([]byte, error) + type CardinalityFunctionKeyExpression struct + func CardinalityExpr(arguments KeyExpression) *CardinalityFunctionKeyExpression + func (c *CardinalityFunctionKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + type ChildSlot struct + ChildID []byte + ChildMBR MBR + LargestHV *big.Int + LargestKey tuple.Tuple + SmallestHV *big.Int + SmallestKey tuple.Tuple + func (s ChildSlot) GetMBR() MBR + type CollectOptions struct + BatchSize int + MaxRecordsPerType int64 + ScannedBytesLimit int64 + Tags []string + TimeLimit time.Duration + type CollectionReport struct + Collected map[string]RecordTypeStatistic + RecordsScanned int64 + Skipped map[string]string + func CollectStatistics(ctx context.Context, db *FDBDatabase, ...) (*CollectionReport, error) + type CommitCheckFunc func() error + type ComparisonKeyFunc func(T) (tuple.Tuple, error) + type CompositeKeyExpression struct + func (c *CompositeKeyExpression) ColumnSize() int + func (c *CompositeKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (c *CompositeKeyExpression) EvaluateFlat(record *FDBStoredRecord[proto.Message], msg proto.Message) ([]any, error) + func (c *CompositeKeyExpression) FieldNames() []string + func (c *CompositeKeyExpression) PackDirect(pk *tuple.Packer, record *FDBStoredRecord[proto.Message], msg proto.Message) bool + func (c *CompositeKeyExpression) SubKeyExpressions() []KeyExpression + func (c *CompositeKeyExpression) ToKeyExpression() *gen.KeyExpression + type ContinuationParseError struct + Cause error + Message string + RawBytes []byte + func (e *ContinuationParseError) Error() string + func (e *ContinuationParseError) Unwrap() error + type Counter struct + func (c *Counter) Count() int64 + func (c *Counter) CumulativeValue() int64 + func (c *Counter) Event() Event + func (c *Counter) Increment(amount int64) + func (c *Counter) Record(value int64) + func (c *Counter) Reset() + type CounterSnapshot struct + Count int64 + CumulativeValue int64 + Event Event + type CursorFactory func(continuation []byte) RecordCursor[T] + type CursorStreamingMode int + const StreamingModeIterator + const StreamingModeLarge + const StreamingModeMedium + const StreamingModeSerial + const StreamingModeSmall + const StreamingModeWantAll + func (m CursorStreamingMode) ToFDB() fdb.StreamingMode + type DefaultTextTokenizer struct + func DefaultTextTokenizerInstance() *DefaultTextTokenizer + func (t *DefaultTextTokenizer) MaxVersion() int + func (t *DefaultTextTokenizer) MinVersion() int + func (t *DefaultTextTokenizer) Name() string + func (t *DefaultTextTokenizer) Tokenize(text string, version int, mode TokenizerMode) (TokenIterator, error) + func (t *DefaultTextTokenizer) TokenizeToList(text string, version int, mode TokenizerMode) ([]string, error) + func (t *DefaultTextTokenizer) TokenizeToMap(text string, version int, mode TokenizerMode) (map[string][]int, error) + type DefaultTextTokenizerFactory struct + func (f *DefaultTextTokenizerFactory) GetTokenizer() TextTokenizer + func (f *DefaultTextTokenizerFactory) Name() string + type DimensionsKeyExpression struct + DimensionsSize int + PrefixSize int + WholeKey KeyExpression + func Dimensions(wholeKey KeyExpression, prefixSize, dimensionsSize int) *DimensionsKeyExpression + func (d *DimensionsKeyExpression) ColumnSize() int + func (d *DimensionsKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (d *DimensionsKeyExpression) FieldNames() []string + func (d *DimensionsKeyExpression) SplitIndexEntry(entry tuple.Tuple) (prefix, dims, suffix tuple.Tuple) + func (d *DimensionsKeyExpression) SuffixSize() int + func (d *DimensionsKeyExpression) ToKeyExpression() *gen.KeyExpression + type DirectPacker interface + PackDirect func(pk *tuple.Packer, record *FDBStoredRecord[proto.Message], msg proto.Message) bool + type EmptyKeyExpression struct + func (e *EmptyKeyExpression) ColumnSize() int + func (e *EmptyKeyExpression) Evaluate(_ *FDBStoredRecord[proto.Message], _ proto.Message) ([][]any, error) + func (e *EmptyKeyExpression) EvaluateFlat(_ *FDBStoredRecord[proto.Message], _ proto.Message) ([]any, error) + func (e *EmptyKeyExpression) FieldNames() []string + func (e *EmptyKeyExpression) ToKeyExpression() *gen.KeyExpression + type EndContinuation struct + func (c *EndContinuation) IsEnd() bool + func (c *EndContinuation) ToBytes() ([]byte, error) + type EndpointType int + const EndpointTypeContinuation + const EndpointTypePrefixString + const EndpointTypeRangeExclusive + const EndpointTypeRangeInclusive + const EndpointTypeTreeEnd + const EndpointTypeTreeStart + type Event struct + Kind Kind + Name string + Title string + type ExecuteProperties struct + DefaultCursorStreamingMode CursorStreamingMode + DryRun bool + FailOnScanLimitReached bool + IsolationLevel IsolationLevel + MaterializationLimit int + ReturnedRowLimit int + ScanState *ScanLimiterState + ScannedBytesLimit int64 + ScannedRecordsLimit int + Skip int + State *ExecuteState + TimeLimit time.Duration + func DefaultExecuteProperties() ExecuteProperties + func DefaultExecutePropertiesIn(env *dst.Env) ExecuteProperties + func (e ExecuteProperties) ClearRowAndTimeLimits() ExecuteProperties + func (e ExecuteProperties) ClearSkipAndLimit() ExecuteProperties + func (e ExecuteProperties) GetMaterializationLimit() int + func (e ExecuteProperties) WithDryRun(dryRun bool) ExecuteProperties + func (e ExecuteProperties) WithIsolationLevel(level IsolationLevel) ExecuteProperties + func (e ExecuteProperties) WithMaterializationLimit(limit int) ExecuteProperties + func (e ExecuteProperties) WithReturnedRowLimit(limit int) ExecuteProperties + func (e ExecuteProperties) WithScannedBytesLimit(limit int64) ExecuteProperties + func (e ExecuteProperties) WithScannedRecordsLimit(limit int) ExecuteProperties + func (e ExecuteProperties) WithSkip(skip int) ExecuteProperties + func (e ExecuteProperties) WithTimeLimit(limit time.Duration) ExecuteProperties + type ExecuteState struct + func NewExecuteState(memLimit int64) *ExecuteState + func (s *ExecuteState) ChargeMemory(n int64) error + func (s *ExecuteState) HasMemLimit() bool + func (s *ExecuteState) IncrementRecursionLevel(id any) int + func (s *ExecuteState) MemLimit() int64 + func (s *ExecuteState) MemUsed() int64 + func (s *ExecuteState) ReleaseMemory(n int64) + func (s *ExecuteState) ResetRecursionLevel(id any) + func (s *ExecuteState) RestoreRecursionLevels(snapshot map[any]int) + func (s *ExecuteState) SnapshotRecursionLevels() map[any]int + type FDBDatabase struct + func NewFDBDatabase(db fdb.Database) *FDBDatabase + func NewFDBDatabaseFromTenant(tenant fdb.Tenant) *FDBDatabase + func NewFDBDatabaseWithBackend(backend fdb.BackendDatabase) *FDBDatabase + func NewFDBDatabaseWithTransactor(transactor fdb.Transactor, db fdb.Database) *FDBDatabase + func (d *FDBDatabase) CreateTransaction() (fdb.Transaction, error) + func (d *FDBDatabase) CreateWritableTransaction() (fdb.WritableTransaction, error) + func (d *FDBDatabase) Env() *dst.Env + func (d *FDBDatabase) GetStoreStateCache() FDBRecordStoreStateCache + func (d *FDBDatabase) LocalityGetBoundaryKeys(r fdb.ExactRange, limit int, readVersion int64) ([]fdb.Key, error) + func (d *FDBDatabase) NewRecordContext(tx fdb.WritableTransaction) *FDBRecordContext + func (d *FDBDatabase) Run(ctx context.Context, fn func(rtx *FDBRecordContext) (any, error)) (any, error) + func (d *FDBDatabase) RunRead(ctx context.Context, fn func(rtx fdb.ReadTransaction) (any, error)) (any, error) + func (d *FDBDatabase) RunWithVersionstamp(ctx context.Context, fn func(rtx *FDBRecordContext) (any, error)) (any, []byte, error) + func (d *FDBDatabase) RunWithWeakReads(ctx context.Context, weak WeakReadSemantics, ...) (any, error) + func (d *FDBDatabase) SetEnv(env *dst.Env) *FDBDatabase + func (d *FDBDatabase) SetStoreStateCache(cache FDBRecordStoreStateCache) + func (d *FDBDatabase) SetTimer(timer *StoreTimer) + func (d *FDBDatabase) Timer() *StoreTimer + type FDBDatabaseFactory struct + StoreStateCacheFactory func() FDBRecordStoreStateCache + func NewFDBDatabaseFactory() *FDBDatabaseFactory + func (f *FDBDatabaseFactory) GetDatabase(clusterFile string) (*FDBDatabase, error) + type FDBDatabaseRunner struct + ContextConfig *RecordContextConfig + InitialDelay time.Duration + MaxAttempts int + MaxDelay time.Duration + func NewFDBDatabaseRunner(db *FDBDatabase) *FDBDatabaseRunner + func (r *FDBDatabaseRunner) OpenContext(ctx context.Context) (*FDBRecordContext, error) + func (r *FDBDatabaseRunner) RunWithRetry(ctx context.Context, fn func(rtx *FDBRecordContext) (any, error)) (any, error) + func (r *FDBDatabaseRunner) SetContextConfig(config *RecordContextConfig) *FDBDatabaseRunner + func (r *FDBDatabaseRunner) SetInitialDelay(d time.Duration) *FDBDatabaseRunner + func (r *FDBDatabaseRunner) SetMaxAttempts(n int) *FDBDatabaseRunner + func (r *FDBDatabaseRunner) SetMaxDelay(d time.Duration) *FDBDatabaseRunner + type FDBIndexedRecord struct + IndexEntry *IndexEntry + Record *FDBStoredRecord[proto.Message] + type FDBMetaDataStore struct + func NewFDBMetaDataStore(ss subspace.Subspace) *FDBMetaDataStore + func (s *FDBMetaDataStore) LoadRecordMetaDataProto(tx fdb.WritableTransaction) (*gen.MetaData, error) + func (s *FDBMetaDataStore) LoadRecordMetaDataProtoAtVersion(tx fdb.WritableTransaction, version int32) (*gen.MetaData, error) + func (s *FDBMetaDataStore) SaveRecordMetaData(tx fdb.WritableTransaction, metaDataProto *gen.MetaData) error + func (s *FDBMetaDataStore) SetEvolutionValidator(v *MetaDataEvolutionValidator) + func (s *FDBMetaDataStore) Subspace() subspace.Subspace + type FDBRecordContext struct + func NewFDBRecordContext(tx fdb.WritableTransaction, env *dst.Env) *FDBRecordContext + func (rc *FDBRecordContext) AddCommitCheck(check CommitCheckFunc) + func (rc *FDBRecordContext) AddPostCommit(hook PostCommitFunc) + func (rc *FDBRecordContext) AddReadConflictRange(r fdb.ExactRange) error + func (rc *FDBRecordContext) AddToLocalVersionCache(versionKey []byte, localVersion int) + func (rc *FDBRecordContext) AddVersionMutation(mutationType VersionMutationType, versionKey []byte, value []byte) + func (rc *FDBRecordContext) Cancel() + func (rc *FDBRecordContext) CheckTransactionSize() error + func (rc *FDBRecordContext) ClaimLocalVersion() int + func (rc *FDBRecordContext) Commit() error + func (rc *FDBRecordContext) CommitWithHooks() error + func (rc *FDBRecordContext) CommitWithVersionstamp() ([]byte, error) + func (rc *FDBRecordContext) Context() context.Context + func (rc *FDBRecordContext) Env() *dst.Env + func (rc *FDBRecordContext) GetApproximateTransactionSize() (int64, error) + func (rc *FDBRecordContext) GetConflictingKeys() []fdb.KeyRange + func (rc *FDBRecordContext) GetLocalVersion(versionKey []byte) (int, bool) + func (rc *FDBRecordContext) GetMetaDataVersionStamp() ([]byte, error) + func (rc *FDBRecordContext) GetReadVersion() (int64, error) + func (rc *FDBRecordContext) HasDirtyStoreState() bool + func (rc *FDBRecordContext) HasVersionMutations() bool + func (rc *FDBRecordContext) PutSession(key string, value any) + func (rc *FDBRecordContext) ReadTransaction(snapshot bool) fdb.ReadTransaction + func (rc *FDBRecordContext) RemoveLocalVersion(versionKey []byte) + func (rc *FDBRecordContext) RemoveLocalVersionsInRange(begin, end fdb.Key) + func (rc *FDBRecordContext) RemoveVersionMutation(versionKey []byte) + func (rc *FDBRecordContext) RemoveVersionMutationsInRange(begin, end fdb.Key) + func (rc *FDBRecordContext) Session(key string) any + func (rc *FDBRecordContext) SetDirtyStoreState(dirty bool) + func (rc *FDBRecordContext) SetMetaDataVersionStamp() + func (rc *FDBRecordContext) SetReadVersion(version int64) + func (rc *FDBRecordContext) SetTimer(timer *StoreTimer) + func (rc *FDBRecordContext) SetTransactionPriority(priority TransactionPriority) error + func (rc *FDBRecordContext) Timer() *StoreTimer + func (rc *FDBRecordContext) Transaction() fdb.WritableTransaction + func (rc *FDBRecordContext) TransactionID() int64 + func (rc *FDBRecordContext) UpdateVersionMutation(mutationType VersionMutationType, versionKey []byte, value []byte, ...) + type FDBRecordStore struct + func (store *FDBRecordStore) AcquireReadLock(key string) + func (store *FDBRecordStore) AcquireWriteLock(key string) + func (store *FDBRecordStore) AddBuildProgress(index *Index, count int64) + func (store *FDBRecordStore) AddRecordReadConflict(primaryKey tuple.Tuple) error + func (store *FDBRecordStore) AddRecordWriteConflict(primaryKey tuple.Tuple) error + func (store *FDBRecordStore) AddUniquenessViolation(index *Index, indexKey tuple.Tuple, primaryKey tuple.Tuple) error + func (store *FDBRecordStore) AddUniquenessViolationWithExisting(index *Index, indexKey tuple.Tuple, primaryKey tuple.Tuple, ...) error + func (store *FDBRecordStore) AsBuilder() *StoreBuilder + func (store *FDBRecordStore) ClearAndMarkIndexWriteOnly(indexName string) (bool, error) + func (store *FDBRecordStore) ClearHeaderUserField(key string) error + func (store *FDBRecordStore) ClearStoreLockState() error + func (store *FDBRecordStore) Context() *FDBRecordContext + func (store *FDBRecordStore) CopyBuilder(newContext *FDBRecordContext) *StoreBuilder + func (store *FDBRecordStore) CountRecords(ctx context.Context, low, high tuple.Tuple, ...) (int, error) + func (store *FDBRecordStore) DeleteAllRecords() error + func (store *FDBRecordStore) DeleteIndexEntries(index *Index) + func (store *FDBRecordStore) DeleteIndexEntriesInRange(index *Index, prefix tuple.Tuple) error + func (store *FDBRecordStore) DeleteRecord(primaryKey tuple.Tuple) (bool, error) + func (store *FDBRecordStore) DeleteRecordsWhere(prefix tuple.Tuple) error + func (store *FDBRecordStore) DryRunDeleteRecord(primaryKey tuple.Tuple) (bool, error) + func (store *FDBRecordStore) DryRunSaveRecord(record proto.Message, existenceCheck RecordExistenceCheck) (*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) Env() *dst.Env + func (store *FDBRecordStore) EstimateIndexSize(index *Index) (int64, error) + func (store *FDBRecordStore) EstimateRecordsSize() (int64, error) + func (store *FDBRecordStore) EstimateRecordsSizeInRange(tupleRange TupleRange) (int64, error) + func (store *FDBRecordStore) EstimateStoreSize() (int64, error) + func (store *FDBRecordStore) EvaluateAggregateFunction(ctx context.Context, recordTypeNames []string, fn *IndexAggregateFunction, ...) (tuple.Tuple, error) + func (store *FDBRecordStore) EvaluateRecordFunction(fn *IndexRecordFunction, record *FDBStoredRecord[proto.Message]) (*int64, error) + func (store *FDBRecordStore) EvaluateStoreFunction(fn *StoreRecordFunction, record *FDBStoredRecord[proto.Message]) (any, error) + func (store *FDBRecordStore) FirstUnbuiltRange(index *Index) (*RangeSetRange, error) + func (store *FDBRecordStore) GetAllIndexStates() map[string]IndexState + func (store *FDBRecordStore) GetAllIndexStatesMap() map[string]IndexState + func (store *FDBRecordStore) GetContext() *FDBRecordContext + func (store *FDBRecordStore) GetDisabledIndexes() []*Index + func (store *FDBRecordStore) GetEnabledIndexes() []*Index + func (store *FDBRecordStore) GetEnabledUniversalIndexes() []*Index + func (store *FDBRecordStore) GetFormatVersion() int32 + func (store *FDBRecordStore) GetHeaderUserField(key string) ([]byte, error) + func (store *FDBRecordStore) GetIncarnation() (int32, error) + func (store *FDBRecordStore) GetIndexMaintainer(index *Index) (IndexMaintainer, error) + func (store *FDBRecordStore) GetIndexState(indexName string) IndexState + func (store *FDBRecordStore) GetIndexesToBuildSince(version int) []*Index + func (store *FDBRecordStore) GetKeySizeLimit() int + func (store *FDBRecordStore) GetMetaData() *RecordMetaData + func (store *FDBRecordStore) GetMetaDataVersion() int32 + func (store *FDBRecordStore) GetRangeSplitPoints(chunkSize int64) ([]fdb.Key, error) + func (store *FDBRecordStore) GetReadableIndexes() []*Index + func (store *FDBRecordStore) GetReadableUniversalIndexes() []*Index + func (store *FDBRecordStore) GetRecordCount() (int64, error) + func (store *FDBRecordStore) GetRecordMetaData() *RecordMetaData + func (store *FDBRecordStore) GetRecordStoreState() *RecordStoreState + func (store *FDBRecordStore) GetSnapshotRecordCount(countKey tuple.Tuple) (int64, error) + func (store *FDBRecordStore) GetSnapshotRecordCountForRecordType(recordTypeName string) (int64, error) + func (store *FDBRecordStore) GetStoreHeader() *gen.DataStoreInfo + func (store *FDBRecordStore) GetSubspace() subspace.Subspace + func (store *FDBRecordStore) GetUserVersion() int32 + func (store *FDBRecordStore) GetValueSizeLimit() int + func (store *FDBRecordStore) GetWriteOnlyIndexes() []*Index + func (store *FDBRecordStore) IndexSecondarySubspace(index *Index) subspace.Subspace + func (store *FDBRecordStore) IndexStateSubspace() subspace.Subspace + func (store *FDBRecordStore) IndexSubspace(index *Index) subspace.Subspace + func (store *FDBRecordStore) InsertRecord(record proto.Message) (*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) IsCacheable() bool + func (store *FDBRecordStore) IsIndexDisabled(indexName string) bool + func (store *FDBRecordStore) IsIndexReadable(indexName string) bool + func (store *FDBRecordStore) IsIndexReadableUniquePending(indexName string) bool + func (store *FDBRecordStore) IsIndexScannable(indexName string) bool + func (store *FDBRecordStore) IsIndexWriteOnly(indexName string) bool + func (store *FDBRecordStore) IsStateCacheable() bool + func (store *FDBRecordStore) IsVersionChanged() bool + func (store *FDBRecordStore) LoadBuildProgress(index *Index) (int64, error) + func (store *FDBRecordStore) LoadIndexingTypeStamp(index *Index) (*gen.IndexBuildIndexingStamp, error) + func (store *FDBRecordStore) LoadRecord(primaryKey tuple.Tuple) (*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) LoadRecordVersion(primaryKey tuple.Tuple, snapshot bool) (*FDBRecordVersion, error) + func (store *FDBRecordStore) MarkIndexDisabled(indexName string) (bool, error) + func (store *FDBRecordStore) MarkIndexReadable(indexName string) (bool, error) + func (store *FDBRecordStore) MarkIndexReadableOrUniquePending(indexName string) (bool, error) + func (store *FDBRecordStore) MarkIndexWriteOnly(indexName string) (bool, error) + func (store *FDBRecordStore) OverrideLockSaveRecord(record proto.Message, existenceCheck RecordExistenceCheck) (*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) RebuildAllIndexes() error + func (store *FDBRecordStore) RebuildIndex(index *Index) error + func (store *FDBRecordStore) RecordExists(primaryKey tuple.Tuple, isolationLevel IsolationLevel) (bool, error) + func (store *FDBRecordStore) RecordsSubspace() subspace.Subspace + func (store *FDBRecordStore) ReleaseReadLock(key string) + func (store *FDBRecordStore) ReleaseWriteLock(key string) + func (store *FDBRecordStore) ReloadRecordStoreState() error + func (store *FDBRecordStore) ResolveUniquenessViolation(index *Index, indexKey tuple.Tuple, primaryKey tuple.Tuple) error + func (store *FDBRecordStore) ResolveUniquenessViolationByDeletion(index *Index, valueKey tuple.Tuple, remainPrimaryKey tuple.Tuple) error + func (store *FDBRecordStore) SaveIndexingTypeStamp(index *Index, stamp *gen.IndexBuildIndexingStamp) error + func (store *FDBRecordStore) SaveRecord(record proto.Message) (*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) SaveRecordBatch(records []proto.Message) ([]*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) SaveRecordWithOptions(record proto.Message, existenceCheck RecordExistenceCheck) (*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) ScanIndex(index *Index, scanRange TupleRange, continuation []byte, ...) RecordCursor[*IndexEntry] + func (store *FDBRecordStore) ScanIndexByType(index *Index, scanType IndexScanType, scanRange TupleRange, ...) RecordCursor[*IndexEntry] + func (store *FDBRecordStore) ScanIndexRecords(indexName string, scanRange TupleRange, continuation []byte, ...) RecordCursor[*FDBIndexedRecord] + func (store *FDBRecordStore) ScanRecordKeys(continuation []byte, scanProperties ScanProperties) RecordCursor[tuple.Tuple] + func (store *FDBRecordStore) ScanRecords(continuation []byte, scanProperties ScanProperties) RecordCursor[*FDBStoredRecord[proto.Message]] + func (store *FDBRecordStore) ScanRecordsByType(recordTypeName string, continuation []byte, scanProperties ScanProperties) RecordCursor[*FDBStoredRecord[proto.Message]] + func (store *FDBRecordStore) ScanRecordsInRange(low, high tuple.Tuple, lowEndpoint, highEndpoint EndpointType, ...) RecordCursor[*FDBStoredRecord[proto.Message]] + func (store *FDBRecordStore) ScanTimeWindowLeaderboard(index *Index, scanType IndexScanType, leaderboardType int, ...) RecordCursor[*IndexEntry] + func (store *FDBRecordStore) ScanUniquenessViolations(index *Index) ([]UniquenessViolation, error) + func (store *FDBRecordStore) ScanUniquenessViolationsForValue(index *Index, valueKey tuple.Tuple) ([]UniquenessViolation, error) + func (store *FDBRecordStore) ScanVectorIndex(index *Index, queryVector []float64, k int, efSearch int, continuation []byte, ...) RecordCursor[*IndexEntry] + func (store *FDBRecordStore) ScanVectorIndexWithPrefix(index *Index, prefix tuple.Tuple, queryVector []float64, k int, efSearch int, ...) RecordCursor[*IndexEntry] + func (store *FDBRecordStore) SearchVectorIndex(index *Index, queryVector []float64, k int, efSearch int) ([]VectorSearchResult, error) + func (store *FDBRecordStore) SearchVectorIndexRecords(ctx context.Context, index *Index, queryVector []float64, k int, efSearch int) ([]*FDBIndexedRecord, error) + func (store *FDBRecordStore) SearchVectorIndexRecordsWithPrefix(ctx context.Context, index *Index, prefix tuple.Tuple, queryVector []float64, ...) ([]*FDBIndexedRecord, error) + func (store *FDBRecordStore) SearchVectorIndexWithPrefix(index *Index, prefix tuple.Tuple, queryVector []float64, k int, efSearch int) ([]VectorSearchResult, error) + func (store *FDBRecordStore) SetFormatVersion(version int32) error + func (store *FDBRecordStore) SetHeaderUserField(key string, value []byte) error + func (store *FDBRecordStore) SetStateCacheability(cacheable bool) (bool, error) + func (store *FDBRecordStore) SetStoreLockState(state gen.DataStoreInfo_StoreLockState_State, reason string) error + func (store *FDBRecordStore) SetUserVersion(version int32) error + func (store *FDBRecordStore) Subspace() subspace.Subspace + func (store *FDBRecordStore) UpdateIncarnation(updater func(current int32) int32) error + func (store *FDBRecordStore) UpdateRecord(record proto.Message) (*FDBStoredRecord[proto.Message], error) + func (store *FDBRecordStore) UpdateRecordCountState(newState gen.DataStoreInfo_RecordCountState) error + func (store *FDBRecordStore) VacuumReadableIndexesBuildData() + func (store *FDBRecordStore) ValidateIndex(ctx context.Context, index *Index) (*IndexValidationResult, error) + type FDBRecordStoreStateCache interface + Clear func() + Get func(store *FDBRecordStore, existenceCheck StoreExistenceCheck) (*FDBRecordStoreStateCacheEntry, error) + func PassThroughStoreStateCache() FDBRecordStoreStateCache + type FDBRecordStoreStateCacheEntry struct + func (e *FDBRecordStoreStateCacheEntry) GetMetaDataVersionStamp() []byte + func (e *FDBRecordStoreStateCacheEntry) GetRecordStoreState() *RecordStoreState + type FDBRecordVersion struct + func CompleteVersionFromBytes(b []byte) (*FDBRecordVersion, error) + func FirstInDBVersion(dbVersion int64) *FDBRecordVersion + func FirstInGlobalVersion(globalVersion []byte) (*FDBRecordVersion, error) + func FromVersionstamp(vs tuple.Versionstamp) *FDBRecordVersion + func IncompleteVersion(localVersion int) (*FDBRecordVersion, error) + func LastInDBVersion(dbVersion int64) *FDBRecordVersion + func LastInGlobalVersion(globalVersion []byte) (*FDBRecordVersion, error) + func MaxVersion() *FDBRecordVersion + func MinVersion() *FDBRecordVersion + func NewCompleteVersion(globalVersion []byte, localVersion int) (*FDBRecordVersion, error) + func (v *FDBRecordVersion) Equal(other *FDBRecordVersion) bool + func (v *FDBRecordVersion) GetDBVersion() (int64, error) + func (v *FDBRecordVersion) GetGlobalVersion() ([]byte, error) + func (v *FDBRecordVersion) GetLocalVersion() int + func (v *FDBRecordVersion) IsComplete() bool + func (v *FDBRecordVersion) Less(other *FDBRecordVersion) bool + func (v *FDBRecordVersion) Next() (*FDBRecordVersion, error) + func (v *FDBRecordVersion) Prev() (*FDBRecordVersion, error) + func (v *FDBRecordVersion) String() string + func (v *FDBRecordVersion) ToBytes() []byte + func (v *FDBRecordVersion) ToVersionstamp() (tuple.Versionstamp, error) + func (v *FDBRecordVersion) WithCommittedVersion(committedVersion []byte) (*FDBRecordVersion, error) + type FDBStoredRecord struct + KeyCount int + KeySize int + PrimaryKey tuple.Tuple + Record M + RecordType *RecordType + Split bool + Store *FDBRecordStore + ValueSize int + Version *FDBRecordVersion + func (r *FDBStoredRecord[M]) HasVersion() bool + type FanType int + const FanTypeConcatenate + const FanTypeFanOut + const FanTypeNone + type FieldKeyExpression struct + func (f *FieldKeyExpression) ColumnSize() int + func (f *FieldKeyExpression) Evaluate(_ *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (f *FieldKeyExpression) EvaluateFlat(record *FDBStoredRecord[proto.Message], msg proto.Message) ([]any, error) + func (f *FieldKeyExpression) EvaluateInt64(record *FDBStoredRecord[proto.Message], msg proto.Message) (int64, bool, error) + func (f *FieldKeyExpression) EvaluateScalar(record *FDBStoredRecord[proto.Message], msg proto.Message) (any, error) + func (f *FieldKeyExpression) FieldNames() []string + func (f *FieldKeyExpression) PackDirect(pk *tuple.Packer, _ *FDBStoredRecord[proto.Message], msg proto.Message) bool + func (f *FieldKeyExpression) ToKeyExpression() *gen.KeyExpression + type FlatEvaluator interface + EvaluateFlat func(record *FDBStoredRecord[proto.Message], msg proto.Message) ([]any, error) + type FormerIndex struct + AddedVersion int + FormerName string + RemovedVersion int + SubspaceKey any + type FoundSplitOutOfOrderError struct + Expected int64 + Found int64 + KeyTuple tuple.Tuple + func (e *FoundSplitOutOfOrderError) Error() string + func (e *FoundSplitOutOfOrderError) Unwrap() error + type FoundSplitWithoutStartError struct + KeyTuple tuple.Tuple + NextIndex int64 + Reverse bool + func (e *FoundSplitWithoutStartError) Error() string + type FunctionEvaluator func(record *FDBStoredRecord[proto.Message], msg proto.Message, arguments [][]any) ([][]any, error) + type FunctionKeyExpression struct + func FunctionExpr(name string, arguments KeyExpression) *FunctionKeyExpression + func OrderFuncExpr(direction string, arguments KeyExpression) *FunctionKeyExpression + func (f *FunctionKeyExpression) Arguments() KeyExpression + func (f *FunctionKeyExpression) ColumnSize() int + func (f *FunctionKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (f *FunctionKeyExpression) FieldNames() []string + func (f *FunctionKeyExpression) Name() string + func (f *FunctionKeyExpression) ToKeyExpression() *gen.KeyExpression + type GroupingKeyExpression struct + func GroupAll(expr KeyExpression) *GroupingKeyExpression + func GroupBy(grouped KeyExpression, groupBy ...KeyExpression) *GroupingKeyExpression + func Ungrouped(expr KeyExpression) *GroupingKeyExpression + func (g *GroupingKeyExpression) ColumnSize() int + func (g *GroupingKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (g *GroupingKeyExpression) EvaluateFlat(record *FDBStoredRecord[proto.Message], msg proto.Message) ([]any, error) + func (g *GroupingKeyExpression) FieldNames() []string + func (g *GroupingKeyExpression) GetGroupedCount() int + func (g *GroupingKeyExpression) GetGroupingCount() int + func (g *GroupingKeyExpression) ToKeyExpression() *gen.KeyExpression + type HNSWConfig struct + EfConstruction int + EfRepair int + ExtendCandidates bool + KeepPrunedConnections bool + M int + MMax int + MMax0 int + MaintainStatsProbability float64 + MaxNumConcurrentDeleteFromLayer int + MaxNumConcurrentNeighborhoodFetches int + MaxNumConcurrentNodeFetches int + Metric VectorMetric + NumDimensions int + Quantizer VectorQuantizer + SampleVectorStatsProbability float64 + StatsThreshold int + UseInlining bool + func DefaultHNSWConfig(numDimensions int) HNSWConfig + type HNSWStats struct + CacheHits atomic.Int64 + FDBBatchGets atomic.Int64 + FDBGets atomic.Int64 + FDBRangeReads atomic.Int64 + func GetHNSWStats(ctx context.Context) *HNSWStats + func WithHNSWStats(ctx context.Context) (context.Context, *HNSWStats) + type IncompleteVersionstampError struct + Context string + func (e *IncompleteVersionstampError) Error() string + type Index struct + AddedVersion int + LastModifiedVersion int + Name string + Options map[string]string + Predicate IndexPredicate + RootExpression KeyExpression + Type string + func NewBitmapValueIndex(name string, rootExpression KeyExpression) *Index + func NewCountIndex(name string, rootExpression KeyExpression) *Index + func NewCountNotNullIndex(name string, rootExpression KeyExpression) *Index + func NewCountUpdatesIndex(name string, rootExpression KeyExpression) *Index + func NewGroupCountCompanion(idx *Index) (*Index, bool) + func NewIndex(name string, rootExpression KeyExpression) *Index + func NewMaxEverLongIndex(name string, rootExpression KeyExpression) *Index + func NewMaxEverTupleIndex(name string, rootExpression KeyExpression) *Index + func NewMaxEverVersionIndex(name string, rootExpression KeyExpression) *Index + func NewMinEverLongIndex(name string, rootExpression KeyExpression) *Index + func NewMinEverTupleIndex(name string, rootExpression KeyExpression) *Index + func NewMultidimensionalIndex(name string, rootExpression KeyExpression) *Index + func NewPermutedMaxIndex(name string, rootExpression KeyExpression, permutedSize int) *Index + func NewPermutedMinIndex(name string, rootExpression KeyExpression, permutedSize int) *Index + func NewRankIndex(name string, rootExpression KeyExpression) *Index + func NewSumIndex(name string, rootExpression KeyExpression) *Index + func NewTextIndex(name string, rootExpression KeyExpression) *Index + func NewTimeWindowLeaderboardIndex(name string, rootExpression KeyExpression) *Index + func NewVectorIndex(name string, rootExpression KeyExpression, numDimensions int) *Index + func NewVersionIndex(name string, rootExpression KeyExpression) *Index + func (i *Index) CreatesDuplicates() bool + func (idx *Index) CanonicalType() string + func (idx *Index) GetBooleanOption(key string, defaultVal bool) bool + func (idx *Index) GetPredicateProto() *gen.Predicate + func (idx *Index) GetReplacedByIndexNames() []string + func (idx *Index) HasExplicitSubspaceKey() bool + func (idx *Index) HasFilteringPredicate() bool + func (idx *Index) HasPredicate() bool + func (idx *Index) HasPrimaryKeyComponentPositions() bool + func (idx *Index) HasRowNumberWindowPredicate() bool + func (idx *Index) IsAtomicMutationIndex() bool + func (idx *Index) IsClearWhenZero() bool + func (idx *Index) IsUnique() bool + func (idx *Index) PrimaryKeyComponentPositions() []int + func (idx *Index) RowNumberWindowSpec() (*RowNumberWindowSpec, error) + func (idx *Index) SetClearWhenZero(clear bool) *Index + func (idx *Index) SetPredicate(p IndexPredicate) *Index + func (idx *Index) SetPredicateProto(p *gen.Predicate) error + func (idx *Index) SetSubspaceKey(key any) *Index + func (idx *Index) SetUnique() *Index + func (idx *Index) SubspaceTupleKey() any + func (idx *Index) TrimPrimaryKey(primaryKey tuple.Tuple) (tuple.Tuple, error) + type IndexAggregateFunction struct + Index string + Name string + Operand KeyExpression + func NewCountAggregateFunction(operand KeyExpression) *IndexAggregateFunction + func NewMaxAggregateFunction(operand KeyExpression) *IndexAggregateFunction + func NewMaxEverAggregateFunction(operand KeyExpression) *IndexAggregateFunction + func NewMinAggregateFunction(operand KeyExpression) *IndexAggregateFunction + func NewMinEverAggregateFunction(operand KeyExpression) *IndexAggregateFunction + func NewSumAggregateFunction(operand KeyExpression) *IndexAggregateFunction + type IndexBuildState struct + RecordsInTotal *int64 + RecordsScanned *int64 + State IndexState + func LoadIndexBuildState(store *FDBRecordStore, index *Index) (*IndexBuildState, error) + type IndexEntry struct + Index *Index + Key tuple.Tuple + Value tuple.Tuple + func (e *IndexEntry) IndexValues() tuple.Tuple + func (e *IndexEntry) PrimaryKey() tuple.Tuple + type IndexKeySizeError struct + IndexName string + KeySize int + Limit int + PrimaryKey tuple.Tuple + func (e *IndexKeySizeError) Error() string + type IndexMaintainer interface + CanDeleteWhere func(prefix tuple.Tuple) error + DeleteWhere func(prefix tuple.Tuple) error + Scan func(scanRange TupleRange, continuation []byte, scanProperties ScanProperties) RecordCursor[*IndexEntry] + Update func(oldRecord, newRecord *FDBStoredRecord[proto.Message]) error + UpdateWhileWriteOnly func(oldRecord, newRecord *FDBStoredRecord[proto.Message]) error + type IndexNotBuiltError struct + IndexName string + func (e *IndexNotBuiltError) Error() string + type IndexNotFoundError struct + IndexName string + func (e *IndexNotFoundError) Error() string + type IndexNotReadableError struct + CurrentState IndexState + IndexName string + func (e *IndexNotReadableError) Error() string + type IndexPredicate func(msg proto.Message) bool + type IndexRebuildPolicy func(index *Index, recordCount int64, indexOnNewRecordTypes bool) IndexState + type IndexRecordFunction struct + Index string + Name string + Operand KeyExpression + TimeWindow *TimeWindowForFunction + type IndexScanType string + const IndexScanByDistance + const IndexScanByDistanceOrderedStream + const IndexScanByGroup + const IndexScanByRank + const IndexScanByTextToken + const IndexScanByTimeWindow + const IndexScanByValue + type IndexState int + const IndexStateDisabled + const IndexStateReadable + const IndexStateReadableUniquePending + const IndexStateWriteOnly + func AlwaysRebuildPolicy(_ *Index, _ int64, _ bool) IndexState + func DefaultIndexRebuildPolicy(index *Index, recordCount int64, indexOnNewRecordTypes bool) IndexState + func WriteOnlyIfTooLargePolicy(index *Index, recordCount int64, indexOnNewRecordTypes bool) IndexState + func (s IndexState) IsDisabled() bool + func (s IndexState) IsScannable() bool + func (s IndexState) IsWriteOnly() bool + func (s IndexState) String() string + type IndexValidationEntry struct + IndexKey tuple.Tuple + PrimaryKey tuple.Tuple + type IndexValidationResult struct + MissingEntries []IndexValidationEntry + OrphanedEntries []IndexValidationEntry + TotalEntriesScanned int + TotalRecordsScanned int + func (r *IndexValidationResult) IsValid() bool + type IndexValueSizeError struct + IndexName string + Limit int + PrimaryKey tuple.Tuple + ValueSize int + func (e *IndexValueSizeError) Error() string + type IndexVersionKind string + const IndexVersionAdded + const IndexVersionLastModified + type IndexVersionTooNewError struct + AddedVersion int + IndexName string + Kind IndexVersionKind + LastModifiedVersion int + MetaDataVersion int + func (e *IndexVersionTooNewError) Error() string + func (e *IndexVersionTooNewError) Unwrap() error + type IndexingHeartbeat struct + func NewIndexingHeartbeat(info string, leaseLengthMs int64, allowMutual bool, env *dst.Env) *IndexingHeartbeat + func (h *IndexingHeartbeat) CheckAndUpdate(tx fdb.WritableTransaction, storeSubspace subspace.Subspace, index *Index) error + func (h *IndexingHeartbeat) Cleanup(tx fdb.WritableTransaction, storeSubspace subspace.Subspace, index *Index) + type IndexingPolicy struct + AllowUnblock bool + AllowUnblockID string + AllowedTakeovers map[TakeoverType]bool + ForceStampOverwrite bool + func (p *IndexingPolicy) ShouldAllowTypeConversionContinue(newStamp, savedStamp *gen.IndexBuildIndexingStamp) bool + func (p *IndexingPolicy) ShouldAllowUnblock(stampBlockID string) bool + type IndexingRangeSet struct + func NewIndexingRangeSet(storeSubspace subspace.Subspace, index *Index) *IndexingRangeSet + func (irs *IndexingRangeSet) Clear(tr fdb.WritableTransaction) + func (irs *IndexingRangeSet) ContainsKey(tr fdb.WritableTransaction, key []byte) (bool, error) + func (irs *IndexingRangeSet) FirstMissingRange(tr fdb.WritableTransaction) (*RangeSetRange, error) + func (irs *IndexingRangeSet) InsertRange(tr fdb.WritableTransaction, begin, end []byte, requireEmpty bool) (bool, error) + func (irs *IndexingRangeSet) IsComplete(tr fdb.WritableTransaction) (bool, error) + func (irs *IndexingRangeSet) ListMissingRanges(tr fdb.WritableTransaction) ([]RangeSetRange, error) + func (irs *IndexingRangeSet) ListMissingRangesInBytes(tr fdb.WritableTransaction, begin, end []byte) ([]RangeSetRange, error) + type Int64Evaluator interface + EvaluateInt64 func(record *FDBStoredRecord[proto.Message], msg proto.Message) (int64, bool, error) + type IntersectionChildResume struct + Continuation []byte + Started bool + func DecodeIntersectionContinuation(data []byte, n int) ([]IntersectionChildResume, error) + type InvalidNameError = protoname.InvalidNameError + type IsolationLevel int + func (level IsolationLevel) IsSnapshot() bool + func (level IsolationLevel) String() string + type ItemSlot struct + HilbertValue *big.Int + KeySuffix tuple.Tuple + Point Point + Value tuple.Tuple + func (s ItemSlot) GetMBR() MBR + func (s ItemSlot) ItemKey() tuple.Tuple + type KVCallback func(keyLen, valueLen int) + type KeyExpression interface + ColumnSize func() int + Evaluate func(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + FieldNames func() []string + ToKeyExpression func() *gen.KeyExpression + func Concat(exprs ...KeyExpression) KeyExpression + func EmptyKey() KeyExpression + func FanOut(name string) KeyExpression + func Field(name string) KeyExpression + func FieldConcatenate(name string) KeyExpression + func GetNestedExpression(expr KeyExpression) KeyExpression + func GroupingKeyExpressionOf(g *GroupingKeyExpression) (KeyExpression, bool) + func KeyExpressionFromProto(expr *gen.KeyExpression) (KeyExpression, error) + func Nest(parentField string, child KeyExpression) KeyExpression + func NestFanOut(parentField string, child KeyExpression) KeyExpression + type KeyExpressionError struct + Message string + func (e *KeyExpressionError) Error() string + type KeyWithValueExpression struct + func KeyWithValue(inner KeyExpression, splitPoint int) *KeyWithValueExpression + func (k *KeyWithValueExpression) ColumnSize() int + func (k *KeyWithValueExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (k *KeyWithValueExpression) FieldNames() []string + func (k *KeyWithValueExpression) InnerKey() KeyExpression + func (k *KeyWithValueExpression) SplitEvaluatedKey(fullKey []any) (keyPart []any, valuePart []any) + func (k *KeyWithValueExpression) SplitPoint() int + func (k *KeyWithValueExpression) ToKeyExpression() *gen.KeyExpression + type Kind uint8 + const KindCount + const KindSize + const KindSizeDistribution + const KindTimed + const KindUnspecified + func (k Kind) String() string + type ListKeyExpression struct + func ListExpr(children ...KeyExpression) *ListKeyExpression + func (l *ListKeyExpression) ColumnSize() int + func (l *ListKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (l *ListKeyExpression) FieldNames() []string + func (l *ListKeyExpression) GetChildren() []KeyExpression + func (l *ListKeyExpression) ToKeyExpression() *gen.KeyExpression + type LiteralKeyExpression struct + func Literal(value any) *LiteralKeyExpression + func (l *LiteralKeyExpression) ColumnSize() int + func (l *LiteralKeyExpression) Evaluate(_ *FDBStoredRecord[proto.Message], _ proto.Message) ([][]any, error) + func (l *LiteralKeyExpression) FieldNames() []string + func (l *LiteralKeyExpression) GetValue() any + func (l *LiteralKeyExpression) ToKeyExpression() *gen.KeyExpression + type MBR struct + High []int64 + Low []int64 + func MBRFromPoint(p Point) MBR + func MBRFromTuple(t tuple.Tuple, numDimensions int) (MBR, error) + func (m MBR) ContainsPoint(p Point) bool + func (m MBR) NumDimensions() int + func (m MBR) Overlaps(other MBR) bool + func (m MBR) Union(other MBR) MBR + type MemoryLimitExceededError struct + Limit int64 + Used int64 + func (e *MemoryLimitExceededError) Error() string + type MetaDataError struct + Message string + func (e *MetaDataError) Error() string + type MetaDataEvolutionError struct + Message string + func (e *MetaDataEvolutionError) Error() string + type MetaDataEvolutionValidator struct + func DefaultMetaDataEvolutionValidator() *MetaDataEvolutionValidator + func (v *MetaDataEvolutionValidator) Validate(oldMetaData, newMetaData *RecordMetaData) error + type MetaDataEvolutionValidatorBuilder struct + func NewMetaDataEvolutionValidator() *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) Build() *MetaDataEvolutionValidator + func (b *MetaDataEvolutionValidatorBuilder) SetAllowDeprecatedFieldRenames(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowFieldRenames(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowIndexRebuilds(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowMissingFormerIndexNames(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowNoSinceVersion(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowNoVersionChange(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowOlderFormerIndexAddedVersion(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowUndeprecatingFields(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetAllowUnsplitToSplit(v bool) *MetaDataEvolutionValidatorBuilder + func (b *MetaDataEvolutionValidatorBuilder) SetDisallowTypeRenames(v bool) *MetaDataEvolutionValidatorBuilder + type MetaDataVersionMustIncreaseError struct + NewVersion int32 + OldVersion int32 + func (e *MetaDataVersionMustIncreaseError) Error() string + type MetaDataVersionStampStoreStateCache struct + func NewMetaDataVersionStampStoreStateCache(opts ...MetaDataVersionStampStoreStateCacheOption) *MetaDataVersionStampStoreStateCache + func (c *MetaDataVersionStampStoreStateCache) Clear() + func (c *MetaDataVersionStampStoreStateCache) Get(store *FDBRecordStore, existenceCheck StoreExistenceCheck) (*FDBRecordStoreStateCacheEntry, error) + type MetaDataVersionStampStoreStateCacheOption func(*MetaDataVersionStampStoreStateCache) + func WithExpireAfterAccess(d time.Duration) MetaDataVersionStampStoreStateCacheOption + func WithMaxSize(n int) MetaDataVersionStampStoreStateCacheOption + type NestingKeyExpression struct + func (n *NestingKeyExpression) ColumnSize() int + func (n *NestingKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (n *NestingKeyExpression) FieldNames() []string + func (n *NestingKeyExpression) ToKeyExpression() *gen.KeyExpression + type NoNextReason int + const ByteLimitReached + const ReturnLimitReached + const ScanLimitReached + const SourceExhausted + const TimeLimitReached + func (r NoNextReason) IsLimitReached() bool + func (r NoNextReason) IsOutOfBand() bool + func (r NoNextReason) IsSourceExhausted() bool + type NodeKind byte + const NodeKindIntermediate + const NodeKindLeaf + type OnlineIndexer struct + func (oi *OnlineIndexer) BlockIndex(ctx context.Context, blockID string, ttl time.Duration) error + func (oi *OnlineIndexer) BuildIndex(ctx context.Context) (int64, error) + func (oi *OnlineIndexer) MarkReadableIfBuilt(ctx context.Context) (bool, error) + func (oi *OnlineIndexer) QueryIndexingStamps(ctx context.Context) (map[string]*gen.IndexBuildIndexingStamp, error) + func (oi *OnlineIndexer) UnblockIndex(ctx context.Context, blockID string) error + type OnlineIndexerBuilder struct + func NewOnlineIndexerBuilder() *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) AddTargetIndex(index *Index) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) Build() (*OnlineIndexer, error) + func (b *OnlineIndexerBuilder) SetAllowUniquePendingState(allow bool) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetDatabase(db *FDBDatabase) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetEnforcedPostTransactionDelay(ms int) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetFormatVersion(version int32) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetIndex(index *Index) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetLeaseLengthMs(ms int64) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetLimit(limit int) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetLogger(logger *slog.Logger) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetMarkReadable(v bool) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetMaxRetries(maxRetries int) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetMetaData(md *RecordMetaData) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetMutualIndexing() *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetMutualIndexingBoundaries(boundaries [][]byte) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetPolicy(policy *IndexingPolicy) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetProgressLogIntervalMillis(ms int64) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetRecordTypes(types ...string) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetRecordsPerSecond(rps int) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetSourceIndex(index *Index) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetSubspace(ss subspace.Subspace) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetTargetIndexes(indexes []*Index) *OnlineIndexerBuilder + func (b *OnlineIndexerBuilder) SetTimeLimit(d time.Duration) *OnlineIndexerBuilder + type OrderDirection struct + type OrdinaryIndexScanFunc func(scanRange TupleRange, props ScanProperties) RecordCursor[*IndexEntry] + func OrdinaryIndexScanner(store *FDBRecordStore, index *Index) OrdinaryIndexScanFunc + type PartlyBuiltError struct + ExpectedStamp string + IndexName string + Message string + SavedStamp string + func (e *PartlyBuiltError) Error() string + type PassThroughRecordStoreStateCache struct + func (c *PassThroughRecordStoreStateCache) Clear() + func (c *PassThroughRecordStoreStateCache) Get(store *FDBRecordStore, existenceCheck StoreExistenceCheck) (*FDBRecordStoreStateCacheEntry, error) + type Point struct + Coordinates tuple.Tuple + func (p Point) Coordinate(dim int) int64 + func (p Point) NumDimensions() int + type PostCommitFunc func() + type RTree struct + func NewRTree(storage *rtreeStorage, config RTreeConfig) (*RTree, error) + func (rt *RTree) Clear(tx fdb.WritableTransaction) error + func (rt *RTree) Delete(tx fdb.WritableTransaction, point Point, keySuffix tuple.Tuple) error + func (rt *RTree) InsertOrUpdate(tx fdb.WritableTransaction, point Point, keySuffix tuple.Tuple, ...) error + func (rt *RTree) Scan(tx fdb.ReadTransaction, lastHV *big.Int, lastKey tuple.Tuple, ...) ([]ItemSlot, error) + func (rt *RTree) ScanIterator(tx fdb.ReadTransaction, lastHV *big.Int, lastKey tuple.Tuple, ...) *RTreeIterator + type RTreeConfig struct + MaxM int + MinM int + NumDimensions int + SplitS int + StoreHilbertValues bool + func DefaultRTreeConfig(numDimensions int) RTreeConfig + type RTreeIterator struct + func (it *RTreeIterator) Next() (ItemSlot, bool, error) + type RangeSet struct + func NewRangeSet(ss subspace.Subspace) *RangeSet + func (rs *RangeSet) Clear(tr fdb.WritableTransaction) + func (rs *RangeSet) Contains(tr fdb.WritableTransaction, key []byte) (bool, error) + func (rs *RangeSet) InsertRange(tr fdb.WritableTransaction, begin, end []byte, requireEmpty bool) (bool, error) + func (rs *RangeSet) IsEmpty(tr fdb.WritableTransaction) (bool, error) + func (rs *RangeSet) MissingRanges(tr fdb.WritableTransaction, begin, end []byte, limit int) ([]RangeSetRange, error) + type RangeSetEmptyKeyError struct + func (e *RangeSetEmptyKeyError) Error() string + type RangeSetInvertedRangeError struct + Begin []byte + End []byte + func (e *RangeSetInvertedRangeError) Error() string + type RangeSetKeyTooLargeError struct + Key []byte + func (e *RangeSetKeyTooLargeError) Error() string + type RangeSetRange struct + Begin []byte + End []byte + type RankQuerier interface + RankForScore func(score tuple.Tuple, nullsAreLow bool) (*int64, error) + ScoreForRank func(rank tuple.Tuple) (tuple.Tuple, error) + type RecordAlreadyExistsError struct + Message string + PrimaryKey any + func (e *RecordAlreadyExistsError) Error() string + type RecordContextConfig struct + Priority TransactionPriority + Tags []string + Timer *StoreTimer + TransactionID string + TransactionSizeErrorBytes int64 + TransactionSizeWarnBytes int64 + TransactionTimeout time.Duration + func (c *RecordContextConfig) SetTags(tags []string) error + type RecordCoreStorageError struct + IndexKey tuple.Tuple + IndexName string + Message string + PrimaryKey tuple.Tuple + func (e *RecordCoreStorageError) Error() string + type RecordCountKeySizeMismatchError struct + KeyColumnSize int + ValueSize int + func (e *RecordCountKeySizeMismatchError) Error() string + type RecordCursor interface + Close func() error + IsClosed func() bool + OnNext func(ctx context.Context) (RecordCursorResult[T], error) + func Chained[T any](generator func(prev *T) (*T, error), encode func(T) []byte, ...) RecordCursor[T] + func ConcatCursors[T any](first, second CursorFactory[T], continuation []byte) RecordCursor[T] + func Dedup[T any](innerFactory CursorFactory[T], equal func(a, b T) bool, pack func(T) []byte, ...) RecordCursor[T] + func Empty[T any]() RecordCursor[T] + func Fallback[T any](inner RecordCursor[T], ...) RecordCursor[T] + func FlatMapPipelinedWithCheck[T, V any](outerFactory CursorFactory[T], innerFactory func(T, []byte) RecordCursor[V], ...) RecordCursor[V] + func FlatMapPipelined[T, V any](outerFactory CursorFactory[T], innerFactory func(T, []byte) RecordCursor[V], ...) RecordCursor[V] + func FromListWithContinuation[T any](items []T, continuation []byte) RecordCursor[T] + func FromList[T any](items []T) RecordCursor[T] + func InstrumentIndexScanCursor(timer *StoreTimer, inner RecordCursor[*IndexEntry]) RecordCursor[*IndexEntry] + func IntersectionMultiResume[T any](cursors []RecordCursor[T], compKeyFunc ComparisonKeyFunc[T], reverse bool, ...) RecordCursor[[]T] + func IntersectionMulti[T any](cursors []RecordCursor[T], compKeyFunc ComparisonKeyFunc[T], reverse bool) RecordCursor[[]T] + func IntersectionResume[T any](cursors []RecordCursor[T], compKeyFunc ComparisonKeyFunc[T], reverse bool, ...) RecordCursor[T] + func Intersection[T any](cursors []RecordCursor[T], compKeyFunc ComparisonKeyFunc[T], reverse bool) RecordCursor[T] + func LimitRowsCursor[T any](cursor RecordCursor[T], n int) RecordCursor[T] + func MapCursor[T, R any](cursor RecordCursor[T], fn func(T) R) RecordCursor[R] + func MapErrCursor[T, R any](cursor RecordCursor[T], fn func(T) (R, error)) RecordCursor[R] + func NewAutoContinuingCursor[T any](runner *FDBDatabaseRunner, ...) RecordCursor[T] + func OrElseWithContinuation[T any](primaryFactory CursorFactory[T], alternativeFactory CursorFactory[T], ...) RecordCursor[T] + func OrElse[T any](primary RecordCursor[T], alternative func() RecordCursor[T]) RecordCursor[T] + func OuterMergeMultiResume[T any](cursors []RecordCursor[T], compKeyFunc ComparisonKeyFunc[T], reverse bool, ...) RecordCursor[[]T] + func SkipCursor[T any](cursor RecordCursor[T], n int) RecordCursor[T] + func SkipThenLimit[T any](cursor RecordCursor[T], skip, limit int) RecordCursor[T] + func Stopped[T any](reason NoNextReason, continuation RecordCursorContinuation) RecordCursor[T] + type RecordCursorContinuation interface + IsEnd func() bool + ToBytes func() ([]byte, error) + type RecordCursorResult struct + func MapResult[T, R any](result RecordCursorResult[T], fn func(T) R) RecordCursorResult[R] + func NewResultNoNext[T any](reason NoNextReason, continuation RecordCursorContinuation) RecordCursorResult[T] + func NewResultWithValue[T any](value T, continuation RecordCursorContinuation) RecordCursorResult[T] + func (r RecordCursorResult[T]) GetContinuation() RecordCursorContinuation + func (r RecordCursorResult[T]) GetNoNextReason() NoNextReason + func (r RecordCursorResult[T]) GetValue() T + func (r RecordCursorResult[T]) HasNext() bool + func (r RecordCursorResult[T]) HasStoppedBeforeEnd() bool + func (r RecordCursorResult[T]) WithContinuation(continuation RecordCursorContinuation) RecordCursorResult[T] + type RecordDeserializationError struct + Cause error + PrimaryKey any + func (e *RecordDeserializationError) Error() string + func (e *RecordDeserializationError) Unwrap() error + type RecordDoesNotExistError struct + Message string + PrimaryKey any + func (e *RecordDoesNotExistError) Error() string + type RecordExistenceCheck int + const RecordExistenceCheckErrorIfExists + const RecordExistenceCheckErrorIfNotExists + const RecordExistenceCheckErrorIfNotExistsOrTypeChanged + const RecordExistenceCheckErrorIfTypeChanged + const RecordExistenceCheckNone + func (c RecordExistenceCheck) ErrorIfExists() bool + func (c RecordExistenceCheck) ErrorIfNotExists() bool + func (c RecordExistenceCheck) ErrorIfTypeChanged() bool + func (c RecordExistenceCheck) String() string + type RecordIndexUniquenessViolationError struct + ExistingKey tuple.Tuple + IndexKey tuple.Tuple + IndexName string + PrimaryKey tuple.Tuple + func (e *RecordIndexUniquenessViolationError) Error() string + type RecordMetaData struct + func RecordMetaDataFromProto(md *gen.MetaData) (*RecordMetaData, error) + func (m *RecordMetaData) AmbiguousDeclaredNames() ([]string, bool) + func (m *RecordMetaData) CommonPrimaryKey() KeyExpression + func (m *RecordMetaData) CommonPrimaryKeyLength() int + func (m *RecordMetaData) DeclaresSyntheticRecordTypes() bool + func (m *RecordMetaData) FileDescriptor() protoreflect.FileDescriptor + func (m *RecordMetaData) GetAllIndexes() map[string]*Index + func (m *RecordMetaData) GetFormerIndexes() []*FormerIndex + func (m *RecordMetaData) GetFormerIndexesSince(version int) []*FormerIndex + func (m *RecordMetaData) GetIndex(name string) *Index + func (m *RecordMetaData) GetIndexFromSubspaceKey(key any) *Index + func (m *RecordMetaData) GetIndexesForRecordType(name string) []*Index + func (m *RecordMetaData) GetIndexesToBuildSince(version int) []*Index + func (m *RecordMetaData) GetRecordCountKey() KeyExpression + func (m *RecordMetaData) GetRecordType(name string) *RecordType + func (m *RecordMetaData) GetRecordTypeFromRecordTypeKey(key any) *RecordType + func (m *RecordMetaData) GetSubspaceKeyCounter() int64 + func (m *RecordMetaData) GetUnionDescriptor() protoreflect.MessageDescriptor + func (m *RecordMetaData) GetUnionFieldForRecordType(rt *RecordType) protoreflect.FieldDescriptor + func (m *RecordMetaData) GetUniversalIndexes() []*Index + func (m *RecordMetaData) HasIndexes() bool + func (m *RecordMetaData) IsSplitLongRecords() bool + func (m *RecordMetaData) IsStoreRecordVersions() bool + func (m *RecordMetaData) PrimaryKeyHasRecordTypePrefix() bool + func (m *RecordMetaData) RecordTypes() map[string]*RecordType + func (m *RecordMetaData) RecordTypesForIndex(idx *Index) []*RecordType + func (m *RecordMetaData) SyntheticRecordTypeNames() []string + func (m *RecordMetaData) ToProto() (*gen.MetaData, error) + func (m *RecordMetaData) UsesSubspaceKeyCounter() bool + func (m *RecordMetaData) Version() int + type RecordMetaDataBuilder struct + func NewRecordMetaDataBuilder() *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) AddIndex(recordTypeName string, index *Index) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) AddMultiTypeIndex(recordTypeNames []string, index *Index) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) AddUniversalIndex(index *Index) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) Build() (*RecordMetaData, error) + func (b *RecordMetaDataBuilder) EnableCounterBasedSubspaceKeys() *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) GetFormerIndexes() []*FormerIndex + func (b *RecordMetaDataBuilder) GetRecordCountKey() KeyExpression + func (b *RecordMetaDataBuilder) GetRecordType(name string) *RecordTypeBuilder + func (b *RecordMetaDataBuilder) GetRecordTypes() map[string]*RecordType + func (b *RecordMetaDataBuilder) GetSubspaceKeyCounter() int64 + func (b *RecordMetaDataBuilder) GetVersion() int + func (b *RecordMetaDataBuilder) IsSplitLongRecords() bool + func (b *RecordMetaDataBuilder) IsStoreRecordVersions() bool + func (b *RecordMetaDataBuilder) RemoveIndex(indexName string) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetRecordCountKey(key KeyExpression) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetRecords(fd protoreflect.FileDescriptor) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetRecordsSourceProto(fdp *descriptorpb.FileDescriptorProto) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetRecordsWithUnionName(fd protoreflect.FileDescriptor, unionName string) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetSplitLongRecords(split bool) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetStoreRecordVersions(store bool) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetSubspaceKeyCounter(counter int64) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) SetVersion(version int) *RecordMetaDataBuilder + func (b *RecordMetaDataBuilder) UsesSubspaceKeyCounter() bool + type RecordSerializationError struct + Cause error + func (e *RecordSerializationError) Error() string + func (e *RecordSerializationError) Unwrap() error + type RecordStoreAlreadyExistsError struct + func (e *RecordStoreAlreadyExistsError) Error() string + type RecordStoreDoesNotExistError struct + func (e *RecordStoreDoesNotExistError) Error() string + type RecordStoreNoInfoButNotEmptyError struct + FirstKey []byte + func (e *RecordStoreNoInfoButNotEmptyError) Error() string + type RecordStoreState struct + IndexStates map[string]IndexState + StoreHeader *gen.DataStoreInfo + type RecordStoreStateNotLoadedError struct + func (e *RecordStoreStateNotLoadedError) Error() string + type RecordType struct + Descriptor protoreflect.MessageDescriptor + Name string + PrimaryKey KeyExpression + RecordTypeIndex int + SinceVersion int + UnionFieldDescriptor protoreflect.FieldDescriptor + func (rt *RecordType) GetAllIndexes() []*Index + func (rt *RecordType) GetIndexes() []*Index + func (rt *RecordType) GetMultiTypeIndexes() []*Index + func (rt *RecordType) GetRecordTypeKey() any + func (rt *RecordType) HasExplicitRecordTypeKey() bool + func (rt *RecordType) IsSynthetic() bool + func (rt *RecordType) PrimaryKeyHasRecordTypePrefix() bool + type RecordTypeBuilder struct + func (rtb *RecordTypeBuilder) SetPrimaryKey(keyExpr KeyExpression) *RecordTypeBuilder + func (rtb *RecordTypeBuilder) SetRecordTypeKey(key any) *RecordTypeBuilder + type RecordTypeChangedError struct + ActualType string + ExpectedType string + Message string + PrimaryKey any + func (e *RecordTypeChangedError) Error() string + type RecordTypeKeyExpression struct + func RecordTypeKey() *RecordTypeKeyExpression + func (r *RecordTypeKeyExpression) ColumnSize() int + func (r *RecordTypeKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (r *RecordTypeKeyExpression) EvaluateFlat(record *FDBStoredRecord[proto.Message], msg proto.Message) ([]any, error) + func (r *RecordTypeKeyExpression) EvaluateScalar(record *FDBStoredRecord[proto.Message], msg proto.Message) (any, error) + func (r *RecordTypeKeyExpression) FieldNames() []string + func (r *RecordTypeKeyExpression) Nest(expr KeyExpression) KeyExpression + func (r *RecordTypeKeyExpression) PackDirect(pk *tuple.Packer, record *FDBStoredRecord[proto.Message], msg proto.Message) bool + func (r *RecordTypeKeyExpression) ToKeyExpression() *gen.KeyExpression + type RecordTypeKeyTypeError struct + Key any + Reason string + func (e *RecordTypeKeyTypeError) Error() string + type RecordTypeKeyUnresolvedError struct + MessageType string + func (e *RecordTypeKeyUnresolvedError) Error() string + type RecordTypeStatistic struct + CollectedAtUnixNanos int64 + CollectedAtVersion int64 + Count int64 + type RowNumberWindowDirection int + const RowNumberWindowAscending + const RowNumberWindowDescending + func (d RowNumberWindowDirection) String() string + type RowNumberWindowSpec struct + Direction RowNumberWindowDirection + OrderingField []string + PartitionFieldPaths [][]string + Size int + func (s *RowNumberWindowSpec) OrderingKey() (KeyExpression, error) + func (s *RowNumberWindowSpec) PartitionKey() (KeyExpression, error) + func (s *RowNumberWindowSpec) PartitionKeyColumnSize() (int, error) + func (s *RowNumberWindowSpec) String() string + type SPFreshConfig struct + Alpha float64 + BuildAssignCells int + CellMax int + CellTarget int + CooldownSec int + Kn int + Lmax int + LminRatio int + Metric VectorMetric + NumDimensions int + NumExBits int + Replication int + Sidecar bool + func DefaultSPFreshConfig(numDimensions int) SPFreshConfig + func (c SPFreshConfig) Lmin() int + type SPFreshIntegrityReport struct + ActiveFines int + BadTargets int + MaxPostingLen int + Members int + MembershipWithoutEntry int + OK int + Oversized int + OversizedHard int + Sampled int + TargetStates map[string]int + Violations []SPFreshIntegrityViolation + func SPFreshCheckIntegrity(rtx *FDBRecordContext, store *FDBRecordStore, indexName string, sample int) (SPFreshIntegrityReport, error) + type SPFreshIntegrityViolation struct + FineID int64 + Kind string + PrimaryKey tuple.Tuple + func (v SPFreshIntegrityViolation) String() string + type SPFreshMaintenanceOptions struct + DisableRefine bool + OnRefine func(SPFreshRefineResult, error) + OnSweep func(SPFreshSweepResult, error) + Refine SPFreshRefineOptions + RefineInterval time.Duration + Sweep SPFreshSweepOptions + SweepInterval time.Duration + Tenants []SPFreshTenant + type SPFreshRecallReport struct + CorpusSize int + K int + MeanRecall float64 + MinRecall float64 + PerfectFraction float64 + QueriesRun int + func MeasureSPFreshRecall(ctx context.Context, store *FDBRecordStore, indexName string, ...) (SPFreshRecallReport, error) + type SPFreshRefineOptions struct + BudgetPerTenant int + Timer *StoreTimer + type SPFreshRefineResult struct + Converged int + Moves int + Refined int + func RefineSPFreshIndexes(ctx context.Context, db *FDBDatabase, tenants []SPFreshTenant, ...) (SPFreshRefineResult, error) + type SPFreshSweepOptions struct + MaxActionsPerTenant int + MaxRoundsPerTenant int + Timer *StoreTimer + type SPFreshSweepResult struct + Actions int + Undrained int + Worked int + func SweepSPFreshIndexes(ctx context.Context, db *FDBDatabase, tenants []SPFreshTenant, ...) (SPFreshSweepResult, error) + type SPFreshTenant struct + IndexName string + StoreBuilder func(*FDBRecordContext) (*FDBRecordStore, error) + type ScalarEvaluator interface + EvaluateScalar func(record *FDBStoredRecord[proto.Message], msg proto.Message) (any, error) + type ScanLimitReachedError struct + Reason NoNextReason + func (e *ScanLimitReachedError) Error() string + type ScanLimiterState struct + func NewScanLimiterState() *ScanLimiterState + func NewScanLimiterStateIn(env *dst.Env) *ScanLimiterState + func (s *ScanLimiterState) AddBytesScanned(n int64) + func (s *ScanLimiterState) AddRecordScanned() + func (s *ScanLimiterState) AnchorAt(t time.Time) + func (s *ScanLimiterState) BytesScanned() int64 + func (s *ScanLimiterState) Elapsed() time.Duration + func (s *ScanLimiterState) RecordsScanned() int + func (s *ScanLimiterState) StartTime() time.Time + type ScanProperties struct + CursorStreamingMode CursorStreamingMode + ExecuteProperties ExecuteProperties + Reverse bool + func ForwardScan() ScanProperties + func NewScanProperties(executeProps ExecuteProperties) ScanProperties + func ReverseScan() ScanProperties + func (s ScanProperties) GetExecuteProperties() ExecuteProperties + func (s ScanProperties) IsReverse() bool + func (s ScanProperties) WithExecuteProperties(props ExecuteProperties) ScanProperties + func (s ScanProperties) WithReverse(reverse bool) ScanProperties + func (s ScanProperties) WithStreamingMode(mode CursorStreamingMode) ScanProperties + type SlidingWindowCorruptionError struct + IndexName string + Message string + func (e *SlidingWindowCorruptionError) Error() string + type SlidingWindowDeleteWhereError struct + IndexName string + Message string + func (e *SlidingWindowDeleteWhereError) Error() string + type SplitKeyExpression struct + func Split(joined KeyExpression, splitSize int) *SplitKeyExpression + func (s *SplitKeyExpression) ColumnSize() int + func (s *SplitKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], msg proto.Message) ([][]any, error) + func (s *SplitKeyExpression) FieldNames() []string + func (s *SplitKeyExpression) GetJoined() KeyExpression + func (s *SplitKeyExpression) GetSplitSize() int + func (s *SplitKeyExpression) ToKeyExpression() *gen.KeyExpression + type StaleMetaDataVersionError struct + LocalVersion int + StoredVersion int + func (e *StaleMetaDataVersionError) Error() string + type StartContinuation struct + func (c *StartContinuation) IsEnd() bool + func (c *StartContinuation) ToBytes() ([]byte, error) + type StatisticsReadRefusal string + const StatisticsReadAbsent + const StatisticsReadCountMismatch + const StatisticsReadHeaderMissing + const StatisticsReadNonStringKey + const StatisticsReadOK + const StatisticsReadTimestampMismatch + const StatisticsReadUndecodableKey + const StatisticsReadUndecodableValue + const StatisticsReadUnknownIntegerKey + const StatisticsReadVersionMismatch + type StatisticsSubspace struct + func NewStatisticsSubspace(root subspace.Subspace) StatisticsSubspace + type StoreBuilder struct + func NewStoreBuilder() *StoreBuilder + func (b *StoreBuilder) Build() (*FDBRecordStore, error) + func (b *StoreBuilder) Create() (*FDBRecordStore, error) + func (b *StoreBuilder) CreateOrOpen() (*FDBRecordStore, error) + func (b *StoreBuilder) Open() (*FDBRecordStore, error) + func (b *StoreBuilder) SetAssumeAllIndexesReadable(assume bool) *StoreBuilder + func (b *StoreBuilder) SetBypassFullStoreLockReason(reason string) *StoreBuilder + func (b *StoreBuilder) SetContext(ctx *FDBRecordContext) *StoreBuilder + func (b *StoreBuilder) SetDatabase(db *FDBDatabase) *StoreBuilder + func (b *StoreBuilder) SetFormatVersion(version int32) *StoreBuilder + func (b *StoreBuilder) SetIndexRebuildPolicy(policy IndexRebuildPolicy) *StoreBuilder + func (b *StoreBuilder) SetMetaDataProvider(metaData *RecordMetaData) *StoreBuilder + func (b *StoreBuilder) SetSkipPossiblyRebuild(skip bool) *StoreBuilder + func (b *StoreBuilder) SetStoreStateCache(cache FDBRecordStoreStateCache) *StoreBuilder + func (b *StoreBuilder) SetSubspace(subspace subspace.Subspace) *StoreBuilder + type StoreExistenceCheck int + const ExistenceCheckErrorIfExists + const ExistenceCheckErrorIfNotExists + const ExistenceCheckNone + type StoreIsFullyLockedError struct + Reason string + Timestamp int64 + func (e *StoreIsFullyLockedError) Error() string + type StoreIsLockedForRecordUpdatesError struct + Reason string + Timestamp int64 + func (e *StoreIsLockedForRecordUpdatesError) Error() string + type StoreRecordFunction struct + Name string + type StoreStatistics struct + CollectedAtUnixNanos int64 + CollectedAtVersion int64 + PerType map[string]RecordTypeStatistic + func ReadStatistics(ctx context.Context, db *FDBDatabase, stats StatisticsSubspace, ...) (StoreStatistics, bool, error) + func ReadStatisticsAt(ctx context.Context, db *FDBDatabase, stats StatisticsSubspace, ...) (StoreStatistics, bool, int64, error) + type StoreTimer struct + func NewStoreTimer() *StoreTimer + func (t *StoreTimer) Add(other *StoreTimer) + func (t *StoreTimer) GetCount(event Event) int64 + func (t *StoreTimer) GetCounter(event Event) *Counter + func (t *StoreTimer) GetTimeNanos(event Event) int64 + func (t *StoreTimer) Increment(event Event) + func (t *StoreTimer) IncrementBy(event Event, amount int64) + func (t *StoreTimer) KeysAndValues() map[string]int64 + func (t *StoreTimer) Record(event Event, timeNanos int64) + func (t *StoreTimer) RecordSince(event Event, startTime time.Time) + func (t *StoreTimer) RecordSize(event Event, size int64) + func (t *StoreTimer) Reset() + func (t *StoreTimer) Snapshot() map[string]*CounterSnapshot + type SubspaceSplitter interface + SubspaceOf func(keyBytes []byte) (subspace.Subspace, error) + SubspaceTag func(ss subspace.Subspace) (tuple.Tuple, error) + type SynchronizedSessionLockedError struct + ExistingIndexerID string + ExistingInfo string + HeartbeatAgeMs int64 + LeaseLengthMs int64 + func (e *SynchronizedSessionLockedError) Error() string + type SyntheticRecordTypesNotModeledError struct + TypeNames []string + func (e *SyntheticRecordTypesNotModeledError) Error() string + type TagValidationError struct + Message string + Tag string + func (e *TagValidationError) Error() string + type TakeoverType int + const TakeoverByRecordsToMutual + const TakeoverMultiTargetToSingle + const TakeoverMutualToSingle + type TextIndexBunchedSerializer struct + func TextIndexBunchedSerializerInstance() *TextIndexBunchedSerializer + func (s *TextIndexBunchedSerializer) CanAppend() bool + func (s *TextIndexBunchedSerializer) DeserializeEntries(key tuple.Tuple, data []byte) ([]BunchedEntry[tuple.Tuple, []int], error) + func (s *TextIndexBunchedSerializer) DeserializeKey(data []byte, offset, length int) (tuple.Tuple, error) + func (s *TextIndexBunchedSerializer) DeserializeKeys(key tuple.Tuple, data []byte) ([]tuple.Tuple, error) + func (s *TextIndexBunchedSerializer) SerializeEntries(entries []BunchedEntry[tuple.Tuple, []int]) ([]byte, error) + func (s *TextIndexBunchedSerializer) SerializeEntry(key tuple.Tuple, value []int) ([]byte, error) + func (s *TextIndexBunchedSerializer) SerializeKey(key tuple.Tuple) []byte + type TextSubspaceSplitter struct + func NewTextSubspaceSplitter(indexSubspace subspace.Subspace, groupingColumns int) *TextSubspaceSplitter + func (s *TextSubspaceSplitter) SubspaceOf(keyBytes []byte) (subspace.Subspace, error) + func (s *TextSubspaceSplitter) SubspaceTag(ss subspace.Subspace) (tuple.Tuple, error) + type TextTokenizer interface + MaxVersion func() int + MinVersion func() int + Name func() string + Tokenize func(text string, version int, mode TokenizerMode) (TokenIterator, error) + TokenizeToList func(text string, version int, mode TokenizerMode) ([]string, error) + TokenizeToMap func(text string, version int, mode TokenizerMode) (map[string][]int, error) + func GetTextTokenizer(name string) (TextTokenizer, error) + type TextTokenizerFactory interface + GetTokenizer func() TextTokenizer + Name func() string + type TextTokenizerRegistry struct + func GlobalTextTokenizerRegistry() *TextTokenizerRegistry + func (r *TextTokenizerRegistry) GetTokenizer(name string) (TextTokenizer, error) + func (r *TextTokenizerRegistry) Register(factory TextTokenizerFactory) error + func (r *TextTokenizerRegistry) Reset() + type TimeLimitExceededError struct + Elapsed time.Duration + TimeLimit time.Duration + func (e *TimeLimitExceededError) Error() string + type TimeWindowForFunction struct + LeaderboardTimestamp int64 + LeaderboardType int + type TimeWindowLeaderboardWindowUpdate struct + AllTime bool + DeleteBefore int64 + HighScoreFirst bool + NLevels int + Rebuild TimeWindowRebuild + Specs []TimeWindowSpec + UpdateTimestamp int64 + type TimeWindowRebuild int + const TimeWindowRebuildAlways + const TimeWindowRebuildIfOverlappingChanged + const TimeWindowRebuildNever + type TimeWindowSpec struct + BaseTimestamp int64 + Count int + Duration int64 + StartIncrement int64 + Type int + type TokenIterator interface + HasNext func() bool + Next func() string + type TokenizerMode int + const TokenizerModeIndex + const TokenizerModeQuery + type TransactionPriority int + const PriorityBatch + const PriorityDefault + const PrioritySystemImmediate + type TransactionSizeExceededError struct + CurrentBytes int64 + LimitBytes int64 + func (e *TransactionSizeExceededError) Error() string + type TransactionSizeWarningError struct + CurrentBytes int64 + LimitBytes int64 + func (e *TransactionSizeWarningError) Error() string + type TupleRange struct + High tuple.Tuple + HighEndpoint EndpointType + Low tuple.Tuple + LowEndpoint EndpointType + func TupleRangeAllOf(prefix tuple.Tuple) TupleRange + func TupleRangeBetween(low, high tuple.Tuple) TupleRange + func TupleRangeBetweenInclusive(low, high tuple.Tuple) TupleRange + func TupleRangePrefixString(token string) TupleRange + func VectorDistanceScanRange(queryVector []float64, k, efSearch int) TupleRange + func VectorDistanceScanRangeOrdered(queryVector []float64, k, efSearch, cRerank int, prefix tuple.Tuple) TupleRange + func VectorDistanceScanRangeWithPrefix(queryVector []float64, k, efSearch int, prefix tuple.Tuple) TupleRange + func (r TupleRange) Contains(t tuple.Tuple) bool + func (r TupleRange) Prepend(prefix tuple.Tuple) TupleRange + func (r TupleRange) ToFDBRange(ss subspace.Subspace) fdb.KeyRange + type TypedFDBRecordStore struct + func GetTypedRecordStore[T proto.Message](store *FDBRecordStore, recordTypeName string) (*TypedFDBRecordStore[T], error) + func NewTypedRecordStore[T proto.Message](baseStore *FDBRecordStore, recordType *RecordType, ...) *TypedFDBRecordStore[T] + func (ts *TypedFDBRecordStore[T]) AddRecordReadConflict(primaryKey tuple.Tuple) error + func (ts *TypedFDBRecordStore[T]) AddRecordWriteConflict(primaryKey tuple.Tuple) error + func (ts *TypedFDBRecordStore[T]) Context() *FDBRecordContext + func (ts *TypedFDBRecordStore[T]) DeleteAllRecords() error + func (ts *TypedFDBRecordStore[T]) DeleteRecord(primaryKey tuple.Tuple) (bool, error) + func (ts *TypedFDBRecordStore[T]) GetRecordCount() (int64, error) + func (ts *TypedFDBRecordStore[T]) GetSnapshotRecordCount(countKey tuple.Tuple) (int64, error) + func (ts *TypedFDBRecordStore[T]) InsertRecord(record T) (*FDBStoredRecord[T], error) + func (ts *TypedFDBRecordStore[T]) LoadRecord(primaryKey tuple.Tuple) (*FDBStoredRecord[T], error) + func (ts *TypedFDBRecordStore[T]) RecordExists(primaryKey tuple.Tuple, isolationLevel IsolationLevel) (bool, error) + func (ts *TypedFDBRecordStore[T]) SaveRecord(record T) (*FDBStoredRecord[T], error) + func (ts *TypedFDBRecordStore[T]) SaveRecordWithOptions(record T, existenceCheck RecordExistenceCheck) (*FDBStoredRecord[T], error) + func (ts *TypedFDBRecordStore[T]) ScanRecords(continuation []byte, scanProperties ScanProperties) RecordCursor[*FDBStoredRecord[T]] + func (ts *TypedFDBRecordStore[T]) Subspace() subspace.Subspace + func (ts *TypedFDBRecordStore[T]) UpdateRecord(record T) (*FDBStoredRecord[T], error) + type UniquenessViolation struct + ExistingKey tuple.Tuple + IndexKey tuple.Tuple + IndexName string + PrimaryKey tuple.Tuple + type UnknownIndexTypeError struct + IndexName string + IndexType string + func (e *UnknownIndexTypeError) Error() string + func (e *UnknownIndexTypeError) Unwrap() error + type UnknownOrElseCursorStateError struct + func (e *UnknownOrElseCursorStateError) Error() string + type UnknownStoreLockStateError struct + LockStateValue int32 + func (e *UnknownStoreLockStateError) Error() string + type UnsupportedFeatureForFormatVersionError struct + Feature string + RequiredVersion int32 + Version int32 + func (e *UnsupportedFeatureForFormatVersionError) Error() string + type UnsupportedFormatVersionError struct + MaxVersion int32 + Version int32 + func (e *UnsupportedFormatVersionError) Error() string + type VectorMetric int + const VectorMetricCosine + const VectorMetricEuclidean + const VectorMetricEuclideanSquare + const VectorMetricInnerProduct + type VectorQuantizer interface + Decode func(storedBytes []byte, numDimensions int) ([]float64, error) + Distance func(query []float64, storedBytes []byte, numDimensions int) (float64, error) + Encode func(vector []float64) []byte + GetTypeByte func() byte + type VectorScanBounds struct + EfSearch int + K int + QueryVector []float64 + type VectorSearchResult struct + Distance float64 + PrimaryKey tuple.Tuple + func SearchSPFreshIndex(store *FDBRecordStore, indexName string, queryVector []float64, k int) ([]VectorSearchResult, error) + type VersionKeyExpression struct + func VersionKey() *VersionKeyExpression + func (v *VersionKeyExpression) ColumnSize() int + func (v *VersionKeyExpression) Evaluate(record *FDBStoredRecord[proto.Message], _ proto.Message) ([][]any, error) + func (v *VersionKeyExpression) FieldNames() []string + func (v *VersionKeyExpression) ToKeyExpression() *gen.KeyExpression + type VersionMutationType int + const MutationTypeSetVersionstampedKey + const MutationTypeSetVersionstampedValue + type WeakReadSemantics struct + IsCausalReadRisky bool + MinVersion int64 + StalenessBoundMillis int64
Go to main page