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.SerializableThe configuration for a Consistent replicated state synchronizer.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSynchronizerConfig.SynchronizerConfigBuilder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static SynchronizerConfig.SynchronizerConfigBuilderbuilder()protected booleancanEqual(java.lang.Object other)booleanequals(java.lang.Object o)static SynchronizerConfigfromBytes(java.nio.ByteBuffer buff)EventWriterConfiggetEventWriterConfig()This writer config is used by the segment writers in the StateSynchronizer.intgetReadBufferSize()This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.inthashCode()voidsetEventWriterConfig(EventWriterConfig eventWriterConfig)This writer config is used by the segment writers in the StateSynchronizer.voidsetReadBufferSize(int readBufferSize)This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.java.nio.ByteBuffertoBytes()java.lang.StringtoString()
-
-
-
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:
equalsin classjava.lang.Object
-
canEqual
protected boolean canEqual(java.lang.Object other)
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-