Interface IStream
A Kinesis Stream.
Namespace: Amazon.CDK.AWS.Kinesis
Assembly: Amazon.CDK.Lib.dll
Syntax (csharp)
public interface IStream : IResource
Syntax (vb)
Public Interface IStream
Inherits IResource, IConstruct, IDependable
Synopsis
Properties
EncryptionKey | Optional KMS encryption key associated with this stream. |
StreamArn | The ARN of the stream. |
StreamName | The name of the stream. |
Methods
Grant(IGrantable, String[]) | Grant the indicated permissions on this stream to the provided IAM principal. |
GrantRead(IGrantable) | Grant read permissions for this stream and its contents to an IAM principal (Role/Group/User). |
GrantReadWrite(IGrantable) | Grants read/write permissions for this stream and its contents to an IAM principal (Role/Group/User). |
GrantWrite(IGrantable) | Grant write permissions for this stream and its contents to an IAM principal (Role/Group/User). |
Metric(String, IMetricOptions) | Return stream metric based from its metric name. |
MetricGetRecords(IMetricOptions) | The number of records retrieved from the shard, measured over the specified time period. |
MetricGetRecordsBytes(IMetricOptions) | The number of bytes retrieved from the Kinesis stream, measured over the specified time period. |
MetricGetRecordsIteratorAgeMilliseconds(IMetricOptions) | The age of the last record in all GetRecords calls made against a Kinesis stream, measured over the specified time period. |
MetricGetRecordsLatency(IMetricOptions) | The time taken per GetRecords operation, measured over the specified time period. |
MetricGetRecordsSuccess(IMetricOptions) | The number of successful GetRecords operations per stream, measured over the specified time period. |
MetricIncomingBytes(IMetricOptions) | The number of bytes successfully put to the Kinesis stream over the specified time period. |
MetricIncomingRecords(IMetricOptions) | The number of records successfully put to the Kinesis stream over the specified time period. |
MetricPutRecordBytes(IMetricOptions) | The number of bytes put to the Kinesis stream using the PutRecord operation over the specified time period. |
MetricPutRecordLatency(IMetricOptions) | The time taken per PutRecord operation, measured over the specified time period. |
MetricPutRecordsBytes(IMetricOptions) | The number of bytes put to the Kinesis stream using the PutRecords operation over the specified time period. |
MetricPutRecordsFailedRecords(IMetricOptions) | The number of records rejected due to internal failures in a PutRecords operation per Kinesis data stream, measured over the specified time period. |
MetricPutRecordsLatency(IMetricOptions) | The time taken per PutRecords operation, measured over the specified time period. |
MetricPutRecordsSuccess(IMetricOptions) | The number of PutRecords operations where at least one record succeeded, per Kinesis stream, measured over the specified time period. |
MetricPutRecordsSuccessfulRecords(IMetricOptions) | The number of successful records in a PutRecords operation per Kinesis data stream, measured over the specified time period. |
MetricPutRecordsThrottledRecords(IMetricOptions) | The number of records rejected due to throttling in a PutRecords operation per Kinesis data stream, measured over the specified time period. |
MetricPutRecordsTotalRecords(IMetricOptions) | The total number of records sent in a PutRecords operation per Kinesis data stream, measured over the specified time period. |
MetricPutRecordSuccess(IMetricOptions) | The number of successful PutRecord operations per Kinesis stream, measured over the specified time period. |
MetricReadProvisionedThroughputExceeded(IMetricOptions) | The number of GetRecords calls throttled for the stream over the specified time period. |
MetricWriteProvisionedThroughputExceeded(IMetricOptions) | The number of records rejected due to throttling for the stream over the specified time period. |
Properties
EncryptionKey
Optional KMS encryption key associated with this stream.
virtual IKey EncryptionKey { get; }
Property Value
StreamArn
The ARN of the stream.
string StreamArn { get; }
Property Value
System.String
Remarks
Attribute: true
StreamName
The name of the stream.
string StreamName { get; }
Property Value
System.String
Remarks
Attribute: true
Methods
Grant(IGrantable, String[])
Grant the indicated permissions on this stream to the provided IAM principal.
Grant Grant(IGrantable grantee, params string[] actions)
Parameters
- grantee IGrantable
- actions System.String[]
Returns
GrantRead(IGrantable)
Grant read permissions for this stream and its contents to an IAM principal (Role/Group/User).
Grant GrantRead(IGrantable grantee)
Parameters
- grantee IGrantable
Returns
Remarks
If an encryption key is used, permission to ues the key to decrypt the contents of the stream will also be granted.
GrantReadWrite(IGrantable)
Grants read/write permissions for this stream and its contents to an IAM principal (Role/Group/User).
Grant GrantReadWrite(IGrantable grantee)
Parameters
- grantee IGrantable
Returns
Remarks
If an encryption key is used, permission to use the key for encrypt/decrypt will also be granted.
GrantWrite(IGrantable)
Grant write permissions for this stream and its contents to an IAM principal (Role/Group/User).
Grant GrantWrite(IGrantable grantee)
Parameters
- grantee IGrantable
Returns
Remarks
If an encryption key is used, permission to ues the key to encrypt the contents of the stream will also be granted.
Metric(String, IMetricOptions)
Return stream metric based from its metric name.
Metric Metric(string metricName, IMetricOptions props = null)
Parameters
- metricName System.String
name of the stream metric.
- props IMetricOptions
properties of the metric.
Returns
MetricGetRecords(IMetricOptions)
The number of records retrieved from the shard, measured over the specified time period.
Metric MetricGetRecords(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
Minimum, Maximum, and Average statistics represent the records in a single GetRecords operation for the stream in the specified time period.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricGetRecordsBytes(IMetricOptions)
The number of bytes retrieved from the Kinesis stream, measured over the specified time period.
Metric MetricGetRecordsBytes(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
Minimum, Maximum, and Average statistics represent the bytes in a single GetRecords operation for the stream in the specified time period.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricGetRecordsIteratorAgeMilliseconds(IMetricOptions)
The age of the last record in all GetRecords calls made against a Kinesis stream, measured over the specified time period.
Metric MetricGetRecordsIteratorAgeMilliseconds(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
Age is the difference between the current time and when the last record of the GetRecords call was written to the stream. The Minimum and Maximum statistics can be used to track the progress of Kinesis consumer applications. A value of zero indicates that the records being read are completely caught up with the stream.
The metric defaults to maximum over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricGetRecordsLatency(IMetricOptions)
The time taken per GetRecords operation, measured over the specified time period.
Metric MetricGetRecordsLatency(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricGetRecordsSuccess(IMetricOptions)
The number of successful GetRecords operations per stream, measured over the specified time period.
Metric MetricGetRecordsSuccess(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricIncomingBytes(IMetricOptions)
The number of bytes successfully put to the Kinesis stream over the specified time period.
Metric MetricIncomingBytes(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
This metric includes bytes from PutRecord and PutRecords operations. Minimum, Maximum, and Average statistics represent the bytes in a single put operation for the stream in the specified time period.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricIncomingRecords(IMetricOptions)
The number of records successfully put to the Kinesis stream over the specified time period.
Metric MetricIncomingRecords(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
This metric includes record counts from PutRecord and PutRecords operations. Minimum, Maximum, and Average statistics represent the records in a single put operation for the stream in the specified time period.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordBytes(IMetricOptions)
The number of bytes put to the Kinesis stream using the PutRecord operation over the specified time period.
Metric MetricPutRecordBytes(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordLatency(IMetricOptions)
The time taken per PutRecord operation, measured over the specified time period.
Metric MetricPutRecordLatency(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordsBytes(IMetricOptions)
The number of bytes put to the Kinesis stream using the PutRecords operation over the specified time period.
Metric MetricPutRecordsBytes(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordsFailedRecords(IMetricOptions)
The number of records rejected due to internal failures in a PutRecords operation per Kinesis data stream, measured over the specified time period.
Metric MetricPutRecordsFailedRecords(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
Occasional internal failures are to be expected and should be retried.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordsLatency(IMetricOptions)
The time taken per PutRecords operation, measured over the specified time period.
Metric MetricPutRecordsLatency(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordsSuccess(IMetricOptions)
The number of PutRecords operations where at least one record succeeded, per Kinesis stream, measured over the specified time period.
Metric MetricPutRecordsSuccess(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordsSuccessfulRecords(IMetricOptions)
The number of successful records in a PutRecords operation per Kinesis data stream, measured over the specified time period.
Metric MetricPutRecordsSuccessfulRecords(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordsThrottledRecords(IMetricOptions)
The number of records rejected due to throttling in a PutRecords operation per Kinesis data stream, measured over the specified time period.
Metric MetricPutRecordsThrottledRecords(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordsTotalRecords(IMetricOptions)
The total number of records sent in a PutRecords operation per Kinesis data stream, measured over the specified time period.
Metric MetricPutRecordsTotalRecords(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricPutRecordSuccess(IMetricOptions)
The number of successful PutRecord operations per Kinesis stream, measured over the specified time period.
Metric MetricPutRecordSuccess(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
Average reflects the percentage of successful writes to a stream.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.
MetricReadProvisionedThroughputExceeded(IMetricOptions)
The number of GetRecords calls throttled for the stream over the specified time period.
Metric MetricReadProvisionedThroughputExceeded(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
The most commonly used statistic for this metric is Average.
When the Minimum statistic has a value of 1, all records were throttled for the stream during the specified time period.
When the Maximum statistic has a value of 0 (zero), no records were throttled for the stream during the specified time period.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties
MetricWriteProvisionedThroughputExceeded(IMetricOptions)
The number of records rejected due to throttling for the stream over the specified time period.
Metric MetricWriteProvisionedThroughputExceeded(IMetricOptions props = null)
Parameters
- props IMetricOptions
properties of the metric.
Returns
Remarks
This metric includes throttling from PutRecord and PutRecords operations.
When the Minimum statistic has a non-zero value, records were being throttled for the stream during the specified time period.
When the Maximum statistic has a value of 0 (zero), no records were being throttled for the stream during the specified time period.
The metric defaults to average over 5 minutes, it can be changed by passing statistic
and period
properties.