Uses of Interface
software.amazon.lambda.durable.DurableFuture
Packages that use DurableFuture
Package
Description
-
Uses of DurableFuture in software.amazon.lambda.durable
Subinterfaces of DurableFuture in software.amazon.lambda.durableModifier and TypeInterfaceDescriptioninterfaceResult of creating a callback, containing the callback ID and providing access to the result.interfaceUser-facing context for managing parallel branch execution within a durable function.Methods in software.amazon.lambda.durable that return DurableFutureModifier and TypeMethodDescriptiondefault <T> DurableFuture<T>ParallelDurableFuture.branch(String name, Class<T> resultType, Function<DurableContext, T> func) Registers and immediately starts a branch (respects maxConcurrency).default <T> DurableFuture<T>ParallelDurableFuture.branch(String name, Class<T> resultType, Function<DurableContext, T> func, ParallelBranchConfig config) Registers and immediately starts a branch (respects maxConcurrency).default <T> DurableFuture<T>ParallelDurableFuture.branch(String name, TypeToken<T> resultType, Function<DurableContext, T> func) Registers and immediately starts a branch (respects maxConcurrency).<T> DurableFuture<T>ParallelDurableFuture.branch(String name, TypeToken<T> resultType, Function<DurableContext, T> func, ParallelBranchConfig config) Registers and immediately starts a branch (respects maxConcurrency).default <T,U> DurableFuture<T> DurableContext.invokeAsync(String name, String functionName, U payload, Class<T> resultType) Asynchronously invokes another Lambda function, returning aDurableFuture.default <T,U> DurableFuture<T> DurableContext.invokeAsync(String name, String functionName, U payload, Class<T> resultType, InvokeConfig config) Invokes another Lambda function using aTypeTokenand custom configuration, blocking until complete.default <T,U> DurableFuture<T> DurableContext.invokeAsync(String name, String functionName, U payload, TypeToken<T> resultType) Asynchronously invokes another Lambda function using aTypeTokenfor generic result types.<T,U> DurableFuture<T> DurableContext.invokeAsync(String name, String functionName, U payload, TypeToken<T> resultType, InvokeConfig config) Asynchronously invokes another Lambda function using aTypeTokenand custom configuration.default <I,O> DurableFuture<MapResult<O>> DurableContext.mapAsync(String name, Collection<I> items, Class<O> resultType, DurableContext.MapFunction<I, O> function) default <I,O> DurableFuture<MapResult<O>> DurableContext.mapAsync(String name, Collection<I> items, Class<O> resultType, DurableContext.MapFunction<I, O> function, MapConfig config) default <I,O> DurableFuture<MapResult<O>> DurableContext.mapAsync(String name, Collection<I> items, TypeToken<O> resultType, DurableContext.MapFunction<I, O> function) <I,O> DurableFuture<MapResult<O>> DurableContext.mapAsync(String name, Collection<I> items, TypeToken<O> resultType, DurableContext.MapFunction<I, O> function, MapConfig config) default <T> DurableFuture<T>DurableContext.runInChildContextAsync(String name, Class<T> resultType, Function<DurableContext, T> func) Runs a function in a child context, blocking until it completes.default <T> DurableFuture<T>DurableContext.runInChildContextAsync(String name, Class<T> resultType, Function<DurableContext, T> func, RunInChildContextConfig config) Runs a function in a child context, blocking until it completes.default <T> DurableFuture<T>DurableContext.runInChildContextAsync(String name, TypeToken<T> resultType, Function<DurableContext, T> func) Runs a function in a child context, blocking until it completes.<T> DurableFuture<T>DurableContext.runInChildContextAsync(String name, TypeToken<T> resultType, Function<DurableContext, T> func, RunInChildContextConfig config) Runs a function in a child context, blocking until it completes.default <T> DurableFuture<T>DurableContext.stepAsync(String name, Class<T> resultType, Function<StepContext, T> func) Asynchronously executes a durable step, returning aDurableFuturethat can be composed or blocked on.default <T> DurableFuture<T>DurableContext.stepAsync(String name, Class<T> resultType, Function<StepContext, T> func, StepConfig config) Asynchronously executes a durable step using custom configuration.default <T> DurableFuture<T>Deprecated.use the variants accepting StepContext insteaddefault <T> DurableFuture<T>DurableContext.stepAsync(String name, Class<T> resultType, Supplier<T> func, StepConfig config) Deprecated.use the variants accepting StepContext insteaddefault <T> DurableFuture<T>DurableContext.stepAsync(String name, TypeToken<T> resultType, Function<StepContext, T> func) Asynchronously executes a durable step using aTypeTokenfor generic result types.<T> DurableFuture<T>DurableContext.stepAsync(String name, TypeToken<T> resultType, Function<StepContext, T> func, StepConfig config) Asynchronously executes a durable step using aTypeTokenand custom configuration.default <T> DurableFuture<T>Deprecated.use the variants accepting StepContext insteaddefault <T> DurableFuture<T>DurableContext.stepAsync(String name, TypeToken<T> resultType, Supplier<T> func, StepConfig config) Deprecated.use the variants accepting StepContext insteadAsynchronously suspends execution for the specified duration.default <T> DurableFuture<T>DurableContext.waitForCallbackAsync(String name, Class<T> resultType, BiConsumer<String, StepContext> func) Asynchronously executes a submitter and waits for an external callback.default <T> DurableFuture<T>DurableContext.waitForCallbackAsync(String name, Class<T> resultType, BiConsumer<String, StepContext> func, WaitForCallbackConfig waitForCallbackConfig) Asynchronously executes a submitter and waits for an external callback with custom configuration.default <T> DurableFuture<T>DurableContext.waitForCallbackAsync(String name, TypeToken<T> resultType, BiConsumer<String, StepContext> func) Asynchronously executes a submitter and waits for an external callback using aTypeToken.<T> DurableFuture<T>DurableContext.waitForCallbackAsync(String name, TypeToken<T> resultType, BiConsumer<String, StepContext> func, WaitForCallbackConfig waitForCallbackConfig) Asynchronously executes a submitter and waits for an external callback using aTypeTokenand custom configuration.default <T> DurableFuture<T>DurableContext.waitForConditionAsync(String name, Class<T> resultType, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc) Asynchronously polls a condition function until it signals done.default <T> DurableFuture<T>DurableContext.waitForConditionAsync(String name, Class<T> resultType, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc, WaitForConditionConfig<T> config) Asynchronously polls a condition function until it signals done, using custom configuration.default <T> DurableFuture<T>DurableContext.waitForConditionAsync(String name, TypeToken<T> resultType, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc) Asynchronously polls a condition function until it signals done, using aTypeToken.<T> DurableFuture<T>DurableContext.waitForConditionAsync(String name, TypeToken<T> resultType, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc, WaitForConditionConfig<T> config) Asynchronously polls a condition function until it signals done, using aTypeTokenand custom configuration.Methods in software.amazon.lambda.durable with parameters of type DurableFutureModifier and TypeMethodDescriptionstatic <T> List<T>DurableFuture.allOf(DurableFuture<T>... futures) Waits for all provided futures to complete and returns their results in order.static ObjectDurableFuture.anyOf(DurableFuture<?>... futures) Waits for any of the provided futures to complete and returns its result.Method parameters in software.amazon.lambda.durable with type arguments of type DurableFutureModifier and TypeMethodDescriptionstatic <T> List<T>DurableFuture.allOf(List<DurableFuture<T>> futures) Waits for all provided futures to complete and returns their results in order. -
Uses of DurableFuture in software.amazon.lambda.durable.context
Methods in software.amazon.lambda.durable.context that return DurableFutureModifier and TypeMethodDescription<T,U> DurableFuture<T> DurableContextImpl.invokeAsync(String name, String functionName, U payload, TypeToken<T> resultType, InvokeConfig config) <I,O> DurableFuture<MapResult<O>> DurableContextImpl.mapAsync(String name, Collection<I> items, TypeToken<O> resultType, DurableContext.MapFunction<I, O> function, MapConfig config) <T> DurableFuture<T>DurableContextImpl.runInChildContextAsync(String name, TypeToken<T> resultType, Function<DurableContext, T> func, RunInChildContextConfig config) Runs a function in a child context, blocking until it completes.<T> DurableFuture<T>DurableContextImpl.stepAsync(String name, TypeToken<T> resultType, Function<StepContext, T> func, StepConfig config) <T> DurableFuture<T>DurableContextImpl.waitForCallbackAsync(String name, TypeToken<T> resultType, BiConsumer<String, StepContext> func, WaitForCallbackConfig waitForCallbackConfig) <T> DurableFuture<T>DurableContextImpl.waitForConditionAsync(String name, TypeToken<T> resultType, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc, WaitForConditionConfig<T> config) -
Uses of DurableFuture in software.amazon.lambda.durable.operation
Classes in software.amazon.lambda.durable.operation that implement DurableFutureModifier and TypeClassDescriptionclassDurable operation for creating and waiting on external callbacks.classManages the lifecycle of a child execution context.classAbstract base class for concurrent execution of multiple child context operations.classInvokeOperation<T,I> Durable operation that invokes another Lambda function and waits for its result.classMapOperation<I,O> Executes a map operation: applies a function to each item in a collection concurrently, with each item running in its own child context.classManages parallel execution of multiple branches as child context operations.classBase class for all durable operations (STEP, WAIT, etc.).classDurable operation that executes a user-provided function with retry support.classDurable operation that periodically checks a user-supplied condition function, using a configurable wait strategy to determine polling intervals and termination.classDurable operation that suspends execution for a specified duration without consuming compute.Methods in software.amazon.lambda.durable.operation that return DurableFutureModifier and TypeMethodDescription<T> DurableFuture<T>ParallelOperation.branch(String name, TypeToken<T> resultType, Function<DurableContext, T> func, ParallelBranchConfig config) -
Uses of DurableFuture in software.amazon.lambda.durable.util
Classes in software.amazon.lambda.durable.util that implement DurableFuture