|
@@ -357,7 +357,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("HasCollectionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -390,7 +390,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("CreateDatabaseRequest databaseName:%s", requestParam.getDatabaseName());
|
|
|
|
|
|
try {
|
|
@@ -417,7 +417,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo("ListDatabasesRequest");
|
|
|
+ logDebug("ListDatabasesRequest");
|
|
|
String title = "ListDatabasesRequest";
|
|
|
|
|
|
try {
|
|
@@ -443,7 +443,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DropDatabaseRequest databaseName:%s", requestParam.getDatabaseName());
|
|
|
|
|
|
try {
|
|
@@ -470,7 +470,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("CreateCollectionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -517,7 +517,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DropCollectionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -546,7 +546,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("LoadCollectionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -587,7 +587,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("ReleaseCollectionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -613,7 +613,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("RenameCollectionRequest collectionName:%s", requestParam.getOldCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -640,7 +640,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DescribeCollectionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -669,7 +669,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetCollectionStatisticsRequest collectionName:%s",
|
|
|
requestParam.getCollectionName());
|
|
|
|
|
@@ -711,7 +711,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "ShowCollectionsRequest";
|
|
|
|
|
|
try {
|
|
@@ -741,7 +741,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("AlterCollectionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -777,7 +777,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "FlushRequest";
|
|
|
|
|
|
try {
|
|
@@ -816,7 +816,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo("FlushAllRequest");
|
|
|
+ logDebug("FlushAllRequest");
|
|
|
String title = "FlushAllRequest";
|
|
|
|
|
|
try {
|
|
@@ -844,7 +844,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("CreatePartitionRequest collectionName:%s, partitionName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getPartitionName());
|
|
|
|
|
@@ -872,7 +872,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DropPartitionRequest collectionName:%s, partitionName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getPartitionName());
|
|
|
|
|
@@ -900,7 +900,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("HasPartitionRequest collectionName:%s, partitionName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getPartitionName());
|
|
|
|
|
@@ -929,7 +929,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("LoadPartitionsRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -969,7 +969,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("ReleasePartitionsRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -996,7 +996,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetPartitionStatisticsRequest collectionName:%s, partitionName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getPartitionName());
|
|
|
|
|
@@ -1037,7 +1037,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("ShowPartitionsRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1064,7 +1064,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("CreateAliasRequest collectionName:%s, alias:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getAlias());
|
|
|
|
|
@@ -1092,7 +1092,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DropAliasRequest alias:%s", requestParam.getAlias());
|
|
|
|
|
|
try {
|
|
@@ -1118,7 +1118,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("AlterAliasRequest collectionName:%s, alias:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getAlias());
|
|
|
|
|
@@ -1146,7 +1146,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("CreateIndexRequest collectionName:%s, fieldName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getFieldName());
|
|
|
|
|
@@ -1232,7 +1232,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DropIndexRequest collectionName:%s, indexName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getIndexName());
|
|
|
|
|
@@ -1260,7 +1260,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DescribeIndexRequest collectionName:%s, indexName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getIndexName());
|
|
|
|
|
@@ -1293,7 +1293,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetIndexStateRequest collectionName:%s, indexName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getIndexName());
|
|
|
|
|
@@ -1323,7 +1323,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetIndexBuildProgressRequest collectionName:%s, indexName:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getIndexName());
|
|
|
|
|
@@ -1351,7 +1351,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DeleteRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1380,7 +1380,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("InsertRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1414,7 +1414,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
R.failed(new ClientNotConnectedException("Client rpc channel is not ready")));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("InsertAsyncRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
DescribeCollectionParam.Builder builder = DescribeCollectionParam.newBuilder()
|
|
@@ -1467,7 +1467,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("UpsertRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1500,7 +1500,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
R.failed(new ClientNotConnectedException("Client rpc channel is not ready")));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("UpsertAsyncRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
DescribeCollectionParam.Builder builder = DescribeCollectionParam.newBuilder()
|
|
@@ -1553,7 +1553,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("SearchRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1581,7 +1581,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
R.failed(new ClientNotConnectedException("Client rpc channel is not ready")));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("SearchAsyncRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
SearchRequest searchRequest = ParamUtils.convertSearchParam(requestParam);
|
|
@@ -1625,7 +1625,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("QueryRequest collectionName:%s, expr:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getExpr());
|
|
|
|
|
@@ -1661,7 +1661,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
R.failed(new ClientNotConnectedException("Client rpc channel is not ready")));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("QueryAsyncRequest collectionName:%s, expr:%s",
|
|
|
requestParam.getCollectionName(), requestParam.getExpr());
|
|
|
|
|
@@ -1706,7 +1706,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("QueryAsyncRequest request:%s", requestParam.getRequest());
|
|
|
|
|
|
try {
|
|
@@ -1732,7 +1732,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetFlushState collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1760,7 +1760,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "GetFlushAllState";
|
|
|
|
|
|
try {
|
|
@@ -1788,7 +1788,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetPersistentSegmentInfoRequest collectionName:%s",
|
|
|
requestParam.getCollectionName());
|
|
|
|
|
@@ -1815,7 +1815,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetQuerySegmentInfoRequest collectionName:%s",
|
|
|
requestParam.getCollectionName());
|
|
|
|
|
@@ -1842,7 +1842,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetReplicasRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1876,7 +1876,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "LoadBalanceRequest";
|
|
|
|
|
|
try {
|
|
@@ -1904,7 +1904,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetCompactionStateRequest compactionID:%d", requestParam.getCompactionID());
|
|
|
|
|
|
try {
|
|
@@ -1930,7 +1930,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("ManualCompactionRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -1963,7 +1963,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetCompactionPlansRequest compactionID:%d", requestParam.getCompactionID());
|
|
|
|
|
|
try {
|
|
@@ -1989,7 +1989,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("CreateCredentialRequest userName:%s", requestParam.getUsername());
|
|
|
|
|
|
try {
|
|
@@ -2016,7 +2016,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("UpdateCredentialRequest userName:%s", requestParam.getUsername());
|
|
|
|
|
|
try {
|
|
@@ -2044,7 +2044,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DeleteCredentialRequest userName:%s", requestParam.getUsername());
|
|
|
|
|
|
try {
|
|
@@ -2070,7 +2070,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "ListCredUsersRequest";
|
|
|
|
|
|
try {
|
|
@@ -2099,7 +2099,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("AddUserToRoleRequest userName:%s, roleName:%s",
|
|
|
requestParam.getUserName(), requestParam.getRoleName());
|
|
|
|
|
@@ -2128,7 +2128,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("RemoveUserFromRoleRequest userName:%s, roleName:%s",
|
|
|
requestParam.getUserName(), requestParam.getRoleName());
|
|
|
|
|
@@ -2157,7 +2157,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("RemoveUserFromRoleRequest roleName:%s", requestParam.getRoleName());
|
|
|
|
|
|
try {
|
|
@@ -2185,7 +2185,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DropRoleRequest roleName:%s", requestParam.getRoleName());
|
|
|
|
|
|
try {
|
|
@@ -2211,7 +2211,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("SelectRoleRequest roleName:%s", requestParam.getRoleName());
|
|
|
|
|
|
try {
|
|
@@ -2240,7 +2240,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("SelectUserRequest userName:%s", requestParam.getUserName());
|
|
|
|
|
|
try {
|
|
@@ -2267,7 +2267,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GrantRolePrivilegeRequest roleName:%s", requestParam.getRoleName());
|
|
|
|
|
|
GrantEntity.Builder builder = GrantEntity.newBuilder()
|
|
@@ -2303,7 +2303,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("RevokeRolePrivilegeRequest roleName:%s", requestParam.getRoleName());
|
|
|
|
|
|
try {
|
|
@@ -2336,7 +2336,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("SelectGrantForRoleRequest roleName:%s", requestParam.getRoleName());
|
|
|
|
|
|
try {
|
|
@@ -2363,7 +2363,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("SelectGrantForRoleAndObjectRequest roleName:%s", requestParam.getRoleName());
|
|
|
|
|
|
try {
|
|
@@ -2393,7 +2393,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("BulkInsertRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -2428,7 +2428,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetBulkInsertStateRequest taskID:%d", requestParam.getTask());
|
|
|
|
|
|
try {
|
|
@@ -2454,7 +2454,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("ListBulkInsertTasksRequest collectionName:%s",
|
|
|
requestParam.getCollectionName());
|
|
|
|
|
@@ -2482,7 +2482,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetLoadingProgressRequest collectionName:%s",
|
|
|
requestParam.getCollectionName());
|
|
|
|
|
@@ -2510,7 +2510,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("GetLoadStateRequest collectionName:%s",
|
|
|
requestParam.getCollectionName());
|
|
|
|
|
@@ -2584,7 +2584,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("CreateResourceGroupRequest groupName:%s",
|
|
|
requestParam.getGroupName());
|
|
|
|
|
@@ -2611,7 +2611,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DropResourceGroupRequest groupName:%s",
|
|
|
requestParam.getGroupName());
|
|
|
|
|
@@ -2638,7 +2638,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "ListResourceGroupsRequest";
|
|
|
|
|
|
try {
|
|
@@ -2663,7 +2663,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DescribeResourceGroupRequest groupName:%s",
|
|
|
requestParam.getGroupName());
|
|
|
|
|
@@ -2690,7 +2690,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("TransferNodeRequest nodeNumber:%d, sourceGroup:%s, targetGroup:%s",
|
|
|
requestParam.getNodeNumber(), requestParam.getSourceGroupName(), requestParam.getTargetGroupName());
|
|
|
|
|
@@ -2719,7 +2719,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("TransferReplicaRequest replicaNumber:%d, sourceGroup:%s, targetGroup:%s",
|
|
|
requestParam.getReplicaNumber(), requestParam.getSourceGroupName(), requestParam.getTargetGroupName());
|
|
|
|
|
@@ -2751,7 +2751,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
if (!clientIsReady()) {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "CreateSimpleCollectionRequest";
|
|
|
|
|
|
try {
|
|
@@ -2792,7 +2792,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
if (!clientIsReady()) {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "ListCollectionsRequest";
|
|
|
|
|
|
try {
|
|
@@ -2819,7 +2819,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
if (!clientIsReady()) {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "InsertRowsRequest";
|
|
|
|
|
|
try {
|
|
@@ -2846,7 +2846,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
if (!clientIsReady()) {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("DeleteIdsRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|
|
@@ -2886,7 +2886,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
if (!clientIsReady()) {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "GetIdsRequest";
|
|
|
|
|
|
try {
|
|
@@ -2932,7 +2932,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
if (!clientIsReady()) {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = "QuerySimpleRequest";
|
|
|
|
|
|
try {
|
|
@@ -2981,7 +2981,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
|
|
|
if (!clientIsReady()) {
|
|
|
return R.failed(new ClientNotConnectedException("Client rpc channel is not ready"));
|
|
|
}
|
|
|
- logInfo(requestParam.toString());
|
|
|
+ logDebug(requestParam.toString());
|
|
|
String title = String.format("SearchSimpleRequest collectionName:%s", requestParam.getCollectionName());
|
|
|
|
|
|
try {
|