Uses of Class
software.amazon.lambda.durable.TypeToken
Packages that use TypeToken
Package
Description
-
Uses of TypeToken in software.amazon.lambda.durable
Methods in software.amazon.lambda.durable that return TypeTokenModifier and TypeMethodDescriptionstatic <U> TypeToken<U>Creates a TypeToken for a simple (non-generic) class.Methods in software.amazon.lambda.durable with parameters of type TypeTokenModifier and TypeMethodDescriptiondefault <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> DurableCallbackFuture<T>DurableContext.createCallback(String name, TypeToken<T> resultType) Creates a callback using aTypeTokenfor generic result types.<T> DurableCallbackFuture<T>DurableContext.createCallback(String name, TypeToken<T> resultType, CallbackConfig config) Creates a callback operation that suspends execution until an external system completes it.default <T,U> T Invokes another Lambda function using aTypeTokenfor generic result types, blocking until complete.default <T,U> T DurableContext.invoke(String name, String functionName, U payload, TypeToken<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> MapResult<O> DurableContext.map(String name, Collection<I> items, TypeToken<O> resultType, DurableContext.MapFunction<I, O> function) default <I,O> MapResult<O> DurableContext.map(String name, Collection<I> items, TypeToken<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> TDurableContext.runInChildContext(String name, TypeToken<T> resultType, Function<DurableContext, T> func) Runs a function in a child context using aTypeTokenfor generic result types, blocking until complete.default <T> TDurableContext.runInChildContext(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.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> TDurableContext.step(String name, TypeToken<T> resultType, Function<StepContext, T> func) Executes a durable step using aTypeTokenfor generic result types, blocking until it completes.default <T> TDurableContext.step(String name, TypeToken<T> resultType, Function<StepContext, T> func, StepConfig config) Executes a durable step using aTypeTokenand configuration, blocking until it completes.default <T> TDeprecated.use the variants accepting StepContext insteaddefault <T> TDurableContext.step(String name, TypeToken<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 insteaddefault <T> TDurableContext.waitForCallback(String name, TypeToken<T> resultType, BiConsumer<String, StepContext> func) Executes a submitter and waits for an external callback using aTypeToken, blocking until complete.default <T> TDurableContext.waitForCallback(String name, TypeToken<T> resultType, BiConsumer<String, StepContext> func, WaitForCallbackConfig waitForCallbackConfig) Executes a submitter and waits for an external callback using aTypeTokenand 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> TDurableContext.waitForCondition(String name, TypeToken<T> resultType, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc) Polls a condition function until it signals done, using aTypeToken, blocking until complete.default <T> TDurableContext.waitForCondition(String name, TypeToken<T> resultType, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc, WaitForConditionConfig<T> config) Polls a condition function until it signals done, using aTypeTokenand custom configuration, blocking until complete.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. -
Uses of TypeToken in software.amazon.lambda.durable.context
Methods in software.amazon.lambda.durable.context with parameters of type TypeTokenModifier and TypeMethodDescription<T> DurableCallbackFuture<T>DurableContextImpl.createCallback(String name, TypeToken<T> resultType, CallbackConfig config) <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 TypeToken in software.amazon.lambda.durable.execution
Methods in software.amazon.lambda.durable.execution with parameters of type TypeTokenModifier and TypeMethodDescriptionstatic <I,O> DurableExecutionOutput DurableExecutor.execute(DurableExecutionInput input, com.amazonaws.services.lambda.runtime.Context lambdaContext, TypeToken<I> inputType, BiFunction<I, DurableContext, O> handler, DurableConfig config) static <I,O> com.amazonaws.services.lambda.runtime.RequestHandler<DurableExecutionInput, DurableExecutionOutput> DurableExecutor.wrap(TypeToken<I> inputType, BiFunction<I, DurableContext, O> handler, DurableConfig config) Wraps a user handler in a RequestHandler that can be used by the Lambda runtime. -
Uses of TypeToken in software.amazon.lambda.durable.operation
Methods in software.amazon.lambda.durable.operation with parameters of type TypeTokenModifier and TypeMethodDescription<T> DurableFuture<T>ParallelOperation.branch(String name, TypeToken<T> resultType, Function<DurableContext, T> func, ParallelBranchConfig config) protected <R> ChildContextOperation<R>ConcurrencyOperation.createItem(String operationId, String name, Function<DurableContext, R> function, TypeToken<R> resultType, SerDes serDes, OperationSubType branchSubType, DurableContextImpl parentContext) Creates a child context operation for a single item (branch or iteration).protected <R> ChildContextOperation<R>ConcurrencyOperation.enqueueItem(String name, Function<DurableContext, R> function, TypeToken<R> resultType, SerDes serDes, OperationSubType branchSubType) Creates and enqueues an item without starting execution.Constructors in software.amazon.lambda.durable.operation with parameters of type TypeTokenModifierConstructorDescriptionCallbackOperation(OperationIdentifier operationIdentifier, TypeToken<T> resultTypeToken, CallbackConfig config, DurableContextImpl durableContext) ChildContextOperation(OperationIdentifier operationIdentifier, Function<DurableContext, T> function, TypeToken<T> resultTypeToken, RunInChildContextConfig config, DurableContextImpl durableContext) ChildContextOperation(OperationIdentifier operationIdentifier, Function<DurableContext, T> function, TypeToken<T> resultTypeToken, RunInChildContextConfig config, DurableContextImpl durableContext, ConcurrencyOperation<?> parentOperation) protectedConcurrencyOperation(OperationIdentifier operationIdentifier, TypeToken<T> resultTypeToken, SerDes resultSerDes, DurableContextImpl durableContext, int maxConcurrency, Integer minSuccessful, Integer toleratedFailureCount) InvokeOperation(OperationIdentifier operationIdentifier, String functionName, I payload, TypeToken<T> resultTypeToken, InvokeConfig config, DurableContextImpl durableContext) MapOperation(OperationIdentifier operationIdentifier, List<I> items, DurableContext.MapFunction<I, O> function, TypeToken<O> itemResultType, MapConfig config, DurableContextImpl durableContext) protectedSerializableDurableOperation(OperationIdentifier operationIdentifier, TypeToken<T> resultTypeToken, SerDes resultSerDes, DurableContextImpl durableContext) Constructs a new durable operation.protectedSerializableDurableOperation(OperationIdentifier operationIdentifier, TypeToken<T> resultTypeToken, SerDes resultSerDes, DurableContextImpl durableContext, BaseDurableOperation parentOperation) StepOperation(OperationIdentifier operationIdentifier, Function<StepContext, T> function, TypeToken<T> resultTypeToken, StepConfig config, DurableContextImpl durableContext) WaitForConditionOperation(String operationId, String name, BiFunction<T, StepContext, WaitForConditionResult<T>> checkFunc, TypeToken<T> resultTypeToken, WaitForConditionConfig<T> config, DurableContextImpl durableContext) -
Uses of TypeToken in software.amazon.lambda.durable.serde
Methods in software.amazon.lambda.durable.serde with parameters of type TypeTokenModifier and TypeMethodDescription<T> TDurableInputOutputSerDes.deserialize(String data, TypeToken<T> typeToken) Deserializes a JSON string to DurableExecutionInput object<T> TJacksonSerDes.deserialize(String data, TypeToken<T> typeToken) <T> TSerDes.deserialize(String data, TypeToken<T> typeToken) Deserializes a JSON string to an object of the specified generic type. -
Uses of TypeToken in software.amazon.lambda.durable.testing
Methods in software.amazon.lambda.durable.testing with parameters of type TypeTokenModifier and TypeMethodDescriptionstatic <I,O> CloudDurableTestRunner<I, O> Creates a runner for the given function ARN with TypeToken-based input/output types.static <I,O> CloudDurableTestRunner<I, O> CloudDurableTestRunner.create(String functionArn, TypeToken<I> inputType, TypeToken<O> outputType, software.amazon.awssdk.services.lambda.LambdaClient lambdaClient) Creates a runner with a customLambdaClientand TypeToken-based input/output types.static <I,O> LocalDurableTestRunner<I, O> LocalDurableTestRunner.create(TypeToken<I> inputType, BiFunction<I, DurableContext, O> handlerFn) Creates a LocalDurableTestRunner with default configuration.static <I,O> LocalDurableTestRunner<I, O> LocalDurableTestRunner.create(TypeToken<I> inputType, BiFunction<I, DurableContext, O> handlerFn, DurableConfig config) Creates a LocalDurableTestRunner that uses a custom configuration.static <I,O> LocalDurableTestRunner<I, O> LocalDurableTestRunner.create(TypeToken<I> inputType, DurableHandler<I, O> handler) Creates a LocalDurableTestRunner from a DurableHandler instance, automatically extracting the configuration.<T> TDeserializes and returns the execution output using a TypeToken for generic types.<T> TTestOperation.getStepResult(TypeToken<T> type) Deserializes and returns the step result using a TypeToken for generic types.<O> TestResult<O>HistoryEventProcessor.processEvents(List<software.amazon.awssdk.services.lambda.model.Event> events, TypeToken<O> outputType) Processes a list of execution history events into a structuredTestResult.Constructors in software.amazon.lambda.durable.testing with parameters of type TypeToken