Functions — github.com/brewlabshq/qlaster-public

hub / github.com/brewlabshq/qlaster-public / functions

Functions169 in github.com/brewlabshq/qlaster-public

⨍ Functions 169◇ Types & classes 43

Functionclose_sentinel_marks_consumer_closed

()

src/shm/ring.rs:313

Functioncompression_probe_accepts_low_entropy_payload

()

src/types.rs:1432

Functioncompression_probe_rejects_high_entropy_payload

()

src/types.rs:1438

Functioncompression_probe_skips_below_threshold

()

src/types.rs:1451

Functionconnection_ready_shm_rejects_missing_fields

()

src/types.rs:1187

Functionconnection_ready_shm_roundtrip

()

src/types.rs:1172

Methodcreate

Create a new shared-memory byte queue at `path` with at least `capacity` bytes of queue storage.

src/shm/ring.rs:60

Functioncreate_and_simple_push_pop_roundtrip

Methoddecode_owned_with_meta

( bytes: Vec<u8>, )

src/types.rs:607

Functiondecode_rejects_truncated_and_garbage_payloads

()

src/types.rs:1396

Methoddecode_with_meta

(uds_path: impl Into<PathBuf>)

src/consumer/shm.rs:47

Methoddropped_frames

(&self)

src/shm/ring.rs:144

Functionempty_filter_matches_nothing

()

src/sender/mod.rs:743

Functionfilter_from_request_deduplicates_and_matches_pubkey_or_owner

()

src/sender/mod.rs:684

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/shm/ring.rs:31

Functionframe_decode_routes_by_tag

()

src/types.rs:1317

Functionframe_larger_than_capacity_is_rejected

()

src/shm/ring.rs:302

Functionframed_roundtrip_supports_multiple_and_empty_payloads

( decoded: DecodedAccountUpdate, payload: Bytes, )

src/types.rs:641

Methodfrom_owned_fd

(fd: OwnedFd)

src/shm/eventfd.rs:61

Methodfrom_request

(req: &SubscriptionRequest)

src/sender/mod.rs:160

Methodfrom_sets

( account_pubkeys: HashSet<solana_pubkey::Pubkey>, account_owners: HashSet<solana_pubkey::Pubk

src/sender/mod.rs:128

(entry: &ManagedConnection)

src/sender/mod.rs:240

Methodmetrics

(&self)

src/consumer/shm.rs:211

Functionmulti_part_frames_concatenate_correctly

()

src/shm/ring.rs:253

Functionmultiple_shm_consumers_get_disjoint_filters

()

tests/shm_flow.rs:350

Methodnew

(slot_index: u8, generation: u64)

src/shm/eventfd.rs:46

Methodnew

()

src/sender/mod.rs:226

Functionnotify_on_consumer_side_handle_is_unsupported

()

src/shm/eventfd.rs:408

Functionnotify_then_drain_returns_count

()

src/shm/eventfd.rs:363

Methodnow_ms

()

src/sender/mod.rs:233

Functionping_and_ready_roundtrip

()

src/types.rs:1201

Functionqueue_wraps_without_splitting_frames

()

src/shm/ring.rs:281

Functionread_framed_rejects_oversized_frame_header

()

src/wire.rs:62

Functionread_framed_rejects_truncated_payload

()

src/wire.rs:80

Functionrequest_rejects_invalid_version_and_tag

()

src/types.rs:1338

Functionring_full_returns_shm_full_and_drops_frame

()

src/shm/ring.rs:266

Functionround_trip_payload_and_fd

()

src/shm/uds.rs:255

Functionround_trip_without_fd_returns_none

()

src/shm/uds.rs:282

Functionsample_update

(account_pubkey: Pubkey, account_owner: Pubkey)

src/sender/mod.rs:670

Methodshm

(ring: Arc<ShmRingProducer>, wakeup: Arc<EventFd>)

src/transport.rs:32

Functionshm_end_to_end_filter_and_delivery

()

tests/shm_flow.rs:91

Functionshm_slot_stream_is_always_on

()

tests/shm_flow.rs:304

Functionshm_transaction_stream_requires_subscription

()

tests/shm_flow.rs:214

Methodslot_token

(entry: &ManagedConnection)

src/sender/mod.rs:270

Functionslot_update_roundtrip_and_metadata

()

src/types.rs:1291

Functionsubscription_request_roundtrip

Functiontransaction_subscription_is_explicit_and_sticky

()

src/sender/mod.rs:730

Functiontransaction_update_roundtrip_and_metadata

Push a frame to the ring. On failure (sink closed / ring out of room), the frame is returned so the caller can drop the slow consumer.

src/transport.rs:38

Functionupdate_rejects_invalid_version_and_tag

()

src/types.rs:1363

Methodwith_slot_write_version

(mut self, slot: u64, write_version: u64)

src/types.rs:505

← previous101–169 of 169, ranked by callers