Documentation
¶
Index ¶
- Constants
- Variables
- func CollectionLevelReplicaNumber(kvs []*commonpb.KeyValuePair) (int64, error)
- func CollectionLevelResourceGroups(kvs []*commonpb.KeyValuePair) ([]string, error)
- func DatabaseLevelReplicaNumber(kvs []*commonpb.KeyValuePair) (int64, error)
- func DatabaseLevelResourceGroups(kvs []*commonpb.KeyValuePair) ([]string, error)
- func FieldHasMmapKey(schema *schemapb.CollectionSchema, fieldID int64) bool
- func GetCollectionLoadFields(schema *schemapb.CollectionSchema, skipDynamicField bool) []int64
- func GetIndexType(indexParams []*commonpb.KeyValuePair) string
- func GetReplicateEndTS(kvs []*commonpb.KeyValuePair) (uint64, bool)
- func GetReplicateID(kvs []*commonpb.KeyValuePair) (string, bool)
- func HasLazyload(props []*commonpb.KeyValuePair) bool
- func IsCollectionLazyLoadEnabled(kvs ...*commonpb.KeyValuePair) bool
- func IsIgnorableError(err error) bool
- func IsMmapDataEnabled(kvs ...*commonpb.KeyValuePair) (bool, bool)
- func IsMmapIndexEnabled(kvs ...*commonpb.KeyValuePair) (bool, bool)
- func IsPartitionKeyIsolationKvEnabled(kvs ...*commonpb.KeyValuePair) (bool, error)
- func IsPartitionKeyIsolationPropEnabled(props map[string]string) (bool, error)
- func IsReplicateEnabled(kvs []*commonpb.KeyValuePair) (bool, bool)
- func IsSystemField(fieldID int64) bool
- func MapEquals(m1, m2 map[int64]int64) bool
- func NewIgnorableError(err error) error
- func ShouldFieldBeLoaded(kvs []*commonpb.KeyValuePair) (bool, error)
- func ValidateAutoIndexMmapConfig(autoIndexConfigEnable, isVectorField bool, indexParams map[string]string) error
- func WrapNodeIDNotMatchError(targetID, nodeID int64) error
- func WrapNodeIDNotMatchMsg(targetID, nodeID int64) string
- type ByteSlice
- type ClusterStatus
- type EPHealth
- type IgnorableError
- type Int64Tuple
- type KeyDataPairs
- type KeyValuePairs
- type MQClusterStatus
- type MetaClusterStatus
- type Str2Str
- type StringList
Constants ¶
View Source
const ( // StartOfUserFieldID represents the starting ID of the user-defined field StartOfUserFieldID = 100 // StartOfUserFunctionID represents the starting ID of the user-defined function StartOfUserFunctionID = 100 // RowIDField is the ID of the RowID field reserved by the system RowIDField = 0 // TimeStampField is the ID of the Timestamp field reserved by the system TimeStampField = 1 // RowIDFieldName defines the name of the RowID field RowIDFieldName = "RowID" // TimeStampFieldName defines the name of the Timestamp field TimeStampFieldName = "Timestamp" // MetaFieldName is the field name of dynamic schema MetaFieldName = "$meta" // DefaultShardsNum defines the default number of shards when creating a collection DefaultShardsNum = int32(1) // DefaultPartitionsWithPartitionKey defines the default number of partitions when use partition key DefaultPartitionsWithPartitionKey = int64(16) // InvalidPartitionID indicates that the partition is not specified. It will be set when the partitionName is empty InvalidPartitionID = int64(-1) // AllPartitionsID indicates data applies to all partitions. AllPartitionsID = int64(-1) // InvalidFieldID indicates that the field does not exist . It will be set when the field is not found. InvalidFieldID = int64(-1) // NotRegisteredID means node is not registered into etcd. NotRegisteredID = int64(-1) // InvalidNodeID indicates that node is not valid in querycoord replica or shard cluster. InvalidNodeID = int64(-1) )
View Source
const ( MinimalScalarIndexEngineVersion = int32(0) CurrentScalarIndexEngineVersion = int32(1) )
View Source
const ( // SegmentInsertLogPath storage path const for segment insert binlog. SegmentInsertLogPath = `insert_log` // SegmentDeltaLogPath storage path const for segment delta log. SegmentDeltaLogPath = `delta_log` // SegmentStatslogPath storage path const for segment stats log. SegmentStatslogPath = `stats_log` // SegmentIndexPath storage path const for segment index files. SegmentIndexPath = `index_files` // SegmentBm25LogPath storage path const for bm25 statistic SegmentBm25LogPath = `bm25_stats` // PartitionStatsPath storage path const for partition stats files PartitionStatsPath = `part_stats` // AnalyzeStatsPath storage path const for analyze. AnalyzeStatsPath = `analyze_stats` OffsetMapping = `offset_mapping` Centroids = "centroids" // TextIndexPath storage path const for text index TextIndexPath = "text_log" // JSONIndexPath storage path const for json index JSONIndexPath = "json_key_index_log" )
View Source
const ( TopKKey = "topk" SearchParamKey = "search_param" SegmentNumKey = "segment_num" WithFilterKey = "with_filter" DataTypeKey = "data_type" ChannelNumKey = "channel_num" WithOptimizeKey = "with_optimize" CollectionKey = "collection" RecallEvalKey = "recall_eval" IndexParamsKey = "params" IndexTypeKey = "index_type" MetricTypeKey = "metric_type" DimKey = "dim" MaxLengthKey = "max_length" MaxCapacityKey = "max_capacity" DropRatioBuildKey = "drop_ratio_build" IsSparseKey = "is_sparse" AutoIndexName = "AUTOINDEX" BitmapCardinalityLimitKey = "bitmap_cardinality_limit" IgnoreGrowing = "ignore_growing" ConsistencyLevel = "consistency_level" HintsKey = "hints" JSONCastTypeKey = "json_cast_type" JSONPathKey = "json_path" )
Search, Index parameter keys
View Source
const ( EnableAnalyzerKey = `enable_analyzer` AnalyzerParamKey = `analyzer_params` )
Doc-in-doc-out
View Source
const ( CollectionTTLConfigKey = "collection.ttl.seconds" CollectionAutoCompactionKey = "collection.autocompaction.enabled" // rate limit CollectionInsertRateMaxKey = "collection.insertRate.max.mb" CollectionInsertRateMinKey = "collection.insertRate.min.mb" CollectionUpsertRateMaxKey = "collection.upsertRate.max.mb" CollectionUpsertRateMinKey = "collection.upsertRate.min.mb" CollectionDeleteRateMaxKey = "collection.deleteRate.max.mb" CollectionDeleteRateMinKey = "collection.deleteRate.min.mb" CollectionBulkLoadRateMaxKey = "collection.bulkLoadRate.max.mb" CollectionBulkLoadRateMinKey = "collection.bulkLoadRate.min.mb" CollectionQueryRateMaxKey = "collection.queryRate.max.qps" CollectionQueryRateMinKey = "collection.queryRate.min.qps" CollectionSearchRateMaxKey = "collection.searchRate.max.vps" CollectionSearchRateMinKey = "collection.searchRate.min.vps" CollectionDiskQuotaKey = "collection.diskProtection.diskQuota.mb" PartitionDiskQuotaKey = "partition.diskProtection.diskQuota.mb" // database level properties DatabaseReplicaNumber = "database.replica.number" DatabaseResourceGroups = "database.resource_groups" DatabaseDiskQuotaKey = "database.diskQuota.mb" DatabaseMaxCollectionsKey = "database.max.collections" DatabaseForceDenyWritingKey = "database.force.deny.writing" DatabaseForceDenyReadingKey = "database.force.deny.reading" DatabaseForceDenyDDLKey = "database.force.deny.ddl" // all ddl DatabaseForceDenyCollectionDDLKey = "database.force.deny.collectionDDL" DatabaseForceDenyPartitionDDLKey = "database.force.deny.partitionDDL" DatabaseForceDenyIndexDDLKey = "database.force.deny.index" DatabaseForceDenyFlushDDLKey = "database.force.deny.flush" DatabaseForceDenyCompactionDDLKey = "database.force.deny.compaction" // collection level load properties CollectionReplicaNumber = "collection.replica.number" CollectionResourceGroups = "collection.resource_groups" )
View Source
const ( MmapEnabledKey = "mmap.enabled" LazyLoadEnableKey = "lazyload.enabled" PartitionKeyIsolationKey = "partitionkey.isolation" FieldSkipLoadKey = "field.skipLoad" IndexOffsetCacheEnabledKey = "indexoffsetcache.enabled" ReplicateIDKey = "replicate.id" ReplicateEndTSKey = "replicate.endTS" IndexNonEncoding = "index.nonEncoding" )
common properties
View Source
const ( PropertiesKey string = "properties" TraceIDKey string = "uber-trace-id" )
View Source
const ( // LatestVerision is the magic number for watch latest revision LatestRevision = int64(-1) )
Variables ¶
View Source
var Endian = binary.LittleEndian
Endian is type alias of binary.LittleEndian. Milvus uses little endian by default.
View Source
var ErrNodeIDNotMatch = errors.New("target node id not match")
ErrNodeIDNotMatch stands for the error that grpc target id and node session id not match.
View Source
var FieldNameKeywords = map[string]struct{}{
"$meta": {},
"like": {},
"exists": {},
"EXISTS": {},
"and": {},
"or": {},
"not": {},
"in": {},
"json_contains": {},
"JSON_CONTAINS": {},
"json_contains_all": {},
"JSON_CONTAINS_ALL": {},
"json_contains_any": {},
"JSON_CONTAINS_ANY": {},
"array_contains": {},
"ARRAY_CONTAINS": {},
"array_contains_all": {},
"ARRAY_CONTAINS_ALL": {},
"array_contains_any": {},
"ARRAY_CONTAINS_ANY": {},
"array_length": {},
"ARRAY_LENGTH": {},
"true": {},
"True": {},
"TRUE": {},
"false": {},
"False": {},
"FALSE": {},
"text_match": {},
"TEXT_MATCH": {},
}
View Source
var Version semver.Version
Version current version for session
Functions ¶
func CollectionLevelReplicaNumber ¶
func CollectionLevelReplicaNumber(kvs []*commonpb.KeyValuePair) (int64, error)
func CollectionLevelResourceGroups ¶
func CollectionLevelResourceGroups(kvs []*commonpb.KeyValuePair) ([]string, error)
func DatabaseLevelReplicaNumber ¶
func DatabaseLevelReplicaNumber(kvs []*commonpb.KeyValuePair) (int64, error)
func DatabaseLevelResourceGroups ¶
func DatabaseLevelResourceGroups(kvs []*commonpb.KeyValuePair) ([]string, error)
func FieldHasMmapKey ¶
func FieldHasMmapKey(schema *schemapb.CollectionSchema, fieldID int64) bool
func GetCollectionLoadFields ¶
func GetCollectionLoadFields(schema *schemapb.CollectionSchema, skipDynamicField bool) []int64
GetCollectionLoadFields returns the load field ids according to the type params.
func GetIndexType ¶
func GetIndexType(indexParams []*commonpb.KeyValuePair) string
func GetReplicateEndTS ¶
func GetReplicateEndTS(kvs []*commonpb.KeyValuePair) (uint64, bool)
func GetReplicateID ¶
func GetReplicateID(kvs []*commonpb.KeyValuePair) (string, bool)
func HasLazyload ¶
func HasLazyload(props []*commonpb.KeyValuePair) bool
func IsCollectionLazyLoadEnabled ¶
func IsCollectionLazyLoadEnabled(kvs ...*commonpb.KeyValuePair) bool
func IsIgnorableError ¶
func IsMmapDataEnabled ¶
func IsMmapDataEnabled(kvs ...*commonpb.KeyValuePair) (bool, bool)
func IsMmapIndexEnabled ¶
func IsMmapIndexEnabled(kvs ...*commonpb.KeyValuePair) (bool, bool)
func IsPartitionKeyIsolationKvEnabled ¶
func IsPartitionKeyIsolationKvEnabled(kvs ...*commonpb.KeyValuePair) (bool, error)
func IsReplicateEnabled ¶
func IsReplicateEnabled(kvs []*commonpb.KeyValuePair) (bool, bool)
func IsSystemField ¶
func NewIgnorableError ¶
func ShouldFieldBeLoaded ¶
func ShouldFieldBeLoaded(kvs []*commonpb.KeyValuePair) (bool, error)
func WrapNodeIDNotMatchError ¶
WrapNodeIDNotMatchError wraps `ErrNodeIDNotMatch` with targetID and sessionID.
func WrapNodeIDNotMatchMsg ¶
WrapNodeIDNotMatchMsg fmt error msg with `ErrNodeIDNotMatch`, targetID and sessionID.
Types ¶
type ClusterStatus ¶
type IgnorableError ¶
type IgnorableError struct {
// contains filtered or unexported fields
}
func (*IgnorableError) Error ¶
func (i *IgnorableError) Error() string
type Int64Tuple ¶
type Int64Tuple struct {
Key, Value int64
}
type KeyDataPairs ¶
type KeyDataPairs []*commonpb.KeyDataPair
func CloneKeyDataPairs ¶
func CloneKeyDataPairs(pairs KeyDataPairs) KeyDataPairs
func (KeyDataPairs) Clone ¶
func (pairs KeyDataPairs) Clone() KeyDataPairs
func (KeyDataPairs) Equal ¶
func (pairs KeyDataPairs) Equal(other KeyDataPairs) bool
func (KeyDataPairs) ToMap ¶
func (pairs KeyDataPairs) ToMap() map[string][]byte
type KeyValuePairs ¶
type KeyValuePairs []*commonpb.KeyValuePair
func CloneKeyValuePairs ¶
func CloneKeyValuePairs(pairs KeyValuePairs) KeyValuePairs
func (KeyValuePairs) Clone ¶
func (pairs KeyValuePairs) Clone() KeyValuePairs
func (KeyValuePairs) Equal ¶
func (pairs KeyValuePairs) Equal(other KeyValuePairs) bool
func (KeyValuePairs) ToMap ¶
func (pairs KeyValuePairs) ToMap() map[string]string
type MQClusterStatus ¶
type MQClusterStatus struct { ClusterStatus MqType string `json:"mq_type"` }
type MetaClusterStatus ¶
type MetaClusterStatus struct { ClusterStatus MetaType string `json:"meta_type"` }
type Str2Str ¶
func CloneStr2Str ¶
type StringList ¶
type StringList []string
func CloneStringList ¶
func CloneStringList(l StringList) StringList
func (StringList) Clone ¶
func (l StringList) Clone() StringList
func (StringList) Equal ¶
func (l StringList) Equal(other StringList) bool
Click to show internal directories.
Click to hide internal directories.