DynamoDBStorage
class
Namespace: Orleans.Transactions.DynamoDB
Wrapper around AWS DynamoDB SDK.
public class DynamoDBStorageConstructors
DynamoDBStorage(ILogger, string, string?, string?, string?, string?, int, int, bool, bool, bool)Create a DynamoDBStorage instance
Methods
ConvertUpdate(Dictionary<string, AttributeValue>, Dictionary<string, AttributeValue>, string, Dictionary<string, AttributeValue>)Creates a DynamoDB update expression and its expression attribute values.DeleTableAsync(string)Delete a table from DynamoDBDeleteEntriesAsync(string, IReadOnlyCollection<Dictionary<string, AttributeValue>>)Delete multiple entries from a DynamoDB table (Batch delete)DeleteEntriesAsync(string, IReadOnlyCollection<Dictionary<string, AttributeValue>>, CancellationToken)Deletes a batch of entries using the supplied cancellation token.DeleteEntryAsync(string, Dictionary<string, AttributeValue>, string, Dictionary<string, AttributeValue>)Delete an entry from a DynamoDB tableGetEntriesTxAsync(string, IEnumerable<Dictionary<string, AttributeValue>>, Func<Dictionary<string, AttributeValue>, TResult>)Transactionally reads entries from a DynamoDB tableGetEntriesTxAsync(string, IEnumerable<Dictionary<string, AttributeValue>>, Func<Dictionary<string, AttributeValue>, TResult>, CancellationToken)Transactionally reads entries using the supplied cancellation token.InitializeTable(string, List<KeySchemaElement>, List<AttributeDefinition>, List<GlobalSecondaryIndex>, string?, CancellationToken)Create a DynamoDB table if it doesn't existPutEntriesAsync(string, IReadOnlyCollection<Dictionary<string, AttributeValue>>)Crete or replace multiple entries in a DynamoDB table (Batch put)PutEntryAsync(string, Dictionary<string, AttributeValue>, CancellationToken, string, Dictionary<string, AttributeValue>)Creates or replaces an entry using the supplied cancellation token.PutEntryAsync(string, Dictionary<string, AttributeValue>, string, Dictionary<string, AttributeValue>)Create or Replace an entry in a DynamoDB TableQueryAllAsync(string, Dictionary<string, AttributeValue>, string, Func<Dictionary<string, AttributeValue>, TResult>, CancellationToken, string, bool, bool)Queries all matching entries using the supplied cancellation token.QueryAllAsync(string, Dictionary<string, AttributeValue>, string, Func<Dictionary<string, AttributeValue>, TResult>, string, bool, bool)Query for multiple entries in a DynamoDB table by filtering its keysQueryAsync(string, Dictionary<string, AttributeValue>, string, Func<Dictionary<string, AttributeValue>, TResult>, CancellationToken, string, bool, Dictionary<string, AttributeValue>, bool)Queries a page of entries using the supplied cancellation token.QueryAsync(string, Dictionary<string, AttributeValue>, string, Func<Dictionary<string, AttributeValue>, TResult>, string, bool, Dictionary<string, AttributeValue>, bool)Query for multiple entries in a DynamoDB table by filtering its keysReadSingleEntryAsync(string, Dictionary<string, AttributeValue>, Func<Dictionary<string, AttributeValue>, TResult>)Read an entry from a DynamoDB tableReadSingleEntryAsync(string, Dictionary<string, AttributeValue>, Func<Dictionary<string, AttributeValue>, TResult>, CancellationToken)Reads an entry using the supplied cancellation token.ScanAsync(string, Dictionary<string, AttributeValue>, string, Func<Dictionary<string, AttributeValue>, TResult>)Scan a DynamoDB table by querying the entry fields.UpsertEntryAsync(string, Dictionary<string, AttributeValue>, Dictionary<string, AttributeValue>, CancellationToken, string, Dictionary<string, AttributeValue>, string, Dictionary<string, AttributeValue>)Creates or updates an entry using the supplied cancellation token.UpsertEntryAsync(string, Dictionary<string, AttributeValue>, Dictionary<string, AttributeValue>, string, Dictionary<string, AttributeValue>, string, Dictionary<string, AttributeValue>)Create or update an entry in a DynamoDB TableWriteTxAsync(CancellationToken, IEnumerable<Put>, IEnumerable<Update>, IEnumerable<Delete>, IEnumerable<ConditionCheck>)Transactionally writes entries using the supplied cancellation token.WriteTxAsync(IEnumerable<Put>, IEnumerable<Update>, IEnumerable<Delete>, IEnumerable<ConditionCheck>)Transactionally performs write requestsWriteTxAsync(List<TransactWriteItem>)Transactionally performs write requests
Fields
DefaultReadCapacityUnitsThe default number of read capacity units for provisioned DynamoDB tables.DefaultWriteCapacityUnitsThe default number of write capacity units for provisioned DynamoDB tables.secretKeySecret key for this dynamoDB table
