com.amazonaws.services.lambda.runtime.api.client.runtimeapi

Class LambdaRuntimeApiClientImpl

java.lang.Object

com.amazonaws.services.lambda.runtime.api.client.runtimeapi.LambdaRuntimeApiClientImpl

All Implemented Interfaces:

LambdaRuntimeApiClient

public class LambdaRuntimeApiClientImpl
extends Object
implements LambdaRuntimeApiClient

Constructor Summary

Constructors

Constructor and Description
LambdaRuntimeApiClientImpl(String hostnameAndPort)

Method Summary

Modifier and Type	Method and Description
static <T> T	getSupplierResultWithExponentialBackoff(LambdaContextLogger lambdaLogger, long initialDelayMS, long maxBackoffPeriodMS, int maxNumOfAttempts, java.util.function.Supplier<T> supplier, java.util.function.Function<Exception,String> exceptionMessageComposer, Exception maxRetriesException)
InvocationRequest	nextInvocation() Get next invocation
InvocationRequest	nextInvocationWithExponentialBackoff(LambdaContextLogger lambdaLogger) Get next invocation with exponential backoff
void	reportInitError(LambdaError error) Report Init error
void	reportInvocationError(String requestId, LambdaError error) Report invocation error
void	reportInvocationSuccess(String requestId, byte[] response) Report invocation success
void	reportRestoreError(LambdaError error) SnapStart endpoint to report errors during afterRestore hooks execution
void	restoreNext() SnapStart endpoint to report that beforeCheckoint hooks were executed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LambdaRuntimeApiClientImpl

public LambdaRuntimeApiClientImpl(String hostnameAndPort)

Method Detail

reportInitError

public void reportInitError(LambdaError error)
                     throws IOException

Description copied from interface: LambdaRuntimeApiClient

Report Init error

Specified by:

reportInitError in interface LambdaRuntimeApiClient

Parameters:

error - error to report

Throws:

IOException

nextInvocation

public InvocationRequest nextInvocation()

Description copied from interface: LambdaRuntimeApiClient

Get next invocation

Specified by:

nextInvocation in interface LambdaRuntimeApiClient

getSupplierResultWithExponentialBackoff

public static <T> T getSupplierResultWithExponentialBackoff(LambdaContextLogger lambdaLogger,
                                                            long initialDelayMS,
                                                            long maxBackoffPeriodMS,
                                                            int maxNumOfAttempts,
                                                            java.util.function.Supplier<T> supplier,
                                                            java.util.function.Function<Exception,String> exceptionMessageComposer,
                                                            Exception maxRetriesException)
                                                     throws Exception

Throws:

Exception

nextInvocationWithExponentialBackoff

public InvocationRequest nextInvocationWithExponentialBackoff(LambdaContextLogger lambdaLogger)
                                                       throws Exception

Description copied from interface: LambdaRuntimeApiClient

Get next invocation with exponential backoff

Specified by:

nextInvocationWithExponentialBackoff in interface LambdaRuntimeApiClient

Throws:

Exception

reportInvocationSuccess

public void reportInvocationSuccess(String requestId,
                                    byte[] response)

Description copied from interface: LambdaRuntimeApiClient

Report invocation success

Specified by:

reportInvocationSuccess in interface LambdaRuntimeApiClient

Parameters:

requestId - request id

response - byte array representing response

reportInvocationError

public void reportInvocationError(String requestId,
                                  LambdaError error)
                           throws IOException

Description copied from interface: LambdaRuntimeApiClient

Report invocation error

Specified by:

reportInvocationError in interface LambdaRuntimeApiClient

Parameters:

requestId - request id

error - error to report

Throws:

IOException

restoreNext

public void restoreNext()
                 throws IOException

Description copied from interface: LambdaRuntimeApiClient

SnapStart endpoint to report that beforeCheckoint hooks were executed

Specified by:

restoreNext in interface LambdaRuntimeApiClient

Throws:

IOException

reportRestoreError

public void reportRestoreError(LambdaError error)
                        throws IOException

Description copied from interface: LambdaRuntimeApiClient

SnapStart endpoint to report errors during afterRestore hooks execution

Specified by:

reportRestoreError in interface LambdaRuntimeApiClient

Parameters:

error - error to report

Throws:

IOException