io.milvus.server

Class MockMilvusServerImpl

java.lang.Object

io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

io.milvus.server.MockMilvusServerImpl

All Implemented Interfaces:

io.grpc.BindableService

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

Constructor Summary

Constructors

Constructor and Description
MockMilvusServerImpl()

Method Summary

Modifier and Type	Method and Description
void	alterAlias(io.milvus.grpc.AlterAliasRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.Status> 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	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)

Methods inherited from class io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MockMilvusServerImpl

public MockMilvusServerImpl()

Method Detail

createCollection

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

Overrides:

createCollection in class 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)

Overrides:

describeCollection in class 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)

Overrides:

dropCollection in class 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)

Overrides:

getCollectionStatistics in class 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)

Overrides:

hasCollection in class 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)

Overrides:

loadCollection in class 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)

Overrides:

releaseCollection in class 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)

Overrides:

showCollections in class 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)

Overrides:

createPartition in class 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)

Overrides:

dropPartition in class 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)

Overrides:

hasPartition in class 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)

Overrides:

loadPartitions in class 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)

Overrides:

releasePartitions in class 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)

Overrides:

getPartitionStatistics in class 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)

Overrides:

showPartitions in class 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)

Overrides:

createAlias in class 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)

Overrides:

dropAlias in class 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)

Overrides:

alterAlias in class 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)

Overrides:

createIndex in class 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)

Overrides:

describeIndex in class 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)

Overrides:

getIndexState in class 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)

Overrides:

getIndexBuildProgress in class 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)

Overrides:

dropIndex in class 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)

Overrides:

insert in class 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)

Overrides:

delete in class io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

import_

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

Description copied from class: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

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

Overrides:

import_ in class io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

getImportState

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

Overrides:

getImportState in class io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

listImportTasks

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

Overrides:

listImportTasks in class 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)

Overrides:

search in class 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)

Overrides:

flush in class 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)

Overrides:

query in class io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setQueryResponse

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

getFlushState

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

Overrides:

getFlushState in class 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)

Overrides:

getPersistentSegmentInfo in class 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)

Overrides:

getQuerySegmentInfo in class 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)

Overrides:

getReplicas in class 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)

Description copied from class: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

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

Overrides:

getMetrics in class 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)

Overrides:

loadBalance in class 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)

Overrides:

getCompactionState in class 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)

Overrides:

manualCompaction in class 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)

Overrides:

getCompactionStateWithPlans in class io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

createCredential

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

Description copied from class: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

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

Overrides:

createCredential in class 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)

Overrides:

updateCredential in class 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)

Overrides:

deleteCredential in class 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)

Overrides:

listCredUsers in class io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

setRespListCredUsers

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

setGetCompactionPlansResponse

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