Index

A

ack_timeout (hstreamdb.Subscription attribute) append() (hstreamdb.BufferedProducer method) (hstreamdb.HStreamDBClient method)

attributes (hstreamdb.RecordHeader attribute)

B

batch_id (hstreamdb.RecordId attribute) batch_index (hstreamdb.RecordId attribute)

BufferedProducer (class in hstreamdb) BufferedProducer.AppendCallback (class in hstreamdb)

C

close() (hstreamdb.BufferedProducer method) Consumer (class in hstreamdb)

create_reader() (hstreamdb.HStreamDBClient method) create_stream() (hstreamdb.HStreamDBClient method) create_subscription() (hstreamdb.HStreamDBClient method)

D

delete_reader() (hstreamdb.HStreamDBClient method) delete_stream() (hstreamdb.HStreamDBClient method)

delete_subscription() (hstreamdb.HStreamDBClient method) does_subscription_exist() (hstreamdb.HStreamDBClient method)

F

flush() (hstreamdb.BufferedProducer method)

flush_by_key() (hstreamdb.BufferedProducer method) flushall() (hstreamdb.BufferedProducer method)

G

GroupKeyTy (hstreamdb.BufferedProducer attribute)

H

header (hstreamdb.Record attribute) hstreamdb module

HStreamDBClient (class in hstreamdb)

I

id (hstreamdb.Record attribute)

init_cluster_info() (hstreamdb.HStreamDBClient method) insecure_client() (in module hstreamdb)

K

key (hstreamdb.RecordHeader attribute)

L

list_shards() (hstreamdb.HStreamDBClient method)

list_streams() (hstreamdb.HStreamDBClient method) list_subscriptions() (hstreamdb.HStreamDBClient method)

M

max_unacks (hstreamdb.Subscription attribute)

module hstreamdb

N

name (hstreamdb.Stream attribute) nanos (hstreamdb.TimeStamp attribute)

new_consumer() (hstreamdb.HStreamDBClient method) new_producer() (hstreamdb.HStreamDBClient method)

O

on_fail() (hstreamdb.BufferedProducer.AppendCallback method)

on_success() (hstreamdb.BufferedProducer.AppendCallback method)

P

payload (hstreamdb.Record attribute)

publish_time (hstreamdb.RecordHeader attribute)

R

read_reader() (hstreamdb.HStreamDBClient method) Record (class in hstreamdb) RecordHeader (class in hstreamdb)

RecordId (class in hstreamdb) replication_factor (hstreamdb.Stream attribute) ResponseTy (hstreamdb.Consumer attribute)

S

seconds (hstreamdb.TimeStamp attribute) secure_client() (in module hstreamdb) shard_id (hstreamdb.RecordId attribute) start() (hstreamdb.Consumer method)

Stream (class in hstreamdb) stream_name (hstreamdb.Subscription attribute) StreamKeyId (hstreamdb.BufferedProducer attribute) Subscription (class in hstreamdb) subscription_id (hstreamdb.Subscription attribute)

T

TimeStamp (class in hstreamdb)

W

wait() (hstreamdb.BufferedProducer method)

wait_and_close() (hstreamdb.BufferedProducer method) with_reader() (hstreamdb.HStreamDBClient method)