Struct SharedStringArena 

pub struct SharedStringArena { /* private fields */ }

Implementations

impl SharedStringArena

pub fn create( path: impl AsRef<Path>, capacity_bytes: usize, ) -> Result<Self, ArenaError>

pub fn open( path: impl AsRef<Path>, expected_capacity_bytes: usize, ) -> Result<Self, ArenaError>

pub fn capacity_bytes(&self) -> usize

pub fn used_bytes(&self) -> usize

pub fn remaining_bytes(&self) -> usize

pub fn intern(&self, s: &str) -> Result<StringRef, ArenaError>

Append a string to the arena. Returns a StringRef that resolves to the bytes in any mapping of the same file.

Returns Err(Full) when the arena has no room. The empty string "" interns at the current offset with len = 0.

pub fn intern_bytes(&self, bytes: &[u8]) -> Result<StringRef, ArenaError>

Append arbitrary bytes (not necessarily UTF-8) to the arena. Useful for storing binary blobs alongside strings. Retrieve with get_bytes; get will reject non-UTF-8 with InvalidUtf8.

pub fn get_bytes(&self, r: StringRef) -> Result<&[u8], ArenaError>

Resolve a StringRef to its &[u8]. Returns Err(InvalidRef) when the ref doesn’t fall inside the arena’s used region.

pub fn get(&self, r: StringRef) -> Result<&str, ArenaError>

Resolve a StringRef to a &str. Returns Err(InvalidUtf8) when the bytes aren’t valid UTF-8 (the arena doesn’t enforce validity per-segment; it’s checked on read).

pub fn intern_and_get(&self, s: &str) -> Result<(StringRef, &str), ArenaError>

Convenience: intern AND return a &str view into the just-written bytes plus the ref.

pub fn clear(&self)

Reset the arena to empty. NOT concurrency-safe; callers must ensure no other threads/processes are interning or reading. Existing StringRefs become invalid (their bytes may be overwritten by subsequent interns).

pub fn flush(&self) -> Result<(), ArenaError>

pub fn flush_async(&self) -> Result<(), ArenaError>

Non-blocking flush: schedules a writeback via the OS. Note: Windows is only partially async (sync to page cache, not to disk).

Trait Implementations

impl AdaptiveInstance for SharedStringArena

fn header(&self) -> &HandshakeHeader

fn ring(&self) -> &ObservationRing

fn make_policy(&self) -> Box<dyn Policy>

fn apply_migration(&self, new_tag: u32)

Called by the sidecar when the policy returns a new strategy tag. Default implementation: just set the tag on the header. Primitives that need heavier migration (data-layout swap) override this to perform the swap before (or after) updating the tag.

impl Send for SharedStringArena

impl Sync for SharedStringArena