Index

D

DOUBLE (river.FieldType attribute)

dtype() (river.StreamSchema method)

F

field_definitions (river.StreamSchema attribute) FieldDefinition (class in river) FieldType (class in river)

FIXED_WIDTH_BYTES (river.FieldType attribute) FLOAT (river.FieldType attribute) from_dtype() (river.StreamSchema static method)

G

good (river.StreamReader attribute)

I

initialize() (river.StreamReader method) (river.StreamWriter method) initialized_at_us (river.StreamReader attribute) (river.StreamWriter attribute)

INT16 (river.FieldType attribute) INT32 (river.FieldType attribute) INT64 (river.FieldType attribute)

M

metadata (river.StreamReader attribute) (river.StreamWriter attribute)

N

name (river.FieldDefinition attribute)

new_buffer() (river.StreamReader method) (river.StreamWriter method)

R

read() (river.StreamReader method) redis_hostname (river.RedisConnection attribute) redis_password (river.RedisConnection attribute) redis_port (river.RedisConnection attribute) RedisConnection (class in river) RedisException (class in river) river::FieldDefinition (C++ struct) river::FieldDefinition::type (C++ enum) river::FieldDefinition::type::DOUBLE (C++ enumerator) river::FieldDefinition::type::FIXED_WIDTH_BYTES (C++ enumerator) river::FieldDefinition::type::FLOAT (C++ enumerator) river::FieldDefinition::type::INT16 (C++ enumerator) river::FieldDefinition::type::INT32 (C++ enumerator) river::FieldDefinition::type::INT64 (C++ enumerator) river::FieldDefinition::type::VARIABLE_WIDTH_BYTES (C++ enumerator) river::internal::RedisException (C++ class) river::RedisConnection (C++ class) river::StreamReader (C++ class) river::StreamReader::AddListener (C++ function) river::StreamReader::eof_key (C++ function) river::StreamReader::Good (C++ function) river::StreamReader::Initialize (C++ function) river::StreamReader::initialized_at_us (C++ function) river::StreamReader::is_initialized (C++ function)

river::StreamReader::local_minus_server_clock_us (C++ function) river::StreamReader::Metadata (C++ function) river::StreamReader::operator bool (C++ function) river::StreamReader::Read (C++ function) river::StreamReader::ReadBytes (C++ function) river::StreamReader::schema (C++ function) river::StreamReader::Seek (C++ function) river::StreamReader::Stop (C++ function) river::StreamReader::StreamReader (C++ function) river::StreamReader::Tail (C++ function) river::StreamReader::TailBytes (C++ function) river::StreamReader::total_samples_read (C++ function) river::StreamSchema (C++ class) river::StreamWriter (C++ class) river::StreamWriter::Initialize (C++ function) river::StreamWriter::initialized_at_us (C++ function) river::StreamWriter::Metadata (C++ function) river::StreamWriter::schema (C++ function) river::StreamWriter::SetMetadata (C++ function) river::StreamWriter::Stop (C++ function) river::StreamWriter::stream_name (C++ function) river::StreamWriter::StreamWriter (C++ function) river::StreamWriter::total_samples_written (C++ function) river::StreamWriter::Write (C++ function) river::StreamWriter::WriteBytes (C++ function)

S

schema (river.StreamReader attribute) (river.StreamWriter attribute) stop() (river.StreamReader method) (river.StreamWriter method) stream_name (river.StreamReader attribute) (river.StreamWriter attribute)

StreamDoesNotExistException (class in river) StreamExistsException (class in river) StreamReader (class in river) StreamReaderException (class in river) StreamSchema (class in river) StreamWriter (class in river) StreamWriterException (class in river)

T

tail() (river.StreamReader method) total_samples_read (river.StreamReader attribute)

total_samples_written (river.StreamWriter attribute) type (river.FieldDefinition attribute)

V

VARIABLE_WIDTH_BYTES (river.FieldType attribute)

W

write() (river.StreamWriter method)