RefreshLoad
This operation reloads a collection to include newly inserted data in search results.
func (c *Client) RefreshLoad(ctx context.Context, option RefreshLoadOption, callOptions ...grpc.CallOption) (LoadTask, error)
Request Syntax
Creates the request for RefreshLoad().
option := milvusclient.NewRefreshLoadOption(collectionName)
result, err := client.RefreshLoad(ctx, option)
PARAMETERS:
-
collectionName (string) -
[REQUIRED]
The name of the target collection.
BUILDER METHODS:
-
NewRefreshLoadOption(collectionName string)Creates the request for RefreshLoad().
RETURN TYPE:
LoadTask, error
RETURNS:
A LoadTask that can be used to wait for the load operation to complete. Returns an error if the operation fails.
METHODS:
-
Await (error) -
Blocks until the refreshed load is confirmed complete, polling the server at the task's check interval until the refresh progress reports 100 or the context is cancelled.
ERROR HANDLING:
-
error
The operation fails. Check
err != nilfor failure details.
Example
Demonstrates RefreshLoad() usage.
import (
"context"
"github.com/milvus-io/milvus/client/v3/milvusclient"
)
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
collectionName := `customized_setup_1`
cli, err := milvusclient.New(ctx, &milvusclient.ClientConfig{
Address: milvusAddr,
})
if err != nil {
// handle err
}
loadTask, err := cli.RefreshLoad(ctx, milvusclient.NewRefreshLoadOption(collectionName))
if err != nil {
// handle err
}
err = loadTask.Await(ctx)
if err != nil {
// handler err
}