C D E F G H L P R S T Z

C

com.github.zk1931.jzab - package com.github.zk1931.jzab

An implementation of ZooKeeper Atomic Broadcast.

compareTo(Zxid) - Method in class com.github.zk1931.jzab.Zxid

ctx - Variable in class com.github.zk1931.jzab.PendingRequests.Tuple

D

deliver(Zxid, ByteBuffer, String, Object) - Method in interface com.github.zk1931.jzab.StateMachine

Callback for Zab.send(java.nio.ByteBuffer, java.lang.Object).

E

equals(Object) - Method in class com.github.zk1931.jzab.Zxid

F

flush(ByteBuffer, Object) - Method in class com.github.zk1931.jzab.Zab

Flushes a request through pipeline.

flushed(Zxid, ByteBuffer, Object) - Method in interface com.github.zk1931.jzab.StateMachine

Callback for Zab.flush(java.nio.ByteBuffer, java.lang.Object).

following(String, Set<String>) - Method in interface com.github.zk1931.jzab.StateMachine

Notifies the state machine that Zab is in following phase with given leader and cluster members.

fromByteArray(byte[]) - Static method in class com.github.zk1931.jzab.Zxid

fromSimpleString(String) - Static method in class com.github.zk1931.jzab.Zxid

G

getEpoch() - Method in class com.github.zk1931.jzab.Zxid

getFuture() - Method in class com.github.zk1931.jzab.Zab

Get the future of the background working thread of Zab.

getKeyStore() - Method in class com.github.zk1931.jzab.ZabConfig.SslParameters

getKeyStorePassword() - Method in class com.github.zk1931.jzab.ZabConfig.SslParameters

getLogDir() - Method in class com.github.zk1931.jzab.ZabConfig

Gets the directory for storing transaction log.

getMaxBatchSize() - Method in class com.github.zk1931.jzab.ZabConfig

Gets the maximum batch size of SyncProposalProcessor.

getMinSyncTimeoutMs() - Method in class com.github.zk1931.jzab.ZabConfig

Gets the timeout for synchronizing peers (default is 3000 milliseconds).

getServerId() - Method in class com.github.zk1931.jzab.Zab

Returns the server Id for this Zab instance.

getSslParameters() - Method in class com.github.zk1931.jzab.ZabConfig

Gets the SSL parameters for Jzab.

getTimeoutMs() - Method in class com.github.zk1931.jzab.ZabConfig

Gets the timeout of heartbeat messages (default is 1000 milliseconds).

getTrustStore() - Method in class com.github.zk1931.jzab.ZabConfig.SslParameters

getTrustStorePassword() - Method in class com.github.zk1931.jzab.ZabConfig.SslParameters

getXid() - Method in class com.github.zk1931.jzab.Zxid

getZxidLength() - Static method in class com.github.zk1931.jzab.Zxid

H

hashCode() - Method in class com.github.zk1931.jzab.Zxid

L

leading(Set<String>, Set<String>) - Method in interface com.github.zk1931.jzab.StateMachine

Notifies the state machine that Zab is in leading phase with given sets of active followers and cluster members.

P

param - Variable in class com.github.zk1931.jzab.PendingRequests.Tuple

pendingFlushes - Variable in class com.github.zk1931.jzab.PendingRequests

The pending flush requests.

pendingRemoves - Variable in class com.github.zk1931.jzab.PendingRequests

The pending remove requests.

PendingRequests - Class in com.github.zk1931.jzab

Stores different kinds of pending requests.

PendingRequests.Tuple - Class in com.github.zk1931.jzab

The tuple holds both request and ctx.

pendingSends - Variable in class com.github.zk1931.jzab.PendingRequests

The pending send requests.

pendingSnapshots - Variable in class com.github.zk1931.jzab.PendingRequests

The pending snapshot requests.

preprocess(Zxid, ByteBuffer) - Method in interface com.github.zk1931.jzab.StateMachine

Converts a message to an idempotent transaction.

R

recovering(PendingRequests) - Method in interface com.github.zk1931.jzab.StateMachine

Notifies the state machine that Zab is in recovering phase.

remove(String, Object) - Method in class com.github.zk1931.jzab.Zab

Removes a peer from the cluster.

removed(String, Object) - Method in interface com.github.zk1931.jzab.StateMachine

Callback for Zab.remove(java.lang.String, java.lang.Object).

restore(FileInputStream) - Method in interface com.github.zk1931.jzab.StateMachine

Deserializes the application state from a FileInputStream.

S

save(FileOutputStream) - Method in interface com.github.zk1931.jzab.StateMachine

Serializes the application state to a FileOutputStream.

send(ByteBuffer, Object) - Method in class com.github.zk1931.jzab.Zab

Submits a request to Zab.

setLogDir(String) - Method in class com.github.zk1931.jzab.ZabConfig

Sets the directory for the persistent states.

setMaxBatchSize(int) - Method in class com.github.zk1931.jzab.ZabConfig

Sets the maximum batching size for SyncProposalProcessor.

setMinSyncTimeoutMs(int) - Method in class com.github.zk1931.jzab.ZabConfig

Sets the minimum timeout.

setSslParameters(ZabConfig.SslParameters) - Method in class com.github.zk1931.jzab.ZabConfig

Sets the SSL parameters for Jzab.

setTimeoutMs(int) - Method in class com.github.zk1931.jzab.ZabConfig

Sets the timeout of heartbeat message.

shutdown() - Method in class com.github.zk1931.jzab.Zab

Shut down the Zab.

snapshotDone(String, Object) - Method in interface com.github.zk1931.jzab.StateMachine

Callback for Zab.takeSnapshot(java.lang.Object).

StateMachine - Interface in com.github.zk1931.jzab

The state machine interface for interacting with Zab.

T

takeSnapshot(Object) - Method in class com.github.zk1931.jzab.Zab

Issues the request to take a snapshot.

toByteArray() - Method in class com.github.zk1931.jzab.Zxid

Serialize this Zxid into a fixed size (8 bytes) byte array.

toSimpleString() - Method in class com.github.zk1931.jzab.Zxid

toString() - Method in class com.github.zk1931.jzab.Zxid

Z

Zab - Class in com.github.zk1931.jzab

Zab is a fault-tolerant, replicated protocol that guarantees all requests submitted to it will be delivered in same order to all servers in the cluster.

Zab(StateMachine, ZabConfig) - Constructor for class com.github.zk1931.jzab.Zab

Constructs a Zab instance by recovering from the log directory.

Zab(StateMachine, ZabConfig, String, String) - Constructor for class com.github.zk1931.jzab.Zab

Constructs a Zab instance by joining an existing cluster.

Zab(StateMachine, ZabConfig, String, Set<String>) - Constructor for class com.github.zk1931.jzab.Zab

Constructs a Zab instance by booting from static cluster configuration.

ZabConfig - Class in com.github.zk1931.jzab

Configuration parameters for Zab.

ZabConfig() - Constructor for class com.github.zk1931.jzab.ZabConfig

ZabConfig.SslParameters - Class in com.github.zk1931.jzab

SSL-related parameters.

ZabConfig.SslParameters(File, String, File, String) - Constructor for class com.github.zk1931.jzab.ZabConfig.SslParameters

ZabConfig.SslParameters() - Constructor for class com.github.zk1931.jzab.ZabConfig.SslParameters

ZabException - Exception in com.github.zk1931.jzab

Exceptions thrown by Zab.

ZabException.InvalidPhase - Exception in com.github.zk1931.jzab

Zab is in an invalid phase to perform a certain operation.

ZabException.TooManyPendingRequests - Exception in com.github.zk1931.jzab

Thrown when there are too many pending requests.

Zxid - Class in com.github.zk1931.jzab

Simple implementation of Zxid.

Zxid(long, long) - Constructor for class com.github.zk1931.jzab.Zxid

C D E F G H L P R S T Z