AzureTableDataManager<T> Class

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.OrleansServiceBus v2.4.5

Utility class to encapsulate row-based access to Azure table storage.

public class AzureTableDataManager<T> where T : class, ITableEntity, new()

type AzureTableDataManager<'T (requires 'T : null and 'T :> ITableEntity and 'T : (new : unit -> 'T))> = class

Public Class AzureTableDataManager(Of T)

Type Parameters

T

Table data entry used by this table / manager.

Inheritance

Object

AzureTableDataManager<T>

Remarks

These functions are mostly intended for internal usage by Orleans runtime, but due to certain assembly packaging constraints this class needs to have public visibility.

Constructors

AzureTableDataManager<T>(String, String, ILoggerFactory)

Constructor

Properties

ConnectionString	Connection string for the Azure storage account used to host this table.
Logger	Logger for this table manager instance.
Table
TableName	Name of the table this instance is managing.

Methods

BulkInsertTableEntries(IReadOnlyCollection<T>)	Inserts a set of new data entries into the table. Fails if the data does already exists.
ClearTableAsync()	Deletes all entities the Azure table.
CreateTableEntryAsync(T)	Create a new data entry in the Azure table (insert new, not update existing). Fails if the data already exists.
DeleteTableAsync()	Deletes the Azure table.
DeleteTableEntriesAsync(IReadOnlyCollection<Tuple<T,String>>)	Deletes a set of already existing data entries in the table, by using eTag. Fails if the data does not already exist or if eTag does not match.
DeleteTableEntryAsync(T, String)	Deletes an already existing data in the table, by using eTag. Fails if the data does not already exist or if eTag does not match.
InitTableAsync()	Connects to, or creates and initializes a new Azure table if it does not already exist.
ReadAllTableEntriesAsync()	Read all entries in the table. NOTE: This could be a very expensive and slow operation for large tables!
ReadAllTableEntriesForPartitionAsync(String)	Read all entries in one partition of the storage table. NOTE: This could be an expensive and slow operation for large table partitions!
ReadSingleTableEntryAsync(String, String)	Read a single table entry from the storage table.
ReadTableEntriesAndEtagsAsync(String)	Read data entries and their corresponding eTags from the Azure table.
UpdateTableEntryAsync(T, String)	Updates a data entry in the Azure table: updates an already existing data in the table, by using eTag. Fails if the data does not already exist or of eTag does not match.
UpsertTableEntryAsync(T)	Inserts a data entry in the Azure table: creates a new one if does not exists or overwrites (without eTag) an already existing version (the "update in place" semantics).