com.alipay.sofa.jraft.core

Class ReadOnlyServiceImpl

java.lang.Object

com.alipay.sofa.jraft.core.ReadOnlyServiceImpl

All Implemented Interfaces:

FSMCaller.LastAppliedLogIndexListener, Lifecycle<ReadOnlyServiceOptions>, ReadOnlyService

public class ReadOnlyServiceImpl
extends Object
implements ReadOnlyService, FSMCaller.LastAppliedLogIndexListener

Read-only service implementation.

Author:

dennis

Constructor Summary

Constructors

Constructor and Description
ReadOnlyServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	addRequest(byte[] reqCtx, ReadIndexClosure closure) Adds a ReadIndex request.
void	addRequest(ReadOnlyOption readOnlyOptions, byte[] reqCtx, ReadIndexClosure closure) Adds a ReadIndex request.
boolean	init(ReadOnlyServiceOptions opts) Initialize the service.
void	join() Waits for service shutdown.
void	onApplied(long appliedIndex) Called when lastAppliedIndex updates.
void	setError(RaftException error) Called when the node is turned into error state.
void	shutdown() Dispose the resources for service.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadOnlyServiceImpl

public ReadOnlyServiceImpl()

Method Detail

init

public boolean init(ReadOnlyServiceOptions opts)

Description copied from interface: Lifecycle

Initialize the service.

Specified by:

init in interface Lifecycle<ReadOnlyServiceOptions>

Returns:

true when successes.

setError

public void setError(RaftException error)

Description copied from interface: ReadOnlyService

Called when the node is turned into error state.

Specified by:

setError in interface ReadOnlyService

Parameters:

error - error with raft info

shutdown

public void shutdown()

Description copied from interface: Lifecycle

Dispose the resources for service.

Specified by:

shutdown in interface Lifecycle<ReadOnlyServiceOptions>

join

public void join()
          throws InterruptedException

Description copied from interface: ReadOnlyService

Waits for service shutdown.

Specified by:

join in interface ReadOnlyService

Throws:

InterruptedException - if the current thread is interrupted while waiting

addRequest

public void addRequest(byte[] reqCtx,
                       ReadIndexClosure closure)

Description copied from interface: ReadOnlyService

Adds a ReadIndex request.

Specified by:

addRequest in interface ReadOnlyService

Parameters:

reqCtx - request context of readIndex

closure - callback

addRequest

public void addRequest(ReadOnlyOption readOnlyOptions,
                       byte[] reqCtx,
                       ReadIndexClosure closure)

Description copied from interface: ReadOnlyService

Adds a ReadIndex request.

Specified by:

addRequest in interface ReadOnlyService

Parameters:

readOnlyOptions - how the read only request is processed

reqCtx - request context of readIndex

closure - callback

onApplied

public void onApplied(long appliedIndex)

Called when lastAppliedIndex updates.

Specified by:

onApplied in interface FSMCaller.LastAppliedLogIndexListener

Parameters:

appliedIndex - applied index