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()));
}