CollectionsInternalServiceBase constructor

CollectionsInternalServiceBase()

Implementation

CollectionsInternalServiceBase() {
  $addMethod($grpc.ServiceMethod<$0.GetCollectionInfoRequestInternal, $1.GetCollectionInfoResponse>(
      'Get',
      get_Pre,
      false,
      false,
      ($core.List<$core.int> value) => $0.GetCollectionInfoRequestInternal.fromBuffer(value),
      ($1.GetCollectionInfoResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.InitiateShardTransferRequest, $1.CollectionOperationResponse>(
      'Initiate',
      initiate_Pre,
      false,
      false,
      ($core.List<$core.int> value) => $0.InitiateShardTransferRequest.fromBuffer(value),
      ($1.CollectionOperationResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.WaitForShardStateRequest, $1.CollectionOperationResponse>(
      'WaitForShardState',
      waitForShardState_Pre,
      false,
      false,
      ($core.List<$core.int> value) => $0.WaitForShardStateRequest.fromBuffer(value),
      ($1.CollectionOperationResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.GetShardRecoveryPointRequest, $0.GetShardRecoveryPointResponse>(
      'GetShardRecoveryPoint',
      getShardRecoveryPoint_Pre,
      false,
      false,
      ($core.List<$core.int> value) => $0.GetShardRecoveryPointRequest.fromBuffer(value),
      ($0.GetShardRecoveryPointResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.UpdateShardCutoffPointRequest, $1.CollectionOperationResponse>(
      'UpdateShardCutoffPoint',
      updateShardCutoffPoint_Pre,
      false,
      false,
      ($core.List<$core.int> value) => $0.UpdateShardCutoffPointRequest.fromBuffer(value),
      ($1.CollectionOperationResponse value) => value.writeToBuffer()));
}