alluxio.master.journal.raft

Class RaftJournalAppender

java.lang.Object

alluxio.master.journal.raft.RaftJournalAppender

All Implemented Interfaces:

Closeable, AutoCloseable

public class RaftJournalAppender
extends Object
implements Closeable

A client to append messages to RAFT log state.

Constructor Summary

Constructors

Constructor and Description
RaftJournalAppender(org.apache.ratis.server.RaftServer server, java.util.function.Supplier<org.apache.ratis.client.RaftClient> clientSupplier, org.apache.ratis.protocol.ClientId localClientId, InstancedConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
void	close()
CompletableFuture<org.apache.ratis.protocol.RaftClientReply>	sendAsync(org.apache.ratis.protocol.Message message, org.apache.ratis.util.TimeDuration timeout) Sends a request to raft server asynchronously.

Methods inherited from class java.lang.Object

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

Constructor Detail

RaftJournalAppender

public RaftJournalAppender(org.apache.ratis.server.RaftServer server,
                           java.util.function.Supplier<org.apache.ratis.client.RaftClient> clientSupplier,
                           org.apache.ratis.protocol.ClientId localClientId,
                           InstancedConfiguration configuration)

Parameters:

server - the local raft server

clientSupplier - a function for building a remote raft client

localClientId - the client id for local requests

configuration - the server configuration

Method Detail

sendAsync

public CompletableFuture<org.apache.ratis.protocol.RaftClientReply> sendAsync(org.apache.ratis.protocol.Message message,
                                                                              org.apache.ratis.util.TimeDuration timeout)
                                                                       throws IOException

Sends a request to raft server asynchronously.

Parameters:

message - the message to send

timeout - the time duration to wait before giving up on the request

Returns:

a future of the server reply

Throws:

IOException - if an exception occured while sending the request

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException