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:SubscribeToShardEvent.t ->
?resourceNotFoundException:ResourceNotFoundException.t ->
?resourceInUseException:ResourceInUseException.t ->
?kMSDisabledException:KMSDisabledException.t ->
?kMSInvalidStateException:KMSInvalidStateException.t ->
?kMSAccessDeniedException:KMSAccessDeniedException.t ->
?kMSNotFoundException:KMSNotFoundException.t ->
?kMSOptInRequired:KMSOptInRequired.t ->
?kMSThrottlingException:KMSThrottlingException.t ->
?internalFailureException:InternalFailureException.t ->
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 ]