mirror of
https://github.com/milvus-io/milvus.git
synced 2026-07-21 10:15:43 +00:00
alohaha22andGitHub
63b8210726
issue: #50573 ## What this PR does This PR fixes `DumpMessages` transaction handling. When the WAL scanner returns an assembled transaction message, `DumpMessages` now expands it into separate responses: - begin transaction message - data messages that pass the existing message type filter - commit transaction message This allows recovery and CDC consumers to decode and replay transaction data messages correctly. The PR also supports inclusive start semantics through `include_start_message`, while preserving the existing default behavior of starting after `start_message_id` for compatibility. ## Tests - Added unit coverage for default StartAfter policy. - Added unit coverage for IncludeStartMessage StartFrom policy. - Added unit coverage for transaction expansion and send error handling. - Ran `gofmt` and `git diff --check`. Linked proto change: milvus-io/milvus-proto#616 Signed-off-by: alohaha22 <shawn.work1229@outlook.com>
Go MilvusClient
Go MilvusClient for Milvus. To contribute code to this project, please read our contribution guidelines first.
Getting started
Prerequisites
Go 1.24.12 or higher
Install Milvus Go SDK
-
Use
go getto install the latest version of the Milvus Go SDK and dependencies:go get -u github.com/milvus-io/milvus/client/v2 -
Include the Go MilvusClient in your application:
import "github.com/milvus-io/milvus/client/v2/milvusclient" //...other snippet ... ctx, cancel := context.WithCancel(context.Background()) defer cancel() milvusAddr := "YOUR_MILVUS_ENDPOINT" cli, err := milvusclient.New(ctx, &milvusclient.ClientConfig{ Address: milvusAddr, }) if err != nil { // handle error } // Do your work with milvus client
API Documentation
Refer to https://milvus.io/api-reference/go/v2.5.x/About.md for the Go SDK API documentation.
Code format
The Go source code is formatted using gci & gofumpt. Please run make lint-fix before sumbit a PR.