Namespace DynaSharp.Streams
Classes
- ChangeRecord
One change to an item of a table, as a stream delivers it.
- Change<T>
A change of an item of one entity, read from the images of a stream record: what As<T>() and
ReadChangesAsyncof TableStreamExtensions give.
- DescribeStreamRequest
Reads the settings of a stream and its shards (DynamoDB Streams
DescribeStream).
- DescribeStreamResponse
The result of DescribeStreamRequest.
- DynamoDbStreamsClient
A client for the Amazon DynamoDB Streams low-level API: it lists the streams of tables, describes their shards and reads the records of changes to items. It is the counterpart of DynamoDbClient for the change log, and is configured with the same DynamoDbClientOptions.
- GetRecordsRequest
Reads records from a shard (DynamoDB Streams
GetRecords).
- GetRecordsResponse
The result of GetRecordsRequest.
- GetShardIteratorRequest
Gets an iterator that marks a position in a shard, to read records from (DynamoDB Streams
GetShardIterator).
- GetShardIteratorResponse
The result of GetShardIteratorRequest.
- ListStreamsRequest
Lists the streams of the account in the region, or of one table (DynamoDB Streams
ListStreams).
- ListStreamsResponse
One page of the result of ListStreamsRequest.
- ReadShardRequest
Reads one shard of a stream from a position to its end, for ReadShardAsync(ReadShardRequest, CancellationToken).
- ReadStreamRequest
Reads every shard of a stream in one process, for ReadStreamAsync(ReadStreamRequest, CancellationToken).
- RecordIdentity
The identity behind a change that DynamoDB made itself.
- SequenceNumberRange
The sequence numbers of the first and last record of a shard.
- Shard
A shard of a stream: a sequence of records that is read in order.
- ShardFilter
Restricts the shards that
DescribeStreamlists.
- StreamDescription
The settings of a stream and one page of its shards.
- StreamRecord
The change that a stream ChangeRecord describes.
- StreamSummary
The summary of a stream of a table, as listed by
ListStreams.
- TableStreamExtensions
Reads the stream of a table, which
DescribeTablenames, so the caller needs no ARN.
Structs
- MixedChange<T1, T2>
One change of a typed read of several entities: a Change<T> of one of the types, from
shop.ReadChangesAsync<Customer, Order>(streams, ...). Ask withchange.Is(out Change<Customer>? customer), or handle every case withMatch, which is what stays correct when a type is added.
- MixedChange<T1, T2, T3>
One change of a typed read of several entities: a Change<T> of one of the types, from
shop.ReadChangesAsync<Customer, Order>(streams, ...). Ask withchange.Is(out Change<Customer>? customer), or handle every case withMatch, which is what stays correct when a type is added.
- MixedChange<T1, T2, T3, T4>
One change of a typed read of several entities: a Change<T> of one of the types, from
shop.ReadChangesAsync<Customer, Order>(streams, ...). Ask withchange.Is(out Change<Customer>? customer), or handle every case withMatch, which is what stays correct when a type is added.
- ShardChangeRecord
A record of ReadStreamAsync(ReadStreamRequest, CancellationToken), with the shard it came from.
Enums
- OperationType
The kind of change a stream record describes.
- ShardFilterType
The kind of filter in a ShardFilter.
- ShardIteratorType
Where in a shard reading starts.
- StreamStatus
The state of a stream.