Package dev.restate.integration

@NullMarked package dev.restate.integration

APIs for producing invocations to Restate through the ingestion protocol.

Class	Description
ExactlyOnceProducer	Sends invocations to Restate with exactly-once deduplication.
IntegrationClient	Entry point for producing invocations to Restate ingress over the ingestion API.
IntegrationClient.Builder	Builder for IntegrationClient.
IntegrationClientException	The failure that pending producer futures complete with when the ingestion stream errors or closes.
IntegrationClientException.Kind	Classification of an ingestion stream failure.
Invocation	A single invocation to send through a Producer / ExactlyOnceProducer.
InvocationMetadata	Invocation metadata.
Producer	Sends invocations to Restate with at-least-once delivery.
ProducerBase	Common producer offsets, acknowledgement, flushing, and lifecycle operations.
ProducerBufferExhaustedException	Thrown by send when the producer cannot admit an invocation within the configured ProducerOptions.maxBlockTime(), or the thread is interrupted while waiting.
ProducerOptions	Configuration shared by at-least-once and exactly-once producers.
ProducerOptions.Builder	Builder for ProducerOptions.
SendAttempt	Result of a non-blocking producer admission attempt.
SendAttempt.Accepted	The invocation was accepted; the future completes on durable acknowledgement.
SendAttempt.Backpressured	The invocation was not accepted because the producer was backpressured.
SendResult	Send result metadata.
Version	Generated at build time by the `generateVersionClass` Gradle task.