Interface IKeyValueStoreTransaction

A transaction for a key value store.

Inherited Members

ITransaction.CommitAsync(CancellationToken)

ITransaction.Rollback()

Namespace: Reaqtor.QueryEngine

Assembly: Reaqtor.QueryEngine.Interfaces.dll

Syntax

public interface IKeyValueStoreTransaction : ITransaction, IDisposable

Properties

Item[String, String]

Gets the value for the given key transactionally.

Declaration

byte[] this[string tableName, string key] { get; }

Parameters

Type	Name	Description
System.String	tableName	The name of the table to access.
System.String	key	The key whose value is to be got.

Property Value

Type	Description
System.Byte[]	The value for the key.

Methods

Add(String, String, Byte[])

Add an item into a key value store transactionally.

Declaration

void Add(string tableName, string key, byte[] value)

Parameters

Type	Name	Description
System.String	tableName	The name of the table to insert into.
System.String	key	The key to insert.
System.Byte[]	value	The value associated with the key.

Contains(String, String)

Queries the table transactionally to determine whether a key exists.

Declaration

bool Contains(string tableName, string key)

Parameters

Type	Name	Description
System.String	tableName	The name of the table to query.
System.String	key	The key for which to query.

Returns

Type	Description
System.Boolean	True if the key is found; false if it is not.

GetEnumerator(String)

Gets an enumerator for the table.

Declaration

IEnumerator<KeyValuePair<string, byte[]>> GetEnumerator(string tableName)

Parameters

Type	Name	Description
System.String	tableName	The table which is to be enumerated.

Returns

Type	Description
System.Collections.Generic.IEnumerator<System.Collections.Generic.KeyValuePair<System.String, System.Byte[]>>	An enumerator that will enumerate the table.

Remove(String, String)

Removes a key-value pair transactionally.

Declaration

void Remove(string tableName, string key)

Parameters

Type	Name	Description
System.String	tableName	The name of the table from which to remove.
System.String	key	The key to remove.

Update(String, String, Byte[])

Updates the value for the given key transactionally.

Declaration

void Update(string tableName, string key, byte[] value)

Parameters

Type	Name	Description
System.String	tableName	The name of the table to update.
System.String	key	The key to update.
System.Byte[]	value	The updated value.