Values.SubscribeToShardEventStreamSourceThis is a tagged union for all of the types of events an enhanced fan-out consumer can receive over HTTP/2 after a call to SubscribeToShard.
type nonrec t = {subscribeToShardEvent : SubscribeToShardEvent.t option;After you call SubscribeToShard, Kinesis Data Streams sends events of this type to your consumer. For an example of how to handle these events, see Enhanced Fan-Out Using the Kinesis Data Streams API.
*)resourceNotFoundException : ResourceNotFoundException.t option;resourceInUseException : ResourceInUseException.t option;kMSDisabledException : KMSDisabledException.t option;kMSInvalidStateException : KMSInvalidStateException.t option;kMSAccessDeniedException : KMSAccessDeniedException.t option;kMSNotFoundException : KMSNotFoundException.t option;kMSOptInRequired : KMSOptInRequired.t option;kMSThrottlingException : KMSThrottlingException.t option;internalFailureException : InternalFailureException.t option;The processing of the request failed because of an unknown error, exception, or failure.
*)}val make :
?subscribeToShardEvent:??? ->
?resourceNotFoundException:??? ->
?resourceInUseException:??? ->
?kMSDisabledException:??? ->
?kMSInvalidStateException:??? ->
?kMSAccessDeniedException:??? ->
?kMSNotFoundException:??? ->
?kMSOptInRequired:??? ->
?kMSThrottlingException:??? ->
?internalFailureException:??? ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `Structure of
(string
* [> `List of
[> `Structure of
(string
* [> `Blob of Data.t
| `Enum of string
| `List of [> `String of ShardId.t ] list
| `String of SequenceNumber.t
| `Structure of
(string * [> `String of HashKey.t ]) list
| `Timestamp of Timestamp.t ])
list ]
list
| `Long of MillisBehindLatest.t
| `String of SequenceNumber.t ])
list ])
list ]