Package io.pravega.client.state
Class SynchronizerConfig
- java.lang.Object
-
- io.pravega.client.state.SynchronizerConfig
-
- All Implemented Interfaces:
java.io.Serializable
public class SynchronizerConfig extends java.lang.Object implements java.io.Serializable
The configuration for a Consistent replicated state synchronizer.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
SynchronizerConfig.SynchronizerConfigBuilder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static SynchronizerConfig.SynchronizerConfigBuilder
builder()
protected boolean
canEqual(java.lang.Object other)
boolean
equals(java.lang.Object o)
static SynchronizerConfig
fromBytes(java.nio.ByteBuffer buff)
EventWriterConfig
getEventWriterConfig()
This writer config is used by the segment writers in the StateSynchronizer.int
getReadBufferSize()
This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.int
hashCode()
void
setEventWriterConfig(EventWriterConfig eventWriterConfig)
This writer config is used by the segment writers in the StateSynchronizer.void
setReadBufferSize(int readBufferSize)
This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.java.nio.ByteBuffer
toBytes()
java.lang.String
toString()
-
-
-
Method Detail
-
toBytes
public java.nio.ByteBuffer toBytes()
-
fromBytes
public static SynchronizerConfig fromBytes(java.nio.ByteBuffer buff)
-
builder
public static SynchronizerConfig.SynchronizerConfigBuilder builder()
-
getEventWriterConfig
public EventWriterConfig getEventWriterConfig()
This writer config is used by the segment writers in the StateSynchronizer. The default values enable connection pooling and ensures the background connection retry attempts continue until the StateSynchronizer is closed.- Returns:
- writer config used by the segment writers in the StateSynchronizer
-
getReadBufferSize
public int getReadBufferSize()
This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment. The default buffer size is 256KB.- Returns:
- Size used to allocate buffer space for the bytes the StateSynchronizer reader reads from the segment.
-
setEventWriterConfig
public void setEventWriterConfig(EventWriterConfig eventWriterConfig)
This writer config is used by the segment writers in the StateSynchronizer. The default values enable connection pooling and ensures the background connection retry attempts continue until the StateSynchronizer is closed.- Parameters:
eventWriterConfig
- writer config used by the segment writers in the StateSynchronizer
-
setReadBufferSize
public void setReadBufferSize(int readBufferSize)
This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment. The default buffer size is 256KB.- Parameters:
readBufferSize
- Size used to allocate buffer space for the bytes the StateSynchronizer reader reads from the segment.
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
canEqual
protected boolean canEqual(java.lang.Object other)
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-