Package io.pravega.client.stream

Class EventWriterConfig.EventWriterConfigBuilder

  • Enclosing class:
    EventWriterConfig
    public static final class EventWriterConfig.EventWriterConfigBuilder
extends java.lang.Object

    • Method Detail

      • initialBackoffMillis

        public EventWriterConfig.EventWriterConfigBuilder initialBackoffMillis​(int initialBackoffMillis)
        Initial backoff in milli seconds used in the retry logic of the writer. The default value is 1ms.
        Parameters:
        initialBackoffMillis - Initial backoff in milli seconds in the retry logic of the writer.
        Returns:
        this.

      • maxBackoffMillis

        public EventWriterConfig.EventWriterConfigBuilder maxBackoffMillis​(int maxBackoffMillis)
        Maximum backoff in milli seconds used in the retry logic of the writer. The default value is 20000.
        Parameters:
        maxBackoffMillis - Maximum backoff in milli seconds used in the retry logic of the writer.
        Returns:
        this.

      • retryAttempts

        public EventWriterConfig.EventWriterConfigBuilder retryAttempts​(int retryAttempts)
        Maximum retry attempts performed by the writer before throwing a RetriesExhaustedException. The default value is 10.
        Parameters:
        retryAttempts - Maximum retry attempts performed by the writer before throwing a RetriesExhaustedException.
        Returns:
        this.

      • backoffMultiple

        public EventWriterConfig.EventWriterConfigBuilder backoffMultiple​(int backoffMultiple)
        Backoff multiplier used in the retry logic of the writer. The default value is 10.
        Parameters:
        backoffMultiple - Backoff multiplier used in the retry logic of the writer.
        Returns:
        this.

      • enableConnectionPooling

        public EventWriterConfig.EventWriterConfigBuilder enableConnectionPooling​(boolean enableConnectionPooling)
        Enable or disable connection pooling for writer. The default value is false.
        Parameters:
        enableConnectionPooling - Enable or disable connection pooling for writer.
        Returns:
        this.

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object