milvus-clj.core — com.constacts/milvus-clj 0.2.2

client clj

(client {:keys [host port database username password client-key-path
                client-pem-path ca-pem-path server-pem-path
                connection-timeout-ms keep-alive-timeout-ms
                keep-alive-without-calls? secure? idle-timeout-ms]})

This function creates a Milvus client instance.

close clj

(close client)

(close client max-wait-sec)

Disconnects from a Milvus server with configurable timeout value. Call this method before the application terminates. This method throws an InterruptedException exception if it is interrupted.

create-collection clj

(create-collection client
                   {:keys [collection-name shards-num description field-types
                           consistency-level partition-num]})

This function creates a collection with a specified schema.

create-database clj

(create-database client database-name)

This function creates a database.

create-index clj

(create-index client
              {:keys [collection-name field-name index-type index-name
                      metric-type extra-param sync-mode?
                      sync-load-waiting-interval sync-load-waiting-timeout]})

This function creates an index on a field in a specified collection.

data-types clj

delete clj

(delete client {:keys [collection-name partition-name expr]})

This function deletes an entity or entities from a collection by filtering the primary key field with boolean expression.

drop-collection clj

(drop-collection client collection-name)

This function drops a specified collection.

drop-database clj

(drop-database client database-name)

This function drops a database. Note that this method drops all data in the database.

drop-index clj

(drop-index client {:keys [collection-name index-name]})

This function drops an index and its corresponding index file in the collection.

flush-collections clj

(flush-collections client
                   {:keys [collection-names sync-flush?
                           sync-flush-waiting-interval-ms
                           sync-flush-waiting-timeout-sec]})

This method triggers a flush action in which all growing segments in the specified collection are marked as sealed and then flushed to storage.

index-types clj

insert clj

(insert client {:keys [collection-name partition-name fields]})

This function inserts entities into a specified collection.

list-databases clj

(list-databases client)

This function lists all databases in the cluster.

load-collection clj

(load-collection client
                 {:keys [collection-name sync-load? sync-load-waiting-interval
                         sync-load-waiting-timeout replica-number refresh?]})

This function loads the specified collection and all the data within to memory for search or query.

metric-types clj

query clj

(query client
       {:keys [collection-name consistency-level partition-names
               travel-timestamp out-fields expr offset limit ignore-growing?]})

This function queries entity(s) based on scalar field(s) filtered by boolean expression.

release-collection clj

(release-collection client {:keys [collection-name]})

This function releases the specified collection and all data within it from memory.

search clj

(search client
        {:keys [collection-name consistency-level partition-names
                travel-timestamp out-fields expr metric-type vector-field-name
                top-k vectors round-decimal params ignore-growing?]})

This function conducts an approximate nearest neighbor (ANN) search on a vector field and pairs up with boolean expression to conduct filtering on scalar fields before searching.

set-log-level clj

(set-log-level client level)

timeout clj

(timeout client timeout-ms)

The timeout setting for RPC call.