vikingdb

Jan 23, 2025

Changes in this version

+ const Sort

type Index

+ func (index *Index) SearchAgg(searchAggOptions *SearchAggOptions) (*SearchAggResult, error)

+ func (index *Index) Sort(sortOptions *SortOptions) (*IndexSortResult, error)

+ type IndexSortResult struct

+ PrimaryKeyNotExist []interface{}

+ SortResult []*SortResultItem

+ type SearchAggOptions struct

+ func NewSearchAggOptions() *SearchAggOptions

+ func (a *SearchAggOptions) SetAgg(agg map[string]interface{}) *SearchAggOptions

+ func (a *SearchAggOptions) SetFilter(filter map[string]interface{}) *SearchAggOptions

+ func (a *SearchAggOptions) SetPartition(partition string) *SearchAggOptions

+ func (a *SearchAggOptions) SetRetry(retry bool) *SearchAggOptions

+ type SearchAggResult struct

+ AggOp string

+ AggResult map[string]interface{}

+ GroupByField string

type SearchOptions

+ func (s *SearchOptions) SetNeedInstruction(needInstruction bool) *SearchOptions

+ func (s *SearchOptions) SetPostProcessInputLimit(postProcessInputLimit int64) *SearchOptions

+ func (s *SearchOptions) SetPostProcessOps(postProcessOps []map[string]interface{}) *SearchOptions

+ func (s *SearchOptions) SetPrimaryKeyIn(primaryKeyIn []interface{}) *SearchOptions

+ func (s *SearchOptions) SetPrimaryKeyNotIn(primaryKeyNotIn []interface{}) *SearchOptions

+ type SortOptions struct

+ func NewSortOptions() *SortOptions

+ func (t *SortOptions) SetPrimaryKeys(primaryKeys []interface{}) *SortOptions

+ func (t *SortOptions) SetQueryVector(queryVector []float64) *SortOptions

+ func (t *SortOptions) SetRetry(retry bool) *SortOptions

+ type SortResultItem struct

+ PrimaryKey interface{}

+ Score float64

Jan 16, 2025

Changes in this version

+ func HasDecimalPart(f float64) bool

+ func ParseJsonFloat64Field(default_val_i interface{}) (float64, error)

+ func ParseJsonInt64Field(default_val_i interface{}) (int64, error)

+ func ParseJsonUseNumber2(input []byte, target interface{}) error

+ func SerilizeToJsonBytesUseNumber(source interface{}) ([]byte, error)

Jan 9, 2025

Changes in this version

+ const Data_Export

type Collection

+ func (collection *Collection) UpdateData(data interface{}, opts ...ParamOption) error

Nov 28, 2024

Changes in this version

+ const Confirm

+ const Confirmed

+ const Done

+ const Fail

+ const Filter_Delete

+ const Init

+ const Queued

+ const Running

type VikingDBService

+ func (vikingDBService *VikingDBService) UpdateTask(taskID string, taskStatus string) error

Nov 21, 2024

Changes in this version

+ const INITIAL_RETRY_DELAY

+ const MAX_RETRIES

+ const MAX_RETRY_DELAY

type SearchOptions

+ func (searchOptions *SearchOptions) SetRetry(retry bool) *SearchOptions

Nov 7, 2024

Changes in this version

+ const Data_Import

+ type Task struct

+ CollectionName string

+ CreateTime string

+ ProcessInfo map[string]interface{}

+ TaskID string

+ TaskParams map[string]interface{}

+ TaskStatus string

+ TaskType string

+ UpdatePerson string

+ UpdateTime string

type VikingDBService

+ func (vikingDBService *VikingDBService) CreateTask(taskType string, taskParams map[string]interface{}) (string, error)

+ func (vikingDBService *VikingDBService) DropTask(taskID string) error

+ func (vikingDBService *VikingDBService) GetTask(taskID string) (*Task, error)

+ func (vikingDBService *VikingDBService) ListTasks() ([]*Task, error)

Oct 17, 2024

Changes in this version

+ type ParamOption func(*ParamOptions)

+ func WithAsyncUpsert(yes bool) ParamOption

+ type ParamOptions struct

+ AsyncUpsert bool

Sep 19, 2024

Changes in this version

type Collection

+ func (collection *Collection) AsyncUpsertData(data interface{}) error

Sep 12, 2024

Changes in this version

+ const Auto

+ const Custom

type Index

+ ShardPolicy string

type IndexOptions

+ func (indexOptions *IndexOptions) SetShardPolicy(shardPolicy string) *IndexOptions

May 9, 2024

Changes in this version

type RawData

+ Image string

Apr 18, 2024

Changes in this version

+ const HNSW_HYBRID

+ const Sparse_Vector

type EmbModel

+ Params map[string]interface{}

type SearchOptions

+ func (searchOptions *SearchOptions) SetDenseWeight(dense_weight float64) *SearchOptions

+ func (searchOptions *SearchOptions) SetSparseVectors(sparse_vectors map[string]interface{}) *SearchOptions

type VikingDBService

+ func (vikingDBService *VikingDBService) EmbeddingV2(embModel EmbModel, rawData interface{}) (map[string]interface{}, error)

Mar 21, 2024

Changes in this version

type UpdateIndexOptions

+ func (updateIndexOptions *UpdateIndexOptions) SetShardCount(shardCount int64) *UpdateIndexOptions

type VikingDBService

+ func (vikingDBService *VikingDBService) SetConnectionTimeout(connectionTimeout int64)

Mar 7, 2024

Changes in this version

+ const DiskANN

type VikingDBService

+ func (vikingDBService *VikingDBService) BatchRerank(datas []map[string]interface{}) ([]float64, error)

Jan 18, 2024

Changes in this version

type VikingDBService

+ func (vikingDBService *VikingDBService) Rerank(query string, content string, title string) (float64, error)

Jan 11, 2024

Changes in this version

+ const Fix16

+ const IVF

+ const PQ

type VikingDBService

+ func (vikingDBService *VikingDBService) SetHeader(header map[string]string)

Dec 28, 2023

Changes in this version

type IndexOptions

+ func (indexOptions *IndexOptions) SetShardCount(shardCount int64) *IndexOptions

+ type UpdateIndexOptions struct

+ func NewUpdateIndexOptions() *UpdateIndexOptions

+ func (updateIndexOptions *UpdateIndexOptions) SetCpuQuota(cpuQuota int64) *UpdateIndexOptions

+ func (updateIndexOptions *UpdateIndexOptions) SetDescription(description string) *UpdateIndexOptions

+ func (updateIndexOptions *UpdateIndexOptions) SetScalarIndex(scalarIndex []string) *UpdateIndexOptions

type VikingDBService

+ func (vikingDBService *VikingDBService) UpdateIndex(collectionName string, indexName string, ...) error

Dec 21, 2023

Changes in this version

+ const Asc

+ const Bool

+ const COSINE

+ const Desc

+ const FLAT

+ const Float

+ const Float32

+ const HNSW

+ const IP

+ const Int64

+ const Int8

+ const L2

+ const ListInt64

+ const ListString

+ const String

+ const Text

+ const Vector

+ type Collection struct

+ CollectionName string

+ CreateTime string

+ Description string

+ Fields []Field

+ Indexes []*Index

+ PrimaryKey string

+ Stat map[string]interface{}

+ UpdatePerson string

+ UpdateTime string

+ VikingDBService *VikingDBService

+ func (collection *Collection) DeleteData(id interface{}) error

+ func (collection *Collection) FetchData(id interface{}) ([]*Data, error)

+ func (collection *Collection) UpsertData(data interface{}) error

+ type Data struct

+ Fields map[string]interface{}

+ Id interface{}

+ Score float64

+ TTL int64

+ Text string

+ Timestamp interface{}

+ type EmbModel struct

+ ModelName string

+ type Field struct

+ DefaultVal interface{}

+ Dim int64

+ FieldName string

+ FieldType string

+ IsPrimaryKey bool

+ PipelineName string

+ type Index struct

+ CollectionName string

+ CpuQuota int64

+ CreateTime string

+ Description string

+ IndexCost interface{}

+ IndexName string

+ PartitionBy string

+ ScalarIndex interface{}

+ ShardCount int64

+ Stat string

+ UpdatePerson string

+ UpdateTime string

+ VectorIndex *VectorIndexParams

+ VikingDBService *VikingDBService

+ func (index *Index) FetchData(id interface{}, searchOptions *SearchOptions) ([]*Data, error)

+ func (index *Index) Search(order interface{}, searchOptions *SearchOptions) ([]*Data, error)

+ func (index *Index) SearchById(id interface{}, searchOptions *SearchOptions) ([]*Data, error)

+ func (index *Index) SearchByText(text TextObject, searchOptions *SearchOptions) ([]*Data, error)

+ func (index *Index) SearchByVector(vector []float64, searchOptions *SearchOptions) ([]*Data, error)

+ type IndexOptions struct

+ func NewIndexOptions() *IndexOptions

+ func (indexOptions *IndexOptions) SetCpuQuota(cpuQuota int64) *IndexOptions

+ func (indexOptions *IndexOptions) SetDescription(description string) *IndexOptions

+ func (indexOptions *IndexOptions) SetPartitionBy(partitionBy string) *IndexOptions

+ func (indexOptions *IndexOptions) SetScalarIndex(scalarIndex []string) *IndexOptions

+ func (indexOptions *IndexOptions) SetVectorIndex(vectorIndex *VectorIndexParams) *IndexOptions

+ type RawData struct

+ DataType string

+ Text string

+ type ScalarOrder struct

+ FieldName string

+ Order string

+ type SearchOptions struct

+ func NewSearchOptions() *SearchOptions

+ func (searchOptions *SearchOptions) SetFilter(filter map[string]interface{}) *SearchOptions

+ func (searchOptions *SearchOptions) SetLimit(limit int64) *SearchOptions

+ func (searchOptions *SearchOptions) SetOutputFields(outputFields []string) *SearchOptions

+ func (searchOptions *SearchOptions) SetPartition(partition string) *SearchOptions

+ type TextObject struct

+ Base64 interface{}

+ Text string

+ Url string

+ type UpdateCollectionOptions struct

+ func NewUpdateCollectionOptions() *UpdateCollectionOptions

+ func (updateCollectionOptions *UpdateCollectionOptions) SetDescription(description string) *UpdateCollectionOptions

+ func (updateCollectionOptions *UpdateCollectionOptions) SetFields(fields []Field) *UpdateCollectionOptions

+ type VectorIndexParams struct

+ Distance string

+ HnswCef int64

+ HnswM int64

+ HnswSef int64

+ IndexType string

+ Quant string

+ type VectorOrder struct

+ Id interface{}

+ Vector interface{}

+ type VikingDBService struct

+ Client *base.Client

+ func NewVikingDBService(host string, region string, ak string, sk string, scheme string) *VikingDBService

+ func (vikingDBService *VikingDBService) CreateCollection(collectionName string, fields []Field, description string) (*Collection, error)

+ func (vikingDBService *VikingDBService) CreateIndex(collectionName string, indexName string, indexOptions *IndexOptions) (*Index, error)

+ func (vikingDBService *VikingDBService) DoRequest(ctx context.Context, api string, query url.Values, body string) (map[string]interface{}, error)

+ func (vikingDBService *VikingDBService) DropCollection(collectionName string) error

+ func (vikingDBService *VikingDBService) DropIndex(collectionName string, indexName string) error

+ func (vikingDBService *VikingDBService) Embedding(embModel EmbModel, rawData interface{}) ([][]float64, error)

+ func (vikingDBService *VikingDBService) GetCollection(collectionName string) (*Collection, error)

+ func (vikingDBService *VikingDBService) GetIndex(collectionName string, indexName string) (*Index, error)

+ func (vikingDBService *VikingDBService) ListCollections() ([]*Collection, error)

+ func (vikingDBService *VikingDBService) ListIndexes(collectionName string) ([]*Index, error)

+ func (vikingDBService *VikingDBService) UpdateCollection(collectionName string, updateCollectionOptions *UpdateCollectionOptions) error