| Package | Description |
|---|---|
| io.atomix.protocols.raft.service | |
| io.atomix.protocols.raft.session |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Void> |
RaftServiceContext.closeSession(long index,
long timestamp,
RaftSession session,
boolean expired)
Unregister the given session.
|
CompletableFuture<io.atomix.protocols.raft.impl.OperationResult> |
RaftServiceContext.executeCommand(long index,
long sequence,
long timestamp,
RaftSession session,
io.atomix.primitive.operation.PrimitiveOperation operation)
Executes the given command on the state machine.
|
CompletableFuture<io.atomix.protocols.raft.impl.OperationResult> |
RaftServiceContext.executeQuery(long index,
long sequence,
long timestamp,
RaftSession session,
io.atomix.primitive.operation.PrimitiveOperation operation)
Executes the given query on the state machine.
|
CompletableFuture<Boolean> |
RaftServiceContext.keepAlive(long index,
long timestamp,
RaftSession session,
long commandSequence,
long eventIndex)
Keeps the given session alive.
|
CompletableFuture<Long> |
RaftServiceContext.openSession(long index,
long timestamp,
RaftSession session)
Registers the given session.
|
| Modifier and Type | Method and Description |
|---|---|
RaftSession |
RaftSessionRegistry.addSession(RaftSession session)
Adds a session.
|
RaftSession |
RaftSessionRegistry.getSession(long sessionId)
Gets a session by session ID.
|
RaftSession |
RaftSessionRegistry.getSession(io.atomix.primitive.session.SessionId sessionId)
Gets a session by session ID.
|
RaftSession |
RaftSessionRegistry.removeSession(io.atomix.primitive.session.SessionId sessionId)
Closes a session.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<RaftSession> |
RaftSessionRegistry.getSessions()
Returns the collection of registered sessions.
|
Collection<RaftSession> |
RaftSessionRegistry.getSessions(io.atomix.primitive.PrimitiveId primitiveId)
Returns a set of sessions associated with the given service.
|
| Modifier and Type | Method and Description |
|---|---|
RaftSession |
RaftSessionRegistry.addSession(RaftSession session)
Adds a session.
|
Copyright © 2013–2018. All rights reserved.