Index A | B | C | D | E | F | G | H | I | L | M | N | O | P | R | S | T | U | V | W A access_tokens (streamstore.schemas.AccessTokenScope attribute) AccessTokenInfo (class in streamstore.schemas) AccessTokenScope (class in streamstore.schemas) account (streamstore.schemas.OperationGroupPermissions attribute) ACTIVE (streamstore.schemas.BasinState attribute) APPEND (streamstore.schemas.Operation attribute) append() (streamstore.Stream method) append_inputs_gen() (in module streamstore.utils) append_session() (streamstore.Stream method) AppendInput (class in streamstore.schemas) AppendOutput (class in streamstore.schemas) ARRIVAL (streamstore.schemas.TimestampingMode attribute) auto_prefix_streams (streamstore.schemas.AccessTokenInfo attribute) AWS (streamstore.schemas.Cloud attribute) AWS_US_EAST_1 (streamstore.schemas.BasinScope attribute) B Basin (class in streamstore) basin (streamstore.schemas.OperationGroupPermissions attribute) basin() (streamstore.S2 method) BasinConfig (class in streamstore.schemas) BasinInfo (class in streamstore.schemas) basins (streamstore.schemas.AccessTokenScope attribute) body (streamstore.schemas.Record attribute) (streamstore.schemas.SequencedRecord attribute) bytes (streamstore.schemas.ReadLimit attribute) C CHECK_TAIL (streamstore.schemas.Operation attribute) check_tail() (streamstore.Stream method) CLIENT_PREFER (streamstore.schemas.TimestampingMode attribute) CLIENT_REQUIRE (streamstore.schemas.TimestampingMode attribute) close() (streamstore.S2 method) CommandRecord (class in streamstore.utils) count (streamstore.schemas.ReadLimit attribute) CREATE_BASIN (streamstore.schemas.Operation attribute) create_basin() (streamstore.S2 method) CREATE_STREAM (streamstore.schemas.Operation attribute) create_stream() (streamstore.Basin method) create_stream_on_append (streamstore.schemas.BasinConfig attribute) created_at (streamstore.schemas.StreamInfo attribute) CREATING (streamstore.schemas.BasinState attribute) D default_stream_config (streamstore.schemas.BasinConfig attribute) DELETE_BASIN (streamstore.schemas.Operation attribute) delete_basin() (streamstore.S2 method) delete_on_empty_min_age (streamstore.schemas.StreamConfig attribute) DELETE_STREAM (streamstore.schemas.Operation attribute) delete_stream() (streamstore.Basin method) deleted_at (streamstore.schemas.StreamInfo attribute) DELETING (streamstore.schemas.BasinState attribute) E end_seq_num (streamstore.schemas.AppendOutput attribute) end_timestamp (streamstore.schemas.AppendOutput attribute) Endpoints (class in streamstore.schemas) EXACT (streamstore.schemas.ResourceMatchOp attribute) expires_at (streamstore.schemas.AccessTokenInfo attribute) EXPRESS (streamstore.schemas.StorageClass attribute) F fence() (streamstore.utils.CommandRecord static method) fencing_token (streamstore.schemas.AppendInput attribute) FirstSeqNum (class in streamstore.schemas) for_cloud() (streamstore.schemas.Endpoints class method) G GET_BASIN_CONFIG (streamstore.schemas.Operation attribute) get_basin_config() (streamstore.S2 method) GET_STREAM_CONFIG (streamstore.schemas.Operation attribute) get_stream_config() (streamstore.Basin method) H has_more (streamstore.schemas.Page attribute) headers (streamstore.schemas.Record attribute) (streamstore.schemas.SequencedRecord attribute) I id (streamstore.schemas.AccessTokenInfo attribute) ISSUE_ACCESS_TOKEN (streamstore.schemas.Operation attribute) issue_access_token() (streamstore.S2 method) items (streamstore.schemas.Page attribute) L last_timestamp (streamstore.schemas.AppendOutput attribute) (streamstore.schemas.Tail attribute) LIST_ACCESS_TOKENS (streamstore.schemas.Operation attribute) list_access_tokens() (streamstore.S2 method) LIST_BASINS (streamstore.schemas.Operation attribute) list_basins() (streamstore.S2 method) LIST_STREAMS (streamstore.schemas.Operation attribute) list_streams() (streamstore.Basin method) M match_op (streamstore.schemas.ResourceMatchRule attribute) match_seq_num (streamstore.schemas.AppendInput attribute) metered_bytes() (in module streamstore.utils) mode (streamstore.schemas.Timestamping attribute) module streamstore streamstore.schemas streamstore.utils N name (streamstore.Basin property) (streamstore.schemas.BasinInfo attribute) (streamstore.schemas.StreamInfo attribute) (streamstore.Stream property) next_seq_num (streamstore.schemas.AppendOutput attribute) (streamstore.schemas.Tail attribute) NextSeqNum (class in streamstore.schemas) O op_group_perms (streamstore.schemas.AccessTokenScope attribute) OperationGroupPermissions (class in streamstore.schemas) ops (streamstore.schemas.AccessTokenScope attribute) P Page (class in streamstore.schemas) PREFIX (streamstore.schemas.ResourceMatchOp attribute) R READ (streamstore.schemas.Operation attribute) (streamstore.schemas.Permission attribute) read() (streamstore.Stream method) read_session() (streamstore.Stream method) READ_WRITE (streamstore.schemas.Permission attribute) ReadLimit (class in streamstore.schemas) RECONFIGURE_BASIN (streamstore.schemas.Operation attribute) reconfigure_basin() (streamstore.S2 method) RECONFIGURE_STREAM (streamstore.schemas.Operation attribute) reconfigure_stream() (streamstore.Basin method) Record (class in streamstore.schemas) records (streamstore.schemas.AppendInput attribute) ResourceMatchRule (class in streamstore.schemas) retention_policy (streamstore.schemas.StreamConfig attribute) REVOKE_ACCESS_TOKEN (streamstore.schemas.Operation attribute) revoke_access_token() (streamstore.S2 method) S S2 (class in streamstore) scope (streamstore.schemas.AccessTokenInfo attribute) (streamstore.schemas.BasinInfo attribute) seq_num (streamstore.schemas.SequencedRecord attribute) SeqNum (class in streamstore.schemas) SequencedRecord (class in streamstore.schemas) STANDARD (streamstore.schemas.StorageClass attribute) start_seq_num (streamstore.schemas.AppendOutput attribute) start_timestamp (streamstore.schemas.AppendOutput attribute) state (streamstore.schemas.BasinInfo attribute) storage_class (streamstore.schemas.StreamConfig attribute) Stream (class in streamstore) stream (streamstore.schemas.OperationGroupPermissions attribute) stream() (streamstore.Basin method) StreamConfig (class in streamstore.schemas) StreamInfo (class in streamstore.schemas) streams (streamstore.schemas.AccessTokenScope attribute) streamstore module streamstore.schemas module streamstore.utils module T Tail (class in streamstore.schemas) TailOffset (class in streamstore.schemas) Timestamp (class in streamstore.schemas) timestamp (streamstore.schemas.Record attribute) (streamstore.schemas.SequencedRecord attribute) Timestamping (class in streamstore.schemas) timestamping (streamstore.schemas.StreamConfig attribute) trim() (streamstore.utils.CommandRecord static method) U uncapped (streamstore.schemas.Timestamping attribute) UNSPECIFIED (streamstore.schemas.BasinScope attribute) (streamstore.schemas.BasinState attribute) (streamstore.schemas.Operation attribute) (streamstore.schemas.Permission attribute) (streamstore.schemas.TimestampingMode attribute) V value (streamstore.schemas.ResourceMatchRule attribute) W WRITE (streamstore.schemas.Permission attribute)