Interface ILambdaQueueFunctionDependencyProvider

The ILambdaQueueFunctionDependencyProvider interface provides all the required dependencies for ALambdaQueueFunction<TMessage> instances. This interface follows the Dependency Provider pattern where all side-effecting methods and properties must be provided by an outside implementation.

Inherited Members

ILambdaFunctionDependencyProvider.UtcNow

ILambdaFunctionDependencyProvider.ConfigSource

ILambdaFunctionDependencyProvider.DebugLoggingEnabled

ILambdaFunctionDependencyProvider.Log(String)

ILambdaFunctionDependencyProvider.DecryptSecretAsync(Byte[], Dictionary<String, String>, CancellationToken)

ILambdaFunctionDependencyProvider.EncryptSecretAsync(Byte[], String, Dictionary<String, String>, CancellationToken)

ILambdaFunctionDependencyProvider.SendMessageToQueueAsync(String, String, IEnumerable<KeyValuePair<String, String>>, CancellationToken)

ILambdaFunctionDependencyProvider.SendEventAsync(DateTimeOffset, String, String, String, String, IEnumerable<String>, CancellationToken)

Namespace: LambdaSharp.SimpleQueueService

Assembly: LambdaSharp.SimpleQueueService.dll

Syntax

public interface ILambdaQueueFunctionDependencyProvider : ILambdaFunctionDependencyProvider

Methods

DeleteMessagesFromQueueAsync(String, IEnumerable<(String MessageId, String ReceiptHandle)>)

Delete a batch of message from an SQS queue. The Lambda function requires sqs:DeleteMessageBatch permission on the specified SQS ARN.

Declaration

Task DeleteMessagesFromQueueAsync(string queueArn, IEnumerable<(string MessageId, string ReceiptHandle)> messages)

Parameters

Type	Name	Description
System.String	queueArn	SQS ARN.
System.Collections.Generic.IEnumerable<System.ValueTuple<System.String, System.String>>	messages	Enumeration of (string MessageId, string ReceiptHandle) tuples specifying which messages to delete.

Returns

Type	Description
System.Threading.Tasks.Task	The task object representing the asynchronous operation.

GetMaxRetriesForQueueAsync(String)

Determine how many times a message should be retried for a given SQS queue.

Declaration

Task<int> GetMaxRetriesForQueueAsync(string queueArn)

Parameters

Type	Name	Description
System.String	queueArn	SQS ARN.

Returns

Type	Description
System.Threading.Tasks.Task<System.Int32>	The task object representing the asynchronous operation.