qdrant_dart 0.6.0

A small, idiomatic REST client for Qdrant collections, points, payloads, and vector search.

example/qdrant_dart_example.dart

import 'dart:io';

import 'package:qdrant_dart/qdrant_dart.dart';

Future<void> main() async {
  final client = QdrantClient(
    baseUrl: Uri.parse(
      Platform.environment['QDRANT_URL'] ?? 'http://127.0.0.1:6333',
    ),
    apiKey: Platform.environment['QDRANT_API_KEY'],
  );
  const collectionName = 'qdrant_dart_example';
  var created = false;

  try {
    created = await client.collections.create(
      collectionName,
      vectors: CollectionVectors.dense(
        DenseVectorParams(size: 4, distance: Distance.cosine),
      ),
    );
    await client.aliases.update([
      CollectionAliasAction.create(
        collectionName: collectionName,
        aliasName: '${collectionName}_current',
      ),
    ]);
    print(
      (await client.aliases.list(collectionName: collectionName))
          .single
          .aliasName,
    );
    await client.payloadIndexes.create(
      collectionName,
      'year',
      schema: PayloadSchemaType.integer,
    );
    await client.collections.updateIndexingThreshold(collectionName, 0);
    await client.points.upsertInBatches(
      collectionName,
      [
        Point(
          id: 1,
          vector: [0.9, 0.1, 0.1, 0.2],
          payload: {'title': 'The Matrix', 'year': 1999},
        ),
      ],
      batchSize: 100,
    );
    await client.collections.updateIndexingThreshold(collectionName, 20000);
    await client.points.setPayload(
      collectionName,
      {'featured': true},
      PointSelector.ids([1]),
    );
    await client.points.updateVectors(collectionName, [
      PointVectorUpdate(id: 1, vector: [0.8, 0.2, 0.1, 0.2]),
    ]);

    final matches = await client.points.query(
      collectionName,
      DenseVector([0.9, 0.1, 0.1, 0.2]),
      filter: Filter(
        must: [FieldCondition.match('year', 1999)],
      ),
      withPayload: true,
    );
    print(matches.single.payload?['title']);
    print(await client.points.count(collectionName));
  } finally {
    try {
      if (created) {
        await client.aliases.update([
          CollectionAliasAction.delete('${collectionName}_current'),
        ]);
        await client.collections.delete(collectionName);
      }
    } finally {
      client.close(force: true);
    }
  }
}