reindexer

package module

Go to main page

Versions in this module

v4

v4.20.0

Feb 4, 2025

Changes in this version

type DBNamespacesConfig

+ StrictMode string

+ type IndexPerfStat struct

+ Cache *LRUCachePerfStat

+ Commits PerfStat

+ Name string

+ Selects PerfStat

+ type LRUCachePerfStat struct

+ CacheHitRate float64

+ IsActive bool

+ TotalQueries uint64

type NamespacePerfStat

+ Indexes IndexPerfStat

+ JoinCache LRUCachePerfStat

+ QueryCountCache LRUCachePerfStat

v4.19.0

Dec 17, 2024

Changes in this version

+ func WithTLSConfig(config *tls.Config) interface

type FtFastConfig

+ SplitterType string

v4.18.0

Oct 31, 2024

v4.17.2

Sep 19, 2024

v4.17.1

Sep 5, 2024

v4.17.0

Aug 16, 2024

v4.16.0

Jul 26, 2024

Changes in this version

+ func WithMaxUpdatesSize(maxUpdatesSizeBytes uint) interface

type DBNamespacesConfig

+ MaxIterationsIdSetPreResult int64

type Reindexer

+ func (db *Reindexer) Subscribe(opts *events.EventsStreamOptions) *events.EventsStream

v4.15.0

Apr 22, 2024

Changes in this version

type ExplainSelector

+ Condition string

type Reindexer

+ func (db *Reindexer) DeleteMeta(namespace, key string) error

+ func (db *Reindexer) EnumMeta(namespace string) ([]string, error)

v4.14.0

Feb 22, 2024

Changes in this version

+ type Bm25ConfigType struct

+ Bm25Type string

+ Bm25b float64

+ Bm25k1 float64

type ExplainResults

+ SubQueriesExplains []ExplainSubQuery

type ExplainSelector

+ Description string

+ Type string

+ type ExplainSubQuery struct

+ Explain ExplainResults

+ Field string

+ Keys int

+ Namespace string

type FtFastConfig

+ Bm25Config *Bm25ConfigType

+ type StopWord struct

+ IsMorpheme bool

+ Word string

v4.13.0

Dec 22, 2023

Changes in this version

+ const AggCount

+ const AggCountCached

+ const ErrCodeStrictMode

+ func WithStrictJoinHandlers() interface

type DBNamespacesConfig

+ CacheConfig *NamespaceCacheConfig

+ type NamespaceCacheConfig struct

+ FTIdxCacheSize uint64

+ FTIdxHitsToCache uint32

+ IdxIdsetCacheSize uint64

+ IdxIdsetHitsToCache uint32

+ JoinCacheSize uint64

+ JoinHitsToCache uint32

+ QueryCountCacheSize uint64

+ QueryCountHitsToCache uint32

type Query

+ func (q *Query) WhereQuery(subQuery *Query, condition int, keys interface{}) *Query

v4.12.0

Oct 13, 2023

Changes in this version

+ type ExplainConditionInjection struct

+ AggType string

+ Explain *ExplainResults

+ InitialCondition string

+ NewCondition string

+ Reason string

+ Succeed bool

+ TotalTime int

+ ValuesCount int

+ type ExplainJoinOnInjections struct

+ Conditions []ExplainConditionInjection

+ InjectedCondition string

+ JoinOnCondition string

+ Reason string

+ RightNsName string

+ Succeed bool

+ TotalTimeUs int

+ Type string

type ExplainResults

+ OnConditionsInjections []ExplainJoinOnInjections

+ PreselectUs int

type ExplainSelector

+ FieldType string

+ type FtBaseRanking struct

+ FullMatch int

+ Kblayout int

+ PrefixMin int

+ StemmerPenalty int

+ SuffixMin int

+ Synonyms int

+ Translit int

+ Typo int

+ TypoPenalty int

type FtFastConfig

+ FtBaseRankingConfig *FtBaseRanking

type FtFuzzyConfig

+ FtBaseRankingConfig *FtBaseRanking

+ type Point [2]float64

type Query

+ func (q *Query) And() *Query

+ func (q *Query) SortStFieldDistance(field1 string, field2 string, desc bool) *Query

+ func (q *Query) SortStPointDistance(field string, p Point, desc bool) *Query

v4.11.0

Jun 9, 2023

Changes in this version

+ func WithConnPoolLoadBalancing(algorithm bindings.LoadBalancingAlgorithm) interface

+ func WithOpenTelemetry() interface

+ func WithPrometheusMetrics() interface

type FtFastConfig

+ TyposDetailedConfig *FtTyposDetailedConfig

+ type FtTyposDetailedConfig struct

+ MaxExtraLetters int

+ MaxMissingLetters int

+ MaxSymbolPermutationDistance int

+ MaxTypoDistance int

type Query

+ func (q *Query) WhereUuid(index string, condition int, keys ...string) *Query

v4.10.1

Apr 5, 2023

v4.10.0

Mar 25, 2023

v4.9.0

Jan 26, 2023

Changes in this version

+ const ALLSET

+ const ANY

+ const AggAvg

+ const AggDistinct

+ const AggFacet

+ const AggMax

+ const AggMin

+ const AggSum

+ const ClientsStatsNamespaceName

+ const CollateASCII

+ const CollateCustom

+ const CollateNone

+ const CollateNumeric

+ const CollateUTF8

+ const ConfigNamespaceName

+ const DWITHIN

+ const EMPTY

+ const EQ

+ const ERROR

+ const ErrCodeConflict

+ const ErrCodeForbidden

+ const ErrCodeLogic

+ const ErrCodeNetwork

+ const ErrCodeNotFound

+ const ErrCodeNotValid

+ const ErrCodeOK

+ const ErrCodeParams

+ const ErrCodeParseBin

+ const ErrCodeParseDSL

+ const ErrCodeParseJson

+ const ErrCodeParseSQL

+ const ErrCodeQueryExec

+ const ErrCodeStateInvalidated

+ const ErrCodeTimeout

+ const ErrCodeWasRelock

+ const GE

+ const GT

+ const INFO

+ const LE

+ const LIKE

+ const LT

+ const MemstatsNamespaceName

+ const NamespacesNamespaceName

+ const PerfstatsNamespaceName

+ const QueriesperfstatsNamespaceName

+ const QueryStrictModeIndexes

+ const QueryStrictModeNames

+ const QueryStrictModeNone

+ const RANGE

+ const ReconnectStrategyNext

+ const ReconnectStrategyPrefferRead

+ const ReconnectStrategyPrefferWrite

+ const ReconnectStrategyRandom

+ const ReconnectStrategyReadOnly

+ const ReconnectStrategySynchronized

+ const ReplicationStatsNamespaceName

+ const SET

+ const TRACE

+ const WARNING

+ var ErrAggInvalid = bindings.NewError("rq: agg is invalid", ErrCodeParams)

+ var ErrCondType = bindings.NewError("rq: cond type not found", ErrCodeParams)

+ var ErrDeepCopyType = bindings.NewError("rq: DeepCopy() returns wrong type", ErrCodeParams)

+ var ErrEmptyAggFieldName = bindings.NewError("rq: empty field name in aggregation", ErrCodeParams)

+ var ErrEmptyFieldName = bindings.NewError("rq: empty field name in filter", ErrCodeParams)

+ var ErrEmptyNamespace = bindings.NewError("rq: empty namespace name", ErrCodeParams)

+ var ErrMustBePointer = bindings.NewError("rq: Argument must be a pointer to element, not element", ErrCodeParams)

+ var ErrNoPK = bindings.NewError("rq: No pk field in struct", ErrCodeParams)

+ var ErrNotFound = bindings.NewError("rq: Not found", ErrCodeNotFound)

+ var ErrOpInvalid = bindings.NewError("rq: op is invalid", ErrCodeParams)

+ var ErrWrongType = bindings.NewError("rq: Wrong type of item", ErrCodeParams)

+ func CreateInt64FromLSN(v LsnT) int64

+ func GetCondType(name string) (int, error)

+ func WithAppName(appName string) interface

+ func WithCgoLimit(cgoLimit int) interface

+ func WithConnPoolSize(connPoolSize int) interface

+ func WithCreateDBIfMissing() interface

+ func WithDedicatedServerThreads() interface

+ func WithNetCompression() interface

+ func WithReconnectionStrategy(strategy ReconnectStrategy, allowUnknownNodes bool) interface

+ func WithRetryAttempts(read int, write int) interface

+ func WithServerConfig(startupTimeout time.Duration, serverConfig *config.ServerConfig) interface

+ func WithTimeouts(loginTimeout time.Duration, requestTimeout time.Duration) interface

+ type AggregateFacetRequest struct

+ func (r *AggregateFacetRequest) Limit(limit int) *AggregateFacetRequest

+ func (r *AggregateFacetRequest) Offset(offset int) *AggregateFacetRequest

+ func (r *AggregateFacetRequest) Sort(field string, desc bool) *AggregateFacetRequest

+ type AggregationResult struct

+ Distincts []string

+ Facets []struct{ ... }

+ Fields []string

+ Type string

+ Value float64

+ type CacheMemStat struct

+ EmptyCount int64

+ HitCountLimit int64

+ ItemsCount int64

+ TotalSize int64

+ type ClientConnectionStat struct

+ ClientVersion string

+ ConnectionId int64

+ CurrentActivity string

+ DbName string

+ Ip string

+ LastRecvTs int64

+ LastSendTs int64

+ RecvBytes int64

+ RecvRate int

+ SendBufBytes int64

+ SendRate int

+ SentBytes int64

+ StartTime int64

+ TxCount int

+ UserName string

+ UserRights string

+ type DBAsyncReplicationConfig struct

+ BatchingReoutines int

+ ConcurrentSyncsPerThread int

+ EnableCompression bool

+ ForceSyncOnLogicError bool

+ ForceSyncOnWrongDataHash bool

+ LogLevel string

+ Namespaces []string

+ Nodes []DBAsyncReplicationNode

+ OnlineUpdatesDelayMSec int

+ ReplicationMode string

+ RetrySyncInterval int

+ Role string

+ SyncThreads int

+ SyncTimeout int

+ UpdatesTimeout int

+ type DBAsyncReplicationNode struct

+ DSN string

+ Namespaces []string

+ type DBConfigItem struct

+ AsyncReplication *DBAsyncReplicationConfig

+ Namespaces *[]DBNamespacesConfig

+ Profiling *DBProfilingConfig

+ Replication *DBReplicationConfig

+ Type string

+ type DBNamespacesConfig struct

+ CopyPolicyMultiplier int

+ IndexUpdatesCountingMode bool

+ JoinCacheMode string

+ Lazyload bool

+ LogLevel string

+ MaxPreselectPart float64

+ MaxPreselectSize int64

+ MinPreselectSize int64

+ Namespace string

+ OptimizationSortWorkers int

+ OptimizationTimeout int

+ StartCopyPolicyTxSize int

+ SyncStorageFlushLimit int

+ TxSizeToAlwaysCopy int

+ UnloadIdleThreshold int

+ WALSize int64

+ type DBProfilingConfig struct

+ ActivityStats bool

+ LongQueryLogging *LongQueryLoggingConfig

+ MemStats bool

+ PerfStats bool

+ QueriesPerfStats bool

+ QueriesThresholdUS int

+ type DBReplicationConfig struct

+ ClusterID int

+ ServerID int

+ type DeepCopy interface

+ DeepCopy func() interface{}

+ type Error interface

+ Code func() int

+ Error func() string

+ type ExplainResults struct

+ GeneralSortUs int

+ IndexesUs int

+ LoopUs int

+ PostprocessUS int

+ PrepareUs int

+ Selectors []ExplainSelector

+ SortByUncommittedIndex bool

+ SortIndex string

+ TotalUs int

+ type ExplainSelector struct

+ Comparators int

+ Cost float64

+ ExplainPreselect *ExplainResults

+ ExplainSelect *ExplainResults

+ Field string

+ Items int

+ Keys int

+ Matched int

+ Method string

+ Selectors []ExplainSelector

+ type FtFastConfig struct

+ Bm25Boost float64

+ Bm25Weight float64

+ DistanceBoost float64

+ DistanceWeight float64

+ EnableKbLayout bool

+ EnableNumbersSearch bool

+ EnablePreselectBeforeFt bool

+ EnableTranslit bool

+ EnableWarmupOnNsCopy bool

+ ExtraWordSymbols string

+ FieldsCfg []FtFastFieldConfig

+ FullMatchBoost float64

+ LogLevel int

+ MaxAreasInDoc int

+ MaxRebuildSteps int

+ MaxStepSize int

+ MaxTotalAreasToCache int

+ MaxTypoLen int

+ MaxTypos int

+ MergeLimit int

+ MinRelevancy float64

+ Optimization string

+ PartialMatchDecrease int

+ PositionBoost float64

+ PositionWeight float64

+ Stemmers []string

+ StopWords []string

+ SumRanksByFieldsRatio float64

+ Synonyms []struct{ ... }

+ TermLenBoost float64

+ TermLenWeight float64

+ func DefaultFtFastConfig() FtFastConfig

+ type FtFastFieldConfig struct

+ Bm25Boost float64

+ Bm25Weight float64

+ FieldName string

+ PositionBoost float64

+ PositionWeight float64

+ TermLenBoost float64

+ TermLenWeight float64

+ func DefaultFtFastFieldConfig(fieldName string) FtFastFieldConfig

+ type FtFuzzyConfig struct

+ BufferSize int

+ EnableKbLayout bool

+ EnableTranslit bool

+ ExtraWordSymbols string

+ LogLevel int

+ MaxDstProc float64

+ MaxSrcProc float64

+ MergeLimit int

+ MinOkProc float64

+ PosDstBoost float64

+ PosSourceBoost float64

+ PosSourceDistBoost float64

+ PosSourceDistMin float64

+ SpaceSize int

+ StartDecreeseBoost float64

+ StartDefaultDecreese float64

+ Stemmers []string

+ StopWords []string

+ func DefaultFtFuzzyConfig() FtFuzzyConfig

+ type IndexDef bindings.IndexDef

+ type IndexDescription struct

+ Conditions []string

+ IsFulltext bool

+ IsSortable bool

+ type Iterator struct

+ func (it *Iterator) AggResults() (v []AggregationResult)

+ func (it *Iterator) AllowUnsafe(allow bool) *Iterator

+ func (it *Iterator) Close()

+ func (it *Iterator) Count() int

+ func (it *Iterator) Error() error

+ func (it *Iterator) FetchAll() (items []interface{}, err error)

+ func (it *Iterator) FetchAllWithRank() (items []interface{}, ranks []int, err error)

+ func (it *Iterator) FetchOne() (item interface{}, err error)

+ func (it *Iterator) GetAggreatedValue(idx int) float64

+ func (it *Iterator) GetExplainResults() (*ExplainResults, error)

+ func (it *Iterator) GetTagsMatcherInfo(nsName string) (stateToken int32, version int32)

+ func (it *Iterator) HasRank() bool

+ func (it *Iterator) JoinedObjects(field string) (objects []interface{}, err error)

+ func (it *Iterator) Next() (hasNext bool)

+ func (it *Iterator) NextObj(obj interface{}) (hasNext bool)

+ func (it *Iterator) Object() interface{}

+ func (it *Iterator) Rank() int

+ func (it *Iterator) TotalCount() int

+ type JSONIterator struct

+ func (it *JSONIterator) Close()

+ func (it *JSONIterator) Count() int

+ func (it *JSONIterator) Error() error

+ func (it *JSONIterator) FetchAll() (json []byte, err error)

+ func (it *JSONIterator) GetExplainResults() (*ExplainResults, error)

+ func (it *JSONIterator) JSON() (json []byte)

+ func (it *JSONIterator) Next() bool

+ type JoinHandler func(field string, item interface{}, subitems []interface{}) (useAutomaticJoinStrategy bool)

+ type Joinable interface

+ Join func(field string, subitems []interface{}, context interface{})

+ type Logger interface

+ Printf func(level int, fmt string, msg ...interface{})

+ type LongQueryLoggingConfig struct

+ SelectItem LongQueryLoggingItem

+ TxItem LongTxLoggingItem

+ UpdDelItem LongQueryLoggingItem

+ type LongQueryLoggingItem struct

+ Normalized bool

+ ThresholdUS int

+ type LongTxLoggingItem struct

+ AverageTxStepThresholdUs int

+ ThresholdUS int

+ type LsnT struct

+ Counter int64

+ ServerId int

+ func CreateLSNFromInt64(v int64) LsnT

+ func (lsn *LsnT) IsCompatibleWith(o LsnT) bool

+ func (lsn *LsnT) IsEmpty() bool

+ func (lsn *LsnT) IsNewerThen(o LsnT) bool

+ type NamespaceDescription struct

+ Indexes []IndexDescription

+ Name string

+ StorageEnabled bool

+ type NamespaceMemStat struct

+ EmptyItemsCount int64

+ Indexes []struct{ ... }

+ ItemsCount int64

+ JoinCache CacheMemStat

+ Name string

+ OptimizationCompleted bool

+ QueryCache CacheMemStat

+ Replication struct{ ... }

+ StorageEnabled bool

+ StorageError string

+ StorageOK bool

+ StoragePath string

+ StorageStatus string

+ StringsWaitingToBeDeletedSize int64

+ Total struct{ ... }

+ type NamespaceOptions struct

+ func DefaultNamespaceOptions() *NamespaceOptions

+ func (opts *NamespaceOptions) DisableObjCache() *NamespaceOptions

+ func (opts *NamespaceOptions) DropOnFileFormatError() *NamespaceOptions

+ func (opts *NamespaceOptions) DropOnIndexesConflict() *NamespaceOptions

+ func (opts *NamespaceOptions) NoStorage() *NamespaceOptions

+ func (opts *NamespaceOptions) ObjCacheSize(count int) *NamespaceOptions

+ type NamespacePerfStat struct

+ Name string

+ Selects PerfStat

+ Transactions TxPerfStat

+ Updates PerfStat

+ type PerfStat struct

+ LastSecAvgLatencyUs int64

+ LastSecAvgLockTimeUs int64

+ LastSecQPS int64

+ LatencyStddev int64

+ MaxLatencyUs int64

+ MinLatencyUs int64

+ TotalAvgLatencyUs int64

+ TotalAvgLockTimeUs int64

+ TotalQueriesCount int64

+ type Query struct

+ Namespace string

+ func (q *Query) AggregateAvg(field string)

+ func (q *Query) AggregateFacet(fields ...string) *AggregateFacetRequest

+ func (q *Query) AggregateMax(field string)

+ func (q *Query) AggregateMin(field string)

+ func (q *Query) AggregateSum(field string)

+ func (q *Query) CachedTotal(totalNames ...string) *Query

+ func (q *Query) CloseBracket() *Query

+ func (q *Query) DWithin(index string, point [2]float64, distance float64) *Query

+ func (q *Query) Debug(level int) *Query

+ func (q *Query) Delete() (int, error)

+ func (q *Query) DeleteCtx(ctx context.Context) (int, error)

+ func (q *Query) Distinct(distinctIndex string) *Query

+ func (q *Query) Drop(field string) *Query

+ func (q *Query) EqualPosition(fields ...string) *Query

+ func (q *Query) Exec() *Iterator

+ func (q *Query) ExecCtx(ctx context.Context) *Iterator

+ func (q *Query) ExecToJson(jsonRoots ...string) *JSONIterator

+ func (q *Query) ExecToJsonCtx(ctx context.Context, jsonRoots ...string) *JSONIterator

+ func (q *Query) Explain() *Query

+ func (q *Query) FetchCount(n int) *Query

+ func (q *Query) Functions(fields ...string) *Query

+ func (q *Query) Get() (item interface{}, found bool)

+ func (q *Query) GetCtx(ctx context.Context) (item interface{}, found bool)

+ func (q *Query) GetJson() (json []byte, found bool)

+ func (q *Query) GetJsonCtx(ctx context.Context) (json []byte, found bool)

+ func (q *Query) InnerJoin(q2 *Query, field string) *Query

+ func (q *Query) Join(q2 *Query, field string) *Query

+ func (q *Query) JoinHandler(field string, handler JoinHandler) *Query

+ func (q *Query) LeftJoin(q2 *Query, field string) *Query

+ func (q *Query) Limit(limitItems int) *Query

+ func (q *Query) MakeCopy(db *Reindexer) *Query

+ func (q *Query) Match(index string, keys ...string) *Query

+ func (q *Query) Merge(q2 *Query) *Query

+ func (q *Query) MustExec() *Iterator

+ func (q *Query) MustExecCtx(ctx context.Context) *Iterator

+ func (q *Query) Not() *Query

+ func (q *Query) Offset(startOffset int) *Query

+ func (q *Query) On(index string, condition int, joinIndex string) *Query

+ func (q *Query) OpenBracket() *Query

+ func (q *Query) Or() *Query

+ func (q *Query) ReqTotal(totalNames ...string) *Query

+ func (q *Query) Select(fields ...string) *Query

+ func (q *Query) Set(field string, values interface{}) *Query

+ func (q *Query) SetContext(ctx interface{}) *Query

+ func (q *Query) SetExpression(field string, value string) *Query

+ func (q *Query) SetObject(field string, values interface{}) *Query

+ func (q *Query) Sort(sortIndex string, desc bool, values ...interface{}) *Query

+ func (q *Query) Strict(mode QueryStrictMode) *Query

+ func (q *Query) Update() *Iterator

+ func (q *Query) UpdateCtx(ctx context.Context) *Iterator

+ func (q *Query) Where(index string, condition int, keys interface{}) *Query

+ func (q *Query) WhereBetweenFields(firstField string, condition int, secondField string) *Query

+ func (q *Query) WhereBool(index string, condition int, keys ...bool) *Query

+ func (q *Query) WhereComposite(index string, condition int, keys ...interface{}) *Query

+ func (q *Query) WhereDouble(index string, condition int, keys ...float64) *Query

+ func (q *Query) WhereInt(index string, condition int, keys ...int) *Query

+ func (q *Query) WhereInt32(index string, condition int, keys ...int32) *Query

+ func (q *Query) WhereInt64(index string, condition int, keys ...int64) *Query

+ func (q *Query) WhereString(index string, condition int, keys ...string) *Query

+ func (q *Query) WithRank() *Query

+ type QueryPerfStat struct

+ Query string

+ type QueryStrictMode int

+ type ReconnectStrategy string

+ type Reindexer struct

+ func NewReindex(dsn interface{}, options ...interface{}) *Reindexer

+ func (db *Reindexer) AddIndex(namespace string, indexDef ...IndexDef) error

+ func (db *Reindexer) BeginTx(namespace string) (*Tx, error)

+ func (db *Reindexer) Close()

+ func (db *Reindexer) CloseNamespace(namespace string) error

+ func (db *Reindexer) ConfigureIndex(namespace, index string, config interface{}) error

+ func (db *Reindexer) Delete(namespace string, item interface{}, precepts ...string) error

+ func (db *Reindexer) DescribeNamespace(namespace string) (*NamespaceDescription, error)

+ func (db *Reindexer) DescribeNamespaces() ([]*NamespaceDescription, error)

+ func (db *Reindexer) DropIndex(namespace, index string) error

+ func (db *Reindexer) DropNamespace(namespace string) error

+ func (db *Reindexer) EnableStorage(storagePath string) error

+ func (db *Reindexer) ExecSQL(query string) *Iterator

+ func (db *Reindexer) ExecSQLToJSON(query string) *JSONIterator

+ func (db *Reindexer) GetMeta(namespace, key string) ([]byte, error)

+ func (db *Reindexer) GetNamespaceMemStat(namespace string) (*NamespaceMemStat, error)

+ func (db *Reindexer) GetNamespacesMemStat() ([]*NamespaceMemStat, error)

+ func (db *Reindexer) GetStats() bindings.Stats

+ func (db *Reindexer) Insert(namespace string, item interface{}, precepts ...string) (int, error)

+ func (db *Reindexer) MustBeginTx(namespace string) *Tx

+ func (db *Reindexer) OpenNamespace(namespace string, opts *NamespaceOptions, s interface{}) (err error)

+ func (db *Reindexer) Ping() error

+ func (db *Reindexer) PutMeta(namespace, key string, data []byte) error

+ func (db *Reindexer) Query(namespace string) *Query

+ func (db *Reindexer) QueryFrom(d dsl.DSL) (*Query, error)

+ func (db *Reindexer) RegisterNamespace(namespace string, opts *NamespaceOptions, s interface{}) (err error)

+ func (db *Reindexer) RenameNamespace(srcNsName string, dstNsName string) error

+ func (db *Reindexer) RenameNs(srcNsName string, dstNsName string)

+ func (db *Reindexer) ReopenLogFiles() error

+ func (db *Reindexer) ResetCaches()

+ func (db *Reindexer) ResetStats()

+ func (db *Reindexer) SetDefaultQueryDebug(namespace string, level int) error

+ func (db *Reindexer) SetLogger(log Logger)

+ func (db *Reindexer) Status() bindings.Status

+ func (db *Reindexer) TruncateNamespace(namespace string) error

+ func (db *Reindexer) Update(namespace string, item interface{}, precepts ...string) (int, error)

+ func (db *Reindexer) UpdateIndex(namespace string, indexDef IndexDef) error

+ func (db *Reindexer) Upsert(namespace string, item interface{}, precepts ...string) error

+ func (db *Reindexer) WithContext(ctx context.Context) *Reindexer

+ type ReplicationStat struct

+ AllocatedUpdatesCount int64

+ AllocatedUpdatesSize int64

+ ForceSync ReplicationSyncStat

+ InitialSyncStat struct{ ... }

+ PendingUpdatesCount int64

+ ReplicationNodeStat []struct{ ... }

+ Type string

+ WALSync ReplicationSyncStat

+ type ReplicationSyncStat struct

+ AvgTimeUs int64

+ Count int64

+ MaxTimeUs int64

+ type Tx struct

+ func (tx *Tx) AwaitResults() *Tx

+ func (tx *Tx) Commit() error

+ func (tx *Tx) CommitWithCount() (count int, err error)

+ func (tx *Tx) Delete(item interface{}, precepts ...string) error

+ func (tx *Tx) DeleteAsync(item interface{}, cmpl bindings.Completion, precepts ...string) error

+ func (tx *Tx) DeleteJSON(json []byte, precepts ...string) error

+ func (tx *Tx) DeleteJSONAsync(json []byte, cmpl bindings.Completion, precepts ...string) error

+ func (tx *Tx) Insert(item interface{}, precepts ...string) error

+ func (tx *Tx) InsertAsync(item interface{}, cmpl bindings.Completion, precepts ...string) error

+ func (tx *Tx) MustCommit() int

+ func (tx *Tx) Query() *Query

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) Update(item interface{}, precepts ...string) error

+ func (tx *Tx) UpdateAsync(item interface{}, cmpl bindings.Completion, precepts ...string) error

+ func (tx *Tx) Upsert(item interface{}, precepts ...string) error

+ func (tx *Tx) UpsertAsync(item interface{}, cmpl bindings.Completion, precepts ...string) error

+ func (tx *Tx) UpsertJSON(json []byte, precepts ...string) error

+ func (tx *Tx) UpsertJSONAsync(json []byte, cmpl bindings.Completion, precepts ...string) error

+ type TxPerfStat struct

+ AvgCommitTimeUs int64

+ AvgCopyTimeUs int64

+ AvgPrepareTimeUs int64

+ AvgStepsCount int64

+ MaxCommitTimeUs int64

+ MaxCopyTimeUs int64

+ MaxPrepareTimeUs int64

+ MaxStepsCount int64

+ MinCommitTimeUs int64

+ MinCopyTimeUs int64

+ MinPrepareTimeUs int64

+ MinStepsCount int64

+ TotalCopyCount int64

+ TotalCount int64

Other modules containing this package

github.com/restream/reindexer

github.com/restream/reindexer/v3

github.com/restream/reindexer/v5

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