object Requests
- Source
- Requests.scala
- Alphabetic
- By Inheritance
- Requests
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def batchWriteWithRetries(client: DynamoDbAsyncClient, request: BatchWriteItemRequest, maxRetries: Int, minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double)(implicit system: ActorSystem[_]): Future[Seq[BatchWriteItemResponse]]
Perform a DynamoDB batch write, retrying writes for any unprocessed items (with exponential backoff).
Perform a DynamoDB batch write, retrying writes for any unprocessed items (with exponential backoff).
- client
the DynamoDB async client to use
- request
the batch write request to apply
- maxRetries
max retries, when reached the resulting future will be failed with
failOnMaxRetries- minBackoff
minimum duration to backoff between retries
- maxBackoff
maximum duration to backoff between retries
- randomFactor
adds jitter to the retry delay (use 0 for no jitter)
- returns
when successful return all responses from attempts, otherwise akka.projection.dynamodb.Requests.BatchWriteFailed with last response
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def retryWithBackoff[Request, Response](request: Request, attempt: (Request) => Future[Response], decideRetry: (Request, Response) => Option[Request], maxRetries: Int, minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double, onRetry: (Response, Int, FiniteDuration) => Unit, failOnMaxRetries: (Response) => Throwable)(implicit system: ActorSystem[_]): Future[Seq[Response]]
Retry generic requests with exponential backoff.
Retry generic requests with exponential backoff.
The retry condition is controlled by the
decideRetryfunction. It takes the last request and its response, and if the request should be retried then it can return the next request to attempt.- request
the initial request
- attempt
attempt a request, returning a future of the response
- decideRetry
retry condition decision function, based on the request and response, returning next request
- maxRetries
max retries, when reached the resulting future will be failed with
failOnMaxRetries- minBackoff
minimum duration to backoff between retries
- maxBackoff
maximum duration to backoff between retries
- randomFactor
adds jitter to the retry delay (use 0 for no jitter)
- onRetry
called before each retry, with the response, the current retry count, and the delay for this retry
- failOnMaxRetries
if max retries is reached, create a throwable for the failed future result
- returns
all responses from attempts (in order)
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])