template.yaml

AWSTemplateFormatVersion: "2010-09-09"
Transform: AWS::Serverless-2016-10-31
Description: AWS Lambda Durable Execution SDK Examples

Parameters:
  Architecture:
    Type: String
    Default: arm64
    Description: Lambda Function Architecture
    AllowedValues:
      - x86_64
      - arm64
  JavaVersion:
    Type: String
    Default: 'java17'
    Description: Java runtime version

Conditions:
  IsJava21OrLater:
    !Or
      - !Equals [!Ref JavaVersion, 'java21']
      - !Equals [!Ref JavaVersion, 'java25']

Globals:
  Function:
    Timeout: 900
    MemorySize: 512
    Architectures:
      - !Ref Architecture
    DurableConfig:
      ExecutionTimeout: 300
      RetentionPeriodInDays: 7
    Runtime: !Ref JavaVersion

Resources:
  NoopExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - noop-example
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.general.NoopExample"

  SimpleStepExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - simple-step-example
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.step.SimpleStepExample"

  SimpleInvokeExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'simple-invoke-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.invoke.SimpleInvokeExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
                - lambda:InvokeFunction
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:simple-invoke-example-${JavaVersion}-runtime"
            - Effect: Allow
              Action:
                - lambda:InvokeFunction
              Resource: '*'

  WaitExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'wait-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.wait.WaitExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:wait-example-${JavaVersion}-runtime"

  RetryExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'retry-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.step.RetryExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:retry-example-${JavaVersion}-runtime"

  WaitAtLeastExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'wait-at-least-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.wait.WaitAtLeastExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:wait-at-least-example-${JavaVersion}-runtime"

  WaitAtLeastInProcessExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'wait-at-least-in-process-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.wait.WaitAtLeastInProcessExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:wait-at-least-in-process-example-${JavaVersion}-runtime"

  RetryInProcessExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'retry-in-process-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.step.RetryInProcessExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:retry-in-process-example-${JavaVersion}-runtime"

  GenericTypesExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'generic-types-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.general.GenericTypesExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:generic-types-example-${JavaVersion}-runtime"

  GenericInputOutputExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'generic-input-output-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.general.GenericInputOutputExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:generic-input-output-example-${JavaVersion}-runtime"

  CustomConfigExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'custom-config-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.general.CustomConfigExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:custom-config-example-${JavaVersion}-runtime"

  LoggingExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'logging-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.general.LoggingExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:logging-example-${JavaVersion}-runtime"

  ErrorHandlingExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'error-handling-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.general.ErrorHandlingExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:error-handling-example-${JavaVersion}-runtime"

  CallbackExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'callback-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.callback.CallbackExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:callback-example-${JavaVersion}-runtime"

  ManyAsyncStepsExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'many-async-steps-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:many-async-steps-example-${JavaVersion}-runtime"

  ChildContextExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'child-context-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.child.ChildContextExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:child-context-example-${JavaVersion}-runtime"

  WaitAsyncExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'wait-async-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.wait.WaitAsyncExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:wait-async-example-${JavaVersion}-runtime"

  ManyAsyncChildContextExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'many-async-child-context-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:many-async-child-context-example-${JavaVersion}-runtime"

  SimpleMapExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'simple-map-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.map.SimpleMapExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:simple-map-example-${JavaVersion}-runtime"

  ComplexMapExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'complex-map-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.map.ComplexMapExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:complex-map-example-${JavaVersion}-runtime"

  ComplexFlatMapExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'complex-flat-map-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.map.ComplexFlatMapExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:complex-flat-map-example-${JavaVersion}-runtime"

  WaitForConditionExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'wait-for-condition-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.wait.WaitForConditionExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:wait-for-condition-example-${JavaVersion}-runtime"

  ConcurrentWaitForConditionExampleFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: !Join
        - '-'
        - - 'concurrent-wait-for-condition-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:concurrent-wait-for-condition-example-${JavaVersion}-runtime"

  ManyAsyncStepsVirtualThreadPoolExampleFunction:
    Type: AWS::Serverless::Function
    Condition: IsJava21OrLater
    Properties:
      FunctionName: !Join
        - '-'
        - - 'many-async-steps-virtual-thread-pool-example'
          - !Ref JavaVersion
          - runtime
      Handler: "software.amazon.lambda.durable.examples.vt.ManyAsyncStepsVirtualThreadPoolExample"
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - lambda:CheckpointDurableExecutions
                - lambda:GetDurableExecutionState
              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:many-async-steps-virtual-thread-pool-example-${JavaVersion}-runtime"

Outputs:
  NoopExampleFunction:
    Description: Noop Example Function ARN
    Value: !GetAtt NoopExampleFunction.Arn

  SimpleStepExampleFunction:
    Description: Simple Step Example Function ARN
    Value: !GetAtt SimpleStepExampleFunction.Arn

  SimpleInvokeExampleFunction:
    Description: Simple Invoke Example Function ARN
    Value: !GetAtt SimpleInvokeExampleFunction.Arn

  WaitExampleFunction:
    Description: Wait Example Function ARN
    Value: !GetAtt WaitExampleFunction.Arn

  RetryExampleFunction:
    Description: Retry Example Function ARN
    Value: !GetAtt RetryExampleFunction.Arn

  WaitAtLeastExampleFunction:
    Description: Wait At Least Example Function ARN
    Value: !GetAtt WaitAtLeastExampleFunction.Arn

  WaitAtLeastInProcessExampleFunction:
    Description: Wait At Least In Process Example Function ARN
    Value: !GetAtt WaitAtLeastInProcessExampleFunction.Arn

  RetryInProcessExampleFunction:
    Description: Retry In Process Example Function ARN
    Value: !GetAtt RetryInProcessExampleFunction.Arn

  GenericTypesExampleFunction:
    Description: Generic Types Example Function ARN
    Value: !GetAtt GenericTypesExampleFunction.Arn

  GenericInputOutputExampleFunction:
    Description: Generic Input Output Example Function ARN
    Value: !GetAtt GenericInputOutputExampleFunction.Arn

  CustomConfigExampleFunction:
    Description: Custom Config Example Function ARN
    Value: !GetAtt CustomConfigExampleFunction.Arn

  LoggingExampleFunction:
    Description: Logging Example Function ARN
    Value: !GetAtt LoggingExampleFunction.Arn

  ErrorHandlingExampleFunction:
    Description: Error Handling Example Function ARN
    Value: !GetAtt ErrorHandlingExampleFunction.Arn

  CallbackExampleFunction:
    Description: Callback Example Function ARN
    Value: !GetAtt CallbackExampleFunction.Arn

  ManyAsyncStepsExampleFunction:
    Description: Many Async Steps Example Function ARN
    Value: !GetAtt ManyAsyncStepsExampleFunction.Arn

  ChildContextExampleFunction:
    Description: Child Context Example Function ARN
    Value: !GetAtt ChildContextExampleFunction.Arn

  WaitAsyncExampleFunction:
    Description: Wait Async Example Function ARN
    Value: !GetAtt WaitAsyncExampleFunction.Arn

  ManyAsyncChildContextExampleFunction:
    Description: Many Async Child Context Example Function ARN
    Value: !GetAtt ManyAsyncChildContextExampleFunction.Arn

  SimpleMapExampleFunction:
    Description: Simple Map Example Function ARN
    Value: !GetAtt SimpleMapExampleFunction.Arn

  ComplexMapExampleFunction:
    Description: Complex Map Example Function ARN
    Value: !GetAtt ComplexMapExampleFunction.Arn

  ComplexFlatMapExampleFunction:
    Description: Complex Flat Map Example Function ARN
    Value: !GetAtt ComplexFlatMapExampleFunction.Arn

  WaitForConditionExampleFunction:
    Description: Wait For Condition Example Function ARN
    Value: !GetAtt WaitForConditionExampleFunction.Arn

  ConcurrentWaitForConditionExampleFunction:
    Description: Concurrent Wait For Condition Example Function ARN
    Value: !GetAtt ConcurrentWaitForConditionExampleFunction.Arn

  ManyAsyncStepsVirtualThreadPoolExampleFunction:
    Condition: IsJava21OrLater
    Description: Many Async Steps Virtual Thread Pool Example Function ARN
    Value: !GetAtt ManyAsyncStepsVirtualThreadPoolExampleFunction.Arn