StreamReader
StreamReader.good
StreamReader.initialize()
StreamReader.initialized_at_us
StreamReader.metadata
StreamReader.new_buffer()
StreamReader.read()
StreamReader.schema
StreamReader.stop()
StreamReader.stream_name
StreamReader.tail()
StreamReader.total_samples_read
StreamWriter
StreamWriter.initialize()
StreamWriter.initialized_at_us
StreamWriter.metadata
StreamWriter.new_buffer()
StreamWriter.schema
StreamWriter.stop()
StreamWriter.stream_name
StreamWriter.total_samples_written
StreamWriter.write()
RedisConnection
RedisConnection.redis_hostname
RedisConnection.redis_password
RedisConnection.redis_port
StreamSchema
StreamSchema.dtype()
StreamSchema.field_definitions
StreamSchema.from_dtype()
FieldDefinition
FieldDefinition.name
FieldDefinition.type
FieldType
FieldType.DOUBLE
FieldType.FIXED_WIDTH_BYTES
FieldType.FLOAT
FieldType.INT16
FieldType.INT32
FieldType.INT64
FieldType.VARIABLE_WIDTH_BYTES
RedisException
StreamReaderException
StreamWriterException
StreamDoesNotExistException
StreamExistsException