# Packages
No description provided by the author
No description provided by the author
No description provided by the author
# Functions
No description provided by the author
No description provided by the author
No description provided by the author
EnableBacklog sets the backlog duration in seconds for the stream.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
NewRecordOffset create a RecordOffset of a shard.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
TimeOut set millisecond time-trigger for BatchProducer to flush data to server.
No description provided by the author
WithAckTimeout sets the ack timeout in seconds.
WithBatch set the batchSize-trigger for BatchProducer, batchSize must greater than 0.
WithCaCert set ca path.
WithClientCert set client cert path.
WithClientKey set client key path.
WithCompression set the compression algorithm.
WithFlowControl set the flow control for BatchProducer.
WithMaxRecords is used to specify the maximum number of records that can be read in a single read.
WithMaxUnackedRecords sets the max unacked records.
WithOffset sets the subscription offset.
WithReaderTimeout is used to specify read timeout.
WithReplicationFactor sets the replication factor of the stream.
WithShardCount sets the number of shards in the stream.
WithShardOffset is used to specify the read offset of the reader.
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
1MB.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
EarliestShardOffset specifies that the data is read from the start of the shard.
No description provided by the author
No description provided by the author
LatestShardOffset specifies that the data is read from the current tail of the shard.
# Structs
BatchProducer is a producer that can batch write multiple records to the specified stream.
Consumer will consume records from specific subscription.
FetchRecords encapsulates the results of StreamingFetch.
No description provided by the author
HStreamClient is the client for the HStreamDB service.
Producer produce a single piece of data to the specified stream.
No description provided by the author
No description provided by the author
ShardReader is used to read data from the specified shard.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Interfaces
AppendResult is a handler to process the results of append operation.
ShardOffset is used to specify a specific offset for the shardReader.
No description provided by the author
No description provided by the author
# Type aliases
No description provided by the author
DeleteStreamOpts is the option for DeleteStream.
ProducerOpt is the option for the BatchProducer.
No description provided by the author
ShardReaderOpts is the option for the ShardReader.
StreamOpts is the option for the Stream.
No description provided by the author
No description provided by the author
SubscriptionOpts is the option for the Subscription.
No description provided by the author
TLSOps set tls configurations.
No description provided by the author