refactor: New Client Implementation

.github/workflows/ci.yml

@@ -1,10 +1,10 @@
-name: Go CI
+name: Go Tests
 
 on:
   push:
-    branches: [ master, dev ]
+    branches:
+      - master
   pull_request:
-    branches: [ '**' ]
 
 jobs:
   build:
@@ -19,6 +19,9 @@ jobs:
         with:
           go-version-file: ./go.mod
 
+      - name: Get
+        run: go get ./...
+
       - name: Build
         run: go build ./...
 

.github/workflows/golangci-lint.yml

@@ -0,0 +1,23 @@
+name: golangci-lint
+on:
+  push:
+    branches:
+      - master
+  pull_request:
+
+permissions:
+  contents: read
+
+jobs:
+  golangci:
+    name: lint
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions/setup-go@v5
+        with:
+          go-version: stable
+      - name: golangci-lint
+        uses: golangci/golangci-lint-action@v6
+        with:
+          version: v1.60

README.md

@@ -1,75 +1,3 @@
-# Golang Qdrant client
+# Qdrant-Go V2
 
-Go client for Qdrant vector search engine
-
-## Install
-
-```bash
-go get github.com/qdrant/go-client
-```
-
-## Usage
-
-Run Qdrant with enabled gRPC interface:
-
-```bash
-# With env variable
-docker run -p 6333:6333 -p 6334:6334 \
-    -e QDRANT__SERVICE__GRPC_PORT="6334" \
-    qdrant/qdrant
-```
-
-Or by updating the configuration file:
-
-```yaml
-service:
-  grpc_port: 6334
-```
-
-More info about gRPC in [documentation](https://qdrant.tech/documentation/quick-start/#grpc).
-
-### Making requests
-
-```go
-package main
-
-import (
-	"context"
-	"flag"
-	"log"
-	"time"
-
-	pb "github.com/qdrant/go-client/qdrant"
-	"google.golang.org/grpc"
-	"google.golang.org/grpc/credentials/insecure"
-)
-
-var (
-	addr = flag.String("addr", "localhost:6334", "the address to connect to")
-)
-
-func main() {
-	flag.Parse()
-	// Set up a connection to the server.
-	conn, err := grpc.Dial(*addr, grpc.WithTransportCredentials(insecure.NewCredentials()))
-	if err != nil {
-		log.Fatalf("did not connect: %v", err)
-	}
-	defer conn.Close()
-
-	collections_client := pb.NewCollectionsClient(conn)
-
-	// Contact the server and print out its response.
-	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
-	defer cancel()
-	r, err := collections_client.List(ctx, &pb.ListCollectionsRequest{})
-	if err != nil {
-		log.Fatalf("could not get collections: %v", err)
-	}
-	log.Printf("List of collections: %s", r.GetCollections())
-}
-```
-
-> For authenticated request (using API KEY and TLS) to Qdrant Cloud, please refer to the [authenticated](https://github.com/qdrant/go-client/tree/master/examples/authentication/main.go) example.
-
-A full example for uploading, searching and filtering can be found in the [`examples`](https://github.com/qdrant/go-client/tree/master/examples) directory.
+TODO

examples/authentication/main.go

@@ -2,45 +2,29 @@ package main
 
 import (
 	"context"
-	"crypto/tls"
-	"flag"
 	"log"
-	"time"
 
-	"google.golang.org/grpc/credentials"
-	"google.golang.org/grpc/metadata"
-
-	pb "github.com/qdrant/go-client/qdrant"
-	"google.golang.org/grpc"
-)
-
-var (
-	addr = flag.String("addr", "secure.cloud.qdrant.io:6334", "the address to connect to")
+	"github.com/qdrant/go-client/qdrant"
 )
 
 func main() {
-	flag.Parse()
-	// Set up a connection to the server.
-	config := &tls.Config{}
-	conn, err := grpc.Dial(*addr, grpc.WithTransportCredentials(credentials.NewTLS(config)), grpc.WithUnaryInterceptor(interceptor))
+	// Create new client
+	client, err := qdrant.NewClient(&qdrant.Config{
+		Host:   "xyz-example.eu-central.aws.cloud.qdrant.io",
+		Port:   6334,
+		APIKey: "<paste-your-api-key-here>",
+		UseTLS: true,
+		// TLSConfig: &tls.Config{...},
+		// GrpcOptions: []grpc.DialOption{},
+	})
 	if err != nil {
-		log.Fatalf("did not connect: %v", err)
+		log.Fatalf("could not instantiate: %v", err)
 	}
-	defer conn.Close()
-
-	collections_client := pb.NewCollectionsClient(conn)
-
-	// Contact the server and print out its response.
-	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
-	defer cancel()
-	r, err := collections_client.List(ctx, &pb.ListCollectionsRequest{})
+	defer client.Close()
+	// List collections
+	collections, err := client.ListCollections(context.Background())
 	if err != nil {
 		log.Fatalf("could not get collections: %v", err)
 	}
-	log.Printf("List of collections: %s", r.GetCollections())
-}
-
-func interceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
-	newCtx := metadata.AppendToOutgoingContext(ctx, "api-key", "secret-key-*******")
-	return invoker(newCtx, method, req, reply, cc, opts...)
+	log.Printf("List of collections: %v", collections)
 }