milvus

// createCollections {
ctx := context.Background()

milvusContainer, err := milvus.Run(ctx, "milvusdb/milvus:v2.6.3")
defer func() {
	if err := testcontainers.TerminateContainer(milvusContainer); err != nil {
		log.Printf("failed to terminate container: %s", err)
	}
}()
if err != nil {
	log.Printf("failed to start container: %s", err)
	return
}

connectionStr, err := milvusContainer.ConnectionString(ctx)
if err != nil {
	log.Printf("failed to get connection string: %s", err)
	return
}

// Create a client to interact with the Milvus container
milvusClient, err := milvusclient.New(ctx, &milvusclient.ClientConfig{
	Address: connectionStr,
})
if err != nil {
	log.Print("failed to connect to Milvus:", err.Error())
	return
}
defer milvusClient.Close(ctx)

collectionName := "book"
schema := &entity.Schema{
	CollectionName: collectionName,
	Description:    "Test book search",
	Fields: []*entity.Field{
		{
			Name:       "book_id",
			DataType:   entity.FieldTypeInt64,
			PrimaryKey: true,
			AutoID:     false,
		},
		{
			Name:       "word_count",
			DataType:   entity.FieldTypeInt64,
			PrimaryKey: false,
			AutoID:     false,
		},
		{
			Name:     "book_intro",
			DataType: entity.FieldTypeFloatVector,
			TypeParams: map[string]string{
				"dim": "2",
			},
		},
	},
	EnableDynamicField: true,
}

err = milvusClient.CreateCollection(
	ctx,
	milvusclient.NewCreateCollectionOption(collectionName, schema).WithShardNum(2),
)
if err != nil {
	log.Printf("failed to create collection: %s", err)
	return
}

list, err := milvusClient.ListCollections(ctx, milvusclient.NewListCollectionOption())
if err != nil {
	log.Printf("failed to list collections: %s", err)
	return
}
// }

fmt.Println(len(list))

Output:

1