Index A | B | C | D | E | F | G | H | I | L | M | N | P | R | S | T | U A ACTIVE (streamstore.schemas.BasinState attribute) append() (streamstore._client.Stream method) append_inputs_gen() (in module streamstore.utils) append_session() (streamstore._client.Stream method) AppendInput (class in streamstore.schemas) AppendOutput (class in streamstore.schemas) AWS (streamstore.schemas.Cloud attribute) B Basin (class in streamstore._client) basin() (streamstore.S2 method) BasinConfig (class in streamstore.schemas) BasinInfo (class in streamstore.schemas) body (streamstore.schemas.Record attribute) (streamstore.schemas.SequencedRecord attribute) bytes (streamstore.schemas.ReadLimit attribute) C cell (streamstore.schemas.BasinInfo attribute) check_tail() (streamstore._client.Stream method) close() (streamstore.S2 method) CommandRecord (class in streamstore.utils) count (streamstore.schemas.ReadLimit attribute) create_basin() (streamstore.S2 method) create_stream() (streamstore._client.Basin method) created_at (streamstore.schemas.StreamInfo attribute) CREATING (streamstore.schemas.BasinState attribute) D default_stream_config (streamstore.schemas.BasinConfig attribute) delete_basin() (streamstore.S2 method) delete_stream() (streamstore._client.Basin method) deleted_at (streamstore.schemas.StreamInfo attribute) DELETING (streamstore.schemas.BasinState attribute) E end_seq_num (streamstore.schemas.AppendOutput attribute) EXPRESS (streamstore.schemas.StorageClass attribute) F fence() (streamstore.utils.CommandRecord static method) fencing_token (streamstore.schemas.AppendInput attribute) FirstSeqNum (class in streamstore.schemas) G get_basin_config() (streamstore.S2 method) get_stream_config() (streamstore._client.Basin method) H has_more (streamstore.schemas.Page attribute) headers (streamstore.schemas.Record attribute) (streamstore.schemas.SequencedRecord attribute) I items (streamstore.schemas.Page attribute) L list_basins() (streamstore.S2 method) list_streams() (streamstore._client.Basin method) M match_seq_num (streamstore.schemas.AppendInput attribute) metered_bytes() (in module streamstore.utils) module streamstore streamstore._client streamstore.schemas streamstore.utils N name (streamstore._client.Basin property) (streamstore._client.Stream property) (streamstore.schemas.BasinInfo attribute) (streamstore.schemas.StreamInfo attribute) next_seq_num (streamstore.schemas.AppendOutput attribute) NextSeqNum (class in streamstore.schemas) P Page (class in streamstore.schemas) R read() (streamstore._client.Stream method) read_session() (streamstore._client.Stream method) ReadLimit (class in streamstore.schemas) reconfigure_basin() (streamstore.S2 method) reconfigure_stream() (streamstore._client.Basin method) Record (class in streamstore.schemas) records (streamstore.schemas.AppendInput attribute) retention_age (streamstore.schemas.StreamConfig attribute) S S2 (class in streamstore) S2Error scope (streamstore.schemas.BasinInfo attribute) seq_num (streamstore.schemas.SequencedRecord attribute) SequencedRecord (class in streamstore.schemas) STANDARD (streamstore.schemas.StorageClass attribute) start_seq_num (streamstore.schemas.AppendOutput attribute) state (streamstore.schemas.BasinInfo attribute) storage_class (streamstore.schemas.StreamConfig attribute) Stream (class in streamstore._client) stream() (streamstore._client.Basin method) StreamConfig (class in streamstore.schemas) StreamInfo (class in streamstore.schemas) streamstore module streamstore._client module streamstore.schemas module streamstore.utils module T trim() (streamstore.utils.CommandRecord static method) U UNSPECIFIED (streamstore.schemas.BasinState attribute) (streamstore.schemas.StorageClass attribute)