API

• Python Docs
  • 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
• C++ Docs