Package io.milvus.server

Class MockMilvusServerImpl

  • All Implemented Interfaces:
    io.grpc.BindableService
    public class MockMilvusServerImpl
extends io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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)
      Deprecated: use DescribeIndex instead
      void getIndexState​(io.milvus.grpc.GetIndexStateRequest request, io.grpc.stub.StreamObserver<io.milvus.grpc.GetIndexStateResponse> responseObserver)
      Deprecated: use DescribeIndex instead
      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

        alterCollection, bindService, calcDistance, checkHealth, createRole, dropRole, dummy, getComponentStates, getLoadingProgress, getVersion, operatePrivilege, operateUserRole, registerLink, selectGrant, 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)
        Description copied from class: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase
         Deprecated: use DescribeIndex instead
        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)
        Description copied from class: io.milvus.grpc.MilvusServiceGrpc.MilvusServiceImplBase
         Deprecated: use DescribeIndex instead
        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)