io.milvus.server

类 MockMilvusServerImpl

java.lang.Object

io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

io.milvus.server.MockMilvusServerImpl

所有已实现的接口:

io.grpc.BindableService

public class MockMilvusServerImpl
extends io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

构造器概要

构造器

构造器和说明
MockMilvusServerImpl()

方法概要

限定符和类型	方法和说明
void	alterAlias(io.milvus.grpc.AlterAliasRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	calcDistance(io.milvus.grpc.CalcDistanceRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.CalcDistanceResults> responseObserver)
void	createAlias(io.milvus.grpc.CreateAliasRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	createCollection(io.milvus.grpc.CreateCollectionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	createCredential(io.milvus.grpc.CreateCredentialRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver) https://wiki.lfaidata.foundation/display/MIL/MEP+27+--+Support+Basic+Authentication
void	createIndex(io.milvus.grpc.CreateIndexRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	createPartition(io.milvus.grpc.CreatePartitionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	delete(io.milvus.grpc.DeleteRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.MutationResult> responseObserver)
void	deleteCredential(io.milvus.grpc.DeleteCredentialRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	describeCollection(io.milvus.grpc.DescribeCollectionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.DescribeCollectionResponse> responseObserver)
void	describeIndex(io.milvus.grpc.DescribeIndexRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.DescribeIndexResponse> responseObserver)
void	dropAlias(io.milvus.grpc.DropAliasRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	dropCollection(io.milvus.grpc.DropCollectionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	dropIndex(io.milvus.grpc.DropIndexRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	dropPartition(io.milvus.grpc.DropPartitionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	flush(io.milvus.grpc.FlushRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.FlushResponse> responseObserver)
void	getCollectionStatistics(io.milvus.grpc.GetCollectionStatisticsRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetCollectionStatisticsResponse> responseObserver)
void	getCompactionState(io.milvus.grpc.GetCompactionStateRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetCompactionStateResponse> responseObserver)
void	getCompactionStateWithPlans(io.milvus.grpc.GetCompactionPlansRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetCompactionPlansResponse> responseObserver)
void	getFlushState(io.milvus.grpc.GetFlushStateRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetFlushStateResponse> responseObserver)
void	getImportState(io.milvus.grpc.GetImportStateRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetImportStateResponse> responseObserver)
void	getIndexBuildProgress(io.milvus.grpc.GetIndexBuildProgressRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetIndexBuildProgressResponse> responseObserver)
void	getIndexState(io.milvus.grpc.GetIndexStateRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetIndexStateResponse> responseObserver)
void	getMetrics(io.milvus.grpc.GetMetricsRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetMetricsResponse> responseObserver) https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
void	getPartitionStatistics(io.milvus.grpc.GetPartitionStatisticsRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetPartitionStatisticsResponse> responseObserver)
void	getPersistentSegmentInfo(io.milvus.grpc.GetPersistentSegmentInfoRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetPersistentSegmentInfoResponse> responseObserver)
void	getQuerySegmentInfo(io.milvus.grpc.GetQuerySegmentInfoRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetQuerySegmentInfoResponse> responseObserver)
void	getReplicas(io.milvus.grpc.GetReplicasRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetReplicasResponse> responseObserver)
void	hasCollection(io.milvus.grpc.HasCollectionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.BoolResponse> responseObserver)
void	hasPartition(io.milvus.grpc.HasPartitionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.BoolResponse> responseObserver)
void	import_(io.milvus.grpc.ImportRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.ImportResponse> responseObserver) https://wiki.lfaidata.foundation/display/MIL/MEP+24+--+Support+bulk+load
void	insert(io.milvus.grpc.InsertRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.MutationResult> responseObserver)
void	listCredUsers(io.milvus.grpc.ListCredUsersRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.ListCredUsersResponse> responseObserver)
void	listImportTasks(io.milvus.grpc.ListImportTasksRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.ListImportTasksResponse> responseObserver)
void	loadBalance(io.milvus.grpc.LoadBalanceRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	loadCollection(io.milvus.grpc.LoadCollectionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	loadPartitions(io.milvus.grpc.LoadPartitionsRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	manualCompaction(io.milvus.grpc.ManualCompactionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.ManualCompactionResponse> responseObserver)
void	query(io.milvus.grpc.QueryRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.QueryResults> responseObserver)
void	releaseCollection(io.milvus.grpc.ReleaseCollectionRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	releasePartitions(io.milvus.grpc.ReleasePartitionsRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)
void	search(io.milvus.grpc.SearchRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.SearchResults> responseObserver)
void	setAlterAliasResponse(io.milvus.grpc.Status resp)
void	setCalcDistanceResponse(io.milvus.grpc.CalcDistanceResults resp)
void	setCreateAliasResponse(io.milvus.grpc.Status resp)
void	setCreateCollectionResponse(io.milvus.grpc.Status resp)
void	setCreateIndexResponse(io.milvus.grpc.Status resp)
void	setCreatePartitionResponse(io.milvus.grpc.Status resp)
void	setDeleteResponse(io.milvus.grpc.MutationResult resp)
void	setDescribeCollectionResponse(io.milvus.grpc.DescribeCollectionResponse resp)
void	setDescribeIndexResponse(io.milvus.grpc.DescribeIndexResponse resp)
void	setDropAliasResponse(io.milvus.grpc.Status resp)
void	setDropCollectionResponse(io.milvus.grpc.Status resp)
void	setDropIndexResponse(io.milvus.grpc.Status resp)
void	setDropPartitionResponse(io.milvus.grpc.Status resp)
void	setFlushResponse(io.milvus.grpc.FlushResponse resp)
void	setGetCollectionStatisticsResponse(io.milvus.grpc.GetCollectionStatisticsResponse resp)
void	setGetCompactionPlansResponse(io.milvus.grpc.GetCompactionPlansResponse resp)
void	setGetCompactionStateResponse(io.milvus.grpc.GetCompactionStateResponse resp)
void	setGetFlushStateResponse(io.milvus.grpc.GetFlushStateResponse resp)
void	setGetIndexBuildProgressResponse(io.milvus.grpc.GetIndexBuildProgressResponse resp)
void	setGetIndexStateResponse(io.milvus.grpc.GetIndexStateResponse resp)
void	setGetMetricsResponse(io.milvus.grpc.GetMetricsResponse resp)
void	setGetPartitionStatisticsResponse(io.milvus.grpc.GetPartitionStatisticsResponse resp)
void	setGetPersistentSegmentInfoResponse(io.milvus.grpc.GetPersistentSegmentInfoResponse resp)
void	setGetQuerySegmentInfoResponse(io.milvus.grpc.GetQuerySegmentInfoResponse resp)
void	setGetReplicasResponse(io.milvus.grpc.GetReplicasResponse resp)
void	setHasCollectionResponse(io.milvus.grpc.BoolResponse resp)
void	setHasPartitionResponse(io.milvus.grpc.BoolResponse resp)
void	setInsertResponse(io.milvus.grpc.MutationResult resp)
void	setLoadBalanceResponse(io.milvus.grpc.Status resp)
void	setLoadCollectionResponse(io.milvus.grpc.Status resp)
void	setLoadPartitionsResponse(io.milvus.grpc.Status resp)
void	setManualCompactionResponse(io.milvus.grpc.ManualCompactionResponse resp)
void	setQueryResponse(io.milvus.grpc.QueryResults resp)
void	setReleaseCollectionResponse(io.milvus.grpc.Status resp)
void	setReleasePartitionsResponse(io.milvus.grpc.Status resp)
void	setRespCreateCredential(io.milvus.grpc.Status respCreateCredential)
void	setRespDeleteCredential(io.milvus.grpc.Status respDeleteCredential)
void	setRespListCredUsers(io.milvus.grpc.ListCredUsersResponse respListCredUsers)
void	setRespUpdateCredential(io.milvus.grpc.Status respUpdateCredential)
void	setSearchResponse(io.milvus.grpc.SearchResults resp)
void	setShowCollectionsResponse(io.milvus.grpc.ShowCollectionsResponse resp)
void	setShowPartitionsResponse(io.milvus.grpc.ShowPartitionsResponse resp)
void	showCollections(io.milvus.grpc.ShowCollectionsRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.ShowCollectionsResponse> responseObserver)
void	showPartitions(io.milvus.grpc.ShowPartitionsRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.ShowPartitionsResponse> responseObserver)
void	updateCredential(io.milvus.grpc.UpdateCredentialRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

从类继承的方法 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

bindService, createRole, dropRole, dummy, operatePrivilege, operateUserRole, registerLink, selectGrant, selectResource, selectRole, selectUser

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MockMilvusServerImpl

public MockMilvusServerImpl()

方法详细资料

createCollection

public void createCollection(io.milvus.grpc.CreateCollectionRequest request,
                             io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

createCollection 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setCreateCollectionResponse

public void setCreateCollectionResponse(io.milvus.grpc.Status resp)

describeCollection

public void describeCollection(io.milvus.grpc.DescribeCollectionRequest request,
                               io.grpc.stub.StreamObserver<io.milvus.grpc.DescribeCollectionResponse> responseObserver)

覆盖:

describeCollection 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setDescribeCollectionResponse

public void setDescribeCollectionResponse(io.milvus.grpc.DescribeCollectionResponse resp)

dropCollection

public void dropCollection(io.milvus.grpc.DropCollectionRequest request,
                           io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

dropCollection 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setDropCollectionResponse

public void setDropCollectionResponse(io.milvus.grpc.Status resp)

getCollectionStatistics

public void getCollectionStatistics(io.milvus.grpc.GetCollectionStatisticsRequest request,
                                    io.grpc.stub.StreamObserver<io.milvus.grpc.GetCollectionStatisticsResponse> responseObserver)

覆盖:

getCollectionStatistics 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetCollectionStatisticsResponse

public void setGetCollectionStatisticsResponse(io.milvus.grpc.GetCollectionStatisticsResponse resp)

hasCollection

public void hasCollection(io.milvus.grpc.HasCollectionRequest request,
                          io.grpc.stub.StreamObserver<io.milvus.grpc.BoolResponse> responseObserver)

覆盖:

hasCollection 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setHasCollectionResponse

public void setHasCollectionResponse(io.milvus.grpc.BoolResponse resp)

loadCollection

public void loadCollection(io.milvus.grpc.LoadCollectionRequest request,
                           io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

loadCollection 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setLoadCollectionResponse

public void setLoadCollectionResponse(io.milvus.grpc.Status resp)

releaseCollection

public void releaseCollection(io.milvus.grpc.ReleaseCollectionRequest request,
                              io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

releaseCollection 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setReleaseCollectionResponse

public void setReleaseCollectionResponse(io.milvus.grpc.Status resp)

showCollections

public void showCollections(io.milvus.grpc.ShowCollectionsRequest request,
                            io.grpc.stub.StreamObserver<io.milvus.grpc.ShowCollectionsResponse> responseObserver)

覆盖:

showCollections 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setShowCollectionsResponse

public void setShowCollectionsResponse(io.milvus.grpc.ShowCollectionsResponse resp)

createPartition

public void createPartition(io.milvus.grpc.CreatePartitionRequest request,
                            io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

createPartition 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setCreatePartitionResponse

public void setCreatePartitionResponse(io.milvus.grpc.Status resp)

dropPartition

public void dropPartition(io.milvus.grpc.DropPartitionRequest request,
                          io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

dropPartition 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setDropPartitionResponse

public void setDropPartitionResponse(io.milvus.grpc.Status resp)

hasPartition

public void hasPartition(io.milvus.grpc.HasPartitionRequest request,
                         io.grpc.stub.StreamObserver<io.milvus.grpc.BoolResponse> responseObserver)

覆盖:

hasPartition 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setHasPartitionResponse

public void setHasPartitionResponse(io.milvus.grpc.BoolResponse resp)

loadPartitions

public void loadPartitions(io.milvus.grpc.LoadPartitionsRequest request,
                           io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

loadPartitions 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setLoadPartitionsResponse

public void setLoadPartitionsResponse(io.milvus.grpc.Status resp)

releasePartitions

public void releasePartitions(io.milvus.grpc.ReleasePartitionsRequest request,
                              io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

releasePartitions 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setReleasePartitionsResponse

public void setReleasePartitionsResponse(io.milvus.grpc.Status resp)

getPartitionStatistics

public void getPartitionStatistics(io.milvus.grpc.GetPartitionStatisticsRequest request,
                                   io.grpc.stub.StreamObserver<io.milvus.grpc.GetPartitionStatisticsResponse> responseObserver)

覆盖:

getPartitionStatistics 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetPartitionStatisticsResponse

public void setGetPartitionStatisticsResponse(io.milvus.grpc.GetPartitionStatisticsResponse resp)

showPartitions

public void showPartitions(io.milvus.grpc.ShowPartitionsRequest request,
                           io.grpc.stub.StreamObserver<io.milvus.grpc.ShowPartitionsResponse> responseObserver)

覆盖:

showPartitions 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setShowPartitionsResponse

public void setShowPartitionsResponse(io.milvus.grpc.ShowPartitionsResponse resp)

createAlias

public void createAlias(io.milvus.grpc.CreateAliasRequest request,
                        io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

createAlias 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setCreateAliasResponse

public void setCreateAliasResponse(io.milvus.grpc.Status resp)

dropAlias

public void dropAlias(io.milvus.grpc.DropAliasRequest request,
                      io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

dropAlias 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setDropAliasResponse

public void setDropAliasResponse(io.milvus.grpc.Status resp)

alterAlias

public void alterAlias(io.milvus.grpc.AlterAliasRequest request,
                       io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

alterAlias 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setAlterAliasResponse

public void setAlterAliasResponse(io.milvus.grpc.Status resp)

createIndex

public void createIndex(io.milvus.grpc.CreateIndexRequest request,
                        io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

createIndex 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setCreateIndexResponse

public void setCreateIndexResponse(io.milvus.grpc.Status resp)

describeIndex

public void describeIndex(io.milvus.grpc.DescribeIndexRequest request,
                          io.grpc.stub.StreamObserver<io.milvus.grpc.DescribeIndexResponse> responseObserver)

覆盖:

describeIndex 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setDescribeIndexResponse

public void setDescribeIndexResponse(io.milvus.grpc.DescribeIndexResponse resp)

getIndexState

public void getIndexState(io.milvus.grpc.GetIndexStateRequest request,
                          io.grpc.stub.StreamObserver<io.milvus.grpc.GetIndexStateResponse> responseObserver)

覆盖:

getIndexState 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetIndexStateResponse

public void setGetIndexStateResponse(io.milvus.grpc.GetIndexStateResponse resp)

getIndexBuildProgress

public void getIndexBuildProgress(io.milvus.grpc.GetIndexBuildProgressRequest request,
                                  io.grpc.stub.StreamObserver<io.milvus.grpc.GetIndexBuildProgressResponse> responseObserver)

覆盖:

getIndexBuildProgress 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetIndexBuildProgressResponse

public void setGetIndexBuildProgressResponse(io.milvus.grpc.GetIndexBuildProgressResponse resp)

dropIndex

public void dropIndex(io.milvus.grpc.DropIndexRequest request,
                      io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

dropIndex 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setDropIndexResponse

public void setDropIndexResponse(io.milvus.grpc.Status resp)

insert

public void insert(io.milvus.grpc.InsertRequest request,
                   io.grpc.stub.StreamObserver<io.milvus.grpc.MutationResult> responseObserver)

覆盖:

insert 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setInsertResponse

public void setInsertResponse(io.milvus.grpc.MutationResult resp)

delete

public void delete(io.milvus.grpc.DeleteRequest request,
                   io.grpc.stub.StreamObserver<io.milvus.grpc.MutationResult> responseObserver)

覆盖:

delete 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

import_

public void import_(io.milvus.grpc.ImportRequest request,
                    io.grpc.stub.StreamObserver<io.milvus.grpc.ImportResponse> responseObserver)

从类复制的说明: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

 https://wiki.lfaidata.foundation/display/MIL/MEP+24+--+Support+bulk+load
 

覆盖:

import_ 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

getImportState

public void getImportState(io.milvus.grpc.GetImportStateRequest request,
                           io.grpc.stub.StreamObserver<io.milvus.grpc.GetImportStateResponse> responseObserver)

覆盖:

getImportState 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

listImportTasks

public void listImportTasks(io.milvus.grpc.ListImportTasksRequest request,
                            io.grpc.stub.StreamObserver<io.milvus.grpc.ListImportTasksResponse> responseObserver)

覆盖:

listImportTasks 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setDeleteResponse

public void setDeleteResponse(io.milvus.grpc.MutationResult resp)

search

public void search(io.milvus.grpc.SearchRequest request,
                   io.grpc.stub.StreamObserver<io.milvus.grpc.SearchResults> responseObserver)

覆盖:

search 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setSearchResponse

public void setSearchResponse(io.milvus.grpc.SearchResults resp)

flush

public void flush(io.milvus.grpc.FlushRequest request,
                  io.grpc.stub.StreamObserver<io.milvus.grpc.FlushResponse> responseObserver)

覆盖:

flush 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setFlushResponse

public void setFlushResponse(io.milvus.grpc.FlushResponse resp)

query

public void query(io.milvus.grpc.QueryRequest request,
                  io.grpc.stub.StreamObserver<io.milvus.grpc.QueryResults> responseObserver)

覆盖:

query 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setQueryResponse

public void setQueryResponse(io.milvus.grpc.QueryResults resp)

calcDistance

public void calcDistance(io.milvus.grpc.CalcDistanceRequest request,
                         io.grpc.stub.StreamObserver<io.milvus.grpc.CalcDistanceResults> responseObserver)

覆盖:

calcDistance 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setCalcDistanceResponse

public void setCalcDistanceResponse(io.milvus.grpc.CalcDistanceResults resp)

getFlushState

public void getFlushState(io.milvus.grpc.GetFlushStateRequest request,
                          io.grpc.stub.StreamObserver<io.milvus.grpc.GetFlushStateResponse> responseObserver)

覆盖:

getFlushState 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetFlushStateResponse

public void setGetFlushStateResponse(io.milvus.grpc.GetFlushStateResponse resp)

getPersistentSegmentInfo

public void getPersistentSegmentInfo(io.milvus.grpc.GetPersistentSegmentInfoRequest request,
                                     io.grpc.stub.StreamObserver<io.milvus.grpc.GetPersistentSegmentInfoResponse> responseObserver)

覆盖:

getPersistentSegmentInfo 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetPersistentSegmentInfoResponse

public void setGetPersistentSegmentInfoResponse(io.milvus.grpc.GetPersistentSegmentInfoResponse resp)

getQuerySegmentInfo

public void getQuerySegmentInfo(io.milvus.grpc.GetQuerySegmentInfoRequest request,
                                io.grpc.stub.StreamObserver<io.milvus.grpc.GetQuerySegmentInfoResponse> responseObserver)

覆盖:

getQuerySegmentInfo 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetQuerySegmentInfoResponse

public void setGetQuerySegmentInfoResponse(io.milvus.grpc.GetQuerySegmentInfoResponse resp)

getReplicas

public void getReplicas(io.milvus.grpc.GetReplicasRequest request,
                        io.grpc.stub.StreamObserver<io.milvus.grpc.GetReplicasResponse> responseObserver)

覆盖:

getReplicas 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetReplicasResponse

public void setGetReplicasResponse(io.milvus.grpc.GetReplicasResponse resp)

getMetrics

public void getMetrics(io.milvus.grpc.GetMetricsRequest request,
                       io.grpc.stub.StreamObserver<io.milvus.grpc.GetMetricsResponse> responseObserver)

从类复制的说明: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

 https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
 

覆盖:

getMetrics 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetMetricsResponse

public void setGetMetricsResponse(io.milvus.grpc.GetMetricsResponse resp)

loadBalance

public void loadBalance(io.milvus.grpc.LoadBalanceRequest request,
                        io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

loadBalance 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setLoadBalanceResponse

public void setLoadBalanceResponse(io.milvus.grpc.Status resp)

getCompactionState

public void getCompactionState(io.milvus.grpc.GetCompactionStateRequest request,
                               io.grpc.stub.StreamObserver<io.milvus.grpc.GetCompactionStateResponse> responseObserver)

覆盖:

getCompactionState 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setGetCompactionStateResponse

public void setGetCompactionStateResponse(io.milvus.grpc.GetCompactionStateResponse resp)

manualCompaction

public void manualCompaction(io.milvus.grpc.ManualCompactionRequest request,
                             io.grpc.stub.StreamObserver<io.milvus.grpc.ManualCompactionResponse> responseObserver)

覆盖:

manualCompaction 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setManualCompactionResponse

public void setManualCompactionResponse(io.milvus.grpc.ManualCompactionResponse resp)

getCompactionStateWithPlans

public void getCompactionStateWithPlans(io.milvus.grpc.GetCompactionPlansRequest request,
                                        io.grpc.stub.StreamObserver<io.milvus.grpc.GetCompactionPlansResponse> responseObserver)

覆盖:

getCompactionStateWithPlans 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

createCredential

public void createCredential(io.milvus.grpc.CreateCredentialRequest request,
                             io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

从类复制的说明: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

 https://wiki.lfaidata.foundation/display/MIL/MEP+27+--+Support+Basic+Authentication
 

覆盖:

createCredential 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setRespCreateCredential

public void setRespCreateCredential(io.milvus.grpc.Status respCreateCredential)

updateCredential

public void updateCredential(io.milvus.grpc.UpdateCredentialRequest request,
                             io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

updateCredential 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setRespUpdateCredential

public void setRespUpdateCredential(io.milvus.grpc.Status respUpdateCredential)

deleteCredential

public void deleteCredential(io.milvus.grpc.DeleteCredentialRequest request,
                             io.grpc.stub.StreamObserver<io.milvus.grpc.Status> responseObserver)

覆盖:

deleteCredential 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setRespDeleteCredential

public void setRespDeleteCredential(io.milvus.grpc.Status respDeleteCredential)

listCredUsers

public void listCredUsers(io.milvus.grpc.ListCredUsersRequest request,
                          io.grpc.stub.StreamObserver<io.milvus.grpc.ListCredUsersResponse> responseObserver)

覆盖:

listCredUsers 在类中 io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setRespListCredUsers

public void setRespListCredUsers(io.milvus.grpc.ListCredUsersResponse respListCredUsers)

setGetCompactionPlansResponse

public void setGetCompactionPlansResponse(io.milvus.grpc.GetCompactionPlansResponse resp)