EnableBacklog sets the backlog duration in seconds for the stream.

NewRecordOffset create a RecordOffset of a shard.

TimeOut set millisecond time-trigger for BatchProducer to flush data to server.

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.

1MB.

EarliestShardOffset specifies that the data is read from the start of the shard.

LatestShardOffset specifies that the data is read from the current tail of the shard.

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.

HStreamClient is the client for the HStreamDB service.

Producer produce a single piece of data to the specified stream.

ShardReader is used to read data from the specified shard.

AppendResult is a handler to process the results of append operation.

ShardOffset is used to specify a specific offset for the shardReader.

DeleteStreamOpts is the option for DeleteStream.

ProducerOpt is the option for the BatchProducer.

ShardReaderOpts is the option for the ShardReader.

StreamOpts is the option for the Stream.

SubscriptionOpts is the option for the Subscription.

TLSOps set tls configurations.