源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.ratis.protocol.GroupManagementRequest

示例1
@Override
public void addGroup(HddsProtos.PipelineID pipelineId,
    Collection<DatanodeDetails> peers) throws IOException {
  final PipelineID pipelineID = PipelineID.getFromProtobuf(pipelineId);
  final RaftGroupId groupId = RaftGroupId.valueOf(pipelineID.getId());
  final RaftGroup group = RatisHelper.newRaftGroup(groupId, peers);
  GroupManagementRequest request = GroupManagementRequest.newAdd(
      clientId, server.getId(), nextCallId(), group);

  RaftClientReply reply;
  try {
    reply = server.groupManagement(request);
  } catch (Exception e) {
    throw new IOException(e.getMessage(), e);
  }
  processReply(reply);
}
示例2
@Override
public void removeGroup(HddsProtos.PipelineID pipelineId)
    throws IOException {
  GroupManagementRequest request = GroupManagementRequest.newRemove(
      clientId, server.getId(), nextCallId(),
      RaftGroupId.valueOf(PipelineID.getFromProtobuf(pipelineId).getId()),
      true);

  RaftClientReply reply;
  try {
    reply = server.groupManagement(request);
  } catch (Exception e) {
    throw new IOException(e.getMessage(), e);
  }
  processReply(reply);
}
示例3
@Override
public RaftClientReply groupManagement(GroupManagementRequest request) throws IOException {
  return handleRequest(request,
      ClientProtoUtils::toGroupManagementRequestProto,
      ClientProtoUtils::toRaftClientReply,
      p -> getProtocol().groupManagement(null, p));
}
示例4
@Override
public void groupManagement(GroupManagementRequestProto proto,
      StreamObserver<RaftClientReplyProto> responseObserver) {
  final GroupManagementRequest request = ClientProtoUtils.toGroupManagementRequest(proto);
  GrpcUtil.asyncCall(responseObserver, () -> protocol.groupManagementAsync(request),
      ClientProtoUtils::toRaftClientReplyProto);
}
示例5
@Override
public RaftClientReply groupManagement(GroupManagementRequest request) throws IOException {
  return handleRequest(request,
      ClientProtoUtils::toGroupManagementRequestProto,
      ClientProtoUtils::toRaftClientReply,
      p -> getProtocol().groupManagement(null, p));
}
示例6
@Override
public void groupManagement(GroupManagementRequestProto proto, StreamObserver<RaftClientReplyProto> responseObserver) {
  final GroupManagementRequest request = ClientProtoUtils.toGroupManagementRequest(proto);
  GrpcUtil.asyncCall(responseObserver, () -> protocol.groupManagementAsync(request),
      ClientProtoUtils::toRaftClientReplyProto);
}