db

package
v1.35.21 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 21, 2026 License: BSD-3-Clause Imports: 129 Imported by: 1

Documentation

Overview

Some standard accessors for the shard struct. It is important to NEVER access the shard struct directly, because we lazy load shards, so the information might not be there.

Index

Constants

View Source 
const (
	ShardCodeBaseVersion                  = uint16(2)
	ShardCodeBaseMinimumVersionForStartup = uint16(1)
)

ShardCodeBaseVersion must be increased whenever there are breaking changes - including those that we can handle in a non-breaking way the version checker can then decide on init if it should prevent startup completely. If it does not prevent startup, but there is still a version mismatch, the version can be used to make specific decisions

CHANGELOG

  • Version 1 - Everything up until Weaviate v1.10.1 inclusive
  • Version 2 - Inverted Index is now stored in an always sorted fashion and doc ids are stored as BigEndian. To make this backward-compatible with v1, doc ids need to be read and written as Little Endian. In addition, an additional sort step is required in three places: during a MapList call, during a Map Cursor and during Map Compactions. BM25 is entirely disabled prior to this version
View Source 
const IdLockPoolSize uint64 = 1024

Variables

This section is empty.

Functions

func CombineMultiTargetResults added in v1.26.0 

func CombineMultiTargetResults(ctx context.Context, shard DistanceForVector, logger logrus.FieldLogger, results [][]uint64, dists [][]float32, targetVectors []string, searchVectors []models.Vector, targetCombination *dto.TargetCombination, limit int, targetDist float32) ([]uint64, []float32, error)

func GenerateUniqueString added in v1.27.10 

func GenerateUniqueString(length int) (string, error)

GenerateUniqueString generates a random string of the specified length

func NewFileMapToBlockmaxReindexTracker added in v1.30.11 

func NewFileMapToBlockmaxReindexTracker(lsmPath string, keyParser indexKeyParser) *fileMapToBlockmaxReindexTracker

func NewShardReindexerV3 added in v1.30.0 

func NewShardReindexerV3(ctx context.Context, logger logrus.FieldLogger,
	getIndex func(className schema.ClassName) *Index, concurrency int,
) *shardReindexerV3

func NewShardReindexerV3Noop added in v1.30.0 

func NewShardReindexerV3Noop() *shardReindexerV3Noop

Types

type AsyncReplicationConfig added in v1.34.13 

type AsyncReplicationConfig struct {
	// contains filtered or unexported fields
}

type BackupState 

type BackupState struct {
	BackupID   string
	InProgress bool
}

type Config 

type Config struct {
	RootPath                            string
	QueryLimit                          int64
	QueryMaximumResults                 int64
	QueryHybridMaximumResults           int64
	QueryNestedRefLimit                 int64
	ResourceUsage                       config.ResourceUsage
	MaxImportGoroutinesFactor           float64
	LazySegmentsDisabled                bool
	SegmentInfoIntoFileNameEnabled      bool
	WriteMetadataFilesEnabled           bool
	MemtablesFlushDirtyAfter            int
	MemtablesInitialSizeMB              int
	MemtablesMaxSizeMB                  int
	MemtablesMinActiveSeconds           int
	MemtablesMaxActiveSeconds           int
	MinMMapSize                         int64
	MaxReuseWalSize                     int64
	SegmentsCleanupIntervalSeconds      int
	SeparateObjectsCompactions          bool
	MaxSegmentSize                      int64
	TrackVectorDimensions               bool
	TrackVectorDimensionsInterval       time.Duration
	UsageEnabled                        bool
	ServerVersion                       string
	GitHash                             string
	AvoidMMap                           bool
	DisableLazyLoadShards               bool
	ForceFullReplicasSearch             bool
	TransferInactivityTimeout           time.Duration
	LSMEnableSegmentsChecksumValidation bool
	Replication                         replication.GlobalConfig
	MaximumConcurrentShardLoads         int
	MaximumConcurrentBucketLoads        int
	CycleManagerRoutinesFactor          int
	IndexRangeableInMemory              bool

	HNSWMaxLogSize                               int64
	HNSWDisableSnapshots                         bool
	HNSWSnapshotIntervalSeconds                  int
	HNSWSnapshotOnStartup                        bool
	HNSWSnapshotMinDeltaCommitlogsNumber         int
	HNSWSnapshotMinDeltaCommitlogsSizePercentage int
	HNSWWaitForCachePrefill                      bool
	HNSWFlatSearchConcurrency                    int
	HNSWAcornFilterRatio                         float64
	HNSWGeoIndexEF                               int
	VisitedListPoolMaxSize                       int

	TenantActivityReadLogLevel  *configRuntime.DynamicValue[string]
	TenantActivityWriteLogLevel *configRuntime.DynamicValue[string]
	QuerySlowLogEnabled         *configRuntime.DynamicValue[bool]
	QuerySlowLogThreshold       *configRuntime.DynamicValue[time.Duration]
	InvertedSorterDisabled      *configRuntime.DynamicValue[bool]
	MaintenanceModeEnabled      func() bool
	AsyncIndexingEnabled        bool

	HFreshEnabled   bool
	OperationalMode *configRuntime.DynamicValue[string]

	DisableDimensionMetrics *configRuntime.DynamicValue[bool]
}

type DB 

type DB struct {
	AsyncIndexingEnabled bool
	// contains filtered or unexported fields
}

func New 

func New(logger logrus.FieldLogger, localNodeName string, config Config,
	remoteIndex sharding.RemoteIndexClient, nodeResolver nodeResolver,
	remoteNodesClient sharding.RemoteNodeClient, replicaClient replica.Client,
	promMetrics *monitoring.PrometheusMetrics, memMonitor *memwatch.Monitor,
	nodeSelector cluster.NodeSelector, schemaReader schemaUC.SchemaReader, replicationFSM types.ReplicationFSMReader,
) (*DB, error)

func (*DB) AbortReplication 

func (db *DB) AbortReplication(class,
	shard, requestID string,
) interface{}

func (*DB) AddBatchReferences 

func (db *DB) AddBatchReferences(ctx context.Context, references objects.BatchReferences,
	repl *additional.ReplicationProperties, schemaVersion uint64,
) (objects.BatchReferences, error)

func (*DB) AddReference 

func (db *DB) AddReference(ctx context.Context, source *crossref.RefSource, target *crossref.Ref,
	repl *additional.ReplicationProperties, tenant string, schemaVersion uint64,
) error

func (*DB) Aggregate 

func (db *DB) Aggregate(ctx context.Context,
	params aggregation.Params,
	modules *modules.Provider,
) (*aggregation.Result, error)

func (*DB) AggregateNeighbors 

func (db *DB) AggregateNeighbors(ctx context.Context, vector []float32,
	class string, properties []string, k int,
	filter *filters.LocalFilter,
) ([]classification.NeighborRef, error)

TODO: why is this logic in the persistence package? This is business-logic, move out of here!

func (*DB) BackupDescriptors 

func (db *DB) BackupDescriptors(ctx context.Context, bakid string, classes []string, baseDescrs []*backup.BackupDescriptor,
) <-chan backup.ClassDescriptor

BackupDescriptors returns a channel of class descriptors. Class descriptor records everything needed to restore a class If an error happens a descriptor with an error will be written to the channel just before closing it.

func (*DB) Backupable 

func (db *DB) Backupable(ctx context.Context, classes []string) error

Backupable returns whether all given class can be backed up.

func (*DB) BatchDeleteObjects 

func (db *DB) BatchDeleteObjects(ctx context.Context, params objects.BatchDeleteParams,
	deletionTime time.Time, repl *additional.ReplicationProperties, tenant string, schemaVersion uint64,
) (objects.BatchDeleteResult, error)

func (*DB) BatchPutObjects 

func (db *DB) BatchPutObjects(ctx context.Context, objs objects.BatchObjects,
	repl *additional.ReplicationProperties, schemaVersion uint64,
) (objects.BatchObjects, error)

func (*DB) CommitReplication 

func (db *DB) CommitReplication(class,
	shard, requestID string,
) interface{}

func (*DB) CrossClassVectorSearch added in v1.20.0 

func (db *DB) CrossClassVectorSearch(ctx context.Context, vector models.Vector, targetVector string, offset, limit int,
	filters *filters.LocalFilter,
) ([]search.Result, error)

func (*DB) DeleteExpiredObjects added in v1.35.0 

func (db *DB) DeleteExpiredObjects(ctx context.Context, eg *enterrors.ErrorGroupWrapper, className, deleteOnPropName string, ttlThreshold, deletionTime time.Time, schemaVersion uint64) error

func (*DB) DeleteIndex 

func (db *DB) DeleteIndex(className schema.ClassName) error

DeleteIndex deletes the index

func (*DB) DeleteObject 

func (db *DB) DeleteObject(ctx context.Context, class string, id strfmt.UUID,
	deletionTime time.Time, repl *additional.ReplicationProperties, tenant string, schemaVersion uint64,
) error

DeleteObject from of a specific class giving its ID

func (*DB) Exists 

func (db *DB) Exists(ctx context.Context, class string, id strfmt.UUID,
	repl *additional.ReplicationProperties, tenant string,
) (bool, error)

func (*DB) GetConfig added in v1.22.0 

func (db *DB) GetConfig() Config

func (*DB) GetIndex 

func (db *DB) GetIndex(className schema.ClassName) *Index

GetIndex returns the index if it exists or nil if it doesn't by default it will retry 3 times between 0-150 ms to get the index to handle the eventual consistency.

func (*DB) GetIndexForIncomingReplica added in v1.25.0 

func (db *DB) GetIndexForIncomingReplica(className schema.ClassName) replica.RemoteIndexIncomingRepo

GetIndexForIncomingReplica returns the index if it exists or nil if it doesn't by default it will retry 3 times between 0-150 ms to get the index to handle the eventual consistency.

func (*DB) GetIndexForIncomingSharding added in v1.25.0 

func (db *DB) GetIndexForIncomingSharding(className schema.ClassName) sharding.RemoteIndexIncomingRepo

GetIndexForIncomingSharding returns the index if it exists or nil if it doesn't by default it will retry 3 times between 0-150 ms to get the index to handle the eventual consistency.

func (*DB) GetNodeStatistics added in v1.25.0 

func (db *DB) GetNodeStatistics(ctx context.Context) ([]*models.Statistics, error)

func (*DB) GetNodeStatus added in v1.20.0 

func (db *DB) GetNodeStatus(ctx context.Context, className, shardName string, verbosity string) ([]*models.NodeStatus, error)

GetNodeStatus returns the status of all Weaviate nodes.

func (*DB) GetOneNodeStatus added in v1.31.0 

func (db *DB) GetOneNodeStatus(ctx context.Context, nodeName, className, shardName, output string) (*models.NodeStatus, error)

func (*DB) GetQueryMaximumResults 

func (db *DB) GetQueryMaximumResults() int

func (*DB) GetRemoteIndex added in v1.22.0 

func (db *DB) GetRemoteIndex() sharding.RemoteIndexClient

func (*DB) GetScheduler added in v1.28.0 

func (db *DB) GetScheduler() *queue.Scheduler

func (*DB) GetSchema added in v1.22.0 

func (db *DB) GetSchema() schema.Schema

func (*DB) GetSchemaGetter added in v1.22.0 

func (db *DB) GetSchemaGetter() schemaUC.SchemaGetter

func (*DB) GetUnclassified 

func (db *DB) GetUnclassified(ctx context.Context, className string,
	properties []string, propsToReturn []string, filter *filters.LocalFilter,
) ([]search.Result, error)

TODO: why is this logic in the persistence package? This is business-logic, move out of here!

func (*DB) IncomingGetNodeStatistics added in v1.25.0 

func (db *DB) IncomingGetNodeStatistics() (*models.Statistics, error)

func (*DB) IncomingGetNodeStatus 

func (db *DB) IncomingGetNodeStatus(ctx context.Context, className, shardName, verbosity string) (*models.NodeStatus, error)

IncomingGetNodeStatus returns the index if it exists or nil if it doesn't

func (*DB) IndexExists added in v1.18.5 

func (db *DB) IndexExists(className schema.ClassName) bool

IndexExists returns if an index exists

func (*DB) ListClasses 

func (db *DB) ListClasses(ctx context.Context) []string

func (*DB) LocalNodeStatus added in v1.24.0 

func (db *DB) LocalNodeStatus(ctx context.Context, className, shardName, output string) *models.NodeStatus

func (*DB) LocalTenantActivity added in v1.25.0 

func (db *DB) LocalTenantActivity(filter tenantactivity.UsageFilter) tenantactivity.ByCollection

func (*DB) Merge 

func (db *DB) Merge(ctx context.Context, merge objects.MergeDocument,
	repl *additional.ReplicationProperties, tenant string, schemaVersion uint64,
) error

func (*DB) MultiGet 

func (db *DB) MultiGet(ctx context.Context, query []multi.Identifier,
	additional additional.Properties, tenant string,
) ([]search.Result, error)

func (*DB) Object 

func (db *DB) Object(ctx context.Context, class string, id strfmt.UUID,
	props search.SelectProperties, addl additional.Properties,
	repl *additional.ReplicationProperties, tenant string,
) (*search.Result, error)

Object gets object with id from index of specified class.

func (*DB) ObjectByID 

func (db *DB) ObjectByID(ctx context.Context, id strfmt.UUID,
	props search.SelectProperties, additional additional.Properties,
	tenant string,
) (*search.Result, error)

ObjectByID checks every index of the particular kind for the ID

@warning: this function is deprecated by Object()

func (*DB) ObjectSearch 

func (db *DB) ObjectSearch(ctx context.Context, offset, limit int,
	filters *filters.LocalFilter, sort []filters.Sort,
	additional additional.Properties, tenant string,
) (search.Results, error)

ObjectSearch search each index. Deprecated by Query which searches a specific index

func (*DB) ObjectsByID 

func (db *DB) ObjectsByID(ctx context.Context, id strfmt.UUID,
	props search.SelectProperties, additional additional.Properties,
	tenant string,
) (search.Results, error)

ObjectsByID checks every index of the particular kind for the ID this method is only used for Explore queries where we don't have a class context

func (*DB) PutObject 

func (db *DB) PutObject(ctx context.Context, obj *models.Object,
	vector []float32, vectors map[string][]float32, multivectors map[string][][]float32,
	repl *additional.ReplicationProperties,
	schemaVersion uint64,
) error

func (*DB) Query 

func (db *DB) Query(ctx context.Context, q *objects.QueryInput) (search.Results, *objects.Error)

Query a specific class

func (*DB) ReleaseBackup 

func (db *DB) ReleaseBackup(ctx context.Context, bakID, class string) (err error)

ReleaseBackup release resources acquired by the index during backup

func (*DB) ReplicateDeletion 

func (db *DB) ReplicateDeletion(ctx context.Context, class,
	shard, requestID string, uuid strfmt.UUID, deletionTime time.Time,
) replica.SimpleResponse

func (*DB) ReplicateDeletions 

func (db *DB) ReplicateDeletions(ctx context.Context, class,
	shard, requestID string, uuids []strfmt.UUID, deletionTime time.Time, dryRun bool, schemaVersion uint64,
) replica.SimpleResponse

func (*DB) ReplicateObject 

func (db *DB) ReplicateObject(ctx context.Context, class,
	shard, requestID string, object *storobj.Object,
) replica.SimpleResponse

func (*DB) ReplicateObjects 

func (db *DB) ReplicateObjects(ctx context.Context, class,
	shard, requestID string, objects []*storobj.Object, schemaVersion uint64,
) replica.SimpleResponse

func (*DB) ReplicateReferences 

func (db *DB) ReplicateReferences(ctx context.Context, class,
	shard, requestID string, refs []objects.BatchReference,
) replica.SimpleResponse

func (*DB) ReplicateUpdate 

func (db *DB) ReplicateUpdate(ctx context.Context, class,
	shard, requestID string, mergeDoc *objects.MergeDocument,
) replica.SimpleResponse

func (*DB) ResolveReferences 

func (db *DB) ResolveReferences(ctx context.Context, objs search.Results,
	props search.SelectProperties, groupBy *searchparams.GroupBy,
	addl additional.Properties, tenant string,
) (search.Results, error)

ResolveReferences takes a list of search results and enriches them with any referenced objects

func (*DB) Search added in v1.20.0 

func (db *DB) Search(ctx context.Context, params dto.GetParams) ([]search.Result, error)

func (*DB) SetNodeSelector added in v1.32.0 

func (db *DB) SetNodeSelector(nodeSelector cluster.NodeSelector)

func (*DB) SetReplicationFSM added in v1.32.0 

func (db *DB) SetReplicationFSM(replicationFsm *clusterReplication.ShardReplicationFSM)

func (*DB) SetSchemaGetter 

func (db *DB) SetSchemaGetter(sg schemaUC.SchemaGetter)

func (*DB) SetSchemaReader added in v1.32.0 

func (db *DB) SetSchemaReader(schemaReader schemaUC.SchemaReader)

func (*DB) Shards 

func (db *DB) Shards(ctx context.Context, class string) ([]string, error)

Shards returns the list of nodes where shards of class are contained. If there are no shards for the class, returns an empty list If there are shards for the class but no nodes are found, return an error

func (*DB) Shutdown 

func (db *DB) Shutdown(ctx context.Context) error

func (*DB) SparseObjectSearch added in v1.20.0 

func (db *DB) SparseObjectSearch(ctx context.Context, params dto.GetParams) ([]*storobj.Object, []float32, error)

SparseObjectSearch is used to perform an inverted index search on the db

Earlier use cases required only []search.Result as a return value from the db, and the Class ClassSearch method fit this need. Later on, other use cases presented the need for the raw storage objects, such as hybrid search.

func (*DB) StartupComplete 

func (db *DB) StartupComplete() bool

func (*DB) UsageForIndex added in v1.32.11 

func (db *DB) UsageForIndex(ctx context.Context, className schema.ClassName, jitterInterval time.Duration, exactObjectCount bool, vectorsConfig map[string]models.VectorConfig) (*types.CollectionUsage, error)

func (*DB) VectorSearch 

func (db *DB) VectorSearch(ctx context.Context,
	params dto.GetParams, targetVectors []string, searchVectors []models.Vector,
) ([]search.Result, error)

func (*DB) WaitForStartup 

func (db *DB) WaitForStartup(ctx context.Context) error

func (*DB) WithBitmapBufPool added in v1.31.8 

func (db *DB) WithBitmapBufPool(bufPool roaringset.BitmapBufPool, close func()) *DB

func (*DB) WithReindexer added in v1.30.0 

func (db *DB) WithReindexer(reindexer ShardReindexerV3) *DB

func (*DB) ZeroShotSearch 

func (db *DB) ZeroShotSearch(ctx context.Context, vector []float32,
	class string, properties []string,
	filter *filters.LocalFilter,
) ([]search.Result, error)

TODO: why is this logic in the persistence package? This is business-logic, move out of here!

type DimensionCategory added in v1.24.0 

type DimensionCategory int
const (
	DimensionCategoryStandard DimensionCategory = iota
	DimensionCategoryPQ
	DimensionCategoryBQ
	DimensionCategorySQ
	DimensionCategoryRQ
)

func (DimensionCategory) String added in v1.32.0 

func (c DimensionCategory) String() string

type DimensionInfo added in v1.32.16 

type DimensionInfo struct {
	// contains filtered or unexported fields
}

func GetDimensionCategory added in v1.32.0 

func GetDimensionCategory(cfg schemaConfig.VectorIndexConfig, dynamicUpgraded bool) DimensionInfo

func GetDimensionCategoryLegacy added in v1.32.10 

func GetDimensionCategoryLegacy(cfg schemaConfig.VectorIndexConfig) DimensionInfo

type DimensionMetrics added in v1.32.0 

type DimensionMetrics struct {
	Uncompressed int // Uncompressed dimensions count (for standard vectors)
	Compressed   int // Compressed dimensions count (for PQ/BQ vectors)
}

DimensionMetrics represents the dimension tracking metrics for a vector. The metrics are used to track memory usage and performance characteristics of different vector compression methods.

Usage patterns: - Standard vectors: Only Uncompressed is set (4 bytes per dimension) - PQ (Product Quantization): Only Compressed is set (1 byte per segment) - BQ (Binary Quantization): Only Compressed is set (1 bit per dimension, packed in uint64 blocks)

The metrics are aggregated across all vectors in a shard and published to Prometheus for monitoring and capacity planning.

func (DimensionMetrics) Add added in v1.32.2 

func (dm DimensionMetrics) Add(add DimensionMetrics) DimensionMetrics

Add creates a new DimensionMetrics instance with total values summed pairwise.

type DistanceForVector added in v1.26.0 

type DistanceForVector interface {
	VectorDistanceForQuery(ctx context.Context, id uint64, searchVectors []models.Vector, targets []string) ([]float32, error)
}

type FakeNodeResolver added in v1.32.11 

type FakeNodeResolver struct{}

func (*FakeNodeResolver) AllHostnames added in v1.32.11 

func (f *FakeNodeResolver) AllHostnames() []string

func (*FakeNodeResolver) NodeHostname added in v1.32.11 

func (f *FakeNodeResolver) NodeHostname(nodeName string) (string, bool)

type FakeRemoteClient added in v1.32.11 

type FakeRemoteClient struct{}

func (*FakeRemoteClient) AddAsyncReplicationTargetNode added in v1.32.11 

func (f *FakeRemoteClient) AddAsyncReplicationTargetNode(ctx context.Context, hostName, indexName, shardName string, targetNodeOverride additional.AsyncReplicationTargetNodeOverride, schemaVersion uint64) error

func (*FakeRemoteClient) Aggregate added in v1.32.11 

func (f *FakeRemoteClient) Aggregate(ctx context.Context, hostName, indexName,
	shardName string, params aggregation.Params,
) (*aggregation.Result, error)

func (*FakeRemoteClient) BatchAddReferences added in v1.32.11 

func (f *FakeRemoteClient) BatchAddReferences(ctx context.Context, hostName,
	indexName, shardName string, refs objects.BatchReferences, schemaVersion uint64,
) []error

func (*FakeRemoteClient) BatchPutObjects added in v1.32.11 

func (f *FakeRemoteClient) BatchPutObjects(ctx context.Context, hostName, indexName, shardName string, objs []*storobj.Object, repl *additional.ReplicationProperties, schemaVersion uint64) []error

func (*FakeRemoteClient) DeleteObject added in v1.32.11 

func (f *FakeRemoteClient) DeleteObject(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID, deletionTime time.Time, schemaVersion uint64,
) error

func (*FakeRemoteClient) DeleteObjectBatch added in v1.32.11 

func (f *FakeRemoteClient) DeleteObjectBatch(ctx context.Context, hostName, indexName, shardName string,
	uuids []strfmt.UUID, deletionTime time.Time, dryRun bool, schemaVersion uint64,
) objects.BatchSimpleObjects

func (*FakeRemoteClient) Exists added in v1.32.11 

func (f *FakeRemoteClient) Exists(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID,
) (bool, error)

func (*FakeRemoteClient) FindUUIDs added in v1.32.11 

func (f *FakeRemoteClient) FindUUIDs(ctx context.Context, hostName, indexName, shardName string,
	filters *filters.LocalFilter,
) ([]strfmt.UUID, error)

func (*FakeRemoteClient) GetFile added in v1.32.11 

func (f *FakeRemoteClient) GetFile(ctx context.Context, hostName, indexName, shardName,
	fileName string,
) (io.ReadCloser, error)

func (*FakeRemoteClient) GetFileMetadata added in v1.32.11 

func (f *FakeRemoteClient) GetFileMetadata(ctx context.Context, hostName, indexName, shardName,
	fileName string,
) (file.FileMetadata, error)

func (*FakeRemoteClient) GetObject added in v1.32.11 

func (f *FakeRemoteClient) GetObject(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID, props search.SelectProperties,
	additional additional.Properties,
) (*storobj.Object, error)

func (*FakeRemoteClient) GetShardQueueSize added in v1.32.11 

func (f *FakeRemoteClient) GetShardQueueSize(ctx context.Context,
	hostName, indexName, shardName string,
) (int64, error)

func (*FakeRemoteClient) GetShardStatus added in v1.32.11 

func (f *FakeRemoteClient) GetShardStatus(ctx context.Context,
	hostName, indexName, shardName string,
) (string, error)

func (*FakeRemoteClient) ListFiles added in v1.32.11 

func (f *FakeRemoteClient) ListFiles(ctx context.Context, hostName, indexName, shardName string) ([]string, error)

func (*FakeRemoteClient) MergeObject added in v1.32.11 

func (f *FakeRemoteClient) MergeObject(ctx context.Context, hostName, indexName,
	shardName string, mergeDoc objects.MergeDocument, schemaVersion uint64,
) error

func (*FakeRemoteClient) MultiGetObjects added in v1.32.11 

func (f *FakeRemoteClient) MultiGetObjects(ctx context.Context, hostName, indexName,
	shardName string, ids []strfmt.UUID,
) ([]*storobj.Object, error)

func (*FakeRemoteClient) PauseFileActivity added in v1.32.11 

func (f *FakeRemoteClient) PauseFileActivity(ctx context.Context, hostName, indexName, shardName string, schemaVersion uint64) error

func (*FakeRemoteClient) PutFile added in v1.32.11 

func (f *FakeRemoteClient) PutFile(ctx context.Context, hostName, indexName, shardName,
	fileName string, payload io.ReadSeekCloser,
) error

func (*FakeRemoteClient) PutObject added in v1.32.11 

func (f *FakeRemoteClient) PutObject(ctx context.Context, hostName, indexName,
	shardName string, obj *storobj.Object, schemaVersion uint64,
) error

func (*FakeRemoteClient) RemoveAsyncReplicationTargetNode added in v1.32.11 

func (f *FakeRemoteClient) RemoveAsyncReplicationTargetNode(ctx context.Context, hostName, indexName, shardName string, targetNodeOverride additional.AsyncReplicationTargetNodeOverride) error

func (*FakeRemoteClient) ResumeFileActivity added in v1.32.11 

func (f *FakeRemoteClient) ResumeFileActivity(ctx context.Context, hostName, indexName, shardName string) error

func (*FakeRemoteClient) SearchShard added in v1.32.11 

func (f *FakeRemoteClient) SearchShard(ctx context.Context, hostName, indexName,
	shardName string, vector []models.Vector, targetVector []string, distance float32, limit int,
	filters *filters.LocalFilter, _ *searchparams.KeywordRanking, sort []filters.Sort,
	cursor *filters.Cursor, groupBy *searchparams.GroupBy, additional additional.Properties, targetCombination *dto.TargetCombination,
	properties []string,
) ([]*storobj.Object, []float32, error)

func (*FakeRemoteClient) UpdateShardStatus added in v1.32.11 

func (f *FakeRemoteClient) UpdateShardStatus(ctx context.Context, hostName, indexName, shardName,
	targetStatus string, schemaVersion uint64,
) error

type FakeRemoteNodeClient added in v1.32.11 

type FakeRemoteNodeClient struct{}

func (*FakeRemoteNodeClient) GetNodeStatus added in v1.32.11 

func (f *FakeRemoteNodeClient) GetNodeStatus(ctx context.Context, hostName, className, shardName, output string) (*models.NodeStatus, error)

func (*FakeRemoteNodeClient) GetStatistics added in v1.32.11 

func (f *FakeRemoteNodeClient) GetStatistics(ctx context.Context, hostName string) (*models.Statistics, error)

type FakeReplicationClient added in v1.32.11 

type FakeReplicationClient struct{}

func (*FakeReplicationClient) Abort added in v1.32.11 

func (f *FakeReplicationClient) Abort(ctx context.Context, host, index, shard, requestID string) (replica.SimpleResponse, error)

func (*FakeReplicationClient) AddReferences added in v1.32.11 

func (f *FakeReplicationClient) AddReferences(ctx context.Context, host, index, shard, requestID string,
	refs []objects.BatchReference, schemaVersion uint64,
) (replica.SimpleResponse, error)

func (*FakeReplicationClient) Commit added in v1.32.11 

func (f *FakeReplicationClient) Commit(ctx context.Context, host, index, shard, requestID string, resp interface{}) error

func (*FakeReplicationClient) DeleteObject added in v1.32.11 

func (f *FakeReplicationClient) DeleteObject(ctx context.Context, host, index, shard, requestID string,
	id strfmt.UUID, deletionTime time.Time, schemaVersion uint64,
) (replica.SimpleResponse, error)

func (*FakeReplicationClient) DeleteObjects added in v1.32.11 

func (f *FakeReplicationClient) DeleteObjects(ctx context.Context, host, index, shard, requestID string,
	uuids []strfmt.UUID, deletionTime time.Time, dryRun bool, schemaVersion uint64,
) (replica.SimpleResponse, error)

func (*FakeReplicationClient) DigestObjects added in v1.32.11 

func (*FakeReplicationClient) DigestObjects(ctx context.Context,
	hostName, indexName, shardName string, ids []strfmt.UUID, numRetries int,
) (result []types.RepairResponse, err error)

func (*FakeReplicationClient) DigestObjectsInRange added in v1.32.11 

func (c *FakeReplicationClient) DigestObjectsInRange(ctx context.Context, host, index, shard string,
	initialUUID, finalUUID strfmt.UUID, limit int,
) ([]types.RepairResponse, error)

func (FakeReplicationClient) Exists added in v1.32.11 

func (FakeReplicationClient) Exists(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID,
) (bool, error)

func (*FakeReplicationClient) FetchObject added in v1.32.11 

func (*FakeReplicationClient) FetchObject(ctx context.Context, hostName, indexName,
	shardName string, id strfmt.UUID, props search.SelectProperties,
	additional additional.Properties, numRetries int,
) (replica.Replica, error)

func (*FakeReplicationClient) FetchObjects added in v1.32.11 

func (*FakeReplicationClient) FetchObjects(ctx context.Context, host,
	index, shard string, ids []strfmt.UUID,
) ([]replica.Replica, error)

func (*FakeReplicationClient) FindUUIDs added in v1.32.11 

func (*FakeReplicationClient) FindUUIDs(ctx context.Context,
	hostName, indexName, shardName string, filters *filters.LocalFilter,
) (result []strfmt.UUID, err error)

func (*FakeReplicationClient) HashTreeLevel added in v1.32.11 

func (c *FakeReplicationClient) HashTreeLevel(ctx context.Context, host, index, shard string, level int,
	discriminant *hashtree.Bitset,
) (digests []hashtree.Digest, err error)

func (*FakeReplicationClient) MergeObject added in v1.32.11 

func (f *FakeReplicationClient) MergeObject(ctx context.Context, host, index, shard, requestID string,
	mergeDoc *objects.MergeDocument, schemaVersion uint64,
) (replica.SimpleResponse, error)

func (*FakeReplicationClient) OverwriteObjects added in v1.32.11 

func (*FakeReplicationClient) OverwriteObjects(ctx context.Context,
	host, index, shard string, objects []*objects.VObject,
) ([]types.RepairResponse, error)

func (*FakeReplicationClient) PutObject added in v1.32.11 

func (f *FakeReplicationClient) PutObject(ctx context.Context, host, index, shard, requestID string,
	obj *storobj.Object, schemaVersion uint64,
) (replica.SimpleResponse, error)

func (*FakeReplicationClient) PutObjects added in v1.32.11 

func (f *FakeReplicationClient) PutObjects(ctx context.Context, host, index, shard, requestID string,
	objs []*storobj.Object, schemaVersion uint64,
) (replica.SimpleResponse, error)

type Index 

type Index struct {
	Config IndexConfig

	HFreshEnabled bool

	AsyncIndexingEnabled bool
	// contains filtered or unexported fields
}

Index is the logical unit which contains all the data for one particular class. An index can be further broken up into self-contained units, called Shards, to allow for easy distribution across Nodes

func NewIndex 

func NewIndex(
	ctx context.Context,
	cfg IndexConfig,
	invertedIndexConfig schema.InvertedIndexConfig,
	vectorIndexUserConfig schemaConfig.VectorIndexConfig,
	vectorIndexUserConfigs map[string]schemaConfig.VectorIndexConfig,
	router routerTypes.Router,
	shardResolver *resolver.ShardResolver,
	sg schemaUC.SchemaGetter,
	schemaReader schemaUC.SchemaReader,
	cs inverted.ClassSearcher,
	logger logrus.FieldLogger,
	nodeResolver nodeResolver,
	remoteClient sharding.RemoteIndexClient,
	replicaClient replica.Client,
	globalReplicationConfig *replication.GlobalConfig,
	promMetrics *monitoring.PrometheusMetrics,
	class *models.Class,
	jobQueueCh chan job,
	scheduler *queue.Scheduler,
	indexCheckpoints *indexcheckpoint.Checkpoints,
	allocChecker memwatch.AllocChecker,
	shardReindexer ShardReindexerV3,
	bitmapBufPool roaringset.BitmapBufPool,
	asyncIndexingEnabled bool,
) (*Index, error)

NewIndex creates an index with the specified amount of shards, using only the shards that are local to a node

func (*Index) AbortReplication 

func (i *Index) AbortReplication(ctx context.Context, shard, requestID string) interface{}

func (*Index) AddReferencesBatch added in v1.23.0 

func (i *Index) AddReferencesBatch(ctx context.Context, refs objects.BatchReferences,
	replProps *additional.ReplicationProperties, schemaVersion uint64,
) []error

return value map[int]error gives the error for the index as it received it

func (*Index) AsyncReplicationConfig added in v1.34.13 

func (i *Index) AsyncReplicationConfig() AsyncReplicationConfig

func (*Index) AsyncReplicationEnabled added in v1.34.13 

func (i *Index) AsyncReplicationEnabled() bool

func (*Index) CommitReplication 

func (i *Index) CommitReplication(ctx context.Context, shard, requestID string) interface{}

func (*Index) DebugRepairIndex added in v1.24.23 

func (i *Index) DebugRepairIndex(ctx context.Context, shardName, targetVector string) error

func (*Index) DebugRequantizeIndex added in v1.30.19 

func (i *Index) DebugRequantizeIndex(ctx context.Context, shardName, targetVector string) error

func (*Index) DebugResetVectorIndex added in v1.24.22 

func (i *Index) DebugResetVectorIndex(ctx context.Context, shardName, targetVector string) error

IMPORTANT: DebugResetVectorIndex is intended to be used for debugging purposes only. It drops the selected vector index, creates a new one, then reindexes it in the background. This function assumes the node is not receiving any traffic besides the debug endpoints and that async indexing is enabled.

func (*Index) DeletionStrategy added in v1.28.5 

func (i *Index) DeletionStrategy() string

func (*Index) DigestObjects added in v1.25.0 

func (i *Index) DigestObjects(ctx context.Context,
	shardName string, ids []strfmt.UUID,
) (result []types.RepairResponse, err error)

func (*Index) DigestObjectsInRange added in v1.28.5 

func (i *Index) DigestObjectsInRange(ctx context.Context,
	shardName string, initialUUID, finalUUID strfmt.UUID, limit int,
) (result []types.RepairResponse, err error)

func (*Index) FetchObject added in v1.25.0 

func (i *Index) FetchObject(ctx context.Context,
	shardName string, id strfmt.UUID,
) (replica.Replica, error)

func (*Index) FetchObjects added in v1.25.0 

func (i *Index) FetchObjects(ctx context.Context,
	shardName string, ids []strfmt.UUID,
) ([]replica.Replica, error)

func (*Index) ForEachLoadedShard added in v1.25.7 

func (i *Index) ForEachLoadedShard(f func(name string, shard ShardLike) error) error

func (*Index) ForEachLoadedShardConcurrently added in v1.31.17 

func (i *Index) ForEachLoadedShardConcurrently(f func(name string, shard ShardLike) error) error

func (*Index) ForEachShard added in v1.19.6 

func (i *Index) ForEachShard(f func(name string, shard ShardLike) error) error

ForEachShard applies func f on each shard in the index.

WARNING: only use this if you expect all LazyLoadShards to be loaded! Calling this method may lead to shards being force-loaded, causing unexpected CPU spikes. If you only want to apply f on loaded shards, call ForEachLoadedShard instead. Note: except Dropping and Shutting Down

func (*Index) ForEachShardConcurrently added in v1.21.8 

func (i *Index) ForEachShardConcurrently(f func(name string, shard ShardLike) error) error

func (*Index) GetInvertedIndexConfig added in v1.30.0 

func (i *Index) GetInvertedIndexConfig() schema.InvertedIndexConfig

func (*Index) GetShard added in v1.24.22 

func (i *Index) GetShard(ctx context.Context, shardName string) (
	shard ShardLike, release func(), err error,
)

func (*Index) GetVectorIndexConfig added in v1.30.0 

func (i *Index) GetVectorIndexConfig(targetVector string) schemaConfig.VectorIndexConfig

GetVectorIndexConfig returns a vector index configuration associated with targetVector. In case targetVector is empty string, legacy vector configuration is returned. Method expects that configuration associated with targetVector is present.

func (*Index) GetVectorIndexConfigs added in v1.30.0 

func (i *Index) GetVectorIndexConfigs() map[string]schemaConfig.VectorIndexConfig

GetVectorIndexConfigs returns a map of vector index configurations. If present, legacy vector is return under the key of empty string.

func (*Index) HashTreeLevel added in v1.26.0 

func (i *Index) HashTreeLevel(ctx context.Context,
	shardName string, level int, discriminant *hashtree.Bitset,
) (digests []hashtree.Digest, err error)

func (*Index) ID 

func (i *Index) ID() string

func (*Index) IncomingAddAsyncReplicationTargetNode added in v1.31.0 

func (i *Index) IncomingAddAsyncReplicationTargetNode(
	ctx context.Context,
	shardName string,
	targetNodeOverride additional.AsyncReplicationTargetNodeOverride,
) error

IncomingAddAsyncReplicationTargetNode adds the given target node override for async replication. If the target node override already exists with a different upper time bound, the existing override will use the maximum upper time bound between the two. Async replication will be started if it's not already running.

func (*Index) IncomingAggregate 

func (i *Index) IncomingAggregate(ctx context.Context, shardName string,
	params aggregation.Params, mods interface{},
) (*aggregation.Result, error)

func (*Index) IncomingBatchAddReferences 

func (i *Index) IncomingBatchAddReferences(ctx context.Context, shardName string,
	refs objects.BatchReferences, schemaVersion uint64,
) []error

func (*Index) IncomingBatchPutObjects 

func (i *Index) IncomingBatchPutObjects(ctx context.Context, shardName string,
	objects []*storobj.Object, schemaVersion uint64,
) []error

func (*Index) IncomingCreateShard 

func (i *Index) IncomingCreateShard(ctx context.Context, className string, shardName string) error

func (*Index) IncomingDeleteObject 

func (i *Index) IncomingDeleteObject(ctx context.Context, shardName string,
	id strfmt.UUID, deletionTime time.Time, schemaVersion uint64,
) error

func (*Index) IncomingDeleteObjectBatch 

func (i *Index) IncomingDeleteObjectBatch(ctx context.Context, shardName string,
	uuids []strfmt.UUID, deletionTime time.Time, dryRun bool, schemaVersion uint64,
) objects.BatchSimpleObjects

func (*Index) IncomingDeleteObjectsExpired added in v1.35.0 

func (i *Index) IncomingDeleteObjectsExpired(eg *enterrors.ErrorGroupWrapper, deleteOnPropName string,
	ttlThreshold, deletionTime time.Time, schemaVersion uint64,
) error

func (*Index) IncomingDigestObjects added in v1.18.0 

func (i *Index) IncomingDigestObjects(ctx context.Context,
	shardName string, ids []strfmt.UUID,
) (result []types.RepairResponse, err error)

func (*Index) IncomingDigestObjectsInRange added in v1.28.5 

func (i *Index) IncomingDigestObjectsInRange(ctx context.Context,
	shardName string, initialUUID, finalUUID strfmt.UUID, limit int,
) (result []types.RepairResponse, err error)

func (*Index) IncomingExists 

func (i *Index) IncomingExists(ctx context.Context, shardName string,
	id strfmt.UUID,
) (bool, error)

func (*Index) IncomingFilePutter 

func (i *Index) IncomingFilePutter(ctx context.Context, shardName,
	filePath string,
) (io.WriteCloser, error)

func (*Index) IncomingFindUUIDs added in v1.22.8 

func (i *Index) IncomingFindUUIDs(ctx context.Context, shardName string,
	filters *filters.LocalFilter,
) ([]strfmt.UUID, error)

func (*Index) IncomingGetFile added in v1.31.0 

func (i *Index) IncomingGetFile(ctx context.Context, shardName,
	relativeFilePath string,
) (io.ReadCloser, error)

IncomingGetFile returns a reader for the file at the given path in the specified shard's root directory. The caller must close the returned io.ReadCloser if no error is returned.

func (*Index) IncomingGetFileMetadata added in v1.31.0 

func (i *Index) IncomingGetFileMetadata(ctx context.Context, shardName, relativeFilePath string) (file.FileMetadata, error)

IncomingGetFileMetadata returns file metadata at the given path in the specified shards's root directory.

func (*Index) IncomingGetObject 

func (i *Index) IncomingGetObject(ctx context.Context, shardName string,
	id strfmt.UUID, props search.SelectProperties,
	additional additional.Properties,
) (*storobj.Object, error)

func (*Index) IncomingGetShardQueueSize added in v1.22.0 

func (i *Index) IncomingGetShardQueueSize(ctx context.Context, shardName string) (int64, error)

func (*Index) IncomingGetShardStatus 

func (i *Index) IncomingGetShardStatus(ctx context.Context, shardName string) (string, error)

func (*Index) IncomingHashTreeLevel added in v1.26.0 

func (i *Index) IncomingHashTreeLevel(ctx context.Context,
	shardName string, level int, discriminant *hashtree.Bitset,
) (digests []hashtree.Digest, err error)

func (*Index) IncomingListFiles added in v1.31.0 

func (i *Index) IncomingListFiles(ctx context.Context,
	shardName string,
) ([]string, error)

IncomingListFiles returns a list of files that can be used to get the shard data at the time the pause was requested. You should explicitly call resumeMaintenanceCycles to resume the background processes after you don't need the returned files to stay immutable anymore.

func (*Index) IncomingMergeObject 

func (i *Index) IncomingMergeObject(ctx context.Context, shardName string,
	mergeDoc objects.MergeDocument, schemaVersion uint64,
) error

func (*Index) IncomingMultiGetObjects 

func (i *Index) IncomingMultiGetObjects(ctx context.Context, shardName string,
	ids []strfmt.UUID,
) ([]*storobj.Object, error)

func (*Index) IncomingOverwriteObjects added in v1.18.0 

func (i *Index) IncomingOverwriteObjects(ctx context.Context,
	shardName string, vobjects []*objects.VObject,
) ([]types.RepairResponse, error)

func (*Index) IncomingPauseFileActivity added in v1.31.0 

func (i *Index) IncomingPauseFileActivity(ctx context.Context,
	shardName string,
) error

IncomingPauseFileActivity pauses the background processes of the specified shard. You should explicitly call resumeMaintenanceCycles to resume the background processes after you don't need the returned files to stay immutable anymore.

func (*Index) IncomingPutObject 

func (i *Index) IncomingPutObject(ctx context.Context, shardName string,
	object *storobj.Object, schemaVersion uint64,
) error

func (*Index) IncomingReinitShard 

func (i *Index) IncomingReinitShard(ctx context.Context, shardName string) error

func (*Index) IncomingRemoveAllAsyncReplicationTargetNodes added in v1.31.0 

func (i *Index) IncomingRemoveAllAsyncReplicationTargetNodes(ctx context.Context,
	shardName string,
) error

IncomingAllRemoveAsyncReplicationTargetNodes removes all target node overrides for async replication. Async replication will be reset to it's default configuration.

func (*Index) IncomingRemoveAsyncReplicationTargetNode added in v1.31.0 

func (i *Index) IncomingRemoveAsyncReplicationTargetNode(ctx context.Context,
	shardName string,
	targetNodeOverride additional.AsyncReplicationTargetNodeOverride,
) error

IncomingRemoveAsyncReplicationTargetNode removes the given target node override for async replication. The removal is a no-op if the target node override does not exist or if the upper time bound of the given target node override is less than the existing override's upper time bound. If there are no target node overrides left, async replication will be reset to it's default configuration.

func (*Index) IncomingResumeFileActivity added in v1.31.0 

func (i *Index) IncomingResumeFileActivity(ctx context.Context,
	shardName string,
) error

IncomingResumeFileActivity resumes the background processes of the specified shard.

func (*Index) IncomingSearch 

func (i *Index) IncomingSearch(ctx context.Context, shardName string,
	searchVectors []models.Vector, targetVectors []string, distance float32, limit int,
	filters *filters.LocalFilter, keywordRanking *searchparams.KeywordRanking,
	sort []filters.Sort, cursor *filters.Cursor, groupBy *searchparams.GroupBy,
	additional additional.Properties, targetCombination *dto.TargetCombination, properties []string,
) ([]*storobj.Object, []float32, error)

func (*Index) IncomingUpdateShardStatus 

func (i *Index) IncomingUpdateShardStatus(ctx context.Context, shardName, targetStatus string, schemaVersion uint64) error

func (*Index) IterateObjects 

func (i *Index) IterateObjects(ctx context.Context, cb func(index *Index, shard ShardLike, object *storobj.Object) error) (err error)

Iterate over all objects in the index, applying the callback function to each one. Adding or removing objects during iteration is not supported.

func (*Index) IterateShards added in v1.19.0 

func (i *Index) IterateShards(ctx context.Context, cb func(index *Index, shard ShardLike) error) (err error)

Iterate over all objects in the shard, applying the callback function to each one. Adding or removing objects during iteration is not supported.

func (*Index) LoadLocalShard added in v1.31.0 

func (i *Index) LoadLocalShard(ctx context.Context, shardName string, implicitShardLoading bool) error

func (*Index) OverwriteObjects added in v1.25.0 

func (idx *Index) OverwriteObjects(ctx context.Context,
	shard string, updates []*objects.VObject,
) ([]types.RepairResponse, error)

OverwriteObjects if their state didn't change in the meantime It returns nil if all object have been successfully overwritten and otherwise a list of failed operations.

func (*Index) ReleaseBackup 

func (i *Index) ReleaseBackup(ctx context.Context, id string) error

ReleaseBackup marks the specified backup as inactive and restarts all async background and maintenance processes. It errors if the backup does not exist or is already inactive.

func (*Index) ReplicateDeletion 

func (i *Index) ReplicateDeletion(ctx context.Context, shard, requestID string, uuid strfmt.UUID, deletionTime time.Time) replica.SimpleResponse

func (*Index) ReplicateDeletions 

func (i *Index) ReplicateDeletions(ctx context.Context, shard, requestID string,
	uuids []strfmt.UUID, deletionTime time.Time, dryRun bool, schemaVersion uint64,
) replica.SimpleResponse

func (*Index) ReplicateObject 

func (i *Index) ReplicateObject(ctx context.Context, shard, requestID string, object *storobj.Object) replica.SimpleResponse

func (*Index) ReplicateObjects 

func (i *Index) ReplicateObjects(ctx context.Context, shard, requestID string, objects []*storobj.Object, schemaVersion uint64) replica.SimpleResponse

func (*Index) ReplicateReferences 

func (i *Index) ReplicateReferences(ctx context.Context, shard, requestID string, refs []objects.BatchReference) replica.SimpleResponse

func (*Index) ReplicateUpdate 

func (i *Index) ReplicateUpdate(ctx context.Context, shard, requestID string, doc *objects.MergeDocument) replica.SimpleResponse

func (*Index) ReplicationFactor added in v1.28.5 

func (i *Index) ReplicationFactor() int64

func (*Index) Shutdown 

func (i *Index) Shutdown(ctx context.Context) error

func (*Index) UnloadLocalShard added in v1.29.9 

func (i *Index) UnloadLocalShard(ctx context.Context, shardName string) error

type IndexConfig 

type IndexConfig struct {
	RootPath                            string
	ClassName                           schema.ClassName
	QueryMaximumResults                 int64
	QueryHybridMaximumResults           int64
	QueryNestedRefLimit                 int64
	ResourceUsage                       config.ResourceUsage
	LazySegmentsDisabled                bool
	SegmentInfoIntoFileNameEnabled      bool
	WriteMetadataFilesEnabled           bool
	MemtablesFlushDirtyAfter            int
	MemtablesInitialSizeMB              int
	MemtablesMaxSizeMB                  int
	MemtablesMinActiveSeconds           int
	MemtablesMaxActiveSeconds           int
	MinMMapSize                         int64
	MaxReuseWalSize                     int64
	SegmentsCleanupIntervalSeconds      int
	SeparateObjectsCompactions          bool
	CycleManagerRoutinesFactor          int
	IndexRangeableInMemory              bool
	MaxSegmentSize                      int64
	ReplicationFactor                   int64
	DeletionStrategy                    string
	AsyncReplicationEnabled             bool
	AsyncReplicationConfig              AsyncReplicationConfig
	AsyncReplicationWorkersLimiter      *dynsemaphore.DynamicWeighted
	AvoidMMap                           bool
	DisableLazyLoadShards               bool
	ForceFullReplicasSearch             bool
	TransferInactivityTimeout           time.Duration
	LSMEnableSegmentsChecksumValidation bool
	TrackVectorDimensions               bool
	TrackVectorDimensionsInterval       time.Duration
	UsageEnabled                        bool
	ShardLoadLimiter                    *loadlimiter.LoadLimiter
	BucketLoadLimiter                   *loadlimiter.LoadLimiter

	HNSWMaxLogSize                               int64
	HNSWDisableSnapshots                         bool
	HNSWSnapshotIntervalSeconds                  int
	HNSWSnapshotOnStartup                        bool
	HNSWSnapshotMinDeltaCommitlogsNumber         int
	HNSWSnapshotMinDeltaCommitlogsSizePercentage int
	HNSWWaitForCachePrefill                      bool
	HNSWFlatSearchConcurrency                    int
	HNSWAcornFilterRatio                         float64
	HNSWGeoIndexEF                               int
	VisitedListPoolMaxSize                       int

	QuerySlowLogEnabled    *configRuntime.DynamicValue[bool]
	QuerySlowLogThreshold  *configRuntime.DynamicValue[time.Duration]
	InvertedSorterDisabled *configRuntime.DynamicValue[bool]
	MaintenanceModeEnabled func() bool

	HFreshEnabled bool

	AutoTenantActivation bool

	DisableDimensionMetrics *configRuntime.DynamicValue[bool]
}

type IndexGetter added in v1.32.0 

type IndexGetter interface {
	GetIndexLike(className schema.ClassName) IndexLike
}

IndexGetter interface defines the methods that the service uses from db.IndexGetter This allows for better testability by using interfaces instead of concrete types

type IndexLike added in v1.32.0 

type IndexLike interface {
	ForEachShard(f func(name string, shard ShardLike) error) error
	CalculateUnloadedObjectsMetrics(ctx context.Context, tenantName string) (usagetypes.ObjectUsage, error)
	CalculateUnloadedVectorsMetrics(ctx context.Context, tenantName string) (int64, error)
}

IndexLike interface defines the methods that the service uses from db.Index This allows for better testability by using interfaces instead of concrete types

type KnnAggregator 

type KnnAggregator struct {
	// contains filtered or unexported fields
}

TODO: this is business logic, move out of here

func NewKnnAggregator 

func NewKnnAggregator(input search.Results, sourceVector []float32) *KnnAggregator

func (*KnnAggregator) Aggregate 

func (a *KnnAggregator) Aggregate(k int, properties []string) ([]classification.NeighborRef, error)

type LazyLoadShard added in v1.23.0 

type LazyLoadShard struct {
	// contains filtered or unexported fields
}

func NewLazyLoadShard added in v1.23.0 

func NewLazyLoadShard(ctx context.Context, promMetrics *monitoring.PrometheusMetrics,
	shardName string, index *Index, class *models.Class, jobQueueCh chan job,
	indexCheckpoints *indexcheckpoint.Checkpoints, memMonitor memwatch.AllocChecker,
	shardLoadLimiter *loadlimiter.LoadLimiter, shardReindexer ShardReindexerV3,
	lazyLoadSegments bool, bitmapBufPool roaringset.BitmapBufPool,
) *LazyLoadShard

func (*LazyLoadShard) Activity added in v1.25.0 

func (l *LazyLoadShard) Activity() (int32, int32)

func (*LazyLoadShard) AddReferencesBatch added in v1.23.0 

func (l *LazyLoadShard) AddReferencesBatch(ctx context.Context, refs objects.BatchReferences) []error

func (*LazyLoadShard) Aggregate added in v1.23.0 

func (l *LazyLoadShard) Aggregate(ctx context.Context, params aggregation.Params, modules *modules.Provider) (*aggregation.Result, error)

func (*LazyLoadShard) AnalyzeObject added in v1.23.0 

func (l *LazyLoadShard) AnalyzeObject(object *storobj.Object) ([]inverted.Property, []inverted.NilProperty, error)

func (*LazyLoadShard) ConvertQueue added in v1.28.0 

func (l *LazyLoadShard) ConvertQueue(targetVector string) error

func (*LazyLoadShard) Counter added in v1.23.0 

func (l *LazyLoadShard) Counter() *indexcounter.Counter

func (*LazyLoadShard) CreateBackupSnapshot added in v1.35.15 

func (l *LazyLoadShard) CreateBackupSnapshot(ctx context.Context, sd *backup.ShardDescriptor, stagingRoot string) ([]string, error)

func (*LazyLoadShard) DebugGetDocIdLockStatus added in v1.31.17 

func (s *LazyLoadShard) DebugGetDocIdLockStatus() (bool, error)

func (*LazyLoadShard) DebugResetVectorIndex added in v1.24.22 

func (l *LazyLoadShard) DebugResetVectorIndex(ctx context.Context, targetVector string) error

func (*LazyLoadShard) DeleteObject added in v1.23.0 

func (l *LazyLoadShard) DeleteObject(ctx context.Context, id strfmt.UUID, deletionTime time.Time) error

func (*LazyLoadShard) DeleteObjectBatch added in v1.23.0 

func (l *LazyLoadShard) DeleteObjectBatch(ctx context.Context, ids []strfmt.UUID, deletionTime time.Time, dryRun bool) objects.BatchSimpleObjects

func (*LazyLoadShard) Dimensions added in v1.23.0 

func (l *LazyLoadShard) Dimensions(ctx context.Context, targetVector string) (int, error)

func (*LazyLoadShard) Exists added in v1.23.0 

func (l *LazyLoadShard) Exists(ctx context.Context, id strfmt.UUID) (bool, error)

func (*LazyLoadShard) FillQueue added in v1.28.0 

func (l *LazyLoadShard) FillQueue(targetVector string, from uint64) error

func (*LazyLoadShard) FindUUIDs added in v1.23.0 

func (l *LazyLoadShard) FindUUIDs(ctx context.Context, filters *filters.LocalFilter) ([]strfmt.UUID, error)

func (*LazyLoadShard) ForEachVectorIndex added in v1.30.0 

func (l *LazyLoadShard) ForEachVectorIndex(f func(targetVector string, index VectorIndex) error) error

func (*LazyLoadShard) ForEachVectorQueue added in v1.30.0 

func (l *LazyLoadShard) ForEachVectorQueue(f func(targetVector string, queue *VectorIndexQueue) error) error

func (*LazyLoadShard) GetFile added in v1.31.0 

func (l *LazyLoadShard) GetFile(ctx context.Context, relativeFilePath string) (io.ReadCloser, error)

func (*LazyLoadShard) GetFileMetadata added in v1.31.0 

func (l *LazyLoadShard) GetFileMetadata(ctx context.Context, relativeFilePath string) (file.FileMetadata, error)

func (*LazyLoadShard) GetPropertyLengthTracker added in v1.23.0 

func (l *LazyLoadShard) GetPropertyLengthTracker() *inverted.JsonShardMetaData

func (*LazyLoadShard) GetStatus added in v1.23.0 

func (l *LazyLoadShard) GetStatus() storagestate.Status

func (*LazyLoadShard) GetVectorIndex added in v1.30.0 

func (l *LazyLoadShard) GetVectorIndex(targetVector string) (VectorIndex, bool)

func (*LazyLoadShard) GetVectorIndexQueue added in v1.30.0 

func (l *LazyLoadShard) GetVectorIndexQueue(targetVector string) (*VectorIndexQueue, bool)

func (*LazyLoadShard) HaltForTransfer added in v1.26.0 

func (l *LazyLoadShard) HaltForTransfer(ctx context.Context, offloading bool, inactivityTimeout time.Duration) error

func (*LazyLoadShard) HashTreeLevel added in v1.26.0 

func (l *LazyLoadShard) HashTreeLevel(ctx context.Context, level int, discriminant *hashtree.Bitset) (digests []hashtree.Digest, err error)

func (*LazyLoadShard) ID added in v1.23.0 

func (l *LazyLoadShard) ID() string

func (*LazyLoadShard) Index added in v1.23.0 

func (l *LazyLoadShard) Index() *Index

func (*LazyLoadShard) ListBackupFiles added in v1.23.0 

func (l *LazyLoadShard) ListBackupFiles(ctx context.Context, ret *backup.ShardDescriptor) ([]string, error)

func (*LazyLoadShard) Load added in v1.23.0 

func (l *LazyLoadShard) Load(ctx context.Context) error

func (*LazyLoadShard) MergeObject added in v1.23.0 

func (l *LazyLoadShard) MergeObject(ctx context.Context, object objects.MergeDocument) error

func (*LazyLoadShard) Metrics added in v1.23.0 

func (l *LazyLoadShard) Metrics() *Metrics

func (*LazyLoadShard) MultiObjectByID added in v1.23.0 

func (l *LazyLoadShard) MultiObjectByID(ctx context.Context, query []multi.Identifier) ([]*storobj.Object, error)

func (*LazyLoadShard) Name added in v1.23.0 

func (l *LazyLoadShard) Name() string

func (*LazyLoadShard) NotifyReady added in v1.23.0 

func (l *LazyLoadShard) NotifyReady()

func (*LazyLoadShard) ObjectByID added in v1.23.0 

func (l *LazyLoadShard) ObjectByID(ctx context.Context, id strfmt.UUID, props search.SelectProperties, additional additional.Properties) (*storobj.Object, error)

func (*LazyLoadShard) ObjectCount added in v1.23.0 

func (l *LazyLoadShard) ObjectCount(ctx context.Context) (int, error)

func (*LazyLoadShard) ObjectCountAsync added in v1.23.10 

func (l *LazyLoadShard) ObjectCountAsync(ctx context.Context) (int64, error)

func (*LazyLoadShard) ObjectDigestErrDeleted added in v1.34.20 

func (l *LazyLoadShard) ObjectDigestErrDeleted(ctx context.Context, id strfmt.UUID) (types.RepairResponse, error)

func (*LazyLoadShard) ObjectDigests added in v1.34.20 

func (l *LazyLoadShard) ObjectDigests(ctx context.Context, query []multi.Identifier) ([]types.RepairResponse, error)

func (*LazyLoadShard) ObjectDigestsInRange added in v1.28.5 

func (l *LazyLoadShard) ObjectDigestsInRange(ctx context.Context,
	initialUUID, finalUUID strfmt.UUID, limit int,
) (objs []types.RepairResponse, err error)

func (*LazyLoadShard) ObjectList added in v1.23.0 

func (l *LazyLoadShard) ObjectList(ctx context.Context, limit int, sort []filters.Sort, cursor *filters.Cursor, additional additional.Properties, className schema.ClassName) ([]*storobj.Object, error)

func (*LazyLoadShard) ObjectSearch added in v1.23.0 

func (l *LazyLoadShard) ObjectSearch(ctx context.Context, limit int, filters *filters.LocalFilter, keywordRanking *searchparams.KeywordRanking, sort []filters.Sort, cursor *filters.Cursor, additional additional.Properties, properties []string) ([]*storobj.Object, []float32, error)

func (*LazyLoadShard) ObjectVectorSearch added in v1.23.0 

func (l *LazyLoadShard) ObjectVectorSearch(ctx context.Context, searchVectors []models.Vector, targetVectors []string, targetDist float32, limit int, filters *filters.LocalFilter, sort []filters.Sort, groupBy *searchparams.GroupBy, additional additional.Properties, targetCombination *dto.TargetCombination, properties []string) ([]*storobj.Object, []float32, error)

func (*LazyLoadShard) PutObject added in v1.23.0 

func (l *LazyLoadShard) PutObject(ctx context.Context, object *storobj.Object) error

func (*LazyLoadShard) PutObjectBatch added in v1.23.0 

func (l *LazyLoadShard) PutObjectBatch(ctx context.Context, objects []*storobj.Object) []error

func (*LazyLoadShard) QuantizedDimensions added in v1.23.0 

func (l *LazyLoadShard) QuantizedDimensions(ctx context.Context, targetVector string, segments int) (int, error)

func (*LazyLoadShard) RepairIndex added in v1.24.23 

func (l *LazyLoadShard) RepairIndex(ctx context.Context, targetVector string) error

func (*LazyLoadShard) RequantizeIndex added in v1.30.19 

func (l *LazyLoadShard) RequantizeIndex(ctx context.Context, targetVector string) error

func (*LazyLoadShard) SetAsyncReplicationState added in v1.34.13 

func (l *LazyLoadShard) SetAsyncReplicationState(ctx context.Context, config AsyncReplicationConfig, enabled bool) error

func (*LazyLoadShard) SetPropertyLengths added in v1.23.0 

func (l *LazyLoadShard) SetPropertyLengths(props []inverted.Property) error

func (*LazyLoadShard) SetStatusReadonly added in v1.25.22 

func (l *LazyLoadShard) SetStatusReadonly(reason string) error

func (*LazyLoadShard) Shutdown added in v1.23.0 

func (l *LazyLoadShard) Shutdown(ctx context.Context) error

func (*LazyLoadShard) Store added in v1.23.0 

func (l *LazyLoadShard) Store() *lsmkv.Store

func (*LazyLoadShard) UpdateStatus added in v1.23.0 

func (l *LazyLoadShard) UpdateStatus(status, reason string) error

func (*LazyLoadShard) UpdateVectorIndexConfig added in v1.23.0 

func (l *LazyLoadShard) UpdateVectorIndexConfig(ctx context.Context, updated schemaConfig.VectorIndexConfig) error

func (*LazyLoadShard) UpdateVectorIndexConfigs added in v1.24.1 

func (l *LazyLoadShard) UpdateVectorIndexConfigs(ctx context.Context, updated map[string]schemaConfig.VectorIndexConfig) error

func (*LazyLoadShard) VectorDistanceForQuery added in v1.26.0 

func (l *LazyLoadShard) VectorDistanceForQuery(ctx context.Context, id uint64, searchVectors []models.Vector, targets []string) ([]float32, error)

func (*LazyLoadShard) Versioner added in v1.23.0 

func (l *LazyLoadShard) Versioner() *shardVersioner

func (*LazyLoadShard) WasDeleted added in v1.23.0 

func (l *LazyLoadShard) WasDeleted(ctx context.Context, id strfmt.UUID) (bool, time.Time, error)

type Metrics 

type Metrics struct {
	// contains filtered or unexported fields
}

func NewMetrics 

func NewMetrics(
	logger logrus.FieldLogger, prom *monitoring.PrometheusMetrics,
	className, shardName string,
) (*Metrics, error)

func (*Metrics) AddAsyncReplicationPropagationObjectCount added in v1.31.16 

func (m *Metrics) AddAsyncReplicationPropagationObjectCount(n int)

func (*Metrics) BatchCount added in v1.27.0 

func (m *Metrics) BatchCount(size int)

func (*Metrics) BatchCountBytes added in v1.27.0 

func (m *Metrics) BatchCountBytes(size int64)

func (*Metrics) BatchDelete 

func (m *Metrics) BatchDelete(start time.Time, op string)

func (*Metrics) BatchObject 

func (m *Metrics) BatchObject(start time.Time, size int)

func (*Metrics) DecAsyncReplicationHashTreeInitRunning added in v1.31.16 

func (m *Metrics) DecAsyncReplicationHashTreeInitRunning()

func (*Metrics) DecAsyncReplicationHashbeatTriggerRunning added in v1.31.17 

func (m *Metrics) DecAsyncReplicationHashbeatTriggerRunning()

func (*Metrics) DecAsyncReplicationHashbeaterRunning added in v1.31.17 

func (m *Metrics) DecAsyncReplicationHashbeaterRunning()

func (*Metrics) DecAsyncReplicationIterationRunning added in v1.34.13 

func (m *Metrics) DecAsyncReplicationIterationRunning()

func (*Metrics) DeleteShardLabels added in v1.21.7 

func (m *Metrics) DeleteShardLabels(class, shard string)

func (*Metrics) FilteredVectorFilter added in v1.18.0 

func (m *Metrics) FilteredVectorFilter(dur time.Duration)

func (*Metrics) FilteredVectorObjects added in v1.18.0 

func (m *Metrics) FilteredVectorObjects(dur time.Duration)

func (*Metrics) FilteredVectorSort added in v1.18.0 

func (m *Metrics) FilteredVectorSort(dur time.Duration)

func (*Metrics) FilteredVectorVector added in v1.18.0 

func (m *Metrics) FilteredVectorVector(dur time.Duration)

func (*Metrics) IncAsyncReplicationHashTreeInitCount added in v1.31.17 

func (m *Metrics) IncAsyncReplicationHashTreeInitCount()

func (*Metrics) IncAsyncReplicationHashTreeInitFailure added in v1.31.16 

func (m *Metrics) IncAsyncReplicationHashTreeInitFailure()

func (*Metrics) IncAsyncReplicationHashTreeInitRunning added in v1.31.16 

func (m *Metrics) IncAsyncReplicationHashTreeInitRunning()

func (*Metrics) IncAsyncReplicationHashbeatTriggerRunning added in v1.31.17 

func (m *Metrics) IncAsyncReplicationHashbeatTriggerRunning()

func (*Metrics) IncAsyncReplicationHashbeaterRunning added in v1.31.17 

func (m *Metrics) IncAsyncReplicationHashbeaterRunning()

func (*Metrics) IncAsyncReplicationIterationCount added in v1.31.16 

func (m *Metrics) IncAsyncReplicationIterationCount()

func (*Metrics) IncAsyncReplicationIterationFailureCount added in v1.31.16 

func (m *Metrics) IncAsyncReplicationIterationFailureCount()

func (*Metrics) IncAsyncReplicationIterationRunning added in v1.34.13 

func (m *Metrics) IncAsyncReplicationIterationRunning()

func (*Metrics) IncAsyncReplicationPropagationCount added in v1.31.16 

func (m *Metrics) IncAsyncReplicationPropagationCount()

func (*Metrics) IncAsyncReplicationPropagationFailureCount added in v1.31.16 

func (m *Metrics) IncAsyncReplicationPropagationFailureCount()

func (*Metrics) InvertedDeleteDelta 

func (m *Metrics) InvertedDeleteDelta(start time.Time)

func (*Metrics) InvertedDeleteOld 

func (m *Metrics) InvertedDeleteOld(start time.Time)

func (*Metrics) InvertedExtend 

func (m *Metrics) InvertedExtend(start time.Time, propCount int)

func (*Metrics) ObjectStore 

func (m *Metrics) ObjectStore(start time.Time)

func (*Metrics) ObserveAsyncReplicationHashTreeInitDuration added in v1.31.16 

func (m *Metrics) ObserveAsyncReplicationHashTreeInitDuration(d time.Duration)

func (*Metrics) ObserveAsyncReplicationHashtreeDiffDuration added in v1.31.17 

func (m *Metrics) ObserveAsyncReplicationHashtreeDiffDuration(d time.Duration)

func (*Metrics) ObserveAsyncReplicationIterationDuration added in v1.31.16 

func (m *Metrics) ObserveAsyncReplicationIterationDuration(d time.Duration)

func (*Metrics) ObserveAsyncReplicationObjectDigestsDiffDuration added in v1.31.17 

func (m *Metrics) ObserveAsyncReplicationObjectDigestsDiffDuration(d time.Duration)

func (*Metrics) ObserveAsyncReplicationPropagationDuration added in v1.31.16 

func (m *Metrics) ObserveAsyncReplicationPropagationDuration(d time.Duration)

func (*Metrics) ObserveUpdateShardStatus added in v1.27.18 

func (m *Metrics) ObserveUpdateShardStatus(status string, duration time.Duration)

func (*Metrics) PutObject 

func (m *Metrics) PutObject(start time.Time)

func (*Metrics) PutObjectDetermineStatus 

func (m *Metrics) PutObjectDetermineStatus(start time.Time)

func (*Metrics) PutObjectUpdateInverted 

func (m *Metrics) PutObjectUpdateInverted(start time.Time)

func (*Metrics) PutObjectUpsertObject 

func (m *Metrics) PutObjectUpsertObject(start time.Time)

func (*Metrics) ShardStartup 

func (m *Metrics) ShardStartup(start time.Time)

func (*Metrics) UpdateShardStatus added in v1.27.18 

func (m *Metrics) UpdateShardStatus(old, new string)

func (*Metrics) VectorIndex 

func (m *Metrics) VectorIndex(start time.Time)

type Migrator 

type Migrator struct {
	// contains filtered or unexported fields
}

func NewMigrator 

func NewMigrator(db *DB, logger logrus.FieldLogger, localNodeName string) *Migrator

func (*Migrator) AddClass 

func (m *Migrator) AddClass(ctx context.Context, class *models.Class) error

func (*Migrator) AddProperty 

func (m *Migrator) AddProperty(ctx context.Context, className string, prop ...*models.Property) error

func (*Migrator) AdjustFilterablePropSettings added in v1.19.0 

func (m *Migrator) AdjustFilterablePropSettings(ctx context.Context) error

As of v1.19 property's IndexInverted setting is replaced with IndexFilterable and IndexSearchable Filterable buckets use roaring set strategy and searchable ones use map strategy (therefore are applicable just for text/text[]) Since both type of buckets can coexist for text/text[] props they need to be distinguished by their name: searchable bucket has "searchable" suffix. Up until v1.19 default text/text[]/string/string[] (string/string[] deprecated since v1.19) strategy for buckets was map, migrating from pre v1.19 to v1.19 needs to properly handle existing text/text[] buckets of map strategy having filterable bucket name.

Enabled InvertedIndex translates in v1.19 to both InvertedFilterable and InvertedSearchable enabled, but since only searchable bucket exist (with filterable name), it has to be renamed to searchable bucket. Though IndexFilterable setting is enabled filterable index does not exists, therefore shards are switched into fallback mode, to use searchable buckets instead of filterable ones whenever filtered are expected. Fallback mode effectively sets IndexFilterable to false, although it stays enabled according to schema.

If filterable indexes will be created (that is up to user to decide whether missing indexes should be created later on), shards will not be working in fallback mode, and actual filterable index will be used when needed.

func (*Migrator) DeleteTenants added in v1.20.0 

func (m *Migrator) DeleteTenants(ctx context.Context, class string, tenants []*models.Tenant) error

DeleteTenants deletes tenant from the database and data from the disk, no matter the current status of the tenant

func (*Migrator) DropClass 

func (m *Migrator) DropClass(ctx context.Context, className string, hasFrozen bool) error

func (*Migrator) DropProperty 

func (m *Migrator) DropProperty(ctx context.Context, className string, propertyName string) error

DropProperty is ignored, API compliant change

func (*Migrator) DropShard added in v1.31.0 

func (m *Migrator) DropShard(ctx context.Context, class, shard string) error

func (*Migrator) GetShardsQueueSize added in v1.22.0 

func (m *Migrator) GetShardsQueueSize(ctx context.Context, className, tenant string) (map[string]int64, error)

func (*Migrator) GetShardsStatus 

func (m *Migrator) GetShardsStatus(ctx context.Context, className, tenant string) (map[string]string, error)

func (*Migrator) InvertedReindex added in v1.18.0 

func (m *Migrator) InvertedReindex(ctx context.Context, taskNamesWithArgs map[string]any) error

func (*Migrator) LoadShard added in v1.31.0 

func (m *Migrator) LoadShard(ctx context.Context, class, shard string) error

func (*Migrator) NewTenants added in v1.20.0 

func (m *Migrator) NewTenants(ctx context.Context, class *models.Class, creates []*schemaUC.CreateTenantPayload) error

NewTenants creates new partitions

func (*Migrator) RecalculateVectorDimensions 

func (m *Migrator) RecalculateVectorDimensions(ctx context.Context) error

func (*Migrator) RecountProperties added in v1.19.0 

func (m *Migrator) RecountProperties(ctx context.Context) error

func (*Migrator) SetCluster added in v1.26.0 

func (m *Migrator) SetCluster(c processor)

func (*Migrator) SetNode added in v1.26.0 

func (m *Migrator) SetNode(nodeID string)

func (*Migrator) SetOffloadProvider added in v1.26.0 

func (m *Migrator) SetOffloadProvider(provider provider, moduleName string)

func (*Migrator) Shutdown added in v1.25.0 

func (m *Migrator) Shutdown(ctx context.Context) error

Shutdown no-op if db was never loaded

func (*Migrator) ShutdownShard added in v1.31.0 

func (m *Migrator) ShutdownShard(ctx context.Context, class, shard string) error

func (*Migrator) UpdateClass 

func (m *Migrator) UpdateClass(ctx context.Context, className string, newClassName *string) error

func (*Migrator) UpdateIndex added in v1.25.0 

func (m *Migrator) UpdateIndex(ctx context.Context, incomingClass *models.Class,
	incomingSS *sharding.State,
) error

UpdateIndex ensures that the local index is up2date with the latest sharding state (shards/tenants) and index properties that may have been added in the case that the local node was down during a class update operation.

This method is relevant when the local node is a part of a cluster, particularly with the introduction of the v2 RAFT-based schema

func (*Migrator) UpdateInvertedIndexConfig 

func (m *Migrator) UpdateInvertedIndexConfig(ctx context.Context, className string,
	updated *models.InvertedIndexConfig,
) error

func (*Migrator) UpdateProperty 

func (m *Migrator) UpdateProperty(ctx context.Context, className string, propName string, newName *string) error

func (*Migrator) UpdateReplicationConfig added in v1.26.0 

func (m *Migrator) UpdateReplicationConfig(ctx context.Context, className string, cfg *models.ReplicationConfig) error

func (*Migrator) UpdateShardStatus 

func (m *Migrator) UpdateShardStatus(ctx context.Context, className, shardName, targetStatus string, schemaVersion uint64) error

func (*Migrator) UpdateTenants added in v1.21.0 

func (m *Migrator) UpdateTenants(ctx context.Context, class *models.Class, updates []*schemaUC.UpdateTenantPayload, implicitTenantActivation bool) error

UpdateTenants activates or deactivates tenant partitions and returns a commit func that can be used to either commit or rollback the changes

func (*Migrator) UpdateVectorIndexConfig 

func (m *Migrator) UpdateVectorIndexConfig(ctx context.Context,
	className string, updated schemaConfig.VectorIndexConfig,
) error

func (*Migrator) UpdateVectorIndexConfigs added in v1.24.0 

func (m *Migrator) UpdateVectorIndexConfigs(ctx context.Context,
	className string, updated map[string]schemaConfig.VectorIndexConfig,
) error

func (*Migrator) ValidateInvertedIndexConfigUpdate 

func (m *Migrator) ValidateInvertedIndexConfigUpdate(old, updated *models.InvertedIndexConfig,
) error

func (*Migrator) ValidateVectorIndexConfigUpdate 

func (m *Migrator) ValidateVectorIndexConfigUpdate(
	old, updated schemaConfig.VectorIndexConfig,
) error

func (*Migrator) ValidateVectorIndexConfigsUpdate added in v1.24.0 

func (m *Migrator) ValidateVectorIndexConfigsUpdate(old, updated map[string]schemaConfig.VectorIndexConfig,
) error

func (*Migrator) WaitForStartup added in v1.25.0 

func (m *Migrator) WaitForStartup(ctx context.Context) error

type MockIndexGetter added in v1.32.0 

type MockIndexGetter struct {
	mock.Mock
}

MockIndexGetter is an autogenerated mock type for the IndexGetter type

func NewMockIndexGetter added in v1.32.0 

func NewMockIndexGetter(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockIndexGetter

NewMockIndexGetter creates a new instance of MockIndexGetter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockIndexGetter) EXPECT added in v1.32.0 

func (_m *MockIndexGetter) EXPECT() *MockIndexGetter_Expecter

func (*MockIndexGetter) GetIndexLike added in v1.32.0 

func (_m *MockIndexGetter) GetIndexLike(className schema.ClassName) IndexLike

GetIndexLike provides a mock function with given fields: className

type MockIndexGetter_Expecter added in v1.32.0 

type MockIndexGetter_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockIndexGetter_Expecter) GetIndexLike added in v1.32.0 

func (_e *MockIndexGetter_Expecter) GetIndexLike(className interface{}) *MockIndexGetter_GetIndexLike_Call

GetIndexLike is a helper method to define mock.On call

  • className schema.ClassName

type MockIndexGetter_GetIndexLike_Call added in v1.32.0 

type MockIndexGetter_GetIndexLike_Call struct {
	*mock.Call
}

MockIndexGetter_GetIndexLike_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetIndexLike'

func (*MockIndexGetter_GetIndexLike_Call) Return added in v1.32.0 

func (_c *MockIndexGetter_GetIndexLike_Call) Return(_a0 IndexLike) *MockIndexGetter_GetIndexLike_Call

func (*MockIndexGetter_GetIndexLike_Call) Run added in v1.32.0 

func (_c *MockIndexGetter_GetIndexLike_Call) Run(run func(className schema.ClassName)) *MockIndexGetter_GetIndexLike_Call

func (*MockIndexGetter_GetIndexLike_Call) RunAndReturn added in v1.32.0 

func (_c *MockIndexGetter_GetIndexLike_Call) RunAndReturn(run func(schema.ClassName) IndexLike) *MockIndexGetter_GetIndexLike_Call

type MockIndexLike added in v1.32.0 

type MockIndexLike struct {
	mock.Mock
}

MockIndexLike is an autogenerated mock type for the IndexLike type

func NewMockIndexLike added in v1.32.0 

func NewMockIndexLike(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockIndexLike

NewMockIndexLike creates a new instance of MockIndexLike. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockIndexLike) CalculateUnloadedObjectsMetrics added in v1.32.0 

func (_m *MockIndexLike) CalculateUnloadedObjectsMetrics(ctx context.Context, tenantName string) (types.ObjectUsage, error)

CalculateUnloadedObjectsMetrics provides a mock function with given fields: ctx, tenantName

func (*MockIndexLike) CalculateUnloadedVectorsMetrics added in v1.32.0 

func (_m *MockIndexLike) CalculateUnloadedVectorsMetrics(ctx context.Context, tenantName string) (int64, error)

CalculateUnloadedVectorsMetrics provides a mock function with given fields: ctx, tenantName

func (*MockIndexLike) EXPECT added in v1.32.0 

func (_m *MockIndexLike) EXPECT() *MockIndexLike_Expecter

func (*MockIndexLike) ForEachShard added in v1.32.0 

func (_m *MockIndexLike) ForEachShard(f func(string, ShardLike) error) error

ForEachShard provides a mock function with given fields: f

type MockIndexLike_CalculateUnloadedObjectsMetrics_Call added in v1.32.0 

type MockIndexLike_CalculateUnloadedObjectsMetrics_Call struct {
	*mock.Call
}

MockIndexLike_CalculateUnloadedObjectsMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CalculateUnloadedObjectsMetrics'

func (*MockIndexLike_CalculateUnloadedObjectsMetrics_Call) Return added in v1.32.0 

func (_c *MockIndexLike_CalculateUnloadedObjectsMetrics_Call) Return(_a0 types.ObjectUsage, _a1 error) *MockIndexLike_CalculateUnloadedObjectsMetrics_Call

func (*MockIndexLike_CalculateUnloadedObjectsMetrics_Call) Run added in v1.32.0 

func (_c *MockIndexLike_CalculateUnloadedObjectsMetrics_Call) Run(run func(ctx context.Context, tenantName string)) *MockIndexLike_CalculateUnloadedObjectsMetrics_Call

func (*MockIndexLike_CalculateUnloadedObjectsMetrics_Call) RunAndReturn added in v1.32.0 

func (_c *MockIndexLike_CalculateUnloadedObjectsMetrics_Call) RunAndReturn(run func(context.Context, string) (types.ObjectUsage, error)) *MockIndexLike_CalculateUnloadedObjectsMetrics_Call

type MockIndexLike_CalculateUnloadedVectorsMetrics_Call added in v1.32.0 

type MockIndexLike_CalculateUnloadedVectorsMetrics_Call struct {
	*mock.Call
}

MockIndexLike_CalculateUnloadedVectorsMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CalculateUnloadedVectorsMetrics'

func (*MockIndexLike_CalculateUnloadedVectorsMetrics_Call) Return added in v1.32.0 

func (_c *MockIndexLike_CalculateUnloadedVectorsMetrics_Call) Return(_a0 int64, _a1 error) *MockIndexLike_CalculateUnloadedVectorsMetrics_Call

func (*MockIndexLike_CalculateUnloadedVectorsMetrics_Call) Run added in v1.32.0 

func (_c *MockIndexLike_CalculateUnloadedVectorsMetrics_Call) Run(run func(ctx context.Context, tenantName string)) *MockIndexLike_CalculateUnloadedVectorsMetrics_Call

func (*MockIndexLike_CalculateUnloadedVectorsMetrics_Call) RunAndReturn added in v1.32.0 

func (_c *MockIndexLike_CalculateUnloadedVectorsMetrics_Call) RunAndReturn(run func(context.Context, string) (int64, error)) *MockIndexLike_CalculateUnloadedVectorsMetrics_Call

type MockIndexLike_Expecter added in v1.32.0 

type MockIndexLike_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockIndexLike_Expecter) CalculateUnloadedObjectsMetrics added in v1.32.0 

func (_e *MockIndexLike_Expecter) CalculateUnloadedObjectsMetrics(ctx interface{}, tenantName interface{}) *MockIndexLike_CalculateUnloadedObjectsMetrics_Call

CalculateUnloadedObjectsMetrics is a helper method to define mock.On call

  • ctx context.Context
  • tenantName string

func (*MockIndexLike_Expecter) CalculateUnloadedVectorsMetrics added in v1.32.0 

func (_e *MockIndexLike_Expecter) CalculateUnloadedVectorsMetrics(ctx interface{}, tenantName interface{}) *MockIndexLike_CalculateUnloadedVectorsMetrics_Call

CalculateUnloadedVectorsMetrics is a helper method to define mock.On call

  • ctx context.Context
  • tenantName string

func (*MockIndexLike_Expecter) ForEachShard added in v1.32.0 

func (_e *MockIndexLike_Expecter) ForEachShard(f interface{}) *MockIndexLike_ForEachShard_Call

ForEachShard is a helper method to define mock.On call

  • f func(string , ShardLike) error

type MockIndexLike_ForEachShard_Call added in v1.32.0 

type MockIndexLike_ForEachShard_Call struct {
	*mock.Call
}

MockIndexLike_ForEachShard_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForEachShard'

func (*MockIndexLike_ForEachShard_Call) Return added in v1.32.0 

func (_c *MockIndexLike_ForEachShard_Call) Return(_a0 error) *MockIndexLike_ForEachShard_Call

func (*MockIndexLike_ForEachShard_Call) Run added in v1.32.0 

func (_c *MockIndexLike_ForEachShard_Call) Run(run func(f func(string, ShardLike) error)) *MockIndexLike_ForEachShard_Call

func (*MockIndexLike_ForEachShard_Call) RunAndReturn added in v1.32.0 

func (_c *MockIndexLike_ForEachShard_Call) RunAndReturn(run func(func(string, ShardLike) error) error) *MockIndexLike_ForEachShard_Call

type MockShardLike added in v1.32.0 

type MockShardLike struct {
	mock.Mock
}

MockShardLike is an autogenerated mock type for the ShardLike type

func NewMockShardLike added in v1.32.0 

func NewMockShardLike(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockShardLike

NewMockShardLike creates a new instance of MockShardLike. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockShardLike) Activity added in v1.32.0 

func (_m *MockShardLike) Activity() (int32, int32)

Activity provides a mock function with no fields

func (*MockShardLike) AddReferencesBatch added in v1.32.0 

func (_m *MockShardLike) AddReferencesBatch(ctx context.Context, refs objects.BatchReferences) []error

AddReferencesBatch provides a mock function with given fields: ctx, refs

func (*MockShardLike) Aggregate added in v1.32.0 

func (_m *MockShardLike) Aggregate(ctx context.Context, params aggregation.Params, _a2 *modules.Provider) (*aggregation.Result, error)

Aggregate provides a mock function with given fields: ctx, params, _a2

func (*MockShardLike) AnalyzeObject added in v1.32.0 

func (_m *MockShardLike) AnalyzeObject(_a0 *storobj.Object) ([]inverted.Property, []inverted.NilProperty, error)

AnalyzeObject provides a mock function with given fields: _a0

func (*MockShardLike) ConvertQueue added in v1.32.0 

func (_m *MockShardLike) ConvertQueue(targetVector string) error

ConvertQueue provides a mock function with given fields: targetVector

func (*MockShardLike) Counter added in v1.32.0 

func (_m *MockShardLike) Counter() *indexcounter.Counter

Counter provides a mock function with no fields

func (*MockShardLike) CreateBackupSnapshot added in v1.35.15 

func (_m *MockShardLike) CreateBackupSnapshot(ctx context.Context, sd *backup.ShardDescriptor, stagingRoot string) ([]string, error)

CreateBackupSnapshot provides a mock function with given fields: ctx, sd, stagingRoot

func (*MockShardLike) DebugGetDocIdLockStatus added in v1.32.11 

func (_m *MockShardLike) DebugGetDocIdLockStatus() (bool, error)

DebugGetDocIdLockStatus provides a mock function with no fields

func (*MockShardLike) DebugResetVectorIndex added in v1.32.0 

func (_m *MockShardLike) DebugResetVectorIndex(ctx context.Context, targetVector string) error

DebugResetVectorIndex provides a mock function with given fields: ctx, targetVector

func (*MockShardLike) DeleteObject added in v1.32.0 

func (_m *MockShardLike) DeleteObject(ctx context.Context, id strfmt.UUID, deletionTime time.Time) error

DeleteObject provides a mock function with given fields: ctx, id, deletionTime

func (*MockShardLike) DeleteObjectBatch added in v1.32.0 

func (_m *MockShardLike) DeleteObjectBatch(ctx context.Context, ids []strfmt.UUID, deletionTime time.Time, dryRun bool) objects.BatchSimpleObjects

DeleteObjectBatch provides a mock function with given fields: ctx, ids, deletionTime, dryRun

func (*MockShardLike) Dimensions added in v1.32.0 

func (_m *MockShardLike) Dimensions(ctx context.Context, targetVector string) (int, error)

Dimensions provides a mock function with given fields: ctx, targetVector

func (*MockShardLike) EXPECT added in v1.32.0 

func (_m *MockShardLike) EXPECT() *MockShardLike_Expecter

func (*MockShardLike) Exists added in v1.32.0 

func (_m *MockShardLike) Exists(ctx context.Context, id strfmt.UUID) (bool, error)

Exists provides a mock function with given fields: ctx, id

func (*MockShardLike) FillQueue added in v1.32.0 

func (_m *MockShardLike) FillQueue(targetVector string, from uint64) error

FillQueue provides a mock function with given fields: targetVector, from

func (*MockShardLike) FindUUIDs added in v1.32.0 

func (_m *MockShardLike) FindUUIDs(ctx context.Context, _a1 *filters.LocalFilter) ([]strfmt.UUID, error)

FindUUIDs provides a mock function with given fields: ctx, _a1

func (*MockShardLike) ForEachVectorIndex added in v1.32.0 

func (_m *MockShardLike) ForEachVectorIndex(f func(string, VectorIndex) error) error

ForEachVectorIndex provides a mock function with given fields: f

func (*MockShardLike) ForEachVectorQueue added in v1.32.0 

func (_m *MockShardLike) ForEachVectorQueue(f func(string, *VectorIndexQueue) error) error

ForEachVectorQueue provides a mock function with given fields: f

func (*MockShardLike) GetFile added in v1.32.0 

func (_m *MockShardLike) GetFile(ctx context.Context, relativeFilePath string) (io.ReadCloser, error)

GetFile provides a mock function with given fields: ctx, relativeFilePath

func (*MockShardLike) GetFileMetadata added in v1.32.0 

func (_m *MockShardLike) GetFileMetadata(ctx context.Context, relativeFilePath string) (file.FileMetadata, error)

GetFileMetadata provides a mock function with given fields: ctx, relativeFilePath

func (*MockShardLike) GetPropertyLengthTracker added in v1.32.0 

func (_m *MockShardLike) GetPropertyLengthTracker() *inverted.JsonShardMetaData

GetPropertyLengthTracker provides a mock function with no fields

func (*MockShardLike) GetStatus added in v1.32.0 

func (_m *MockShardLike) GetStatus() storagestate.Status

GetStatus provides a mock function with no fields

func (*MockShardLike) GetVectorIndex added in v1.32.0 

func (_m *MockShardLike) GetVectorIndex(targetVector string) (VectorIndex, bool)

GetVectorIndex provides a mock function with given fields: targetVector

func (*MockShardLike) GetVectorIndexQueue added in v1.32.0 

func (_m *MockShardLike) GetVectorIndexQueue(targetVector string) (*VectorIndexQueue, bool)

GetVectorIndexQueue provides a mock function with given fields: targetVector

func (*MockShardLike) HaltForTransfer added in v1.32.0 

func (_m *MockShardLike) HaltForTransfer(ctx context.Context, offloading bool, inactivityTimeout time.Duration) error

HaltForTransfer provides a mock function with given fields: ctx, offloading, inactivityTimeout

func (*MockShardLike) HashTreeLevel added in v1.32.0 

func (_m *MockShardLike) HashTreeLevel(ctx context.Context, level int, discriminant *hashtree.Bitset) ([]hashtree.Digest, error)

HashTreeLevel provides a mock function with given fields: ctx, level, discriminant

func (*MockShardLike) ID added in v1.32.0 

func (_m *MockShardLike) ID() string

ID provides a mock function with no fields

func (*MockShardLike) Index added in v1.32.0 

func (_m *MockShardLike) Index() *Index

Index provides a mock function with no fields

func (*MockShardLike) ListBackupFiles added in v1.32.0 

func (_m *MockShardLike) ListBackupFiles(ctx context.Context, ret *backup.ShardDescriptor) ([]string, error)

ListBackupFiles provides a mock function with given fields: ctx, ret

func (*MockShardLike) MergeObject added in v1.32.0 

func (_m *MockShardLike) MergeObject(ctx context.Context, object objects.MergeDocument) error

MergeObject provides a mock function with given fields: ctx, object

func (*MockShardLike) Metrics added in v1.32.0 

func (_m *MockShardLike) Metrics() *Metrics

Metrics provides a mock function with no fields

func (*MockShardLike) MultiObjectByID added in v1.32.0 

func (_m *MockShardLike) MultiObjectByID(ctx context.Context, query []multi.Identifier) ([]*storobj.Object, error)

MultiObjectByID provides a mock function with given fields: ctx, query

func (*MockShardLike) Name added in v1.32.0 

func (_m *MockShardLike) Name() string

Name provides a mock function with no fields

func (*MockShardLike) NotifyReady added in v1.32.0 

func (_m *MockShardLike) NotifyReady()

NotifyReady provides a mock function with no fields

func (*MockShardLike) ObjectByID added in v1.32.0 

func (_m *MockShardLike) ObjectByID(ctx context.Context, id strfmt.UUID, props search.SelectProperties, _a3 additional.Properties) (*storobj.Object, error)

ObjectByID provides a mock function with given fields: ctx, id, props, _a3

func (*MockShardLike) ObjectCount added in v1.32.0 

func (_m *MockShardLike) ObjectCount(ctx context.Context) (int, error)

ObjectCount provides a mock function with given fields: ctx

func (*MockShardLike) ObjectCountAsync added in v1.32.0 

func (_m *MockShardLike) ObjectCountAsync(ctx context.Context) (int64, error)

ObjectCountAsync provides a mock function with given fields: ctx

func (*MockShardLike) ObjectDigestErrDeleted added in v1.34.20 

func (_m *MockShardLike) ObjectDigestErrDeleted(ctx context.Context, id strfmt.UUID) (types.RepairResponse, error)

ObjectDigestErrDeleted provides a mock function with given fields: ctx, id

func (*MockShardLike) ObjectDigests added in v1.34.20 

func (_m *MockShardLike) ObjectDigests(ctx context.Context, query []multi.Identifier) ([]types.RepairResponse, error)

ObjectDigests provides a mock function with given fields: ctx, query

func (*MockShardLike) ObjectDigestsInRange added in v1.32.0 

func (_m *MockShardLike) ObjectDigestsInRange(ctx context.Context, initialUUID strfmt.UUID, finalUUID strfmt.UUID, limit int) ([]types.RepairResponse, error)

ObjectDigestsInRange provides a mock function with given fields: ctx, initialUUID, finalUUID, limit

func (*MockShardLike) ObjectList added in v1.32.0 

func (_m *MockShardLike) ObjectList(ctx context.Context, limit int, sort []filters.Sort, cursor *filters.Cursor, _a4 additional.Properties, className schema.ClassName) ([]*storobj.Object, error)

ObjectList provides a mock function with given fields: ctx, limit, sort, cursor, _a4, className

func (*MockShardLike) ObjectSearch added in v1.32.0 

func (_m *MockShardLike) ObjectSearch(ctx context.Context, limit int, _a2 *filters.LocalFilter, keywordRanking *searchparams.KeywordRanking, sort []filters.Sort, cursor *filters.Cursor, _a6 additional.Properties, properties []string) ([]*storobj.Object, []float32, error)

ObjectSearch provides a mock function with given fields: ctx, limit, _a2, keywordRanking, sort, cursor, _a6, properties

func (*MockShardLike) ObjectVectorSearch added in v1.32.0 

func (_m *MockShardLike) ObjectVectorSearch(ctx context.Context, searchVectors []models.Vector, targetVectors []string, targetDist float32, limit int, _a5 *filters.LocalFilter, sort []filters.Sort, groupBy *searchparams.GroupBy, _a8 additional.Properties, targetCombination *dto.TargetCombination, properties []string) ([]*storobj.Object, []float32, error)

ObjectVectorSearch provides a mock function with given fields: ctx, searchVectors, targetVectors, targetDist, limit, _a5, sort, groupBy, _a8, targetCombination, properties

func (*MockShardLike) PutObject added in v1.32.0 

func (_m *MockShardLike) PutObject(_a0 context.Context, _a1 *storobj.Object) error

PutObject provides a mock function with given fields: _a0, _a1

func (*MockShardLike) PutObjectBatch added in v1.32.0 

func (_m *MockShardLike) PutObjectBatch(_a0 context.Context, _a1 []*storobj.Object) []error

PutObjectBatch provides a mock function with given fields: _a0, _a1

func (*MockShardLike) QuantizedDimensions added in v1.32.0 

func (_m *MockShardLike) QuantizedDimensions(ctx context.Context, targetVector string, segments int) (int, error)

QuantizedDimensions provides a mock function with given fields: ctx, targetVector, segments

func (*MockShardLike) RepairIndex added in v1.32.0 

func (_m *MockShardLike) RepairIndex(ctx context.Context, targetVector string) error

RepairIndex provides a mock function with given fields: ctx, targetVector

func (*MockShardLike) RequantizeIndex added in v1.32.12 

func (_m *MockShardLike) RequantizeIndex(ctx context.Context, targetVector string) error

RequantizeIndex provides a mock function with given fields: ctx, targetVector

func (*MockShardLike) SetAsyncReplicationState added in v1.34.13 

func (_m *MockShardLike) SetAsyncReplicationState(ctx context.Context, _a1 AsyncReplicationConfig, enabled bool) error

SetAsyncReplicationState provides a mock function with given fields: ctx, _a1, enabled

func (*MockShardLike) SetPropertyLengths added in v1.32.0 

func (_m *MockShardLike) SetPropertyLengths(props []inverted.Property) error

SetPropertyLengths provides a mock function with given fields: props

func (*MockShardLike) SetStatusReadonly added in v1.32.0 

func (_m *MockShardLike) SetStatusReadonly(reason string) error

SetStatusReadonly provides a mock function with given fields: reason

func (*MockShardLike) Shutdown added in v1.32.0 

func (_m *MockShardLike) Shutdown(_a0 context.Context) error

Shutdown provides a mock function with given fields: _a0

func (*MockShardLike) Store added in v1.32.0 

func (_m *MockShardLike) Store() *lsmkv.Store

Store provides a mock function with no fields

func (*MockShardLike) UpdateStatus added in v1.32.0 

func (_m *MockShardLike) UpdateStatus(status string, reason string) error

UpdateStatus provides a mock function with given fields: status, reason

func (*MockShardLike) UpdateVectorIndexConfig added in v1.32.0 

func (_m *MockShardLike) UpdateVectorIndexConfig(ctx context.Context, updated config.VectorIndexConfig) error

UpdateVectorIndexConfig provides a mock function with given fields: ctx, updated

func (*MockShardLike) UpdateVectorIndexConfigs added in v1.32.0 

func (_m *MockShardLike) UpdateVectorIndexConfigs(ctx context.Context, updated map[string]config.VectorIndexConfig) error

UpdateVectorIndexConfigs provides a mock function with given fields: ctx, updated

func (*MockShardLike) VectorDistanceForQuery added in v1.32.0 

func (_m *MockShardLike) VectorDistanceForQuery(ctx context.Context, id uint64, searchVectors []models.Vector, targets []string) ([]float32, error)

VectorDistanceForQuery provides a mock function with given fields: ctx, id, searchVectors, targets

func (*MockShardLike) Versioner added in v1.32.0 

func (_m *MockShardLike) Versioner() *shardVersioner

Versioner provides a mock function with no fields

func (*MockShardLike) WasDeleted added in v1.32.0 

func (_m *MockShardLike) WasDeleted(ctx context.Context, id strfmt.UUID) (bool, time.Time, error)

WasDeleted provides a mock function with given fields: ctx, id

type MockShardLike_Activity_Call added in v1.32.0 

type MockShardLike_Activity_Call struct {
	*mock.Call
}

MockShardLike_Activity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Activity'

func (*MockShardLike_Activity_Call) Return added in v1.32.0 

func (_c *MockShardLike_Activity_Call) Return(_a0 int32, _a1 int32) *MockShardLike_Activity_Call

func (*MockShardLike_Activity_Call) Run added in v1.32.0 

func (_c *MockShardLike_Activity_Call) Run(run func()) *MockShardLike_Activity_Call

func (*MockShardLike_Activity_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Activity_Call) RunAndReturn(run func() (int32, int32)) *MockShardLike_Activity_Call

type MockShardLike_AddReferencesBatch_Call added in v1.32.0 

type MockShardLike_AddReferencesBatch_Call struct {
	*mock.Call
}

MockShardLike_AddReferencesBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddReferencesBatch'

func (*MockShardLike_AddReferencesBatch_Call) Return added in v1.32.0 

func (_c *MockShardLike_AddReferencesBatch_Call) Return(_a0 []error) *MockShardLike_AddReferencesBatch_Call

func (*MockShardLike_AddReferencesBatch_Call) Run added in v1.32.0 

func (_c *MockShardLike_AddReferencesBatch_Call) Run(run func(ctx context.Context, refs objects.BatchReferences)) *MockShardLike_AddReferencesBatch_Call

func (*MockShardLike_AddReferencesBatch_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_AddReferencesBatch_Call) RunAndReturn(run func(context.Context, objects.BatchReferences) []error) *MockShardLike_AddReferencesBatch_Call

type MockShardLike_Aggregate_Call added in v1.32.0 

type MockShardLike_Aggregate_Call struct {
	*mock.Call
}

MockShardLike_Aggregate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Aggregate'

func (*MockShardLike_Aggregate_Call) Return added in v1.32.0 

func (_c *MockShardLike_Aggregate_Call) Return(_a0 *aggregation.Result, _a1 error) *MockShardLike_Aggregate_Call

func (*MockShardLike_Aggregate_Call) Run added in v1.32.0 

func (_c *MockShardLike_Aggregate_Call) Run(run func(ctx context.Context, params aggregation.Params, _a2 *modules.Provider)) *MockShardLike_Aggregate_Call

func (*MockShardLike_Aggregate_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Aggregate_Call) RunAndReturn(run func(context.Context, aggregation.Params, *modules.Provider) (*aggregation.Result, error)) *MockShardLike_Aggregate_Call

type MockShardLike_AnalyzeObject_Call added in v1.32.0 

type MockShardLike_AnalyzeObject_Call struct {
	*mock.Call
}

MockShardLike_AnalyzeObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AnalyzeObject'

func (*MockShardLike_AnalyzeObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_AnalyzeObject_Call) Return(_a0 []inverted.Property, _a1 []inverted.NilProperty, _a2 error) *MockShardLike_AnalyzeObject_Call

func (*MockShardLike_AnalyzeObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_AnalyzeObject_Call) Run(run func(_a0 *storobj.Object)) *MockShardLike_AnalyzeObject_Call

func (*MockShardLike_AnalyzeObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_AnalyzeObject_Call) RunAndReturn(run func(*storobj.Object) ([]inverted.Property, []inverted.NilProperty, error)) *MockShardLike_AnalyzeObject_Call

type MockShardLike_ConvertQueue_Call added in v1.32.0 

type MockShardLike_ConvertQueue_Call struct {
	*mock.Call
}

MockShardLike_ConvertQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConvertQueue'

func (*MockShardLike_ConvertQueue_Call) Return added in v1.32.0 

func (_c *MockShardLike_ConvertQueue_Call) Return(_a0 error) *MockShardLike_ConvertQueue_Call

func (*MockShardLike_ConvertQueue_Call) Run added in v1.32.0 

func (_c *MockShardLike_ConvertQueue_Call) Run(run func(targetVector string)) *MockShardLike_ConvertQueue_Call

func (*MockShardLike_ConvertQueue_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ConvertQueue_Call) RunAndReturn(run func(string) error) *MockShardLike_ConvertQueue_Call

type MockShardLike_Counter_Call added in v1.32.0 

type MockShardLike_Counter_Call struct {
	*mock.Call
}

MockShardLike_Counter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Counter'

func (*MockShardLike_Counter_Call) Return added in v1.32.0 

func (_c *MockShardLike_Counter_Call) Return(_a0 *indexcounter.Counter) *MockShardLike_Counter_Call

func (*MockShardLike_Counter_Call) Run added in v1.32.0 

func (_c *MockShardLike_Counter_Call) Run(run func()) *MockShardLike_Counter_Call

func (*MockShardLike_Counter_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Counter_Call) RunAndReturn(run func() *indexcounter.Counter) *MockShardLike_Counter_Call

type MockShardLike_CreateBackupSnapshot_Call added in v1.35.15 

type MockShardLike_CreateBackupSnapshot_Call struct {
	*mock.Call
}

MockShardLike_CreateBackupSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateBackupSnapshot'

func (*MockShardLike_CreateBackupSnapshot_Call) Return added in v1.35.15 

func (_c *MockShardLike_CreateBackupSnapshot_Call) Return(_a0 []string, _a1 error) *MockShardLike_CreateBackupSnapshot_Call

func (*MockShardLike_CreateBackupSnapshot_Call) Run added in v1.35.15 

func (_c *MockShardLike_CreateBackupSnapshot_Call) Run(run func(ctx context.Context, sd *backup.ShardDescriptor, stagingRoot string)) *MockShardLike_CreateBackupSnapshot_Call

func (*MockShardLike_CreateBackupSnapshot_Call) RunAndReturn added in v1.35.15 

func (_c *MockShardLike_CreateBackupSnapshot_Call) RunAndReturn(run func(context.Context, *backup.ShardDescriptor, string) ([]string, error)) *MockShardLike_CreateBackupSnapshot_Call

type MockShardLike_DebugGetDocIdLockStatus_Call added in v1.32.11 

type MockShardLike_DebugGetDocIdLockStatus_Call struct {
	*mock.Call
}

MockShardLike_DebugGetDocIdLockStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DebugGetDocIdLockStatus'

func (*MockShardLike_DebugGetDocIdLockStatus_Call) Return added in v1.32.11 

func (_c *MockShardLike_DebugGetDocIdLockStatus_Call) Return(_a0 bool, _a1 error) *MockShardLike_DebugGetDocIdLockStatus_Call

func (*MockShardLike_DebugGetDocIdLockStatus_Call) Run added in v1.32.11 

func (_c *MockShardLike_DebugGetDocIdLockStatus_Call) Run(run func()) *MockShardLike_DebugGetDocIdLockStatus_Call

func (*MockShardLike_DebugGetDocIdLockStatus_Call) RunAndReturn added in v1.32.11 

func (_c *MockShardLike_DebugGetDocIdLockStatus_Call) RunAndReturn(run func() (bool, error)) *MockShardLike_DebugGetDocIdLockStatus_Call

type MockShardLike_DebugResetVectorIndex_Call added in v1.32.0 

type MockShardLike_DebugResetVectorIndex_Call struct {
	*mock.Call
}

MockShardLike_DebugResetVectorIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DebugResetVectorIndex'

func (*MockShardLike_DebugResetVectorIndex_Call) Return added in v1.32.0 

func (_c *MockShardLike_DebugResetVectorIndex_Call) Return(_a0 error) *MockShardLike_DebugResetVectorIndex_Call

func (*MockShardLike_DebugResetVectorIndex_Call) Run added in v1.32.0 

func (_c *MockShardLike_DebugResetVectorIndex_Call) Run(run func(ctx context.Context, targetVector string)) *MockShardLike_DebugResetVectorIndex_Call

func (*MockShardLike_DebugResetVectorIndex_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_DebugResetVectorIndex_Call) RunAndReturn(run func(context.Context, string) error) *MockShardLike_DebugResetVectorIndex_Call

type MockShardLike_DeleteObjectBatch_Call added in v1.32.0 

type MockShardLike_DeleteObjectBatch_Call struct {
	*mock.Call
}

MockShardLike_DeleteObjectBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteObjectBatch'

func (*MockShardLike_DeleteObjectBatch_Call) Return added in v1.32.0 

func (_c *MockShardLike_DeleteObjectBatch_Call) Return(_a0 objects.BatchSimpleObjects) *MockShardLike_DeleteObjectBatch_Call

func (*MockShardLike_DeleteObjectBatch_Call) Run added in v1.32.0 

func (_c *MockShardLike_DeleteObjectBatch_Call) Run(run func(ctx context.Context, ids []strfmt.UUID, deletionTime time.Time, dryRun bool)) *MockShardLike_DeleteObjectBatch_Call

func (*MockShardLike_DeleteObjectBatch_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_DeleteObjectBatch_Call) RunAndReturn(run func(context.Context, []strfmt.UUID, time.Time, bool) objects.BatchSimpleObjects) *MockShardLike_DeleteObjectBatch_Call

type MockShardLike_DeleteObject_Call added in v1.32.0 

type MockShardLike_DeleteObject_Call struct {
	*mock.Call
}

MockShardLike_DeleteObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteObject'

func (*MockShardLike_DeleteObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_DeleteObject_Call) Return(_a0 error) *MockShardLike_DeleteObject_Call

func (*MockShardLike_DeleteObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_DeleteObject_Call) Run(run func(ctx context.Context, id strfmt.UUID, deletionTime time.Time)) *MockShardLike_DeleteObject_Call

func (*MockShardLike_DeleteObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_DeleteObject_Call) RunAndReturn(run func(context.Context, strfmt.UUID, time.Time) error) *MockShardLike_DeleteObject_Call

type MockShardLike_Dimensions_Call added in v1.32.0 

type MockShardLike_Dimensions_Call struct {
	*mock.Call
}

MockShardLike_Dimensions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Dimensions'

func (*MockShardLike_Dimensions_Call) Return added in v1.32.0 

func (_c *MockShardLike_Dimensions_Call) Return(_a0 int, _a1 error) *MockShardLike_Dimensions_Call

func (*MockShardLike_Dimensions_Call) Run added in v1.32.0 

func (_c *MockShardLike_Dimensions_Call) Run(run func(ctx context.Context, targetVector string)) *MockShardLike_Dimensions_Call

func (*MockShardLike_Dimensions_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Dimensions_Call) RunAndReturn(run func(context.Context, string) (int, error)) *MockShardLike_Dimensions_Call

type MockShardLike_Exists_Call added in v1.32.0 

type MockShardLike_Exists_Call struct {
	*mock.Call
}

MockShardLike_Exists_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Exists'

func (*MockShardLike_Exists_Call) Return added in v1.32.0 

func (_c *MockShardLike_Exists_Call) Return(_a0 bool, _a1 error) *MockShardLike_Exists_Call

func (*MockShardLike_Exists_Call) Run added in v1.32.0 

func (_c *MockShardLike_Exists_Call) Run(run func(ctx context.Context, id strfmt.UUID)) *MockShardLike_Exists_Call

func (*MockShardLike_Exists_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Exists_Call) RunAndReturn(run func(context.Context, strfmt.UUID) (bool, error)) *MockShardLike_Exists_Call

type MockShardLike_Expecter added in v1.32.0 

type MockShardLike_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockShardLike_Expecter) Activity added in v1.32.0 

func (_e *MockShardLike_Expecter) Activity() *MockShardLike_Activity_Call

Activity is a helper method to define mock.On call

func (*MockShardLike_Expecter) AddReferencesBatch added in v1.32.0 

func (_e *MockShardLike_Expecter) AddReferencesBatch(ctx interface{}, refs interface{}) *MockShardLike_AddReferencesBatch_Call

AddReferencesBatch is a helper method to define mock.On call

  • ctx context.Context
  • refs objects.BatchReferences

func (*MockShardLike_Expecter) Aggregate added in v1.32.0 

func (_e *MockShardLike_Expecter) Aggregate(ctx interface{}, params interface{}, _a2 interface{}) *MockShardLike_Aggregate_Call

Aggregate is a helper method to define mock.On call

  • ctx context.Context
  • params aggregation.Params
  • _a2 *modules.Provider

func (*MockShardLike_Expecter) AnalyzeObject added in v1.32.0 

func (_e *MockShardLike_Expecter) AnalyzeObject(_a0 interface{}) *MockShardLike_AnalyzeObject_Call

AnalyzeObject is a helper method to define mock.On call

  • _a0 *storobj.Object

func (*MockShardLike_Expecter) ConvertQueue added in v1.32.0 

func (_e *MockShardLike_Expecter) ConvertQueue(targetVector interface{}) *MockShardLike_ConvertQueue_Call

ConvertQueue is a helper method to define mock.On call

  • targetVector string

func (*MockShardLike_Expecter) Counter added in v1.32.0 

func (_e *MockShardLike_Expecter) Counter() *MockShardLike_Counter_Call

Counter is a helper method to define mock.On call

func (*MockShardLike_Expecter) CreateBackupSnapshot added in v1.35.15 

func (_e *MockShardLike_Expecter) CreateBackupSnapshot(ctx interface{}, sd interface{}, stagingRoot interface{}) *MockShardLike_CreateBackupSnapshot_Call

CreateBackupSnapshot is a helper method to define mock.On call

  • ctx context.Context
  • sd *backup.ShardDescriptor
  • stagingRoot string

func (*MockShardLike_Expecter) DebugGetDocIdLockStatus added in v1.32.11 

func (_e *MockShardLike_Expecter) DebugGetDocIdLockStatus() *MockShardLike_DebugGetDocIdLockStatus_Call

DebugGetDocIdLockStatus is a helper method to define mock.On call

func (*MockShardLike_Expecter) DebugResetVectorIndex added in v1.32.0 

func (_e *MockShardLike_Expecter) DebugResetVectorIndex(ctx interface{}, targetVector interface{}) *MockShardLike_DebugResetVectorIndex_Call

DebugResetVectorIndex is a helper method to define mock.On call

  • ctx context.Context
  • targetVector string

func (*MockShardLike_Expecter) DeleteObject added in v1.32.0 

func (_e *MockShardLike_Expecter) DeleteObject(ctx interface{}, id interface{}, deletionTime interface{}) *MockShardLike_DeleteObject_Call

DeleteObject is a helper method to define mock.On call

  • ctx context.Context
  • id strfmt.UUID
  • deletionTime time.Time

func (*MockShardLike_Expecter) DeleteObjectBatch added in v1.32.0 

func (_e *MockShardLike_Expecter) DeleteObjectBatch(ctx interface{}, ids interface{}, deletionTime interface{}, dryRun interface{}) *MockShardLike_DeleteObjectBatch_Call

DeleteObjectBatch is a helper method to define mock.On call

  • ctx context.Context
  • ids []strfmt.UUID
  • deletionTime time.Time
  • dryRun bool

func (*MockShardLike_Expecter) Dimensions added in v1.32.0 

func (_e *MockShardLike_Expecter) Dimensions(ctx interface{}, targetVector interface{}) *MockShardLike_Dimensions_Call

Dimensions is a helper method to define mock.On call

  • ctx context.Context
  • targetVector string

func (*MockShardLike_Expecter) Exists added in v1.32.0 

func (_e *MockShardLike_Expecter) Exists(ctx interface{}, id interface{}) *MockShardLike_Exists_Call

Exists is a helper method to define mock.On call

  • ctx context.Context
  • id strfmt.UUID

func (*MockShardLike_Expecter) FillQueue added in v1.32.0 

func (_e *MockShardLike_Expecter) FillQueue(targetVector interface{}, from interface{}) *MockShardLike_FillQueue_Call

FillQueue is a helper method to define mock.On call

  • targetVector string
  • from uint64

func (*MockShardLike_Expecter) FindUUIDs added in v1.32.0 

func (_e *MockShardLike_Expecter) FindUUIDs(ctx interface{}, _a1 interface{}) *MockShardLike_FindUUIDs_Call

FindUUIDs is a helper method to define mock.On call

  • ctx context.Context
  • _a1 *filters.LocalFilter

func (*MockShardLike_Expecter) ForEachVectorIndex added in v1.32.0 

func (_e *MockShardLike_Expecter) ForEachVectorIndex(f interface{}) *MockShardLike_ForEachVectorIndex_Call

ForEachVectorIndex is a helper method to define mock.On call

  • f func(string , VectorIndex) error

func (*MockShardLike_Expecter) ForEachVectorQueue added in v1.32.0 

func (_e *MockShardLike_Expecter) ForEachVectorQueue(f interface{}) *MockShardLike_ForEachVectorQueue_Call

ForEachVectorQueue is a helper method to define mock.On call

  • f func(string , *VectorIndexQueue) error

func (*MockShardLike_Expecter) GetFile added in v1.32.0 

func (_e *MockShardLike_Expecter) GetFile(ctx interface{}, relativeFilePath interface{}) *MockShardLike_GetFile_Call

GetFile is a helper method to define mock.On call

  • ctx context.Context
  • relativeFilePath string

func (*MockShardLike_Expecter) GetFileMetadata added in v1.32.0 

func (_e *MockShardLike_Expecter) GetFileMetadata(ctx interface{}, relativeFilePath interface{}) *MockShardLike_GetFileMetadata_Call

GetFileMetadata is a helper method to define mock.On call

  • ctx context.Context
  • relativeFilePath string

func (*MockShardLike_Expecter) GetPropertyLengthTracker added in v1.32.0 

func (_e *MockShardLike_Expecter) GetPropertyLengthTracker() *MockShardLike_GetPropertyLengthTracker_Call

GetPropertyLengthTracker is a helper method to define mock.On call

func (*MockShardLike_Expecter) GetStatus added in v1.32.0 

func (_e *MockShardLike_Expecter) GetStatus() *MockShardLike_GetStatus_Call

GetStatus is a helper method to define mock.On call

func (*MockShardLike_Expecter) GetVectorIndex added in v1.32.0 

func (_e *MockShardLike_Expecter) GetVectorIndex(targetVector interface{}) *MockShardLike_GetVectorIndex_Call

GetVectorIndex is a helper method to define mock.On call

  • targetVector string

func (*MockShardLike_Expecter) GetVectorIndexQueue added in v1.32.0 

func (_e *MockShardLike_Expecter) GetVectorIndexQueue(targetVector interface{}) *MockShardLike_GetVectorIndexQueue_Call

GetVectorIndexQueue is a helper method to define mock.On call

  • targetVector string

func (*MockShardLike_Expecter) HaltForTransfer added in v1.32.0 

func (_e *MockShardLike_Expecter) HaltForTransfer(ctx interface{}, offloading interface{}, inactivityTimeout interface{}) *MockShardLike_HaltForTransfer_Call

HaltForTransfer is a helper method to define mock.On call

  • ctx context.Context
  • offloading bool
  • inactivityTimeout time.Duration

func (*MockShardLike_Expecter) HashTreeLevel added in v1.32.0 

func (_e *MockShardLike_Expecter) HashTreeLevel(ctx interface{}, level interface{}, discriminant interface{}) *MockShardLike_HashTreeLevel_Call

HashTreeLevel is a helper method to define mock.On call

  • ctx context.Context
  • level int
  • discriminant *hashtree.Bitset

func (*MockShardLike_Expecter) ID added in v1.32.0 

func (_e *MockShardLike_Expecter) ID() *MockShardLike_ID_Call

ID is a helper method to define mock.On call

func (*MockShardLike_Expecter) Index added in v1.32.0 

func (_e *MockShardLike_Expecter) Index() *MockShardLike_Index_Call

Index is a helper method to define mock.On call

func (*MockShardLike_Expecter) ListBackupFiles added in v1.32.0 

func (_e *MockShardLike_Expecter) ListBackupFiles(ctx interface{}, ret interface{}) *MockShardLike_ListBackupFiles_Call

ListBackupFiles is a helper method to define mock.On call

  • ctx context.Context
  • ret *backup.ShardDescriptor

func (*MockShardLike_Expecter) MergeObject added in v1.32.0 

func (_e *MockShardLike_Expecter) MergeObject(ctx interface{}, object interface{}) *MockShardLike_MergeObject_Call

MergeObject is a helper method to define mock.On call

  • ctx context.Context
  • object objects.MergeDocument

func (*MockShardLike_Expecter) Metrics added in v1.32.0 

func (_e *MockShardLike_Expecter) Metrics() *MockShardLike_Metrics_Call

Metrics is a helper method to define mock.On call

func (*MockShardLike_Expecter) MultiObjectByID added in v1.32.0 

func (_e *MockShardLike_Expecter) MultiObjectByID(ctx interface{}, query interface{}) *MockShardLike_MultiObjectByID_Call

MultiObjectByID is a helper method to define mock.On call

  • ctx context.Context
  • query []multi.Identifier

func (*MockShardLike_Expecter) Name added in v1.32.0 

func (_e *MockShardLike_Expecter) Name() *MockShardLike_Name_Call

Name is a helper method to define mock.On call

func (*MockShardLike_Expecter) NotifyReady added in v1.32.0 

func (_e *MockShardLike_Expecter) NotifyReady() *MockShardLike_NotifyReady_Call

NotifyReady is a helper method to define mock.On call

func (*MockShardLike_Expecter) ObjectByID added in v1.32.0 

func (_e *MockShardLike_Expecter) ObjectByID(ctx interface{}, id interface{}, props interface{}, _a3 interface{}) *MockShardLike_ObjectByID_Call

ObjectByID is a helper method to define mock.On call

  • ctx context.Context
  • id strfmt.UUID
  • props search.SelectProperties
  • _a3 additional.Properties

func (*MockShardLike_Expecter) ObjectCount added in v1.32.0 

func (_e *MockShardLike_Expecter) ObjectCount(ctx interface{}) *MockShardLike_ObjectCount_Call

ObjectCount is a helper method to define mock.On call

  • ctx context.Context

func (*MockShardLike_Expecter) ObjectCountAsync added in v1.32.0 

func (_e *MockShardLike_Expecter) ObjectCountAsync(ctx interface{}) *MockShardLike_ObjectCountAsync_Call

ObjectCountAsync is a helper method to define mock.On call

  • ctx context.Context

func (*MockShardLike_Expecter) ObjectDigestErrDeleted added in v1.34.20 

func (_e *MockShardLike_Expecter) ObjectDigestErrDeleted(ctx interface{}, id interface{}) *MockShardLike_ObjectDigestErrDeleted_Call

ObjectDigestErrDeleted is a helper method to define mock.On call

  • ctx context.Context
  • id strfmt.UUID

func (*MockShardLike_Expecter) ObjectDigests added in v1.34.20 

func (_e *MockShardLike_Expecter) ObjectDigests(ctx interface{}, query interface{}) *MockShardLike_ObjectDigests_Call

ObjectDigests is a helper method to define mock.On call

  • ctx context.Context
  • query []multi.Identifier

func (*MockShardLike_Expecter) ObjectDigestsInRange added in v1.32.0 

func (_e *MockShardLike_Expecter) ObjectDigestsInRange(ctx interface{}, initialUUID interface{}, finalUUID interface{}, limit interface{}) *MockShardLike_ObjectDigestsInRange_Call

ObjectDigestsInRange is a helper method to define mock.On call

  • ctx context.Context
  • initialUUID strfmt.UUID
  • finalUUID strfmt.UUID
  • limit int

func (*MockShardLike_Expecter) ObjectList added in v1.32.0 

func (_e *MockShardLike_Expecter) ObjectList(ctx interface{}, limit interface{}, sort interface{}, cursor interface{}, _a4 interface{}, className interface{}) *MockShardLike_ObjectList_Call

ObjectList is a helper method to define mock.On call

  • ctx context.Context
  • limit int
  • sort []filters.Sort
  • cursor *filters.Cursor
  • _a4 additional.Properties
  • className schema.ClassName

func (*MockShardLike_Expecter) ObjectSearch added in v1.32.0 

func (_e *MockShardLike_Expecter) ObjectSearch(ctx interface{}, limit interface{}, _a2 interface{}, keywordRanking interface{}, sort interface{}, cursor interface{}, _a6 interface{}, properties interface{}) *MockShardLike_ObjectSearch_Call

ObjectSearch is a helper method to define mock.On call

  • ctx context.Context
  • limit int
  • _a2 *filters.LocalFilter
  • keywordRanking *searchparams.KeywordRanking
  • sort []filters.Sort
  • cursor *filters.Cursor
  • _a6 additional.Properties
  • properties []string

func (*MockShardLike_Expecter) ObjectVectorSearch added in v1.32.0 

func (_e *MockShardLike_Expecter) ObjectVectorSearch(ctx interface{}, searchVectors interface{}, targetVectors interface{}, targetDist interface{}, limit interface{}, _a5 interface{}, sort interface{}, groupBy interface{}, _a8 interface{}, targetCombination interface{}, properties interface{}) *MockShardLike_ObjectVectorSearch_Call

ObjectVectorSearch is a helper method to define mock.On call

  • ctx context.Context
  • searchVectors []models.Vector
  • targetVectors []string
  • targetDist float32
  • limit int
  • _a5 *filters.LocalFilter
  • sort []filters.Sort
  • groupBy *searchparams.GroupBy
  • _a8 additional.Properties
  • targetCombination *dto.TargetCombination
  • properties []string

func (*MockShardLike_Expecter) PutObject added in v1.32.0 

func (_e *MockShardLike_Expecter) PutObject(_a0 interface{}, _a1 interface{}) *MockShardLike_PutObject_Call

PutObject is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *storobj.Object

func (*MockShardLike_Expecter) PutObjectBatch added in v1.32.0 

func (_e *MockShardLike_Expecter) PutObjectBatch(_a0 interface{}, _a1 interface{}) *MockShardLike_PutObjectBatch_Call

PutObjectBatch is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 []*storobj.Object

func (*MockShardLike_Expecter) QuantizedDimensions added in v1.32.0 

func (_e *MockShardLike_Expecter) QuantizedDimensions(ctx interface{}, targetVector interface{}, segments interface{}) *MockShardLike_QuantizedDimensions_Call

QuantizedDimensions is a helper method to define mock.On call

  • ctx context.Context
  • targetVector string
  • segments int

func (*MockShardLike_Expecter) RepairIndex added in v1.32.0 

func (_e *MockShardLike_Expecter) RepairIndex(ctx interface{}, targetVector interface{}) *MockShardLike_RepairIndex_Call

RepairIndex is a helper method to define mock.On call

  • ctx context.Context
  • targetVector string

func (*MockShardLike_Expecter) RequantizeIndex added in v1.32.12 

func (_e *MockShardLike_Expecter) RequantizeIndex(ctx interface{}, targetVector interface{}) *MockShardLike_RequantizeIndex_Call

RequantizeIndex is a helper method to define mock.On call

  • ctx context.Context
  • targetVector string

func (*MockShardLike_Expecter) SetAsyncReplicationState added in v1.34.13 

func (_e *MockShardLike_Expecter) SetAsyncReplicationState(ctx interface{}, _a1 interface{}, enabled interface{}) *MockShardLike_SetAsyncReplicationState_Call

SetAsyncReplicationState is a helper method to define mock.On call

  • ctx context.Context
  • _a1 AsyncReplicationConfig
  • enabled bool

func (*MockShardLike_Expecter) SetPropertyLengths added in v1.32.0 

func (_e *MockShardLike_Expecter) SetPropertyLengths(props interface{}) *MockShardLike_SetPropertyLengths_Call

SetPropertyLengths is a helper method to define mock.On call

  • props []inverted.Property

func (*MockShardLike_Expecter) SetStatusReadonly added in v1.32.0 

func (_e *MockShardLike_Expecter) SetStatusReadonly(reason interface{}) *MockShardLike_SetStatusReadonly_Call

SetStatusReadonly is a helper method to define mock.On call

  • reason string

func (*MockShardLike_Expecter) Shutdown added in v1.32.0 

func (_e *MockShardLike_Expecter) Shutdown(_a0 interface{}) *MockShardLike_Shutdown_Call

Shutdown is a helper method to define mock.On call

  • _a0 context.Context

func (*MockShardLike_Expecter) Store added in v1.32.0 

func (_e *MockShardLike_Expecter) Store() *MockShardLike_Store_Call

Store is a helper method to define mock.On call

func (*MockShardLike_Expecter) UpdateStatus added in v1.32.0 

func (_e *MockShardLike_Expecter) UpdateStatus(status interface{}, reason interface{}) *MockShardLike_UpdateStatus_Call

UpdateStatus is a helper method to define mock.On call

  • status string
  • reason string

func (*MockShardLike_Expecter) UpdateVectorIndexConfig added in v1.32.0 

func (_e *MockShardLike_Expecter) UpdateVectorIndexConfig(ctx interface{}, updated interface{}) *MockShardLike_UpdateVectorIndexConfig_Call

UpdateVectorIndexConfig is a helper method to define mock.On call

  • ctx context.Context
  • updated config.VectorIndexConfig

func (*MockShardLike_Expecter) UpdateVectorIndexConfigs added in v1.32.0 

func (_e *MockShardLike_Expecter) UpdateVectorIndexConfigs(ctx interface{}, updated interface{}) *MockShardLike_UpdateVectorIndexConfigs_Call

UpdateVectorIndexConfigs is a helper method to define mock.On call

  • ctx context.Context
  • updated map[string]config.VectorIndexConfig

func (*MockShardLike_Expecter) VectorDistanceForQuery added in v1.32.0 

func (_e *MockShardLike_Expecter) VectorDistanceForQuery(ctx interface{}, id interface{}, searchVectors interface{}, targets interface{}) *MockShardLike_VectorDistanceForQuery_Call

VectorDistanceForQuery is a helper method to define mock.On call

  • ctx context.Context
  • id uint64
  • searchVectors []models.Vector
  • targets []string

func (*MockShardLike_Expecter) Versioner added in v1.32.0 

func (_e *MockShardLike_Expecter) Versioner() *MockShardLike_Versioner_Call

Versioner is a helper method to define mock.On call

func (*MockShardLike_Expecter) WasDeleted added in v1.32.0 

func (_e *MockShardLike_Expecter) WasDeleted(ctx interface{}, id interface{}) *MockShardLike_WasDeleted_Call

WasDeleted is a helper method to define mock.On call

  • ctx context.Context
  • id strfmt.UUID

type MockShardLike_FillQueue_Call added in v1.32.0 

type MockShardLike_FillQueue_Call struct {
	*mock.Call
}

MockShardLike_FillQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FillQueue'

func (*MockShardLike_FillQueue_Call) Return added in v1.32.0 

func (_c *MockShardLike_FillQueue_Call) Return(_a0 error) *MockShardLike_FillQueue_Call

func (*MockShardLike_FillQueue_Call) Run added in v1.32.0 

func (_c *MockShardLike_FillQueue_Call) Run(run func(targetVector string, from uint64)) *MockShardLike_FillQueue_Call

func (*MockShardLike_FillQueue_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_FillQueue_Call) RunAndReturn(run func(string, uint64) error) *MockShardLike_FillQueue_Call

type MockShardLike_FindUUIDs_Call added in v1.32.0 

type MockShardLike_FindUUIDs_Call struct {
	*mock.Call
}

MockShardLike_FindUUIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindUUIDs'

func (*MockShardLike_FindUUIDs_Call) Return added in v1.32.0 

func (_c *MockShardLike_FindUUIDs_Call) Return(_a0 []strfmt.UUID, _a1 error) *MockShardLike_FindUUIDs_Call

func (*MockShardLike_FindUUIDs_Call) Run added in v1.32.0 

func (_c *MockShardLike_FindUUIDs_Call) Run(run func(ctx context.Context, _a1 *filters.LocalFilter)) *MockShardLike_FindUUIDs_Call

func (*MockShardLike_FindUUIDs_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_FindUUIDs_Call) RunAndReturn(run func(context.Context, *filters.LocalFilter) ([]strfmt.UUID, error)) *MockShardLike_FindUUIDs_Call

type MockShardLike_ForEachVectorIndex_Call added in v1.32.0 

type MockShardLike_ForEachVectorIndex_Call struct {
	*mock.Call
}

MockShardLike_ForEachVectorIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForEachVectorIndex'

func (*MockShardLike_ForEachVectorIndex_Call) Return added in v1.32.0 

func (_c *MockShardLike_ForEachVectorIndex_Call) Return(_a0 error) *MockShardLike_ForEachVectorIndex_Call

func (*MockShardLike_ForEachVectorIndex_Call) Run added in v1.32.0 

func (_c *MockShardLike_ForEachVectorIndex_Call) Run(run func(f func(string, VectorIndex) error)) *MockShardLike_ForEachVectorIndex_Call

func (*MockShardLike_ForEachVectorIndex_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ForEachVectorIndex_Call) RunAndReturn(run func(func(string, VectorIndex) error) error) *MockShardLike_ForEachVectorIndex_Call

type MockShardLike_ForEachVectorQueue_Call added in v1.32.0 

type MockShardLike_ForEachVectorQueue_Call struct {
	*mock.Call
}

MockShardLike_ForEachVectorQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForEachVectorQueue'

func (*MockShardLike_ForEachVectorQueue_Call) Return added in v1.32.0 

func (_c *MockShardLike_ForEachVectorQueue_Call) Return(_a0 error) *MockShardLike_ForEachVectorQueue_Call

func (*MockShardLike_ForEachVectorQueue_Call) Run added in v1.32.0 

func (_c *MockShardLike_ForEachVectorQueue_Call) Run(run func(f func(string, *VectorIndexQueue) error)) *MockShardLike_ForEachVectorQueue_Call

func (*MockShardLike_ForEachVectorQueue_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ForEachVectorQueue_Call) RunAndReturn(run func(func(string, *VectorIndexQueue) error) error) *MockShardLike_ForEachVectorQueue_Call

type MockShardLike_GetFileMetadata_Call added in v1.32.0 

type MockShardLike_GetFileMetadata_Call struct {
	*mock.Call
}

MockShardLike_GetFileMetadata_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetFileMetadata'

func (*MockShardLike_GetFileMetadata_Call) Return added in v1.32.0 

func (_c *MockShardLike_GetFileMetadata_Call) Return(_a0 file.FileMetadata, _a1 error) *MockShardLike_GetFileMetadata_Call

func (*MockShardLike_GetFileMetadata_Call) Run added in v1.32.0 

func (_c *MockShardLike_GetFileMetadata_Call) Run(run func(ctx context.Context, relativeFilePath string)) *MockShardLike_GetFileMetadata_Call

func (*MockShardLike_GetFileMetadata_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_GetFileMetadata_Call) RunAndReturn(run func(context.Context, string) (file.FileMetadata, error)) *MockShardLike_GetFileMetadata_Call

type MockShardLike_GetFile_Call added in v1.32.0 

type MockShardLike_GetFile_Call struct {
	*mock.Call
}

MockShardLike_GetFile_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetFile'

func (*MockShardLike_GetFile_Call) Return added in v1.32.0 

func (_c *MockShardLike_GetFile_Call) Return(_a0 io.ReadCloser, _a1 error) *MockShardLike_GetFile_Call

func (*MockShardLike_GetFile_Call) Run added in v1.32.0 

func (_c *MockShardLike_GetFile_Call) Run(run func(ctx context.Context, relativeFilePath string)) *MockShardLike_GetFile_Call

func (*MockShardLike_GetFile_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_GetFile_Call) RunAndReturn(run func(context.Context, string) (io.ReadCloser, error)) *MockShardLike_GetFile_Call

type MockShardLike_GetPropertyLengthTracker_Call added in v1.32.0 

type MockShardLike_GetPropertyLengthTracker_Call struct {
	*mock.Call
}

MockShardLike_GetPropertyLengthTracker_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPropertyLengthTracker'

func (*MockShardLike_GetPropertyLengthTracker_Call) Return added in v1.32.0 

func (_c *MockShardLike_GetPropertyLengthTracker_Call) Return(_a0 *inverted.JsonShardMetaData) *MockShardLike_GetPropertyLengthTracker_Call

func (*MockShardLike_GetPropertyLengthTracker_Call) Run added in v1.32.0 

func (_c *MockShardLike_GetPropertyLengthTracker_Call) Run(run func()) *MockShardLike_GetPropertyLengthTracker_Call

func (*MockShardLike_GetPropertyLengthTracker_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_GetPropertyLengthTracker_Call) RunAndReturn(run func() *inverted.JsonShardMetaData) *MockShardLike_GetPropertyLengthTracker_Call

type MockShardLike_GetStatus_Call added in v1.32.0 

type MockShardLike_GetStatus_Call struct {
	*mock.Call
}

MockShardLike_GetStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStatus'

func (*MockShardLike_GetStatus_Call) Return added in v1.32.0 

func (_c *MockShardLike_GetStatus_Call) Return(_a0 storagestate.Status) *MockShardLike_GetStatus_Call

func (*MockShardLike_GetStatus_Call) Run added in v1.32.0 

func (_c *MockShardLike_GetStatus_Call) Run(run func()) *MockShardLike_GetStatus_Call

func (*MockShardLike_GetStatus_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_GetStatus_Call) RunAndReturn(run func() storagestate.Status) *MockShardLike_GetStatus_Call

type MockShardLike_GetVectorIndexQueue_Call added in v1.32.0 

type MockShardLike_GetVectorIndexQueue_Call struct {
	*mock.Call
}

MockShardLike_GetVectorIndexQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVectorIndexQueue'

func (*MockShardLike_GetVectorIndexQueue_Call) Return added in v1.32.0 

func (_c *MockShardLike_GetVectorIndexQueue_Call) Return(_a0 *VectorIndexQueue, _a1 bool) *MockShardLike_GetVectorIndexQueue_Call

func (*MockShardLike_GetVectorIndexQueue_Call) Run added in v1.32.0 

func (_c *MockShardLike_GetVectorIndexQueue_Call) Run(run func(targetVector string)) *MockShardLike_GetVectorIndexQueue_Call

func (*MockShardLike_GetVectorIndexQueue_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_GetVectorIndexQueue_Call) RunAndReturn(run func(string) (*VectorIndexQueue, bool)) *MockShardLike_GetVectorIndexQueue_Call

type MockShardLike_GetVectorIndex_Call added in v1.32.0 

type MockShardLike_GetVectorIndex_Call struct {
	*mock.Call
}

MockShardLike_GetVectorIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVectorIndex'

func (*MockShardLike_GetVectorIndex_Call) Return added in v1.32.0 

func (_c *MockShardLike_GetVectorIndex_Call) Return(_a0 VectorIndex, _a1 bool) *MockShardLike_GetVectorIndex_Call

func (*MockShardLike_GetVectorIndex_Call) Run added in v1.32.0 

func (_c *MockShardLike_GetVectorIndex_Call) Run(run func(targetVector string)) *MockShardLike_GetVectorIndex_Call

func (*MockShardLike_GetVectorIndex_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_GetVectorIndex_Call) RunAndReturn(run func(string) (VectorIndex, bool)) *MockShardLike_GetVectorIndex_Call

type MockShardLike_HaltForTransfer_Call added in v1.32.0 

type MockShardLike_HaltForTransfer_Call struct {
	*mock.Call
}

MockShardLike_HaltForTransfer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HaltForTransfer'

func (*MockShardLike_HaltForTransfer_Call) Return added in v1.32.0 

func (_c *MockShardLike_HaltForTransfer_Call) Return(_a0 error) *MockShardLike_HaltForTransfer_Call

func (*MockShardLike_HaltForTransfer_Call) Run added in v1.32.0 

func (_c *MockShardLike_HaltForTransfer_Call) Run(run func(ctx context.Context, offloading bool, inactivityTimeout time.Duration)) *MockShardLike_HaltForTransfer_Call

func (*MockShardLike_HaltForTransfer_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_HaltForTransfer_Call) RunAndReturn(run func(context.Context, bool, time.Duration) error) *MockShardLike_HaltForTransfer_Call

type MockShardLike_HashTreeLevel_Call added in v1.32.0 

type MockShardLike_HashTreeLevel_Call struct {
	*mock.Call
}

MockShardLike_HashTreeLevel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HashTreeLevel'

func (*MockShardLike_HashTreeLevel_Call) Return added in v1.32.0 

func (_c *MockShardLike_HashTreeLevel_Call) Return(digests []hashtree.Digest, err error) *MockShardLike_HashTreeLevel_Call

func (*MockShardLike_HashTreeLevel_Call) Run added in v1.32.0 

func (_c *MockShardLike_HashTreeLevel_Call) Run(run func(ctx context.Context, level int, discriminant *hashtree.Bitset)) *MockShardLike_HashTreeLevel_Call

func (*MockShardLike_HashTreeLevel_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_HashTreeLevel_Call) RunAndReturn(run func(context.Context, int, *hashtree.Bitset) ([]hashtree.Digest, error)) *MockShardLike_HashTreeLevel_Call

type MockShardLike_ID_Call added in v1.32.0 

type MockShardLike_ID_Call struct {
	*mock.Call
}

MockShardLike_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*MockShardLike_ID_Call) Return added in v1.32.0 

func (_c *MockShardLike_ID_Call) Return(_a0 string) *MockShardLike_ID_Call

func (*MockShardLike_ID_Call) Run added in v1.32.0 

func (_c *MockShardLike_ID_Call) Run(run func()) *MockShardLike_ID_Call

func (*MockShardLike_ID_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ID_Call) RunAndReturn(run func() string) *MockShardLike_ID_Call

type MockShardLike_Index_Call added in v1.32.0 

type MockShardLike_Index_Call struct {
	*mock.Call
}

MockShardLike_Index_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Index'

func (*MockShardLike_Index_Call) Return added in v1.32.0 

func (_c *MockShardLike_Index_Call) Return(_a0 *Index) *MockShardLike_Index_Call

func (*MockShardLike_Index_Call) Run added in v1.32.0 

func (_c *MockShardLike_Index_Call) Run(run func()) *MockShardLike_Index_Call

func (*MockShardLike_Index_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Index_Call) RunAndReturn(run func() *Index) *MockShardLike_Index_Call

type MockShardLike_ListBackupFiles_Call added in v1.32.0 

type MockShardLike_ListBackupFiles_Call struct {
	*mock.Call
}

MockShardLike_ListBackupFiles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListBackupFiles'

func (*MockShardLike_ListBackupFiles_Call) Return added in v1.32.0 

func (_c *MockShardLike_ListBackupFiles_Call) Return(_a0 []string, _a1 error) *MockShardLike_ListBackupFiles_Call

func (*MockShardLike_ListBackupFiles_Call) Run added in v1.32.0 

func (_c *MockShardLike_ListBackupFiles_Call) Run(run func(ctx context.Context, ret *backup.ShardDescriptor)) *MockShardLike_ListBackupFiles_Call

func (*MockShardLike_ListBackupFiles_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ListBackupFiles_Call) RunAndReturn(run func(context.Context, *backup.ShardDescriptor) ([]string, error)) *MockShardLike_ListBackupFiles_Call

type MockShardLike_MergeObject_Call added in v1.32.0 

type MockShardLike_MergeObject_Call struct {
	*mock.Call
}

MockShardLike_MergeObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MergeObject'

func (*MockShardLike_MergeObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_MergeObject_Call) Return(_a0 error) *MockShardLike_MergeObject_Call

func (*MockShardLike_MergeObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_MergeObject_Call) Run(run func(ctx context.Context, object objects.MergeDocument)) *MockShardLike_MergeObject_Call

func (*MockShardLike_MergeObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_MergeObject_Call) RunAndReturn(run func(context.Context, objects.MergeDocument) error) *MockShardLike_MergeObject_Call

type MockShardLike_Metrics_Call added in v1.32.0 

type MockShardLike_Metrics_Call struct {
	*mock.Call
}

MockShardLike_Metrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Metrics'

func (*MockShardLike_Metrics_Call) Return added in v1.32.0 

func (_c *MockShardLike_Metrics_Call) Return(_a0 *Metrics) *MockShardLike_Metrics_Call

func (*MockShardLike_Metrics_Call) Run added in v1.32.0 

func (_c *MockShardLike_Metrics_Call) Run(run func()) *MockShardLike_Metrics_Call

func (*MockShardLike_Metrics_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Metrics_Call) RunAndReturn(run func() *Metrics) *MockShardLike_Metrics_Call

type MockShardLike_MultiObjectByID_Call added in v1.32.0 

type MockShardLike_MultiObjectByID_Call struct {
	*mock.Call
}

MockShardLike_MultiObjectByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MultiObjectByID'

func (*MockShardLike_MultiObjectByID_Call) Return added in v1.32.0 

func (_c *MockShardLike_MultiObjectByID_Call) Return(_a0 []*storobj.Object, _a1 error) *MockShardLike_MultiObjectByID_Call

func (*MockShardLike_MultiObjectByID_Call) Run added in v1.32.0 

func (_c *MockShardLike_MultiObjectByID_Call) Run(run func(ctx context.Context, query []multi.Identifier)) *MockShardLike_MultiObjectByID_Call

func (*MockShardLike_MultiObjectByID_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_MultiObjectByID_Call) RunAndReturn(run func(context.Context, []multi.Identifier) ([]*storobj.Object, error)) *MockShardLike_MultiObjectByID_Call

type MockShardLike_Name_Call added in v1.32.0 

type MockShardLike_Name_Call struct {
	*mock.Call
}

MockShardLike_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'

func (*MockShardLike_Name_Call) Return added in v1.32.0 

func (_c *MockShardLike_Name_Call) Return(_a0 string) *MockShardLike_Name_Call

func (*MockShardLike_Name_Call) Run added in v1.32.0 

func (_c *MockShardLike_Name_Call) Run(run func()) *MockShardLike_Name_Call

func (*MockShardLike_Name_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Name_Call) RunAndReturn(run func() string) *MockShardLike_Name_Call

type MockShardLike_NotifyReady_Call added in v1.32.0 

type MockShardLike_NotifyReady_Call struct {
	*mock.Call
}

MockShardLike_NotifyReady_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NotifyReady'

func (*MockShardLike_NotifyReady_Call) Return added in v1.32.0 

func (_c *MockShardLike_NotifyReady_Call) Return() *MockShardLike_NotifyReady_Call

func (*MockShardLike_NotifyReady_Call) Run added in v1.32.0 

func (_c *MockShardLike_NotifyReady_Call) Run(run func()) *MockShardLike_NotifyReady_Call

func (*MockShardLike_NotifyReady_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_NotifyReady_Call) RunAndReturn(run func()) *MockShardLike_NotifyReady_Call

type MockShardLike_ObjectByID_Call added in v1.32.0 

type MockShardLike_ObjectByID_Call struct {
	*mock.Call
}

MockShardLike_ObjectByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectByID'

func (*MockShardLike_ObjectByID_Call) Return added in v1.32.0 

func (_c *MockShardLike_ObjectByID_Call) Return(_a0 *storobj.Object, _a1 error) *MockShardLike_ObjectByID_Call

func (*MockShardLike_ObjectByID_Call) Run added in v1.32.0 

func (_c *MockShardLike_ObjectByID_Call) Run(run func(ctx context.Context, id strfmt.UUID, props search.SelectProperties, _a3 additional.Properties)) *MockShardLike_ObjectByID_Call

func (*MockShardLike_ObjectByID_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ObjectByID_Call) RunAndReturn(run func(context.Context, strfmt.UUID, search.SelectProperties, additional.Properties) (*storobj.Object, error)) *MockShardLike_ObjectByID_Call

type MockShardLike_ObjectCountAsync_Call added in v1.32.0 

type MockShardLike_ObjectCountAsync_Call struct {
	*mock.Call
}

MockShardLike_ObjectCountAsync_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectCountAsync'

func (*MockShardLike_ObjectCountAsync_Call) Return added in v1.32.0 

func (_c *MockShardLike_ObjectCountAsync_Call) Return(_a0 int64, _a1 error) *MockShardLike_ObjectCountAsync_Call

func (*MockShardLike_ObjectCountAsync_Call) Run added in v1.32.0 

func (_c *MockShardLike_ObjectCountAsync_Call) Run(run func(ctx context.Context)) *MockShardLike_ObjectCountAsync_Call

func (*MockShardLike_ObjectCountAsync_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ObjectCountAsync_Call) RunAndReturn(run func(context.Context) (int64, error)) *MockShardLike_ObjectCountAsync_Call

type MockShardLike_ObjectCount_Call added in v1.32.0 

type MockShardLike_ObjectCount_Call struct {
	*mock.Call
}

MockShardLike_ObjectCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectCount'

func (*MockShardLike_ObjectCount_Call) Return added in v1.32.0 

func (_c *MockShardLike_ObjectCount_Call) Return(_a0 int, _a1 error) *MockShardLike_ObjectCount_Call

func (*MockShardLike_ObjectCount_Call) Run added in v1.32.0 

func (_c *MockShardLike_ObjectCount_Call) Run(run func(ctx context.Context)) *MockShardLike_ObjectCount_Call

func (*MockShardLike_ObjectCount_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ObjectCount_Call) RunAndReturn(run func(context.Context) (int, error)) *MockShardLike_ObjectCount_Call

type MockShardLike_ObjectDigestErrDeleted_Call added in v1.34.20 

type MockShardLike_ObjectDigestErrDeleted_Call struct {
	*mock.Call
}

MockShardLike_ObjectDigestErrDeleted_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectDigestErrDeleted'

func (*MockShardLike_ObjectDigestErrDeleted_Call) Return added in v1.34.20 

func (_c *MockShardLike_ObjectDigestErrDeleted_Call) Return(_a0 types.RepairResponse, _a1 error) *MockShardLike_ObjectDigestErrDeleted_Call

func (*MockShardLike_ObjectDigestErrDeleted_Call) Run added in v1.34.20 

func (_c *MockShardLike_ObjectDigestErrDeleted_Call) Run(run func(ctx context.Context, id strfmt.UUID)) *MockShardLike_ObjectDigestErrDeleted_Call

func (*MockShardLike_ObjectDigestErrDeleted_Call) RunAndReturn added in v1.34.20 

func (_c *MockShardLike_ObjectDigestErrDeleted_Call) RunAndReturn(run func(context.Context, strfmt.UUID) (types.RepairResponse, error)) *MockShardLike_ObjectDigestErrDeleted_Call

type MockShardLike_ObjectDigestsInRange_Call added in v1.32.0 

type MockShardLike_ObjectDigestsInRange_Call struct {
	*mock.Call
}

MockShardLike_ObjectDigestsInRange_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectDigestsInRange'

func (*MockShardLike_ObjectDigestsInRange_Call) Return added in v1.32.0 

func (_c *MockShardLike_ObjectDigestsInRange_Call) Return(objs []types.RepairResponse, err error) *MockShardLike_ObjectDigestsInRange_Call

func (*MockShardLike_ObjectDigestsInRange_Call) Run added in v1.32.0 

func (_c *MockShardLike_ObjectDigestsInRange_Call) Run(run func(ctx context.Context, initialUUID strfmt.UUID, finalUUID strfmt.UUID, limit int)) *MockShardLike_ObjectDigestsInRange_Call

func (*MockShardLike_ObjectDigestsInRange_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ObjectDigestsInRange_Call) RunAndReturn(run func(context.Context, strfmt.UUID, strfmt.UUID, int) ([]types.RepairResponse, error)) *MockShardLike_ObjectDigestsInRange_Call

type MockShardLike_ObjectDigests_Call added in v1.34.20 

type MockShardLike_ObjectDigests_Call struct {
	*mock.Call
}

MockShardLike_ObjectDigests_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectDigests'

func (*MockShardLike_ObjectDigests_Call) Return added in v1.34.20 

func (_c *MockShardLike_ObjectDigests_Call) Return(_a0 []types.RepairResponse, _a1 error) *MockShardLike_ObjectDigests_Call

func (*MockShardLike_ObjectDigests_Call) Run added in v1.34.20 

func (_c *MockShardLike_ObjectDigests_Call) Run(run func(ctx context.Context, query []multi.Identifier)) *MockShardLike_ObjectDigests_Call

func (*MockShardLike_ObjectDigests_Call) RunAndReturn added in v1.34.20 

func (_c *MockShardLike_ObjectDigests_Call) RunAndReturn(run func(context.Context, []multi.Identifier) ([]types.RepairResponse, error)) *MockShardLike_ObjectDigests_Call

type MockShardLike_ObjectList_Call added in v1.32.0 

type MockShardLike_ObjectList_Call struct {
	*mock.Call
}

MockShardLike_ObjectList_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectList'

func (*MockShardLike_ObjectList_Call) Return added in v1.32.0 

func (_c *MockShardLike_ObjectList_Call) Return(_a0 []*storobj.Object, _a1 error) *MockShardLike_ObjectList_Call

func (*MockShardLike_ObjectList_Call) Run added in v1.32.0 

func (_c *MockShardLike_ObjectList_Call) Run(run func(ctx context.Context, limit int, sort []filters.Sort, cursor *filters.Cursor, _a4 additional.Properties, className schema.ClassName)) *MockShardLike_ObjectList_Call

func (*MockShardLike_ObjectList_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ObjectList_Call) RunAndReturn(run func(context.Context, int, []filters.Sort, *filters.Cursor, additional.Properties, schema.ClassName) ([]*storobj.Object, error)) *MockShardLike_ObjectList_Call

type MockShardLike_ObjectSearch_Call added in v1.32.0 

type MockShardLike_ObjectSearch_Call struct {
	*mock.Call
}

MockShardLike_ObjectSearch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectSearch'

func (*MockShardLike_ObjectSearch_Call) Return added in v1.32.0 

func (_c *MockShardLike_ObjectSearch_Call) Return(_a0 []*storobj.Object, _a1 []float32, _a2 error) *MockShardLike_ObjectSearch_Call

func (*MockShardLike_ObjectSearch_Call) Run added in v1.32.0 

func (_c *MockShardLike_ObjectSearch_Call) Run(run func(ctx context.Context, limit int, _a2 *filters.LocalFilter, keywordRanking *searchparams.KeywordRanking, sort []filters.Sort, cursor *filters.Cursor, _a6 additional.Properties, properties []string)) *MockShardLike_ObjectSearch_Call

func (*MockShardLike_ObjectSearch_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ObjectSearch_Call) RunAndReturn(run func(context.Context, int, *filters.LocalFilter, *searchparams.KeywordRanking, []filters.Sort, *filters.Cursor, additional.Properties, []string) ([]*storobj.Object, []float32, error)) *MockShardLike_ObjectSearch_Call

type MockShardLike_ObjectVectorSearch_Call added in v1.32.0 

type MockShardLike_ObjectVectorSearch_Call struct {
	*mock.Call
}

MockShardLike_ObjectVectorSearch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObjectVectorSearch'

func (*MockShardLike_ObjectVectorSearch_Call) Return added in v1.32.0 

func (_c *MockShardLike_ObjectVectorSearch_Call) Return(_a0 []*storobj.Object, _a1 []float32, _a2 error) *MockShardLike_ObjectVectorSearch_Call

func (*MockShardLike_ObjectVectorSearch_Call) Run added in v1.32.0 

func (_c *MockShardLike_ObjectVectorSearch_Call) Run(run func(ctx context.Context, searchVectors []models.Vector, targetVectors []string, targetDist float32, limit int, _a5 *filters.LocalFilter, sort []filters.Sort, groupBy *searchparams.GroupBy, _a8 additional.Properties, targetCombination *dto.TargetCombination, properties []string)) *MockShardLike_ObjectVectorSearch_Call

func (*MockShardLike_ObjectVectorSearch_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_ObjectVectorSearch_Call) RunAndReturn(run func(context.Context, []models.Vector, []string, float32, int, *filters.LocalFilter, []filters.Sort, *searchparams.GroupBy, additional.Properties, *dto.TargetCombination, []string) ([]*storobj.Object, []float32, error)) *MockShardLike_ObjectVectorSearch_Call

type MockShardLike_PutObjectBatch_Call added in v1.32.0 

type MockShardLike_PutObjectBatch_Call struct {
	*mock.Call
}

MockShardLike_PutObjectBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutObjectBatch'

func (*MockShardLike_PutObjectBatch_Call) Return added in v1.32.0 

func (_c *MockShardLike_PutObjectBatch_Call) Return(_a0 []error) *MockShardLike_PutObjectBatch_Call

func (*MockShardLike_PutObjectBatch_Call) Run added in v1.32.0 

func (_c *MockShardLike_PutObjectBatch_Call) Run(run func(_a0 context.Context, _a1 []*storobj.Object)) *MockShardLike_PutObjectBatch_Call

func (*MockShardLike_PutObjectBatch_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_PutObjectBatch_Call) RunAndReturn(run func(context.Context, []*storobj.Object) []error) *MockShardLike_PutObjectBatch_Call

type MockShardLike_PutObject_Call added in v1.32.0 

type MockShardLike_PutObject_Call struct {
	*mock.Call
}

MockShardLike_PutObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutObject'

func (*MockShardLike_PutObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_PutObject_Call) Return(_a0 error) *MockShardLike_PutObject_Call

func (*MockShardLike_PutObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_PutObject_Call) Run(run func(_a0 context.Context, _a1 *storobj.Object)) *MockShardLike_PutObject_Call

func (*MockShardLike_PutObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_PutObject_Call) RunAndReturn(run func(context.Context, *storobj.Object) error) *MockShardLike_PutObject_Call

type MockShardLike_QuantizedDimensions_Call added in v1.32.0 

type MockShardLike_QuantizedDimensions_Call struct {
	*mock.Call
}

MockShardLike_QuantizedDimensions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QuantizedDimensions'

func (*MockShardLike_QuantizedDimensions_Call) Return added in v1.32.0 

func (_c *MockShardLike_QuantizedDimensions_Call) Return(_a0 int, _a1 error) *MockShardLike_QuantizedDimensions_Call

func (*MockShardLike_QuantizedDimensions_Call) Run added in v1.32.0 

func (_c *MockShardLike_QuantizedDimensions_Call) Run(run func(ctx context.Context, targetVector string, segments int)) *MockShardLike_QuantizedDimensions_Call

func (*MockShardLike_QuantizedDimensions_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_QuantizedDimensions_Call) RunAndReturn(run func(context.Context, string, int) (int, error)) *MockShardLike_QuantizedDimensions_Call

type MockShardLike_RepairIndex_Call added in v1.32.0 

type MockShardLike_RepairIndex_Call struct {
	*mock.Call
}

MockShardLike_RepairIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RepairIndex'

func (*MockShardLike_RepairIndex_Call) Return added in v1.32.0 

func (_c *MockShardLike_RepairIndex_Call) Return(_a0 error) *MockShardLike_RepairIndex_Call

func (*MockShardLike_RepairIndex_Call) Run added in v1.32.0 

func (_c *MockShardLike_RepairIndex_Call) Run(run func(ctx context.Context, targetVector string)) *MockShardLike_RepairIndex_Call

func (*MockShardLike_RepairIndex_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_RepairIndex_Call) RunAndReturn(run func(context.Context, string) error) *MockShardLike_RepairIndex_Call

type MockShardLike_RequantizeIndex_Call added in v1.32.12 

type MockShardLike_RequantizeIndex_Call struct {
	*mock.Call
}

MockShardLike_RequantizeIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RequantizeIndex'

func (*MockShardLike_RequantizeIndex_Call) Return added in v1.32.12 

func (_c *MockShardLike_RequantizeIndex_Call) Return(_a0 error) *MockShardLike_RequantizeIndex_Call

func (*MockShardLike_RequantizeIndex_Call) Run added in v1.32.12 

func (_c *MockShardLike_RequantizeIndex_Call) Run(run func(ctx context.Context, targetVector string)) *MockShardLike_RequantizeIndex_Call

func (*MockShardLike_RequantizeIndex_Call) RunAndReturn added in v1.32.12 

func (_c *MockShardLike_RequantizeIndex_Call) RunAndReturn(run func(context.Context, string) error) *MockShardLike_RequantizeIndex_Call

type MockShardLike_SetAsyncReplicationState_Call added in v1.34.13 

type MockShardLike_SetAsyncReplicationState_Call struct {
	*mock.Call
}

MockShardLike_SetAsyncReplicationState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetAsyncReplicationState'

func (*MockShardLike_SetAsyncReplicationState_Call) Return added in v1.34.13 

func (_c *MockShardLike_SetAsyncReplicationState_Call) Return(_a0 error) *MockShardLike_SetAsyncReplicationState_Call

func (*MockShardLike_SetAsyncReplicationState_Call) Run added in v1.34.13 

func (_c *MockShardLike_SetAsyncReplicationState_Call) Run(run func(ctx context.Context, _a1 AsyncReplicationConfig, enabled bool)) *MockShardLike_SetAsyncReplicationState_Call

func (*MockShardLike_SetAsyncReplicationState_Call) RunAndReturn added in v1.34.13 

func (_c *MockShardLike_SetAsyncReplicationState_Call) RunAndReturn(run func(context.Context, AsyncReplicationConfig, bool) error) *MockShardLike_SetAsyncReplicationState_Call

type MockShardLike_SetPropertyLengths_Call added in v1.32.0 

type MockShardLike_SetPropertyLengths_Call struct {
	*mock.Call
}

MockShardLike_SetPropertyLengths_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetPropertyLengths'

func (*MockShardLike_SetPropertyLengths_Call) Return added in v1.32.0 

func (_c *MockShardLike_SetPropertyLengths_Call) Return(_a0 error) *MockShardLike_SetPropertyLengths_Call

func (*MockShardLike_SetPropertyLengths_Call) Run added in v1.32.0 

func (_c *MockShardLike_SetPropertyLengths_Call) Run(run func(props []inverted.Property)) *MockShardLike_SetPropertyLengths_Call

func (*MockShardLike_SetPropertyLengths_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_SetPropertyLengths_Call) RunAndReturn(run func([]inverted.Property) error) *MockShardLike_SetPropertyLengths_Call

type MockShardLike_SetStatusReadonly_Call added in v1.32.0 

type MockShardLike_SetStatusReadonly_Call struct {
	*mock.Call
}

MockShardLike_SetStatusReadonly_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetStatusReadonly'

func (*MockShardLike_SetStatusReadonly_Call) Return added in v1.32.0 

func (_c *MockShardLike_SetStatusReadonly_Call) Return(_a0 error) *MockShardLike_SetStatusReadonly_Call

func (*MockShardLike_SetStatusReadonly_Call) Run added in v1.32.0 

func (_c *MockShardLike_SetStatusReadonly_Call) Run(run func(reason string)) *MockShardLike_SetStatusReadonly_Call

func (*MockShardLike_SetStatusReadonly_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_SetStatusReadonly_Call) RunAndReturn(run func(string) error) *MockShardLike_SetStatusReadonly_Call

type MockShardLike_Shutdown_Call added in v1.32.0 

type MockShardLike_Shutdown_Call struct {
	*mock.Call
}

MockShardLike_Shutdown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Shutdown'

func (*MockShardLike_Shutdown_Call) Return added in v1.32.0 

func (_c *MockShardLike_Shutdown_Call) Return(_a0 error) *MockShardLike_Shutdown_Call

func (*MockShardLike_Shutdown_Call) Run added in v1.32.0 

func (_c *MockShardLike_Shutdown_Call) Run(run func(_a0 context.Context)) *MockShardLike_Shutdown_Call

func (*MockShardLike_Shutdown_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Shutdown_Call) RunAndReturn(run func(context.Context) error) *MockShardLike_Shutdown_Call

type MockShardLike_Store_Call added in v1.32.0 

type MockShardLike_Store_Call struct {
	*mock.Call
}

MockShardLike_Store_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Store'

func (*MockShardLike_Store_Call) Return added in v1.32.0 

func (_c *MockShardLike_Store_Call) Return(_a0 *lsmkv.Store) *MockShardLike_Store_Call

func (*MockShardLike_Store_Call) Run added in v1.32.0 

func (_c *MockShardLike_Store_Call) Run(run func()) *MockShardLike_Store_Call

func (*MockShardLike_Store_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Store_Call) RunAndReturn(run func() *lsmkv.Store) *MockShardLike_Store_Call

type MockShardLike_UpdateStatus_Call added in v1.32.0 

type MockShardLike_UpdateStatus_Call struct {
	*mock.Call
}

MockShardLike_UpdateStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateStatus'

func (*MockShardLike_UpdateStatus_Call) Return added in v1.32.0 

func (_c *MockShardLike_UpdateStatus_Call) Return(_a0 error) *MockShardLike_UpdateStatus_Call

func (*MockShardLike_UpdateStatus_Call) Run added in v1.32.0 

func (_c *MockShardLike_UpdateStatus_Call) Run(run func(status string, reason string)) *MockShardLike_UpdateStatus_Call

func (*MockShardLike_UpdateStatus_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_UpdateStatus_Call) RunAndReturn(run func(string, string) error) *MockShardLike_UpdateStatus_Call

type MockShardLike_UpdateVectorIndexConfig_Call added in v1.32.0 

type MockShardLike_UpdateVectorIndexConfig_Call struct {
	*mock.Call
}

MockShardLike_UpdateVectorIndexConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateVectorIndexConfig'

func (*MockShardLike_UpdateVectorIndexConfig_Call) Return added in v1.32.0 

func (_c *MockShardLike_UpdateVectorIndexConfig_Call) Return(_a0 error) *MockShardLike_UpdateVectorIndexConfig_Call

func (*MockShardLike_UpdateVectorIndexConfig_Call) Run added in v1.32.0 

func (_c *MockShardLike_UpdateVectorIndexConfig_Call) Run(run func(ctx context.Context, updated config.VectorIndexConfig)) *MockShardLike_UpdateVectorIndexConfig_Call

func (*MockShardLike_UpdateVectorIndexConfig_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_UpdateVectorIndexConfig_Call) RunAndReturn(run func(context.Context, config.VectorIndexConfig) error) *MockShardLike_UpdateVectorIndexConfig_Call

type MockShardLike_UpdateVectorIndexConfigs_Call added in v1.32.0 

type MockShardLike_UpdateVectorIndexConfigs_Call struct {
	*mock.Call
}

MockShardLike_UpdateVectorIndexConfigs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateVectorIndexConfigs'

func (*MockShardLike_UpdateVectorIndexConfigs_Call) Return added in v1.32.0 

func (_c *MockShardLike_UpdateVectorIndexConfigs_Call) Return(_a0 error) *MockShardLike_UpdateVectorIndexConfigs_Call

func (*MockShardLike_UpdateVectorIndexConfigs_Call) Run added in v1.32.0 

func (_c *MockShardLike_UpdateVectorIndexConfigs_Call) Run(run func(ctx context.Context, updated map[string]config.VectorIndexConfig)) *MockShardLike_UpdateVectorIndexConfigs_Call

func (*MockShardLike_UpdateVectorIndexConfigs_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_UpdateVectorIndexConfigs_Call) RunAndReturn(run func(context.Context, map[string]config.VectorIndexConfig) error) *MockShardLike_UpdateVectorIndexConfigs_Call

type MockShardLike_VectorDistanceForQuery_Call added in v1.32.0 

type MockShardLike_VectorDistanceForQuery_Call struct {
	*mock.Call
}

MockShardLike_VectorDistanceForQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'VectorDistanceForQuery'

func (*MockShardLike_VectorDistanceForQuery_Call) Return added in v1.32.0 

func (_c *MockShardLike_VectorDistanceForQuery_Call) Return(_a0 []float32, _a1 error) *MockShardLike_VectorDistanceForQuery_Call

func (*MockShardLike_VectorDistanceForQuery_Call) Run added in v1.32.0 

func (_c *MockShardLike_VectorDistanceForQuery_Call) Run(run func(ctx context.Context, id uint64, searchVectors []models.Vector, targets []string)) *MockShardLike_VectorDistanceForQuery_Call

func (*MockShardLike_VectorDistanceForQuery_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_VectorDistanceForQuery_Call) RunAndReturn(run func(context.Context, uint64, []models.Vector, []string) ([]float32, error)) *MockShardLike_VectorDistanceForQuery_Call

type MockShardLike_Versioner_Call added in v1.32.0 

type MockShardLike_Versioner_Call struct {
	*mock.Call
}

MockShardLike_Versioner_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Versioner'

func (*MockShardLike_Versioner_Call) Return added in v1.32.0 

func (_c *MockShardLike_Versioner_Call) Return(_a0 *shardVersioner) *MockShardLike_Versioner_Call

func (*MockShardLike_Versioner_Call) Run added in v1.32.0 

func (_c *MockShardLike_Versioner_Call) Run(run func()) *MockShardLike_Versioner_Call

func (*MockShardLike_Versioner_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_Versioner_Call) RunAndReturn(run func() *shardVersioner) *MockShardLike_Versioner_Call

type MockShardLike_WasDeleted_Call added in v1.32.0 

type MockShardLike_WasDeleted_Call struct {
	*mock.Call
}

MockShardLike_WasDeleted_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WasDeleted'

func (*MockShardLike_WasDeleted_Call) Return added in v1.32.0 

func (_c *MockShardLike_WasDeleted_Call) Return(_a0 bool, _a1 time.Time, _a2 error) *MockShardLike_WasDeleted_Call

func (*MockShardLike_WasDeleted_Call) Run added in v1.32.0 

func (_c *MockShardLike_WasDeleted_Call) Run(run func(ctx context.Context, id strfmt.UUID)) *MockShardLike_WasDeleted_Call

func (*MockShardLike_WasDeleted_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_WasDeleted_Call) RunAndReturn(run func(context.Context, strfmt.UUID) (bool, time.Time, error)) *MockShardLike_WasDeleted_Call

type MockShardLike_abortReplication_Call added in v1.32.0 

type MockShardLike_abortReplication_Call struct {
	*mock.Call
}

MockShardLike_abortReplication_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'abortReplication'

func (*MockShardLike_abortReplication_Call) Return added in v1.32.0 

func (_c *MockShardLike_abortReplication_Call) Return(_a0 replica.SimpleResponse) *MockShardLike_abortReplication_Call

func (*MockShardLike_abortReplication_Call) Run added in v1.32.0 

func (_c *MockShardLike_abortReplication_Call) Run(run func(_a0 context.Context, _a1 string)) *MockShardLike_abortReplication_Call

func (*MockShardLike_abortReplication_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_abortReplication_Call) RunAndReturn(run func(context.Context, string) replica.SimpleResponse) *MockShardLike_abortReplication_Call

type MockShardLike_addJobToQueue_Call added in v1.32.0 

type MockShardLike_addJobToQueue_Call struct {
	*mock.Call
}

MockShardLike_addJobToQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'addJobToQueue'

func (*MockShardLike_addJobToQueue_Call) Return added in v1.32.0 

func (_c *MockShardLike_addJobToQueue_Call) Return() *MockShardLike_addJobToQueue_Call

func (*MockShardLike_addJobToQueue_Call) Run added in v1.32.0 

func (_c *MockShardLike_addJobToQueue_Call) Run(run func(job0 job)) *MockShardLike_addJobToQueue_Call

func (*MockShardLike_addJobToQueue_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_addJobToQueue_Call) RunAndReturn(run func(job)) *MockShardLike_addJobToQueue_Call

type MockShardLike_addTargetNodeOverride_Call added in v1.32.0 

type MockShardLike_addTargetNodeOverride_Call struct {
	*mock.Call
}

MockShardLike_addTargetNodeOverride_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'addTargetNodeOverride'

func (*MockShardLike_addTargetNodeOverride_Call) Return added in v1.32.0 

func (_c *MockShardLike_addTargetNodeOverride_Call) Return(_a0 error) *MockShardLike_addTargetNodeOverride_Call

func (*MockShardLike_addTargetNodeOverride_Call) Run added in v1.32.0 

func (_c *MockShardLike_addTargetNodeOverride_Call) Run(run func(ctx context.Context, targetNodeOverride additional.AsyncReplicationTargetNodeOverride)) *MockShardLike_addTargetNodeOverride_Call

func (*MockShardLike_addTargetNodeOverride_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_addTargetNodeOverride_Call) RunAndReturn(run func(context.Context, additional.AsyncReplicationTargetNodeOverride) error) *MockShardLike_addTargetNodeOverride_Call

type MockShardLike_addToPropertyMapBucket_Call added in v1.32.0 

type MockShardLike_addToPropertyMapBucket_Call struct {
	*mock.Call
}

MockShardLike_addToPropertyMapBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'addToPropertyMapBucket'

func (*MockShardLike_addToPropertyMapBucket_Call) Return added in v1.32.0 

func (_c *MockShardLike_addToPropertyMapBucket_Call) Return(_a0 error) *MockShardLike_addToPropertyMapBucket_Call

func (*MockShardLike_addToPropertyMapBucket_Call) Run added in v1.32.0 

func (_c *MockShardLike_addToPropertyMapBucket_Call) Run(run func(bucket *lsmkv.Bucket, pair lsmkv.MapPair, key []byte)) *MockShardLike_addToPropertyMapBucket_Call

func (*MockShardLike_addToPropertyMapBucket_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_addToPropertyMapBucket_Call) RunAndReturn(run func(*lsmkv.Bucket, lsmkv.MapPair, []byte) error) *MockShardLike_addToPropertyMapBucket_Call

type MockShardLike_addToPropertyRangeBucket_Call added in v1.32.0 

type MockShardLike_addToPropertyRangeBucket_Call struct {
	*mock.Call
}

MockShardLike_addToPropertyRangeBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'addToPropertyRangeBucket'

func (*MockShardLike_addToPropertyRangeBucket_Call) Return added in v1.32.0 

func (_c *MockShardLike_addToPropertyRangeBucket_Call) Return(_a0 error) *MockShardLike_addToPropertyRangeBucket_Call

func (*MockShardLike_addToPropertyRangeBucket_Call) Run added in v1.32.0 

func (_c *MockShardLike_addToPropertyRangeBucket_Call) Run(run func(bucket *lsmkv.Bucket, docID uint64, key []byte)) *MockShardLike_addToPropertyRangeBucket_Call

func (*MockShardLike_addToPropertyRangeBucket_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_addToPropertyRangeBucket_Call) RunAndReturn(run func(*lsmkv.Bucket, uint64, []byte) error) *MockShardLike_addToPropertyRangeBucket_Call

type MockShardLike_addToPropertySetBucket_Call added in v1.32.0 

type MockShardLike_addToPropertySetBucket_Call struct {
	*mock.Call
}

MockShardLike_addToPropertySetBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'addToPropertySetBucket'

func (*MockShardLike_addToPropertySetBucket_Call) Return added in v1.32.0 

func (_c *MockShardLike_addToPropertySetBucket_Call) Return(_a0 error) *MockShardLike_addToPropertySetBucket_Call

func (*MockShardLike_addToPropertySetBucket_Call) Run added in v1.32.0 

func (_c *MockShardLike_addToPropertySetBucket_Call) Run(run func(bucket *lsmkv.Bucket, docID uint64, key []byte)) *MockShardLike_addToPropertySetBucket_Call

func (*MockShardLike_addToPropertySetBucket_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_addToPropertySetBucket_Call) RunAndReturn(run func(*lsmkv.Bucket, uint64, []byte) error) *MockShardLike_addToPropertySetBucket_Call

type MockShardLike_batchDeleteObject_Call added in v1.32.0 

type MockShardLike_batchDeleteObject_Call struct {
	*mock.Call
}

MockShardLike_batchDeleteObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'batchDeleteObject'

func (*MockShardLike_batchDeleteObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_batchDeleteObject_Call) Return(_a0 error) *MockShardLike_batchDeleteObject_Call

func (*MockShardLike_batchDeleteObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_batchDeleteObject_Call) Run(run func(ctx context.Context, id strfmt.UUID, deletionTime time.Time)) *MockShardLike_batchDeleteObject_Call

func (*MockShardLike_batchDeleteObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_batchDeleteObject_Call) RunAndReturn(run func(context.Context, strfmt.UUID, time.Time) error) *MockShardLike_batchDeleteObject_Call

type MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call added in v1.32.0 

type MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call struct {
	*mock.Call
}

MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'batchExtendInvertedIndexItemsLSMNoFrequency'

func (*MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call) Return added in v1.32.0 

func (_c *MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call) Return(_a0 error) *MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call

func (*MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call) Run added in v1.32.0 

func (_c *MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call) Run(run func(b *lsmkv.Bucket, item inverted.MergeItem)) *MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call

func (*MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call) RunAndReturn(run func(*lsmkv.Bucket, inverted.MergeItem) error) *MockShardLike_batchExtendInvertedIndexItemsLSMNoFrequency_Call

type MockShardLike_commitReplication_Call added in v1.32.0 

type MockShardLike_commitReplication_Call struct {
	*mock.Call
}

MockShardLike_commitReplication_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'commitReplication'

func (*MockShardLike_commitReplication_Call) Return added in v1.32.0 

func (_c *MockShardLike_commitReplication_Call) Return(_a0 interface{}) *MockShardLike_commitReplication_Call

func (*MockShardLike_commitReplication_Call) Run added in v1.32.0 

func (_c *MockShardLike_commitReplication_Call) Run(run func(_a0 context.Context, _a1 string)) *MockShardLike_commitReplication_Call

func (*MockShardLike_commitReplication_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_commitReplication_Call) RunAndReturn(run func(context.Context, string) interface{}) *MockShardLike_commitReplication_Call

type MockShardLike_deleteFromPropertyRangeBucket_Call added in v1.32.0 

type MockShardLike_deleteFromPropertyRangeBucket_Call struct {
	*mock.Call
}

MockShardLike_deleteFromPropertyRangeBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'deleteFromPropertyRangeBucket'

func (*MockShardLike_deleteFromPropertyRangeBucket_Call) Return added in v1.32.0 

func (_c *MockShardLike_deleteFromPropertyRangeBucket_Call) Return(_a0 error) *MockShardLike_deleteFromPropertyRangeBucket_Call

func (*MockShardLike_deleteFromPropertyRangeBucket_Call) Run added in v1.32.0 

func (_c *MockShardLike_deleteFromPropertyRangeBucket_Call) Run(run func(bucket *lsmkv.Bucket, docID uint64, key []byte)) *MockShardLike_deleteFromPropertyRangeBucket_Call

func (*MockShardLike_deleteFromPropertyRangeBucket_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_deleteFromPropertyRangeBucket_Call) RunAndReturn(run func(*lsmkv.Bucket, uint64, []byte) error) *MockShardLike_deleteFromPropertyRangeBucket_Call

type MockShardLike_deleteFromPropertySetBucket_Call added in v1.32.0 

type MockShardLike_deleteFromPropertySetBucket_Call struct {
	*mock.Call
}

MockShardLike_deleteFromPropertySetBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'deleteFromPropertySetBucket'

func (*MockShardLike_deleteFromPropertySetBucket_Call) Return added in v1.32.0 

func (_c *MockShardLike_deleteFromPropertySetBucket_Call) Return(_a0 error) *MockShardLike_deleteFromPropertySetBucket_Call

func (*MockShardLike_deleteFromPropertySetBucket_Call) Run added in v1.32.0 

func (_c *MockShardLike_deleteFromPropertySetBucket_Call) Run(run func(bucket *lsmkv.Bucket, docID uint64, key []byte)) *MockShardLike_deleteFromPropertySetBucket_Call

func (*MockShardLike_deleteFromPropertySetBucket_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_deleteFromPropertySetBucket_Call) RunAndReturn(run func(*lsmkv.Bucket, uint64, []byte) error) *MockShardLike_deleteFromPropertySetBucket_Call

type MockShardLike_drop_Call added in v1.32.0 

type MockShardLike_drop_Call struct {
	*mock.Call
}

MockShardLike_drop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'drop'

func (*MockShardLike_drop_Call) Return added in v1.32.0 

func (_c *MockShardLike_drop_Call) Return(_a0 error) *MockShardLike_drop_Call

func (*MockShardLike_drop_Call) Run added in v1.32.0 

func (_c *MockShardLike_drop_Call) Run(run func(keepFiles bool)) *MockShardLike_drop_Call

func (*MockShardLike_drop_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_drop_Call) RunAndReturn(run func(bool) error) *MockShardLike_drop_Call

type MockShardLike_extendDimensionTrackerLSM_Call added in v1.32.0 

type MockShardLike_extendDimensionTrackerLSM_Call struct {
	*mock.Call
}

MockShardLike_extendDimensionTrackerLSM_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'extendDimensionTrackerLSM'

func (*MockShardLike_extendDimensionTrackerLSM_Call) Return added in v1.32.0 

func (_c *MockShardLike_extendDimensionTrackerLSM_Call) Return(_a0 error) *MockShardLike_extendDimensionTrackerLSM_Call

func (*MockShardLike_extendDimensionTrackerLSM_Call) Run added in v1.32.0 

func (_c *MockShardLike_extendDimensionTrackerLSM_Call) Run(run func(dimLength int, docID uint64, targetVector string)) *MockShardLike_extendDimensionTrackerLSM_Call

func (*MockShardLike_extendDimensionTrackerLSM_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_extendDimensionTrackerLSM_Call) RunAndReturn(run func(int, uint64, string) error) *MockShardLike_extendDimensionTrackerLSM_Call

type MockShardLike_filePutter_Call added in v1.32.0 

type MockShardLike_filePutter_Call struct {
	*mock.Call
}

MockShardLike_filePutter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'filePutter'

func (*MockShardLike_filePutter_Call) Return added in v1.32.0 

func (_c *MockShardLike_filePutter_Call) Return(_a0 io.WriteCloser, _a1 error) *MockShardLike_filePutter_Call

func (*MockShardLike_filePutter_Call) Run added in v1.32.0 

func (_c *MockShardLike_filePutter_Call) Run(run func(_a0 context.Context, _a1 string)) *MockShardLike_filePutter_Call

func (*MockShardLike_filePutter_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_filePutter_Call) RunAndReturn(run func(context.Context, string) (io.WriteCloser, error)) *MockShardLike_filePutter_Call

type MockShardLike_getAsyncReplicationStats_Call added in v1.32.0 

type MockShardLike_getAsyncReplicationStats_Call struct {
	*mock.Call
}

MockShardLike_getAsyncReplicationStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'getAsyncReplicationStats'

func (*MockShardLike_getAsyncReplicationStats_Call) Return added in v1.32.0 

func (_c *MockShardLike_getAsyncReplicationStats_Call) Return(_a0 []*models.AsyncReplicationStatus) *MockShardLike_getAsyncReplicationStats_Call

func (*MockShardLike_getAsyncReplicationStats_Call) Run added in v1.32.0 

func (_c *MockShardLike_getAsyncReplicationStats_Call) Run(run func(ctx context.Context)) *MockShardLike_getAsyncReplicationStats_Call

func (*MockShardLike_getAsyncReplicationStats_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_getAsyncReplicationStats_Call) RunAndReturn(run func(context.Context) []*models.AsyncReplicationStatus) *MockShardLike_getAsyncReplicationStats_Call

type MockShardLike_hasGeoIndex_Call added in v1.32.0 

type MockShardLike_hasGeoIndex_Call struct {
	*mock.Call
}

MockShardLike_hasGeoIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'hasGeoIndex'

func (*MockShardLike_hasGeoIndex_Call) Return added in v1.32.0 

func (_c *MockShardLike_hasGeoIndex_Call) Return(_a0 bool) *MockShardLike_hasGeoIndex_Call

func (*MockShardLike_hasGeoIndex_Call) Run added in v1.32.0 

func (_c *MockShardLike_hasGeoIndex_Call) Run(run func()) *MockShardLike_hasGeoIndex_Call

func (*MockShardLike_hasGeoIndex_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_hasGeoIndex_Call) RunAndReturn(run func() bool) *MockShardLike_hasGeoIndex_Call

type MockShardLike_initPropertyBuckets_Call added in v1.32.0 

type MockShardLike_initPropertyBuckets_Call struct {
	*mock.Call
}

MockShardLike_initPropertyBuckets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'initPropertyBuckets'

func (*MockShardLike_initPropertyBuckets_Call) Return added in v1.32.0 

func (_c *MockShardLike_initPropertyBuckets_Call) Return() *MockShardLike_initPropertyBuckets_Call

func (*MockShardLike_initPropertyBuckets_Call) Run added in v1.32.0 

func (_c *MockShardLike_initPropertyBuckets_Call) Run(run func(ctx context.Context, eg *errors.ErrorGroupWrapper, lazyLoadSegments bool, props ...*models.Property)) *MockShardLike_initPropertyBuckets_Call

func (*MockShardLike_initPropertyBuckets_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_initPropertyBuckets_Call) RunAndReturn(run func(context.Context, *errors.ErrorGroupWrapper, bool, ...*models.Property)) *MockShardLike_initPropertyBuckets_Call

type MockShardLike_isReadOnly_Call added in v1.32.0 

type MockShardLike_isReadOnly_Call struct {
	*mock.Call
}

MockShardLike_isReadOnly_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'isReadOnly'

func (*MockShardLike_isReadOnly_Call) Return added in v1.32.0 

func (_c *MockShardLike_isReadOnly_Call) Return(_a0 error) *MockShardLike_isReadOnly_Call

func (*MockShardLike_isReadOnly_Call) Run added in v1.32.0 

func (_c *MockShardLike_isReadOnly_Call) Run(run func()) *MockShardLike_isReadOnly_Call

func (*MockShardLike_isReadOnly_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_isReadOnly_Call) RunAndReturn(run func() error) *MockShardLike_isReadOnly_Call

type MockShardLike_mayUpsertObjectHashTree_Call added in v1.32.0 

type MockShardLike_mayUpsertObjectHashTree_Call struct {
	*mock.Call
}

MockShardLike_mayUpsertObjectHashTree_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'mayUpsertObjectHashTree'

func (*MockShardLike_mayUpsertObjectHashTree_Call) Return added in v1.32.0 

func (_c *MockShardLike_mayUpsertObjectHashTree_Call) Return(_a0 error) *MockShardLike_mayUpsertObjectHashTree_Call

func (*MockShardLike_mayUpsertObjectHashTree_Call) Run added in v1.32.0 

func (_c *MockShardLike_mayUpsertObjectHashTree_Call) Run(run func(object *storobj.Object, idBytes []byte, status objectInsertStatus)) *MockShardLike_mayUpsertObjectHashTree_Call

func (*MockShardLike_mayUpsertObjectHashTree_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_mayUpsertObjectHashTree_Call) RunAndReturn(run func(*storobj.Object, []byte, objectInsertStatus) error) *MockShardLike_mayUpsertObjectHashTree_Call

type MockShardLike_mutableMergeObjectLSM_Call added in v1.32.0 

type MockShardLike_mutableMergeObjectLSM_Call struct {
	*mock.Call
}

MockShardLike_mutableMergeObjectLSM_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'mutableMergeObjectLSM'

func (*MockShardLike_mutableMergeObjectLSM_Call) Return added in v1.32.0 

func (_c *MockShardLike_mutableMergeObjectLSM_Call) Return(_a0 mutableMergeResult, _a1 error) *MockShardLike_mutableMergeObjectLSM_Call

func (*MockShardLike_mutableMergeObjectLSM_Call) Run added in v1.32.0 

func (_c *MockShardLike_mutableMergeObjectLSM_Call) Run(run func(ctx context.Context, merge objects.MergeDocument, idBytes []byte)) *MockShardLike_mutableMergeObjectLSM_Call

func (*MockShardLike_mutableMergeObjectLSM_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_mutableMergeObjectLSM_Call) RunAndReturn(run func(context.Context, objects.MergeDocument, []byte) (mutableMergeResult, error)) *MockShardLike_mutableMergeObjectLSM_Call

type MockShardLike_pairPropertyWithFrequency_Call added in v1.32.0 

type MockShardLike_pairPropertyWithFrequency_Call struct {
	*mock.Call
}

MockShardLike_pairPropertyWithFrequency_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'pairPropertyWithFrequency'

func (*MockShardLike_pairPropertyWithFrequency_Call) Return added in v1.32.0 

func (_c *MockShardLike_pairPropertyWithFrequency_Call) Return(_a0 lsmkv.MapPair) *MockShardLike_pairPropertyWithFrequency_Call

func (*MockShardLike_pairPropertyWithFrequency_Call) Run added in v1.32.0 

func (_c *MockShardLike_pairPropertyWithFrequency_Call) Run(run func(docID uint64, freq float32, propLen float32)) *MockShardLike_pairPropertyWithFrequency_Call

func (*MockShardLike_pairPropertyWithFrequency_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_pairPropertyWithFrequency_Call) RunAndReturn(run func(uint64, float32, float32) lsmkv.MapPair) *MockShardLike_pairPropertyWithFrequency_Call

type MockShardLike_pathLSM_Call added in v1.32.0 

type MockShardLike_pathLSM_Call struct {
	*mock.Call
}

MockShardLike_pathLSM_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'pathLSM'

func (*MockShardLike_pathLSM_Call) Return added in v1.32.0 

func (_c *MockShardLike_pathLSM_Call) Return(_a0 string) *MockShardLike_pathLSM_Call

func (*MockShardLike_pathLSM_Call) Run added in v1.32.0 

func (_c *MockShardLike_pathLSM_Call) Run(run func()) *MockShardLike_pathLSM_Call

func (*MockShardLike_pathLSM_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_pathLSM_Call) RunAndReturn(run func() string) *MockShardLike_pathLSM_Call

type MockShardLike_prepareAddReferences_Call added in v1.32.0 

type MockShardLike_prepareAddReferences_Call struct {
	*mock.Call
}

MockShardLike_prepareAddReferences_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'prepareAddReferences'

func (*MockShardLike_prepareAddReferences_Call) Return added in v1.32.0 

func (_c *MockShardLike_prepareAddReferences_Call) Return(_a0 replica.SimpleResponse) *MockShardLike_prepareAddReferences_Call

func (*MockShardLike_prepareAddReferences_Call) Run added in v1.32.0 

func (_c *MockShardLike_prepareAddReferences_Call) Run(run func(_a0 context.Context, _a1 string, _a2 []objects.BatchReference)) *MockShardLike_prepareAddReferences_Call

func (*MockShardLike_prepareAddReferences_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_prepareAddReferences_Call) RunAndReturn(run func(context.Context, string, []objects.BatchReference) replica.SimpleResponse) *MockShardLike_prepareAddReferences_Call

type MockShardLike_prepareDeleteObject_Call added in v1.32.0 

type MockShardLike_prepareDeleteObject_Call struct {
	*mock.Call
}

MockShardLike_prepareDeleteObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'prepareDeleteObject'

func (*MockShardLike_prepareDeleteObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_prepareDeleteObject_Call) Return(_a0 replica.SimpleResponse) *MockShardLike_prepareDeleteObject_Call

func (*MockShardLike_prepareDeleteObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_prepareDeleteObject_Call) Run(run func(_a0 context.Context, _a1 string, _a2 strfmt.UUID, _a3 time.Time)) *MockShardLike_prepareDeleteObject_Call

func (*MockShardLike_prepareDeleteObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_prepareDeleteObject_Call) RunAndReturn(run func(context.Context, string, strfmt.UUID, time.Time) replica.SimpleResponse) *MockShardLike_prepareDeleteObject_Call

type MockShardLike_prepareDeleteObjects_Call added in v1.32.0 

type MockShardLike_prepareDeleteObjects_Call struct {
	*mock.Call
}

MockShardLike_prepareDeleteObjects_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'prepareDeleteObjects'

func (*MockShardLike_prepareDeleteObjects_Call) Return added in v1.32.0 

func (_c *MockShardLike_prepareDeleteObjects_Call) Return(_a0 replica.SimpleResponse) *MockShardLike_prepareDeleteObjects_Call

func (*MockShardLike_prepareDeleteObjects_Call) Run added in v1.32.0 

func (_c *MockShardLike_prepareDeleteObjects_Call) Run(run func(_a0 context.Context, _a1 string, _a2 []strfmt.UUID, _a3 time.Time, _a4 bool)) *MockShardLike_prepareDeleteObjects_Call

func (*MockShardLike_prepareDeleteObjects_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_prepareDeleteObjects_Call) RunAndReturn(run func(context.Context, string, []strfmt.UUID, time.Time, bool) replica.SimpleResponse) *MockShardLike_prepareDeleteObjects_Call

type MockShardLike_prepareMergeObject_Call added in v1.32.0 

type MockShardLike_prepareMergeObject_Call struct {
	*mock.Call
}

MockShardLike_prepareMergeObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'prepareMergeObject'

func (*MockShardLike_prepareMergeObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_prepareMergeObject_Call) Return(_a0 replica.SimpleResponse) *MockShardLike_prepareMergeObject_Call

func (*MockShardLike_prepareMergeObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_prepareMergeObject_Call) Run(run func(_a0 context.Context, _a1 string, _a2 *objects.MergeDocument)) *MockShardLike_prepareMergeObject_Call

func (*MockShardLike_prepareMergeObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_prepareMergeObject_Call) RunAndReturn(run func(context.Context, string, *objects.MergeDocument) replica.SimpleResponse) *MockShardLike_prepareMergeObject_Call

type MockShardLike_preparePutObject_Call added in v1.32.0 

type MockShardLike_preparePutObject_Call struct {
	*mock.Call
}

MockShardLike_preparePutObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'preparePutObject'

func (*MockShardLike_preparePutObject_Call) Return added in v1.32.0 

func (_c *MockShardLike_preparePutObject_Call) Return(_a0 replica.SimpleResponse) *MockShardLike_preparePutObject_Call

func (*MockShardLike_preparePutObject_Call) Run added in v1.32.0 

func (_c *MockShardLike_preparePutObject_Call) Run(run func(_a0 context.Context, _a1 string, _a2 *storobj.Object)) *MockShardLike_preparePutObject_Call

func (*MockShardLike_preparePutObject_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_preparePutObject_Call) RunAndReturn(run func(context.Context, string, *storobj.Object) replica.SimpleResponse) *MockShardLike_preparePutObject_Call

type MockShardLike_preparePutObjects_Call added in v1.32.0 

type MockShardLike_preparePutObjects_Call struct {
	*mock.Call
}

MockShardLike_preparePutObjects_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'preparePutObjects'

func (*MockShardLike_preparePutObjects_Call) Return added in v1.32.0 

func (_c *MockShardLike_preparePutObjects_Call) Return(_a0 replica.SimpleResponse) *MockShardLike_preparePutObjects_Call

func (*MockShardLike_preparePutObjects_Call) Run added in v1.32.0 

func (_c *MockShardLike_preparePutObjects_Call) Run(run func(_a0 context.Context, _a1 string, _a2 []*storobj.Object)) *MockShardLike_preparePutObjects_Call

func (*MockShardLike_preparePutObjects_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_preparePutObjects_Call) RunAndReturn(run func(context.Context, string, []*storobj.Object) replica.SimpleResponse) *MockShardLike_preparePutObjects_Call

type MockShardLike_preventShutdown_Call added in v1.32.0 

type MockShardLike_preventShutdown_Call struct {
	*mock.Call
}

MockShardLike_preventShutdown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'preventShutdown'

func (*MockShardLike_preventShutdown_Call) Return added in v1.32.0 

func (_c *MockShardLike_preventShutdown_Call) Return(release func(), err error) *MockShardLike_preventShutdown_Call

func (*MockShardLike_preventShutdown_Call) Run added in v1.32.0 

func (_c *MockShardLike_preventShutdown_Call) Run(run func()) *MockShardLike_preventShutdown_Call

func (*MockShardLike_preventShutdown_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_preventShutdown_Call) RunAndReturn(run func() (func(), error)) *MockShardLike_preventShutdown_Call

type MockShardLike_putObjectLSM_Call added in v1.32.0 

type MockShardLike_putObjectLSM_Call struct {
	*mock.Call
}

MockShardLike_putObjectLSM_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'putObjectLSM'

func (*MockShardLike_putObjectLSM_Call) Return added in v1.32.0 

func (_c *MockShardLike_putObjectLSM_Call) Return(_a0 objectInsertStatus, _a1 error) *MockShardLike_putObjectLSM_Call

func (*MockShardLike_putObjectLSM_Call) Run added in v1.32.0 

func (_c *MockShardLike_putObjectLSM_Call) Run(run func(ctx context.Context, object *storobj.Object, idBytes []byte)) *MockShardLike_putObjectLSM_Call

func (*MockShardLike_putObjectLSM_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_putObjectLSM_Call) RunAndReturn(run func(context.Context, *storobj.Object, []byte) (objectInsertStatus, error)) *MockShardLike_putObjectLSM_Call

type MockShardLike_removeAllTargetNodeOverrides_Call added in v1.32.0 

type MockShardLike_removeAllTargetNodeOverrides_Call struct {
	*mock.Call
}

MockShardLike_removeAllTargetNodeOverrides_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'removeAllTargetNodeOverrides'

func (*MockShardLike_removeAllTargetNodeOverrides_Call) Return added in v1.32.0 

func (_c *MockShardLike_removeAllTargetNodeOverrides_Call) Return(_a0 error) *MockShardLike_removeAllTargetNodeOverrides_Call

func (*MockShardLike_removeAllTargetNodeOverrides_Call) Run added in v1.32.0 

func (_c *MockShardLike_removeAllTargetNodeOverrides_Call) Run(run func(ctx context.Context)) *MockShardLike_removeAllTargetNodeOverrides_Call

func (*MockShardLike_removeAllTargetNodeOverrides_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_removeAllTargetNodeOverrides_Call) RunAndReturn(run func(context.Context) error) *MockShardLike_removeAllTargetNodeOverrides_Call

type MockShardLike_removeTargetNodeOverride_Call added in v1.32.0 

type MockShardLike_removeTargetNodeOverride_Call struct {
	*mock.Call
}

MockShardLike_removeTargetNodeOverride_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'removeTargetNodeOverride'

func (*MockShardLike_removeTargetNodeOverride_Call) Return added in v1.32.0 

func (_c *MockShardLike_removeTargetNodeOverride_Call) Return(_a0 error) *MockShardLike_removeTargetNodeOverride_Call

func (*MockShardLike_removeTargetNodeOverride_Call) Run added in v1.32.0 

func (_c *MockShardLike_removeTargetNodeOverride_Call) Run(run func(ctx context.Context, targetNodeOverride additional.AsyncReplicationTargetNodeOverride)) *MockShardLike_removeTargetNodeOverride_Call

func (*MockShardLike_removeTargetNodeOverride_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_removeTargetNodeOverride_Call) RunAndReturn(run func(context.Context, additional.AsyncReplicationTargetNodeOverride) error) *MockShardLike_removeTargetNodeOverride_Call

type MockShardLike_resetDimensionsLSM_Call added in v1.32.0 

type MockShardLike_resetDimensionsLSM_Call struct {
	*mock.Call
}

MockShardLike_resetDimensionsLSM_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'resetDimensionsLSM'

func (*MockShardLike_resetDimensionsLSM_Call) Return added in v1.32.0 

func (_c *MockShardLike_resetDimensionsLSM_Call) Return(_a0 error) *MockShardLike_resetDimensionsLSM_Call

func (*MockShardLike_resetDimensionsLSM_Call) Run added in v1.32.0 

func (_c *MockShardLike_resetDimensionsLSM_Call) Run(run func(ctx context.Context)) *MockShardLike_resetDimensionsLSM_Call

func (*MockShardLike_resetDimensionsLSM_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_resetDimensionsLSM_Call) RunAndReturn(run func(context.Context) error) *MockShardLike_resetDimensionsLSM_Call

type MockShardLike_resumeMaintenanceCycles_Call added in v1.32.0 

type MockShardLike_resumeMaintenanceCycles_Call struct {
	*mock.Call
}

MockShardLike_resumeMaintenanceCycles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'resumeMaintenanceCycles'

func (*MockShardLike_resumeMaintenanceCycles_Call) Return added in v1.32.0 

func (_c *MockShardLike_resumeMaintenanceCycles_Call) Return(_a0 error) *MockShardLike_resumeMaintenanceCycles_Call

func (*MockShardLike_resumeMaintenanceCycles_Call) Run added in v1.32.0 

func (_c *MockShardLike_resumeMaintenanceCycles_Call) Run(run func(ctx context.Context)) *MockShardLike_resumeMaintenanceCycles_Call

func (*MockShardLike_resumeMaintenanceCycles_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_resumeMaintenanceCycles_Call) RunAndReturn(run func(context.Context) error) *MockShardLike_resumeMaintenanceCycles_Call

type MockShardLike_setFallbackToSearchable_Call added in v1.32.0 

type MockShardLike_setFallbackToSearchable_Call struct {
	*mock.Call
}

MockShardLike_setFallbackToSearchable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'setFallbackToSearchable'

func (*MockShardLike_setFallbackToSearchable_Call) Return added in v1.32.0 

func (_c *MockShardLike_setFallbackToSearchable_Call) Return() *MockShardLike_setFallbackToSearchable_Call

func (*MockShardLike_setFallbackToSearchable_Call) Run added in v1.32.0 

func (_c *MockShardLike_setFallbackToSearchable_Call) Run(run func(fallback bool)) *MockShardLike_setFallbackToSearchable_Call

func (*MockShardLike_setFallbackToSearchable_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_setFallbackToSearchable_Call) RunAndReturn(run func(bool)) *MockShardLike_setFallbackToSearchable_Call

type MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call added in v1.32.0 

type MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call struct {
	*mock.Call
}

MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'updateMultiVectorIndexesIgnoreDelete'

func (*MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call) Return added in v1.32.0 

func (_c *MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call) Return(_a0 error) *MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call

func (*MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call) Run added in v1.32.0 

func (_c *MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call) Run(run func(ctx context.Context, multiVectors map[string][][]float32, status objectInsertStatus)) *MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call

func (*MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call) RunAndReturn(run func(context.Context, map[string][][]float32, objectInsertStatus) error) *MockShardLike_updateMultiVectorIndexesIgnoreDelete_Call

type MockShardLike_updatePropertySpecificIndices_Call added in v1.32.0 

type MockShardLike_updatePropertySpecificIndices_Call struct {
	*mock.Call
}

MockShardLike_updatePropertySpecificIndices_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'updatePropertySpecificIndices'

func (*MockShardLike_updatePropertySpecificIndices_Call) Return added in v1.32.0 

func (_c *MockShardLike_updatePropertySpecificIndices_Call) Return(_a0 error) *MockShardLike_updatePropertySpecificIndices_Call

func (*MockShardLike_updatePropertySpecificIndices_Call) Run added in v1.32.0 

func (_c *MockShardLike_updatePropertySpecificIndices_Call) Run(run func(ctx context.Context, object *storobj.Object, status objectInsertStatus)) *MockShardLike_updatePropertySpecificIndices_Call

func (*MockShardLike_updatePropertySpecificIndices_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_updatePropertySpecificIndices_Call) RunAndReturn(run func(context.Context, *storobj.Object, objectInsertStatus) error) *MockShardLike_updatePropertySpecificIndices_Call

type MockShardLike_updateVectorIndexIgnoreDelete_Call added in v1.32.0 

type MockShardLike_updateVectorIndexIgnoreDelete_Call struct {
	*mock.Call
}

MockShardLike_updateVectorIndexIgnoreDelete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'updateVectorIndexIgnoreDelete'

func (*MockShardLike_updateVectorIndexIgnoreDelete_Call) Return added in v1.32.0 

func (_c *MockShardLike_updateVectorIndexIgnoreDelete_Call) Return(_a0 error) *MockShardLike_updateVectorIndexIgnoreDelete_Call

func (*MockShardLike_updateVectorIndexIgnoreDelete_Call) Run added in v1.32.0 

func (_c *MockShardLike_updateVectorIndexIgnoreDelete_Call) Run(run func(ctx context.Context, vector []float32, status objectInsertStatus)) *MockShardLike_updateVectorIndexIgnoreDelete_Call

func (*MockShardLike_updateVectorIndexIgnoreDelete_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_updateVectorIndexIgnoreDelete_Call) RunAndReturn(run func(context.Context, []float32, objectInsertStatus) error) *MockShardLike_updateVectorIndexIgnoreDelete_Call

type MockShardLike_updateVectorIndexesIgnoreDelete_Call added in v1.32.0 

type MockShardLike_updateVectorIndexesIgnoreDelete_Call struct {
	*mock.Call
}

MockShardLike_updateVectorIndexesIgnoreDelete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'updateVectorIndexesIgnoreDelete'

func (*MockShardLike_updateVectorIndexesIgnoreDelete_Call) Return added in v1.32.0 

func (_c *MockShardLike_updateVectorIndexesIgnoreDelete_Call) Return(_a0 error) *MockShardLike_updateVectorIndexesIgnoreDelete_Call

func (*MockShardLike_updateVectorIndexesIgnoreDelete_Call) Run added in v1.32.0 

func (_c *MockShardLike_updateVectorIndexesIgnoreDelete_Call) Run(run func(ctx context.Context, vectors map[string][]float32, status objectInsertStatus)) *MockShardLike_updateVectorIndexesIgnoreDelete_Call

func (*MockShardLike_updateVectorIndexesIgnoreDelete_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_updateVectorIndexesIgnoreDelete_Call) RunAndReturn(run func(context.Context, map[string][]float32, objectInsertStatus) error) *MockShardLike_updateVectorIndexesIgnoreDelete_Call

type MockShardLike_uuidFromDocID_Call added in v1.32.0 

type MockShardLike_uuidFromDocID_Call struct {
	*mock.Call
}

MockShardLike_uuidFromDocID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'uuidFromDocID'

func (*MockShardLike_uuidFromDocID_Call) Return added in v1.32.0 

func (_c *MockShardLike_uuidFromDocID_Call) Return(_a0 strfmt.UUID, _a1 error) *MockShardLike_uuidFromDocID_Call

func (*MockShardLike_uuidFromDocID_Call) Run added in v1.32.0 

func (_c *MockShardLike_uuidFromDocID_Call) Run(run func(docID uint64)) *MockShardLike_uuidFromDocID_Call

func (*MockShardLike_uuidFromDocID_Call) RunAndReturn added in v1.32.0 

func (_c *MockShardLike_uuidFromDocID_Call) RunAndReturn(run func(uint64) (strfmt.UUID, error)) *MockShardLike_uuidFromDocID_Call

type MockVectorIndex added in v1.32.0 

type MockVectorIndex struct {
	mock.Mock
}

MockVectorIndex is an autogenerated mock type for the VectorIndex type

func NewMockVectorIndex added in v1.32.0 

func NewMockVectorIndex(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockVectorIndex

NewMockVectorIndex creates a new instance of MockVectorIndex. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockVectorIndex) Add added in v1.32.0 

func (_m *MockVectorIndex) Add(ctx context.Context, id uint64, vector []float32) error

Add provides a mock function with given fields: ctx, id, vector

func (*MockVectorIndex) AddBatch added in v1.32.0 

func (_m *MockVectorIndex) AddBatch(ctx context.Context, ids []uint64, vector [][]float32) error

AddBatch provides a mock function with given fields: ctx, ids, vector

func (*MockVectorIndex) Compressed added in v1.32.0 

func (_m *MockVectorIndex) Compressed() bool

Compressed provides a mock function with no fields

func (*MockVectorIndex) CompressionStats added in v1.32.0 

func (_m *MockVectorIndex) CompressionStats() compressionhelpers.CompressionStats

CompressionStats provides a mock function with no fields

func (*MockVectorIndex) ContainsDoc added in v1.32.0 

func (_m *MockVectorIndex) ContainsDoc(docID uint64) bool

ContainsDoc provides a mock function with given fields: docID

func (*MockVectorIndex) Delete added in v1.32.0 

func (_m *MockVectorIndex) Delete(id ...uint64) error

Delete provides a mock function with given fields: id

func (*MockVectorIndex) Drop added in v1.32.0 

func (_m *MockVectorIndex) Drop(ctx context.Context, keepFiles bool) error

Drop provides a mock function with given fields: ctx, keepFiles

func (*MockVectorIndex) EXPECT added in v1.32.0 

func (_m *MockVectorIndex) EXPECT() *MockVectorIndex_Expecter

func (*MockVectorIndex) Flush added in v1.32.0 

func (_m *MockVectorIndex) Flush() error

Flush provides a mock function with no fields

func (*MockVectorIndex) Iterate added in v1.32.0 

func (_m *MockVectorIndex) Iterate(fn func(uint64) bool)

Iterate provides a mock function with given fields: fn

func (*MockVectorIndex) ListFiles added in v1.32.0 

func (_m *MockVectorIndex) ListFiles(ctx context.Context, basePath string) ([]string, error)

ListFiles provides a mock function with given fields: ctx, basePath

func (*MockVectorIndex) Multivector added in v1.32.0 

func (_m *MockVectorIndex) Multivector() bool

Multivector provides a mock function with no fields

func (*MockVectorIndex) PostStartup added in v1.32.0 

func (_m *MockVectorIndex) PostStartup(ctx context.Context)

PostStartup provides a mock function with given fields: ctx

func (*MockVectorIndex) Preload added in v1.32.12 

func (_m *MockVectorIndex) Preload(id uint64, vector []float32)

Preload provides a mock function with given fields: id, vector

func (*MockVectorIndex) QueryVectorDistancer added in v1.32.0 

func (_m *MockVectorIndex) QueryVectorDistancer(queryVector []float32) common.QueryVectorDistancer

QueryVectorDistancer provides a mock function with given fields: queryVector

func (*MockVectorIndex) SearchByVector added in v1.32.0 

func (_m *MockVectorIndex) SearchByVector(ctx context.Context, vector []float32, k int, allow helpers.AllowList) ([]uint64, []float32, error)

SearchByVector provides a mock function with given fields: ctx, vector, k, allow

func (*MockVectorIndex) SearchByVectorDistance added in v1.32.0 

func (_m *MockVectorIndex) SearchByVectorDistance(ctx context.Context, vector []float32, dist float32, maxLimit int64, allow helpers.AllowList) ([]uint64, []float32, error)

SearchByVectorDistance provides a mock function with given fields: ctx, vector, dist, maxLimit, allow

func (*MockVectorIndex) Shutdown added in v1.32.0 

func (_m *MockVectorIndex) Shutdown(ctx context.Context) error

Shutdown provides a mock function with given fields: ctx

func (*MockVectorIndex) SwitchCommitLogs added in v1.32.0 

func (_m *MockVectorIndex) SwitchCommitLogs(ctx context.Context) error

SwitchCommitLogs provides a mock function with given fields: ctx

func (*MockVectorIndex) Type added in v1.33.0 

func (_m *MockVectorIndex) Type() common.IndexType

Type provides a mock function with no fields

func (*MockVectorIndex) UpdateUserConfig added in v1.32.0 

func (_m *MockVectorIndex) UpdateUserConfig(updated config.VectorIndexConfig, callback func()) error

UpdateUserConfig provides a mock function with given fields: updated, callback

func (*MockVectorIndex) ValidateBeforeInsert added in v1.32.0 

func (_m *MockVectorIndex) ValidateBeforeInsert(vector []float32) error

ValidateBeforeInsert provides a mock function with given fields: vector

type MockVectorIndex_AddBatch_Call added in v1.32.0 

type MockVectorIndex_AddBatch_Call struct {
	*mock.Call
}

MockVectorIndex_AddBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddBatch'

func (*MockVectorIndex_AddBatch_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_AddBatch_Call) Return(_a0 error) *MockVectorIndex_AddBatch_Call

func (*MockVectorIndex_AddBatch_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_AddBatch_Call) Run(run func(ctx context.Context, ids []uint64, vector [][]float32)) *MockVectorIndex_AddBatch_Call

func (*MockVectorIndex_AddBatch_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_AddBatch_Call) RunAndReturn(run func(context.Context, []uint64, [][]float32) error) *MockVectorIndex_AddBatch_Call

type MockVectorIndex_Add_Call added in v1.32.0 

type MockVectorIndex_Add_Call struct {
	*mock.Call
}

MockVectorIndex_Add_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Add'

func (*MockVectorIndex_Add_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Add_Call) Return(_a0 error) *MockVectorIndex_Add_Call

func (*MockVectorIndex_Add_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Add_Call) Run(run func(ctx context.Context, id uint64, vector []float32)) *MockVectorIndex_Add_Call

func (*MockVectorIndex_Add_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Add_Call) RunAndReturn(run func(context.Context, uint64, []float32) error) *MockVectorIndex_Add_Call

type MockVectorIndex_Compressed_Call added in v1.32.0 

type MockVectorIndex_Compressed_Call struct {
	*mock.Call
}

MockVectorIndex_Compressed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Compressed'

func (*MockVectorIndex_Compressed_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Compressed_Call) Return(_a0 bool) *MockVectorIndex_Compressed_Call

func (*MockVectorIndex_Compressed_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Compressed_Call) Run(run func()) *MockVectorIndex_Compressed_Call

func (*MockVectorIndex_Compressed_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Compressed_Call) RunAndReturn(run func() bool) *MockVectorIndex_Compressed_Call

type MockVectorIndex_CompressionStats_Call added in v1.32.0 

type MockVectorIndex_CompressionStats_Call struct {
	*mock.Call
}

MockVectorIndex_CompressionStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CompressionStats'

func (*MockVectorIndex_CompressionStats_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_CompressionStats_Call) Return(_a0 compressionhelpers.CompressionStats) *MockVectorIndex_CompressionStats_Call

func (*MockVectorIndex_CompressionStats_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_CompressionStats_Call) Run(run func()) *MockVectorIndex_CompressionStats_Call

func (*MockVectorIndex_CompressionStats_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_CompressionStats_Call) RunAndReturn(run func() compressionhelpers.CompressionStats) *MockVectorIndex_CompressionStats_Call

type MockVectorIndex_ContainsDoc_Call added in v1.32.0 

type MockVectorIndex_ContainsDoc_Call struct {
	*mock.Call
}

MockVectorIndex_ContainsDoc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ContainsDoc'

func (*MockVectorIndex_ContainsDoc_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_ContainsDoc_Call) Return(_a0 bool) *MockVectorIndex_ContainsDoc_Call

func (*MockVectorIndex_ContainsDoc_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_ContainsDoc_Call) Run(run func(docID uint64)) *MockVectorIndex_ContainsDoc_Call

func (*MockVectorIndex_ContainsDoc_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_ContainsDoc_Call) RunAndReturn(run func(uint64) bool) *MockVectorIndex_ContainsDoc_Call

type MockVectorIndex_Delete_Call added in v1.32.0 

type MockVectorIndex_Delete_Call struct {
	*mock.Call
}

MockVectorIndex_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'

func (*MockVectorIndex_Delete_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Delete_Call) Return(_a0 error) *MockVectorIndex_Delete_Call

func (*MockVectorIndex_Delete_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Delete_Call) Run(run func(id ...uint64)) *MockVectorIndex_Delete_Call

func (*MockVectorIndex_Delete_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Delete_Call) RunAndReturn(run func(...uint64) error) *MockVectorIndex_Delete_Call

type MockVectorIndex_Drop_Call added in v1.32.0 

type MockVectorIndex_Drop_Call struct {
	*mock.Call
}

MockVectorIndex_Drop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Drop'

func (*MockVectorIndex_Drop_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Drop_Call) Return(_a0 error) *MockVectorIndex_Drop_Call

func (*MockVectorIndex_Drop_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Drop_Call) Run(run func(ctx context.Context, keepFiles bool)) *MockVectorIndex_Drop_Call

func (*MockVectorIndex_Drop_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Drop_Call) RunAndReturn(run func(context.Context, bool) error) *MockVectorIndex_Drop_Call

type MockVectorIndex_Expecter added in v1.32.0 

type MockVectorIndex_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockVectorIndex_Expecter) Add added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Add(ctx interface{}, id interface{}, vector interface{}) *MockVectorIndex_Add_Call

Add is a helper method to define mock.On call

  • ctx context.Context
  • id uint64
  • vector []float32

func (*MockVectorIndex_Expecter) AddBatch added in v1.32.0 

func (_e *MockVectorIndex_Expecter) AddBatch(ctx interface{}, ids interface{}, vector interface{}) *MockVectorIndex_AddBatch_Call

AddBatch is a helper method to define mock.On call

  • ctx context.Context
  • ids []uint64
  • vector [][]float32

func (*MockVectorIndex_Expecter) Compressed added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Compressed() *MockVectorIndex_Compressed_Call

Compressed is a helper method to define mock.On call

func (*MockVectorIndex_Expecter) CompressionStats added in v1.32.0 

func (_e *MockVectorIndex_Expecter) CompressionStats() *MockVectorIndex_CompressionStats_Call

CompressionStats is a helper method to define mock.On call

func (*MockVectorIndex_Expecter) ContainsDoc added in v1.32.0 

func (_e *MockVectorIndex_Expecter) ContainsDoc(docID interface{}) *MockVectorIndex_ContainsDoc_Call

ContainsDoc is a helper method to define mock.On call

  • docID uint64

func (*MockVectorIndex_Expecter) Delete added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Delete(id ...interface{}) *MockVectorIndex_Delete_Call

Delete is a helper method to define mock.On call

  • id ...uint64

func (*MockVectorIndex_Expecter) Drop added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Drop(ctx interface{}, keepFiles interface{}) *MockVectorIndex_Drop_Call

Drop is a helper method to define mock.On call

  • ctx context.Context
  • keepFiles bool

func (*MockVectorIndex_Expecter) Flush added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Flush() *MockVectorIndex_Flush_Call

Flush is a helper method to define mock.On call

func (*MockVectorIndex_Expecter) Iterate added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Iterate(fn interface{}) *MockVectorIndex_Iterate_Call

Iterate is a helper method to define mock.On call

  • fn func(uint64) bool

func (*MockVectorIndex_Expecter) ListFiles added in v1.32.0 

func (_e *MockVectorIndex_Expecter) ListFiles(ctx interface{}, basePath interface{}) *MockVectorIndex_ListFiles_Call

ListFiles is a helper method to define mock.On call

  • ctx context.Context
  • basePath string

func (*MockVectorIndex_Expecter) Multivector added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Multivector() *MockVectorIndex_Multivector_Call

Multivector is a helper method to define mock.On call

func (*MockVectorIndex_Expecter) PostStartup added in v1.32.0 

func (_e *MockVectorIndex_Expecter) PostStartup(ctx interface{}) *MockVectorIndex_PostStartup_Call

PostStartup is a helper method to define mock.On call

  • ctx context.Context

func (*MockVectorIndex_Expecter) Preload added in v1.32.12 

func (_e *MockVectorIndex_Expecter) Preload(id interface{}, vector interface{}) *MockVectorIndex_Preload_Call

Preload is a helper method to define mock.On call

  • id uint64
  • vector []float32

func (*MockVectorIndex_Expecter) QueryVectorDistancer added in v1.32.0 

func (_e *MockVectorIndex_Expecter) QueryVectorDistancer(queryVector interface{}) *MockVectorIndex_QueryVectorDistancer_Call

QueryVectorDistancer is a helper method to define mock.On call

  • queryVector []float32

func (*MockVectorIndex_Expecter) SearchByVector added in v1.32.0 

func (_e *MockVectorIndex_Expecter) SearchByVector(ctx interface{}, vector interface{}, k interface{}, allow interface{}) *MockVectorIndex_SearchByVector_Call

SearchByVector is a helper method to define mock.On call

  • ctx context.Context
  • vector []float32
  • k int
  • allow helpers.AllowList

func (*MockVectorIndex_Expecter) SearchByVectorDistance added in v1.32.0 

func (_e *MockVectorIndex_Expecter) SearchByVectorDistance(ctx interface{}, vector interface{}, dist interface{}, maxLimit interface{}, allow interface{}) *MockVectorIndex_SearchByVectorDistance_Call

SearchByVectorDistance is a helper method to define mock.On call

  • ctx context.Context
  • vector []float32
  • dist float32
  • maxLimit int64
  • allow helpers.AllowList

func (*MockVectorIndex_Expecter) Shutdown added in v1.32.0 

func (_e *MockVectorIndex_Expecter) Shutdown(ctx interface{}) *MockVectorIndex_Shutdown_Call

Shutdown is a helper method to define mock.On call

  • ctx context.Context

func (*MockVectorIndex_Expecter) SwitchCommitLogs added in v1.32.0 

func (_e *MockVectorIndex_Expecter) SwitchCommitLogs(ctx interface{}) *MockVectorIndex_SwitchCommitLogs_Call

SwitchCommitLogs is a helper method to define mock.On call

  • ctx context.Context

func (*MockVectorIndex_Expecter) Type added in v1.33.0 

func (_e *MockVectorIndex_Expecter) Type() *MockVectorIndex_Type_Call

Type is a helper method to define mock.On call

func (*MockVectorIndex_Expecter) UpdateUserConfig added in v1.32.0 

func (_e *MockVectorIndex_Expecter) UpdateUserConfig(updated interface{}, callback interface{}) *MockVectorIndex_UpdateUserConfig_Call

UpdateUserConfig is a helper method to define mock.On call

  • updated config.VectorIndexConfig
  • callback func()

func (*MockVectorIndex_Expecter) ValidateBeforeInsert added in v1.32.0 

func (_e *MockVectorIndex_Expecter) ValidateBeforeInsert(vector interface{}) *MockVectorIndex_ValidateBeforeInsert_Call

ValidateBeforeInsert is a helper method to define mock.On call

  • vector []float32

type MockVectorIndex_Flush_Call added in v1.32.0 

type MockVectorIndex_Flush_Call struct {
	*mock.Call
}

MockVectorIndex_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'

func (*MockVectorIndex_Flush_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Flush_Call) Return(_a0 error) *MockVectorIndex_Flush_Call

func (*MockVectorIndex_Flush_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Flush_Call) Run(run func()) *MockVectorIndex_Flush_Call

func (*MockVectorIndex_Flush_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Flush_Call) RunAndReturn(run func() error) *MockVectorIndex_Flush_Call

type MockVectorIndex_Iterate_Call added in v1.32.0 

type MockVectorIndex_Iterate_Call struct {
	*mock.Call
}

MockVectorIndex_Iterate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Iterate'

func (*MockVectorIndex_Iterate_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Iterate_Call) Return() *MockVectorIndex_Iterate_Call

func (*MockVectorIndex_Iterate_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Iterate_Call) Run(run func(fn func(uint64) bool)) *MockVectorIndex_Iterate_Call

func (*MockVectorIndex_Iterate_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Iterate_Call) RunAndReturn(run func(func(uint64) bool)) *MockVectorIndex_Iterate_Call

type MockVectorIndex_ListFiles_Call added in v1.32.0 

type MockVectorIndex_ListFiles_Call struct {
	*mock.Call
}

MockVectorIndex_ListFiles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListFiles'

func (*MockVectorIndex_ListFiles_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_ListFiles_Call) Return(_a0 []string, _a1 error) *MockVectorIndex_ListFiles_Call

func (*MockVectorIndex_ListFiles_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_ListFiles_Call) Run(run func(ctx context.Context, basePath string)) *MockVectorIndex_ListFiles_Call

func (*MockVectorIndex_ListFiles_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_ListFiles_Call) RunAndReturn(run func(context.Context, string) ([]string, error)) *MockVectorIndex_ListFiles_Call

type MockVectorIndex_Multivector_Call added in v1.32.0 

type MockVectorIndex_Multivector_Call struct {
	*mock.Call
}

MockVectorIndex_Multivector_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Multivector'

func (*MockVectorIndex_Multivector_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Multivector_Call) Return(_a0 bool) *MockVectorIndex_Multivector_Call

func (*MockVectorIndex_Multivector_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Multivector_Call) Run(run func()) *MockVectorIndex_Multivector_Call

func (*MockVectorIndex_Multivector_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Multivector_Call) RunAndReturn(run func() bool) *MockVectorIndex_Multivector_Call

type MockVectorIndex_PostStartup_Call added in v1.32.0 

type MockVectorIndex_PostStartup_Call struct {
	*mock.Call
}

MockVectorIndex_PostStartup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PostStartup'

func (*MockVectorIndex_PostStartup_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_PostStartup_Call) Return() *MockVectorIndex_PostStartup_Call

func (*MockVectorIndex_PostStartup_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_PostStartup_Call) Run(run func(ctx context.Context)) *MockVectorIndex_PostStartup_Call

func (*MockVectorIndex_PostStartup_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_PostStartup_Call) RunAndReturn(run func(context.Context)) *MockVectorIndex_PostStartup_Call

type MockVectorIndex_Preload_Call added in v1.32.12 

type MockVectorIndex_Preload_Call struct {
	*mock.Call
}

MockVectorIndex_Preload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Preload'

func (*MockVectorIndex_Preload_Call) Return added in v1.32.12 

func (_c *MockVectorIndex_Preload_Call) Return() *MockVectorIndex_Preload_Call

func (*MockVectorIndex_Preload_Call) Run added in v1.32.12 

func (_c *MockVectorIndex_Preload_Call) Run(run func(id uint64, vector []float32)) *MockVectorIndex_Preload_Call

func (*MockVectorIndex_Preload_Call) RunAndReturn added in v1.32.12 

func (_c *MockVectorIndex_Preload_Call) RunAndReturn(run func(uint64, []float32)) *MockVectorIndex_Preload_Call

type MockVectorIndex_QueryVectorDistancer_Call added in v1.32.0 

type MockVectorIndex_QueryVectorDistancer_Call struct {
	*mock.Call
}

MockVectorIndex_QueryVectorDistancer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryVectorDistancer'

func (*MockVectorIndex_QueryVectorDistancer_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_QueryVectorDistancer_Call) Return(_a0 common.QueryVectorDistancer) *MockVectorIndex_QueryVectorDistancer_Call

func (*MockVectorIndex_QueryVectorDistancer_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_QueryVectorDistancer_Call) Run(run func(queryVector []float32)) *MockVectorIndex_QueryVectorDistancer_Call

func (*MockVectorIndex_QueryVectorDistancer_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_QueryVectorDistancer_Call) RunAndReturn(run func([]float32) common.QueryVectorDistancer) *MockVectorIndex_QueryVectorDistancer_Call

type MockVectorIndex_SearchByVectorDistance_Call added in v1.32.0 

type MockVectorIndex_SearchByVectorDistance_Call struct {
	*mock.Call
}

MockVectorIndex_SearchByVectorDistance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchByVectorDistance'

func (*MockVectorIndex_SearchByVectorDistance_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_SearchByVectorDistance_Call) Return(_a0 []uint64, _a1 []float32, _a2 error) *MockVectorIndex_SearchByVectorDistance_Call

func (*MockVectorIndex_SearchByVectorDistance_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_SearchByVectorDistance_Call) Run(run func(ctx context.Context, vector []float32, dist float32, maxLimit int64, allow helpers.AllowList)) *MockVectorIndex_SearchByVectorDistance_Call

func (*MockVectorIndex_SearchByVectorDistance_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_SearchByVectorDistance_Call) RunAndReturn(run func(context.Context, []float32, float32, int64, helpers.AllowList) ([]uint64, []float32, error)) *MockVectorIndex_SearchByVectorDistance_Call

type MockVectorIndex_SearchByVector_Call added in v1.32.0 

type MockVectorIndex_SearchByVector_Call struct {
	*mock.Call
}

MockVectorIndex_SearchByVector_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchByVector'

func (*MockVectorIndex_SearchByVector_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_SearchByVector_Call) Return(_a0 []uint64, _a1 []float32, _a2 error) *MockVectorIndex_SearchByVector_Call

func (*MockVectorIndex_SearchByVector_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_SearchByVector_Call) Run(run func(ctx context.Context, vector []float32, k int, allow helpers.AllowList)) *MockVectorIndex_SearchByVector_Call

func (*MockVectorIndex_SearchByVector_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_SearchByVector_Call) RunAndReturn(run func(context.Context, []float32, int, helpers.AllowList) ([]uint64, []float32, error)) *MockVectorIndex_SearchByVector_Call

type MockVectorIndex_Shutdown_Call added in v1.32.0 

type MockVectorIndex_Shutdown_Call struct {
	*mock.Call
}

MockVectorIndex_Shutdown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Shutdown'

func (*MockVectorIndex_Shutdown_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_Shutdown_Call) Return(_a0 error) *MockVectorIndex_Shutdown_Call

func (*MockVectorIndex_Shutdown_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_Shutdown_Call) Run(run func(ctx context.Context)) *MockVectorIndex_Shutdown_Call

func (*MockVectorIndex_Shutdown_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_Shutdown_Call) RunAndReturn(run func(context.Context) error) *MockVectorIndex_Shutdown_Call

type MockVectorIndex_SwitchCommitLogs_Call added in v1.32.0 

type MockVectorIndex_SwitchCommitLogs_Call struct {
	*mock.Call
}

MockVectorIndex_SwitchCommitLogs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SwitchCommitLogs'

func (*MockVectorIndex_SwitchCommitLogs_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_SwitchCommitLogs_Call) Return(_a0 error) *MockVectorIndex_SwitchCommitLogs_Call

func (*MockVectorIndex_SwitchCommitLogs_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_SwitchCommitLogs_Call) Run(run func(ctx context.Context)) *MockVectorIndex_SwitchCommitLogs_Call

func (*MockVectorIndex_SwitchCommitLogs_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_SwitchCommitLogs_Call) RunAndReturn(run func(context.Context) error) *MockVectorIndex_SwitchCommitLogs_Call

type MockVectorIndex_Type_Call added in v1.33.0 

type MockVectorIndex_Type_Call struct {
	*mock.Call
}

MockVectorIndex_Type_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Type'

func (*MockVectorIndex_Type_Call) Return added in v1.33.0 

func (_c *MockVectorIndex_Type_Call) Return(_a0 common.IndexType) *MockVectorIndex_Type_Call

func (*MockVectorIndex_Type_Call) Run added in v1.33.0 

func (_c *MockVectorIndex_Type_Call) Run(run func()) *MockVectorIndex_Type_Call

func (*MockVectorIndex_Type_Call) RunAndReturn added in v1.33.0 

func (_c *MockVectorIndex_Type_Call) RunAndReturn(run func() common.IndexType) *MockVectorIndex_Type_Call

type MockVectorIndex_UpdateUserConfig_Call added in v1.32.0 

type MockVectorIndex_UpdateUserConfig_Call struct {
	*mock.Call
}

MockVectorIndex_UpdateUserConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateUserConfig'

func (*MockVectorIndex_UpdateUserConfig_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_UpdateUserConfig_Call) Return(_a0 error) *MockVectorIndex_UpdateUserConfig_Call

func (*MockVectorIndex_UpdateUserConfig_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_UpdateUserConfig_Call) Run(run func(updated config.VectorIndexConfig, callback func())) *MockVectorIndex_UpdateUserConfig_Call

func (*MockVectorIndex_UpdateUserConfig_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_UpdateUserConfig_Call) RunAndReturn(run func(config.VectorIndexConfig, func()) error) *MockVectorIndex_UpdateUserConfig_Call

type MockVectorIndex_ValidateBeforeInsert_Call added in v1.32.0 

type MockVectorIndex_ValidateBeforeInsert_Call struct {
	*mock.Call
}

MockVectorIndex_ValidateBeforeInsert_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateBeforeInsert'

func (*MockVectorIndex_ValidateBeforeInsert_Call) Return added in v1.32.0 

func (_c *MockVectorIndex_ValidateBeforeInsert_Call) Return(_a0 error) *MockVectorIndex_ValidateBeforeInsert_Call

func (*MockVectorIndex_ValidateBeforeInsert_Call) Run added in v1.32.0 

func (_c *MockVectorIndex_ValidateBeforeInsert_Call) Run(run func(vector []float32)) *MockVectorIndex_ValidateBeforeInsert_Call

func (*MockVectorIndex_ValidateBeforeInsert_Call) RunAndReturn added in v1.32.0 

func (_c *MockVectorIndex_ValidateBeforeInsert_Call) RunAndReturn(run func([]float32) error) *MockVectorIndex_ValidateBeforeInsert_Call

type MultiTenantShardingStateBuilder added in v1.33.1 

type MultiTenantShardingStateBuilder struct {
	// contains filtered or unexported fields
}

MultiTenantShardingStateBuilder provides a fluent interface for creating multi-tenant sharding states with partition-based sharding and a configurable set of tenants, each with its own name and status.

func NewMultiTenantShardingStateBuilder added in v1.33.1 

func NewMultiTenantShardingStateBuilder() *MultiTenantShardingStateBuilder

NewMultiTenantStateBuilder creates a new builder with default values. Default configuration:

  • replicationFactor: 1
  • nodePrefix: "node"
  • indexName: "multi-tenant-test-index"

func (*MultiTenantShardingStateBuilder) AddTenant added in v1.33.1 

func (b *MultiTenantShardingStateBuilder) AddTenant(name, status string) *MultiTenantShardingStateBuilder

AddTenant adds a tenant with the specified status to the builder.

func (*MultiTenantShardingStateBuilder) Build added in v1.33.1 

func (b *MultiTenantShardingStateBuilder) Build() *sharding.State

Build creates and returns the configured sharding state. Panics if no tenants have been added or if configuration is invalid.

func (*MultiTenantShardingStateBuilder) WithIndexName added in v1.33.1 

func (b *MultiTenantShardingStateBuilder) WithIndexName(name string) *MultiTenantShardingStateBuilder

WithIndexName sets the index name for the sharding state (default: "multi-tenant-test-index").

func (*MultiTenantShardingStateBuilder) WithNodePrefix added in v1.33.1 

func (b *MultiTenantShardingStateBuilder) WithNodePrefix(prefix string) *MultiTenantShardingStateBuilder

WithNodePrefix sets the prefix for generated node names (default: "node"). Nodes will be named as "{prefix}1", "{prefix}2", etc.

func (*MultiTenantShardingStateBuilder) WithReplicationFactor added in v1.33.1 

func (b *MultiTenantShardingStateBuilder) WithReplicationFactor(factor int64) *MultiTenantShardingStateBuilder

WithReplicationFactor sets the number of replicas per tenant shard.

func (*MultiTenantShardingStateBuilder) WithTenant added in v1.33.1 

func (b *MultiTenantShardingStateBuilder) WithTenant(name, status string) *MultiTenantShardingStateBuilder

type PropertyIndexType added in v1.18.0 

type PropertyIndexType uint8
const (
	IndexTypePropValue PropertyIndexType = iota + 1
	IndexTypePropLength
	IndexTypePropNull
	IndexTypePropSearchableValue
	IndexTypePropMetaCount
)

func GetPropNameAndIndexTypeFromBucketName added in v1.18.0 

func GetPropNameAndIndexTypeFromBucketName(bucketName string) (string, PropertyIndexType)

type ReindexableProperty added in v1.18.0 

type ReindexableProperty struct {
	PropertyName    string
	IndexType       PropertyIndexType
	NewIndex        bool // is new index, there is no bucket to replace with
	DesiredStrategy string
	BucketOptions   []lsmkv.BucketOption
}

type Replicator 

type Replicator interface {
	ReplicateObject(ctx context.Context, shardName, requestID string,
		object *storobj.Object) replica.SimpleResponse
	ReplicateObjects(ctx context.Context, shardName, requestID string,
		objects []*storobj.Object) replica.SimpleResponse
	ReplicateUpdate(ctx context.Context, shard, requestID string,
		doc *objects.MergeDocument) replica.SimpleResponse
	ReplicateDeletion(ctx context.Context, shardName, requestID string,
		uuid strfmt.UUID, deletionTime time.Time) replica.SimpleResponse
	ReplicateDeletions(ctx context.Context, shardName, requestID string,
		uuids []strfmt.UUID, deletionTime time.Time, dryRun bool, schemaVersion uint64) replica.SimpleResponse
	ReplicateReferences(ctx context.Context, shard, requestID string,
		refs []objects.BatchReference) replica.SimpleResponse
	CommitReplication(shard,
		requestID string) interface{}
	AbortReplication(shardName,
		requestID string) interface{}
}

type ResultContainer added in v1.26.0 

type ResultContainer interface {
	AddScores(id uint64, targets []string, distances []float32, weights []float32)
	RemoveIdFromResult(id uint64)
}

type ResultContainerHybrid added in v1.26.0 

type ResultContainerHybrid struct {
	ResultsIn []*search.Result

	IDsToRemove map[uint64]struct{}
	// contains filtered or unexported fields
}

func (*ResultContainerHybrid) AddScores added in v1.26.0 

func (r *ResultContainerHybrid) AddScores(id uint64, targets []string, distances []float32, weights []float32)

func (*ResultContainerHybrid) RemoveIdFromResult added in v1.26.0 

func (r *ResultContainerHybrid) RemoveIdFromResult(id uint64)

type ResultContainerStandard added in v1.26.0 

type ResultContainerStandard struct {
	ResultsIn map[uint64]idAndDistance
}

func (*ResultContainerStandard) AddScores added in v1.26.0 

func (r *ResultContainerStandard) AddScores(id uint64, targets []string, distances []float32, weights []float32)

func (*ResultContainerStandard) RemoveIdFromResult added in v1.26.0 

func (r *ResultContainerStandard) RemoveIdFromResult(id uint64)

type Shard 

type Shard struct {
	HFreshEnabled bool
	// contains filtered or unexported fields
}

Shard is the smallest completely-contained index unit. A shard manages database files for all the objects it owns. How a shard is determined for a target object (e.g. Murmur hash, etc.) is still open at this point

func NewShard 

func NewShard(ctx context.Context, promMetrics *monitoring.PrometheusMetrics,
	shardName string, index *Index, class *models.Class, jobQueueCh chan job,
	scheduler *queue.Scheduler, indexCheckpoints *indexcheckpoint.Checkpoints,
	reindexer ShardReindexerV3, lazyLoadSegments bool, bitmapBufPool roaringset.BitmapBufPool,
) (_ *Shard, err error)

func (*Shard) Activity added in v1.25.0 

func (s *Shard) Activity() (int32, int32)

Activity score for read and write

func (*Shard) AddReferencesBatch added in v1.23.0 

func (s *Shard) AddReferencesBatch(ctx context.Context, refs objects.BatchReferences) []error

return value map[int]error gives the error for the index as it received it

func (*Shard) Aggregate added in v1.23.0 

func (s *Shard) Aggregate(ctx context.Context, params aggregation.Params, modules *modules.Provider) (*aggregation.Result, error)

func (*Shard) AnalyzeObject added in v1.23.0 

func (s *Shard) AnalyzeObject(object *storobj.Object) ([]inverted.Property, []inverted.NilProperty, error)

func (*Shard) ConvertQueue added in v1.28.0 

func (s *Shard) ConvertQueue(targetVector string) error

ConvertQueue converts a legacy in-memory queue to an on-disk queue. It detects if the queue has a checkpoint then it enqueues all the remaining vectors to the on-disk queue, then deletes the checkpoint.

func (*Shard) Counter added in v1.23.0 

func (s *Shard) Counter() *indexcounter.Counter

func (*Shard) CreateBackupSnapshot added in v1.35.15 

func (s *Shard) CreateBackupSnapshot(ctx context.Context, sd *backup.ShardDescriptor, stagingRoot string) ([]string, error)

CreateBackupSnapshot halts compaction, lists backup files, hardlinks them into a staging directory, then immediately resumes compaction. This minimizes the compaction pause to just the time needed for enumeration and hardlink creation (typically 2-5s), rather than blocking for the entire upload duration.

func (*Shard) DebugGetDocIdLockStatus added in v1.31.17 

func (s *Shard) DebugGetDocIdLockStatus() (bool, error)

DEBUG METHOD: don't use in any real production use-case - This method gets the lock status of the document IDs in the shard

func (*Shard) DebugResetVectorIndex added in v1.24.22 

func (s *Shard) DebugResetVectorIndex(ctx context.Context, targetVector string) error

IMPORTANT: DebugResetVectorIndex is intended to be used for debugging purposes only. It creates a new vector index and replaces the existing one if any. This function assumes the node is not receiving any traffic besides the debug endpoints and that async indexing is enabled.

func (*Shard) DeleteObject added in v1.23.0 

func (s *Shard) DeleteObject(ctx context.Context, id strfmt.UUID, deletionTime time.Time) error

func (*Shard) DeleteObjectBatch added in v1.22.8 

func (s *Shard) DeleteObjectBatch(ctx context.Context, uuids []strfmt.UUID, deletionTime time.Time, dryRun bool) objects.BatchSimpleObjects

return value map[int]error gives the error for the index as it received it

func (*Shard) Dimensions 

func (s *Shard) Dimensions(ctx context.Context, targetVector string) (int, error)

Dimensions returns the total number of dimensions for a given vector

func (*Shard) DimensionsUsage added in v1.32.0 

func (s *Shard) DimensionsUsage(ctx context.Context, targetVector string) (types.Dimensionality, error)

DimensionsUsage returns the total number of dimensions and the number of objects for a given vector

func (*Shard) Exists added in v1.23.0 

func (s *Shard) Exists(ctx context.Context, id strfmt.UUID) (bool, error)

TODO: This does an actual read which is not really needed, if we see this come up in profiling, we could optimize this by adding an explicit Exists() on the LSMKV which only checks the bloom filters, which at least in the case of a true negative would be considerably faster. For a (false) positive, we'd still need to check, though.

func (*Shard) FillQueue added in v1.28.0 

func (s *Shard) FillQueue(targetVector string, from uint64) error

FillQueue is a helper function that enqueues all vectors from the LSM store to the on-disk queue.

func (*Shard) FindUUIDs added in v1.22.8 

func (s *Shard) FindUUIDs(ctx context.Context, filters *filters.LocalFilter) ([]strfmt.UUID, error)

func (*Shard) ForEachVectorIndex added in v1.30.0 

func (s *Shard) ForEachVectorIndex(f func(targetVector string, index VectorIndex) error) error

ForEachVectorIndex iterates through each vector index initialized in the shard (named and legacy). Iteration stops at the first return of non-nil error.

func (*Shard) ForEachVectorQueue added in v1.30.0 

func (s *Shard) ForEachVectorQueue(f func(targetVector string, queue *VectorIndexQueue) error) error

ForEachVectorQueue iterates through each vector index queue initialized in the shard (named and legacy). Iteration stops at the first return of non-nil error.

func (*Shard) GetFile added in v1.31.0 

func (s *Shard) GetFile(ctx context.Context, relativeFilePath string) (io.ReadCloser, error)

func (*Shard) GetFileMetadata added in v1.31.0 

func (s *Shard) GetFileMetadata(ctx context.Context, relativeFilePath string) (file.FileMetadata, error)

func (*Shard) GetObjectsBucketView added in v1.34.11 

func (s *Shard) GetObjectsBucketView() common.BucketView

GetObjectsBucketView returns a consistent view of the objects bucket that can be reused for multiple reads without acquiring locks for each read.

func (*Shard) GetPropertyLengthTracker added in v1.23.0 

func (s *Shard) GetPropertyLengthTracker() *inverted.JsonShardMetaData

Tracks the lengths of all properties. Must be updated on inserts/deletes.

func (*Shard) GetStatus added in v1.22.0 

func (s *Shard) GetStatus() storagestate.Status

func (*Shard) GetVectorIndex added in v1.22.0 

func (s *Shard) GetVectorIndex(targetVector string) (VectorIndex, bool)

GetVectorIndex retrieves a vector index queue associated with the targetVector. Empty targetVector is treated as a request to access a queue for the legacy vector index.

func (*Shard) GetVectorIndexQueue added in v1.30.0 

func (s *Shard) GetVectorIndexQueue(targetVector string) (*VectorIndexQueue, bool)

GetVectorIndexQueue retrieves a vector index queue associated with the targetVector. Empty targetVector is treated as a request to access a queue for the legacy vector index.

func (*Shard) HaltForTransfer added in v1.26.0 

func (s *Shard) HaltForTransfer(ctx context.Context, offloading bool, inactivityTimeout time.Duration) (err error)

HaltForTransfer stops compaction, and flushing memtable and commit log to begin with backup or cloud offload. This method could be called multiple times with different inactivity timeouts, a zeroed `inactivityTimeout` implies no timeout. If inactivity timeout is reached it will resume maintenance cycle independently on how many halt request has been made.

func (*Shard) HashTreeLevel added in v1.26.0 

func (s *Shard) HashTreeLevel(ctx context.Context, level int, discriminant *hashtree.Bitset) (digests []hashtree.Digest, err error)

func (*Shard) ID 

func (s *Shard) ID() string

func (*Shard) Index added in v1.23.0 

func (s *Shard) Index() *Index

func (*Shard) ListBackupFiles added in v1.23.0 

func (s *Shard) ListBackupFiles(ctx context.Context, ret *backup.ShardDescriptor) ([]string, error)

ListBackupFiles lists all files used to backup a shard

func (*Shard) MergeObject added in v1.23.0 

func (s *Shard) MergeObject(ctx context.Context, merge objects.MergeDocument) error

func (*Shard) Metrics added in v1.23.0 

func (s *Shard) Metrics() *Metrics

Grafana metrics

func (*Shard) MultiObjectByID added in v1.23.0 

func (s *Shard) MultiObjectByID(ctx context.Context, query []multi.Identifier) ([]*storobj.Object, error)

func (*Shard) Name added in v1.23.0 

func (s *Shard) Name() string

Shard name(identifier?)

func (*Shard) NotifyReady added in v1.23.0 

func (s *Shard) NotifyReady()

func (*Shard) ObjectByID added in v1.23.0 

func (s *Shard) ObjectByID(ctx context.Context, id strfmt.UUID, props search.SelectProperties, additional additional.Properties) (*storobj.Object, error)

func (*Shard) ObjectCount added in v1.23.0 

func (s *Shard) ObjectCount(ctx context.Context) (int, error)

ObjectCount returns the exact count at any moment

func (*Shard) ObjectCountAsync added in v1.23.10 

func (s *Shard) ObjectCountAsync(_ context.Context) (int64, error)

ObjectCountAsync returns the eventually consistent "async" count which is much cheaper to obtain

func (*Shard) ObjectDigestErrDeleted added in v1.34.20 

func (s *Shard) ObjectDigestErrDeleted(ctx context.Context, id strfmt.UUID) (types.RepairResponse, error)

func (*Shard) ObjectDigests added in v1.34.20 

func (s *Shard) ObjectDigests(ctx context.Context, query []multi.Identifier) ([]types.RepairResponse, error)

func (*Shard) ObjectDigestsInRange added in v1.28.5 

func (s *Shard) ObjectDigestsInRange(ctx context.Context,
	initialUUID, finalUUID strfmt.UUID, limit int) (
	objs []types.RepairResponse, err error,
)

func (*Shard) ObjectList added in v1.23.0 

func (s *Shard) ObjectList(ctx context.Context, limit int, sort []filters.Sort, cursor *filters.Cursor, additional additional.Properties, className schema.ClassName) ([]*storobj.Object, error)

func (*Shard) ObjectSearch added in v1.23.0 

func (s *Shard) ObjectSearch(ctx context.Context, limit int, filters *filters.LocalFilter,
	keywordRanking *searchparams.KeywordRanking, sort []filters.Sort, cursor *filters.Cursor,
	additional additional.Properties, properties []string,
) ([]*storobj.Object, []float32, error)

func (*Shard) ObjectStorageSize added in v1.32.0 

func (s *Shard) ObjectStorageSize(ctx context.Context) (int64, error)

func (*Shard) ObjectVectorSearch added in v1.23.0 

func (s *Shard) ObjectVectorSearch(ctx context.Context, searchVectors []models.Vector, targetVectors []string, targetDist float32, limit int, filters *filters.LocalFilter, sort []filters.Sort, groupBy *searchparams.GroupBy, additional additional.Properties, targetCombination *dto.TargetCombination, properties []string) ([]*storobj.Object, []float32, error)

func (*Shard) PutObject added in v1.23.0 

func (s *Shard) PutObject(ctx context.Context, object *storobj.Object) error

func (*Shard) PutObjectBatch added in v1.23.0 

func (s *Shard) PutObjectBatch(ctx context.Context,
	objects []*storobj.Object,
) []error

return value map[int]error gives the error for the index as it received it

func (*Shard) QuantizedDimensions added in v1.23.0 

func (s *Shard) QuantizedDimensions(ctx context.Context, targetVector string, segments int) (int, error)

func (*Shard) RepairIndex added in v1.24.23 

func (s *Shard) RepairIndex(ctx context.Context, targetVector string) error

RepairIndex ensures the vector index is consistent with the LSM store. It goes through the LSM store and enqueues any unindexed vector, and it also removes any indexed vector that is not in the LSM store. It it safe to call or interrupt this method at any time. If ASYNC_INDEXING is disabled, it's a no-op.

func (*Shard) RequantizeIndex added in v1.30.19 

func (s *Shard) RequantizeIndex(ctx context.Context, targetVector string) error

Requantize ensures the quantized vectors are consistent with the LSM store. It goes through the LSM store and reencodes any vector, and it also removes any indexed vector that is not in the LSM store. It it safe to call or interrupt this method at any time.

func (*Shard) SetAsyncReplicationState added in v1.34.13 

func (s *Shard) SetAsyncReplicationState(_ context.Context, config AsyncReplicationConfig, enabled bool) error

func (*Shard) SetPropertyLengthTracker added in v1.23.0 

func (s *Shard) SetPropertyLengthTracker(tracker *inverted.JsonShardMetaData)

Tracks the lengths of all properties. Must be updated on inserts/deletes.

func (*Shard) SetPropertyLengths added in v1.23.0 

func (s *Shard) SetPropertyLengths(props []inverted.Property) error

func (*Shard) SetStatusReadonly added in v1.25.22 

func (s *Shard) SetStatusReadonly(reason string) error

func (*Shard) Shutdown added in v1.23.0 

func (s *Shard) Shutdown(ctx context.Context) (err error)

func (*Shard) Store added in v1.23.0 

func (s *Shard) Store() *lsmkv.Store

The physical data store

func (*Shard) UpdateStatus added in v1.23.0 

func (s *Shard) UpdateStatus(in, reason string) error

func (*Shard) UpdateVectorIndexConfig added in v1.23.0 

func (s *Shard) UpdateVectorIndexConfig(ctx context.Context, updated schemaConfig.VectorIndexConfig) error

func (*Shard) UpdateVectorIndexConfigs added in v1.24.1 

func (s *Shard) UpdateVectorIndexConfigs(ctx context.Context, updated map[string]schemaConfig.VectorIndexConfig) error

func (*Shard) VectorDistanceForQuery added in v1.26.0 

func (s *Shard) VectorDistanceForQuery(ctx context.Context, docId uint64, searchVectors []models.Vector, targetVectors []string) ([]float32, error)

func (*Shard) VectorStorageSize added in v1.32.0 

func (s *Shard) VectorStorageSize(ctx context.Context, lsmPath string, directories []string) (int64, int64, error)

VectorStorageSize calculates the total storage size of all vector indexes in the shard

func (*Shard) Versioner added in v1.23.0 

func (s *Shard) Versioner() *shardVersioner

func (*Shard) WasDeleted added in v1.23.0 

func (s *Shard) WasDeleted(ctx context.Context, id strfmt.UUID) (bool, time.Time, error)

type ShardInvertedReindexTask added in v1.18.0 

type ShardInvertedReindexTask interface {
	GetPropertiesToReindex(ctx context.Context, shard ShardLike,
	) ([]ReindexableProperty, error)
	// right now only OnResume is needed, but in the future more
	// callbacks could be added
	// (like OnPrePauseStore, OnPostPauseStore, OnPreResumeStore, etc)
	OnPostResumeStore(ctx context.Context, shard ShardLike) error
	ObjectsIterator(shard ShardLike) objectsIterator
}

type ShardInvertedReindexTaskSetToRoaringSet added in v1.18.0 

type ShardInvertedReindexTaskSetToRoaringSet struct{}

func (*ShardInvertedReindexTaskSetToRoaringSet) GetPropertiesToReindex added in v1.18.0 

func (t *ShardInvertedReindexTaskSetToRoaringSet) GetPropertiesToReindex(ctx context.Context,
	shard ShardLike,
) ([]ReindexableProperty, error)

func (*ShardInvertedReindexTaskSetToRoaringSet) ObjectsIterator added in v1.27.7 

func (t *ShardInvertedReindexTaskSetToRoaringSet) ObjectsIterator(shard ShardLike) objectsIterator

func (*ShardInvertedReindexTaskSetToRoaringSet) OnPostResumeStore added in v1.19.0 

func (t *ShardInvertedReindexTaskSetToRoaringSet) OnPostResumeStore(ctx context.Context, shard ShardLike) error

type ShardInvertedReindexTask_SpecifiedIndex added in v1.27.7 

type ShardInvertedReindexTask_SpecifiedIndex struct {
	// contains filtered or unexported fields
}

func (*ShardInvertedReindexTask_SpecifiedIndex) GetPropertiesToReindex added in v1.27.7 

func (t *ShardInvertedReindexTask_SpecifiedIndex) GetPropertiesToReindex(ctx context.Context,
	shard ShardLike,
) ([]ReindexableProperty, error)

func (*ShardInvertedReindexTask_SpecifiedIndex) ObjectsIterator added in v1.27.7 

func (t *ShardInvertedReindexTask_SpecifiedIndex) ObjectsIterator(shard ShardLike) objectsIterator

func (*ShardInvertedReindexTask_SpecifiedIndex) OnPostResumeStore added in v1.27.7 

func (t *ShardInvertedReindexTask_SpecifiedIndex) OnPostResumeStore(ctx context.Context, shard ShardLike) error

type ShardInvertedReindexer added in v1.18.0 

type ShardInvertedReindexer struct {
	// contains filtered or unexported fields
}

func NewShardInvertedReindexer added in v1.18.0 

func NewShardInvertedReindexer(shard ShardLike, logger logrus.FieldLogger) *ShardInvertedReindexer

func (*ShardInvertedReindexer) AddTask added in v1.18.0 

func (r *ShardInvertedReindexer) AddTask(task ShardInvertedReindexTask)

func (*ShardInvertedReindexer) Do added in v1.18.0 

func (r *ShardInvertedReindexer) Do(ctx context.Context) error

type ShardLike added in v1.23.0 

type ShardLike interface {
	Index() *Index                                                                      // Get the parent index
	Name() string                                                                       // Get the shard name
	Store() *lsmkv.Store                                                                // Get the underlying store
	NotifyReady()                                                                       // Set shard status to ready
	GetStatus() storagestate.Status                                                     // Return the shard status
	UpdateStatus(status, reason string) error                                           // Set shard status
	SetStatusReadonly(reason string) error                                              // Set shard status to readonly with reason
	FindUUIDs(ctx context.Context, filters *filters.LocalFilter) ([]strfmt.UUID, error) // Search and return document ids

	Counter() *indexcounter.Counter
	ObjectCount(ctx context.Context) (int, error)
	ObjectCountAsync(ctx context.Context) (int64, error)
	GetPropertyLengthTracker() *inverted.JsonShardMetaData

	PutObject(context.Context, *storobj.Object) error
	PutObjectBatch(context.Context, []*storobj.Object) []error
	ObjectByID(ctx context.Context, id strfmt.UUID, props search.SelectProperties, additional additional.Properties) (*storobj.Object, error)
	ObjectDigestErrDeleted(ctx context.Context, id strfmt.UUID) (types.RepairResponse, error)
	Exists(ctx context.Context, id strfmt.UUID) (bool, error)
	ObjectSearch(ctx context.Context, limit int, filters *filters.LocalFilter, keywordRanking *searchparams.KeywordRanking, sort []filters.Sort, cursor *filters.Cursor, additional additional.Properties, properties []string) ([]*storobj.Object, []float32, error)
	ObjectVectorSearch(ctx context.Context, searchVectors []models.Vector, targetVectors []string, targetDist float32, limit int, filters *filters.LocalFilter, sort []filters.Sort, groupBy *searchparams.GroupBy, additional additional.Properties, targetCombination *dto.TargetCombination, properties []string) ([]*storobj.Object, []float32, error)
	UpdateVectorIndexConfig(ctx context.Context, updated schemaConfig.VectorIndexConfig) error
	UpdateVectorIndexConfigs(ctx context.Context, updated map[string]schemaConfig.VectorIndexConfig) error
	AddReferencesBatch(ctx context.Context, refs objects.BatchReferences) []error
	DeleteObjectBatch(ctx context.Context, ids []strfmt.UUID, deletionTime time.Time, dryRun bool) objects.BatchSimpleObjects // Delete many objects by id
	DeleteObject(ctx context.Context, id strfmt.UUID, deletionTime time.Time) error                                           // Delete object by id
	MultiObjectByID(ctx context.Context, query []multi.Identifier) ([]*storobj.Object, error)
	ObjectDigests(ctx context.Context, query []multi.Identifier) ([]types.RepairResponse, error)
	ObjectDigestsInRange(ctx context.Context, initialUUID, finalUUID strfmt.UUID, limit int) (objs []types.RepairResponse, err error)
	ID() string // Get the shard id

	HaltForTransfer(ctx context.Context, offloading bool, inactivityTimeout time.Duration) error

	CreateBackupSnapshot(ctx context.Context, sd *backup.ShardDescriptor, stagingRoot string) ([]string, error)
	ListBackupFiles(ctx context.Context, ret *backup.ShardDescriptor) ([]string, error)

	GetFileMetadata(ctx context.Context, relativeFilePath string) (file.FileMetadata, error)
	GetFile(ctx context.Context, relativeFilePath string) (io.ReadCloser, error)
	SetPropertyLengths(props []inverted.Property) error
	AnalyzeObject(*storobj.Object) ([]inverted.Property, []inverted.NilProperty, error)
	Aggregate(ctx context.Context, params aggregation.Params, modules *modules.Provider) (*aggregation.Result, error)
	HashTreeLevel(ctx context.Context, level int, discriminant *hashtree.Bitset) (digests []hashtree.Digest, err error)
	MergeObject(ctx context.Context, object objects.MergeDocument) error
	VectorDistanceForQuery(ctx context.Context, id uint64, searchVectors []models.Vector, targets []string) ([]float32, error)
	ConvertQueue(targetVector string) error
	FillQueue(targetVector string, from uint64) error
	Shutdown(context.Context) error // Shutdown the shard

	// TODO tests only
	ObjectList(ctx context.Context, limit int, sort []filters.Sort, cursor *filters.Cursor,
		additional additional.Properties, className schema.ClassName) ([]*storobj.Object, error) // Search and return objects
	WasDeleted(ctx context.Context, id strfmt.UUID) (bool, time.Time, error) // Check if an object was deleted
	GetVectorIndexQueue(targetVector string) (*VectorIndexQueue, bool)
	GetVectorIndex(targetVector string) (VectorIndex, bool)
	ForEachVectorIndex(f func(targetVector string, index VectorIndex) error) error
	ForEachVectorQueue(f func(targetVector string, queue *VectorIndexQueue) error) error
	// TODO tests only
	Versioner() *shardVersioner // Get the shard versioner

	SetAsyncReplicationState(ctx context.Context, config AsyncReplicationConfig, enabled bool) error

	// Dimensions returns the total number of dimensions for a given vector
	Dimensions(ctx context.Context, targetVector string) (int, error)
	QuantizedDimensions(ctx context.Context, targetVector string, segments int) (int, error)

	Metrics() *Metrics

	// A thread-safe counter that goes up any time there is activity on this
	// shard. The absolute value has no meaning, it's only purpose is to compare
	// the previous value to the current value. First value is for reads, second
	// for writes.
	Activity() (int32, int32)
	// Debug methods
	DebugResetVectorIndex(ctx context.Context, targetVector string) error
	RepairIndex(ctx context.Context, targetVector string) error
	RequantizeIndex(ctx context.Context, targetVector string) error

	// Debug method for docID lock debugging and contention detection and simulation
	DebugGetDocIdLockStatus() (bool, error)
	// contains filtered or unexported methods
}

type ShardReindexTaskV3 added in v1.30.0 

type ShardReindexTaskV3 interface {
	Name() string
	OnBeforeLsmInit(ctx context.Context, shard *Shard) error
	OnAfterLsmInit(ctx context.Context, shard *Shard) error
	// TODO alisza:blockmax change to *Shard?
	OnAfterLsmInitAsync(ctx context.Context, shard ShardLike) (rerunAt time.Time, reloadShard bool, err error)
}

type ShardReindexTask_MapToBlockmax added in v1.30.0 

type ShardReindexTask_MapToBlockmax struct {
	// contains filtered or unexported fields
}

func NewShardInvertedReindexTaskMapToBlockmax added in v1.30.0 

func NewShardInvertedReindexTaskMapToBlockmax(logger logrus.FieldLogger,
	swapBuckets, unswapBuckets, tidyBuckets, reloadShards, rollback, conditionalStart bool,
	processingDuration, pauseDuration time.Duration, perObjectDelay time.Duration, concurrency int,
	cptSelected []config.CollectionPropsTenants, schemaManager *schema.Manager,
) *ShardReindexTask_MapToBlockmax

func (*ShardReindexTask_MapToBlockmax) Name added in v1.30.0 

func (t *ShardReindexTask_MapToBlockmax) Name() string

func (*ShardReindexTask_MapToBlockmax) OnAfterLsmInit added in v1.30.0 

func (t *ShardReindexTask_MapToBlockmax) OnAfterLsmInit(ctx context.Context, shard *Shard) (err error)

func (*ShardReindexTask_MapToBlockmax) OnAfterLsmInitAsync added in v1.30.0 

func (t *ShardReindexTask_MapToBlockmax) OnAfterLsmInitAsync(ctx context.Context, shard ShardLike,
) (rerunAt time.Time, reloadShard bool, err error)

func (*ShardReindexTask_MapToBlockmax) OnBeforeLsmInit added in v1.30.0 

func (t *ShardReindexTask_MapToBlockmax) OnBeforeLsmInit(ctx context.Context, shard *Shard) (err error)

type ShardReindexerV3 added in v1.30.0 

type ShardReindexerV3 interface {
	RunBeforeLsmInit(ctx context.Context, shard *Shard) error
	RunAfterLsmInit(ctx context.Context, shard *Shard) error
	RunAfterLsmInitAsync(ctx context.Context, shard *Shard) error
	Stop(shard *Shard, cause error)
}

type ShardStatus added in v1.25.22 

type ShardStatus struct {
	Status storagestate.Status
	Reason string
}

type Task added in v1.28.0 

type Task[T dto.Embedding] struct {
	// contains filtered or unexported fields
}

func (*Task[T]) Execute added in v1.28.0 

func (t *Task[T]) Execute(ctx context.Context) error

func (*Task[T]) Key added in v1.28.0 

func (t *Task[T]) Key() uint64

func (*Task[T]) NewGroup added in v1.28.0 

func (t *Task[T]) NewGroup(op uint8, tasks ...queue.Task) queue.Task

func (*Task[T]) Op added in v1.28.0 

func (t *Task[T]) Op() uint8

type TaskGroup added in v1.28.0 

type TaskGroup[T dto.Embedding] struct {
	// contains filtered or unexported fields
}

func (*TaskGroup[T]) Execute added in v1.28.0 

func (t *TaskGroup[T]) Execute(ctx context.Context) error

func (*TaskGroup[T]) Key added in v1.28.0 

func (t *TaskGroup[T]) Key() uint64

func (*TaskGroup[T]) Op added in v1.28.0 

func (t *TaskGroup[T]) Op() uint8

type UuidKeyParser added in v1.30.11 

type UuidKeyParser struct{}

func (*UuidKeyParser) FromBytes added in v1.30.11 

func (p *UuidKeyParser) FromBytes(key []byte) indexKey

func (*UuidKeyParser) FromString added in v1.30.11 

func (p *UuidKeyParser) FromString(key string) (indexKey, error)

type VectorIndex 

type VectorIndex interface {
	Type() common.IndexType
	Add(ctx context.Context, id uint64, vector []float32) error
	AddBatch(ctx context.Context, ids []uint64, vector [][]float32) error
	Delete(id ...uint64) error
	SearchByVector(ctx context.Context, vector []float32, k int, allow helpers.AllowList) ([]uint64, []float32, error)
	SearchByVectorDistance(ctx context.Context, vector []float32, dist float32,
		maxLimit int64, allow helpers.AllowList) ([]uint64, []float32, error)
	UpdateUserConfig(updated schemaConfig.VectorIndexConfig, callback func()) error
	Drop(ctx context.Context, keepFiles bool) error
	Shutdown(ctx context.Context) error
	Flush() error
	SwitchCommitLogs(ctx context.Context) error
	ListFiles(ctx context.Context, basePath string) ([]string, error)
	PostStartup(ctx context.Context)
	Compressed() bool
	Multivector() bool
	ValidateBeforeInsert(vector []float32) error
	// ContainsDoc returns true if the index has indexed document with a given id.
	// It must return false if the document does not exist, or has a tombstone.
	ContainsDoc(docID uint64) bool
	Preload(id uint64, vector []float32)
	// Iterate over all indexed document ids in the index.
	// Consistency or order is not guaranteed, as the index may be concurrently modified.
	// If the callback returns false, the iteration will stop.
	Iterate(fn func(docID uint64) bool)
	QueryVectorDistancer(queryVector []float32) common.QueryVectorDistancer
	// CompressionStats returns the compression statistics for this index
	CompressionStats() compressionhelpers.CompressionStats
}

VectorIndex is anything that indexes vectors efficiently. For an example look at ./vector/hnsw/index.go

type VectorIndexMulti added in v1.33.0 

type VectorIndexMulti interface {
	AddMulti(ctx context.Context, docId uint64, vector [][]float32) error
	AddMultiBatch(ctx context.Context, docIds []uint64, vectors [][][]float32) error
	DeleteMulti(id ...uint64) error
	SearchByMultiVector(ctx context.Context, vector [][]float32, k int, allow helpers.AllowList) ([]uint64, []float32, error)
	SearchByMultiVectorDistance(ctx context.Context, vector [][]float32, dist float32,
		maxLimit int64, allow helpers.AllowList) ([]uint64, []float32, error)
	QueryMultiVectorDistancer(queryVector [][]float32) common.QueryVectorDistancer
	ValidateMultiBeforeInsert(vector [][]float32) error
}

VectorIndexMulti is a VectorIndex that supports multi-vector indexing.

type VectorIndexQueue added in v1.28.0 

type VectorIndexQueue struct {
	*queue.DiskQueue
	// contains filtered or unexported fields
}

func NewVectorIndexQueue added in v1.28.0 

func NewVectorIndexQueue(
	shard *Shard,
	targetVector string,
	index VectorIndex,
) (*VectorIndexQueue, error)

func (*VectorIndexQueue) BeforeSchedule added in v1.28.0 

func (iq *VectorIndexQueue) BeforeSchedule() (skip bool)

func (*VectorIndexQueue) Close added in v1.28.0 

func (iq *VectorIndexQueue) Close(ctx context.Context) error

func (*VectorIndexQueue) Delete added in v1.28.0 

func (iq *VectorIndexQueue) Delete(ids ...uint64) error

func (*VectorIndexQueue) DequeueBatch added in v1.30.0 

func (iq *VectorIndexQueue) DequeueBatch() (*queue.Batch, error)

DequeueBatch dequeues a batch of tasks from the queue. If the queue is configured to accumulate vectors in a batch, it will dequeue tasks until the target batch size is reached. Otherwise, dequeues a single chunk file worth of tasks.

func (*VectorIndexQueue) Flush added in v1.28.0 

func (iq *VectorIndexQueue) Flush() error

func (*VectorIndexQueue) Insert added in v1.28.0 

func (iq *VectorIndexQueue) Insert(ctx context.Context, vectors ...common.VectorRecord) error

func (*VectorIndexQueue) OnBatchProcessed added in v1.28.0 

func (iq *VectorIndexQueue) OnBatchProcessed()

Flush the vector index after a batch is processed.

func (*VectorIndexQueue) ResetWith added in v1.28.0 

func (iq *VectorIndexQueue) ResetWith(vidx VectorIndex)

ResetWith resets the queue with the given vector index. The queue must be paused before calling this method.

type VectorIndexQueueMetrics added in v1.28.0 

type VectorIndexQueueMetrics struct {
	// contains filtered or unexported fields
}

func NewVectorIndexQueueMetrics added in v1.28.0 

func NewVectorIndexQueueMetrics(
	logger logrus.FieldLogger, prom *monitoring.PrometheusMetrics,
	className, shardName string, targetVector string,
) *VectorIndexQueueMetrics

func (*VectorIndexQueueMetrics) Delete added in v1.28.0 

func (m *VectorIndexQueueMetrics) Delete(start time.Time, count int)

func (*VectorIndexQueueMetrics) DeleteShardLabels added in v1.28.0 

func (m *VectorIndexQueueMetrics) DeleteShardLabels(class, shard string)

func (*VectorIndexQueueMetrics) Insert added in v1.28.0 

func (m *VectorIndexQueueMetrics) Insert(start time.Time, count int)

func (*VectorIndexQueueMetrics) QueueMetrics added in v1.28.0 

func (m *VectorIndexQueueMetrics) QueueMetrics() *queue.Metrics

Source Files

View all Source files

Directories

Path Synopsis
clusterintegrationtest acts as a test package to provide a component test spanning multiple parts of the application, including everything that's required for a distributed setup.
 clusterintegrationtest acts as a test package to provide a component test spanning multiple parts of the application, including everything that's required for a distributed setup.
stopwords
terms
entities
ent contains common types used throughout various lsmkv (sub-)packages
 ent contains common types used throughout various lsmkv (sub-)packages
gobenc
Package gobenc provides allocation-efficient encoding and decoding of map[uint64]uint32.
 Package gobenc provides allocation-efficient encoding and decoding of map[uint64]uint32.
rbtree
segmentindex
varenc
Package multitenancy provides tenant validation strategies for Weaviate collections based on their multi-tenancy configuration.
 Package multitenancy provides tenant validation strategies for Weaviate collections based on their multi-tenancy configuration.
Queue package implements a queue system for background operations using disk storage.
 Queue package implements a queue system for background operations using disk storage.
Package roaringset contains all the LSM business logic that is unique to the "RoaringSet" strategy
 Package roaringset contains all the LSM business logic that is unique to the "RoaringSet" strategy
Package resolver provides shard resolution strategies for Weaviate collections based on their configuration.
 Package resolver provides shard resolution strategies for Weaviate collections based on their configuration.
vector
cache
common
compressionhelpers
datasets
dynamic
flat
geo
hfresh
hnsw
hnsw/commitlog
hnsw/distancer
hnsw/distancer/asm
asm only has amd64 specific implementations at the moment
 asm only has amd64 specific implementations at the moment
hnsw/packedconn
hnsw/visited
kmeans
multivector
noop
testinghelpers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.