Package io.pravega.client.stream

Class EventWriterConfig

java.lang.Object

io.pravega.client.stream.EventWriterConfig

All Implemented Interfaces:

java.io.Serializable

public class EventWriterConfig
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EventWriterConfig.EventWriterConfigBuilder

Method Summary

Modifier and Type	Method	Description
static EventWriterConfig.EventWriterConfigBuilder	builder()
protected boolean	canEqual(java.lang.Object other)
boolean	equals(java.lang.Object o)
int	getBackoffMultiple()	Backoff multiplier used in the retry logic of the writer.
int	getInitialBackoffMillis()	Initial backoff in milli seconds used in the retry logic of the writer.
int	getMaxBackoffMillis()	Maximum backoff in milli seconds used in the retry logic of the writer.
int	getRetryAttempts()	Maximum retry attempts performed by the writer before throwing a RetriesExhaustedException.
long	getTransactionTimeoutTime()
int	hashCode()
boolean	isAutomaticallyNoteTime()	Automatically invoke EventStreamWriter.noteTime(long) passing System.currentTimeMillis() on a regular interval.
boolean	isEnableConnectionPooling()	Enable or disable connection pooling for writer.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

builder

public static EventWriterConfig.EventWriterConfigBuilder builder()

getInitialBackoffMillis

public int getInitialBackoffMillis()

Initial backoff in milli seconds used in the retry logic of the writer. The default value is 1ms.

Returns:

Initial backoff in milli seconds used in the retry logic of the writer.

getMaxBackoffMillis

public int getMaxBackoffMillis()

Maximum backoff in milli seconds used in the retry logic of the writer. The default value is 20000.

Returns:

Maximum backoff in milli seconds used in the retry logic of the writer.

getRetryAttempts

public int getRetryAttempts()

Maximum retry attempts performed by the writer before throwing a RetriesExhaustedException. The default value is 10.

Returns:

Maximum retry attempts performed by the writer before throwing a RetriesExhaustedException.

getBackoffMultiple

public int getBackoffMultiple()

Backoff multiplier used in the retry logic of the writer. The default value is 10.

Returns:

Backoff multiplier used in the retry logic of the writer.

isEnableConnectionPooling

public boolean isEnableConnectionPooling()

Enable or disable connection pooling for writer. The default value is false.

Returns:

Enable or disable connection pooling for writer.

getTransactionTimeoutTime

public long getTransactionTimeoutTime()

isAutomaticallyNoteTime

public boolean isAutomaticallyNoteTime()

Automatically invoke EventStreamWriter.noteTime(long) passing System.currentTimeMillis() on a regular interval.

Returns:

Interval to regularly invoke EventStreamWriter.noteTime(long).

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

canEqual

protected boolean canEqual(java.lang.Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object