Modules§
- h_
stream_ api_ client - Generated client implementations.
- h_
stream_ record_ header - Nested message and enum types in
HStreamRecordHeader. - shard_
offset - Nested message and enum types in
ShardOffset.
Structs§
- Admin
Command Request - Admin
Command Response - Append
Request - Append
Response - BatchH
Stream Records - Auxiliary types for serialization [HStreamRecord]
- Batched
Record - Check
Subscription Exist Request - Check
Subscription Exist Response - Command
Connect - Command
Connected - Command
Push Query - Command
Query - Command
Query Response - Command
Stream Task - Command
Stream Task Response - Connector
- Consumer
- Create
Connector Request - Connector Related Request and Response
- Create
Query Request - Query realated Request and Response
- Create
Shard Reader Request - Create
Shard Reader Response - Delete
Connector Request - Delete
Query Request - Delete
Query Response - Delete
Shard Reader Request - Delete
Stream Request - Delete
Subscription Request - Delete
View Request - Describe
Cluster Response - Echo
Request - Echo
Response - GetConnector
Request - GetNode
Request - Nodes related Request and Response
- GetQuery
Request - GetStream
Request - GetStream
Response - GetStream
Stats Request - GetStream
Stats Response - GetSubscription
Request - GetSubscription
Response - GetSubscription
Stats Request - GetSubscription
Stats Response - GetView
Request - View related Request and Response
- HStream
Record - HStream
Record Header - List
Connectors Request - List
Connectors Response - List
Consumers Request - List
Consumers Response - List
Nodes Request - List
Nodes Response - List
Queries Request - List
Queries Response - List
Shard Readers Request - List
Shard Readers Response - List
Shards Request - List
Shards Response - List
Streams Request - TODO: Add options for filtering or max_size
- List
Streams Response - List
Streams With Prefix Request - List
Subscriptions Request - List
Subscriptions Response - List
Subscriptions With Prefix Request - List
Views Request - List
Views Response - Lookup
Connector Request - Lookup
Connector Response - Lookup
Resource Request - Lookup
Shard Reader Request - Lookup
Shard Reader Response - Lookup
Shard Request - Lookup
Shard Response - Lookup
Subscription Request - Lookup
Subscription Response - Node
- Pause
Connector Request - PerStream
Time Series Stats AllRequest - PerStream
Time Series Stats AllResponse - PerStream
Time Series Stats Request - PerStream
Time Series Stats Response - Query
- Read
Shard Request - Read
Shard Response - Received
Record - Record
Id - Restart
Query Request - Restart
Query Response - Resume
Connector Request - Server
Node - Server
Node Status - Shard
- Shard
Offset - Stats
Double Vals - Stats
Interval Vals - Stream
- Streaming
Fetch Request - Streaming
Fetch Response - Subscription
- Subscription
Offset - Terminate
Queries Request - Terminate
Queries Response - View