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

↓ 67 callersMethodlen

(&self)

src/types.rs:441

↓ 16 callersMethodencode

(&self)

src/types.rs:129

↓ 14 callersMethodflush

(&self)

src/metrics.rs:53

↓ 13 callersMethodas_raw_fd

(&self)

src/shm/eventfd.rs:137

↓ 12 callersMethodas_ref

(&self)

src/types.rs:467

↓ 11 callersMethodrecord

(&self, elapsed_us: u64)

src/metrics.rs:46

↓ 9 callersMethodencode_parts_at

( &self, sender_created_at_unix_nanos: u64, )

src/types.rs:511

↓ 9 callersFunctiontake_u64_le

(bytes: &[u8], cursor: &mut usize)

src/types.rs:1091

↓ 9 callersMethodtry_push

Push one Qlaster frame into the shared byte queue.

src/shm/ring.rs:109

↓ 8 callersMethodnotify

Increment the kernel counter; wakes any consumer epoll-waiting for readability. Returns Ok on transient saturation (counter at the cap) since the cons

src/shm/eventfd.rs:76

↓ 7 callersFunctionensure_wire

(wire_version: u8, message_tag: u8, expected_tag: u8)

src/types.rs:61

↓ 7 callersFunctionread_framed

(stream: &mut R)

src/wire.rs:7

↓ 7 callersFunctiontest_pubkey

(seed: u8)

tests/shm_flow.rs:38

↓ 7 callersFunctionunix_time_nanos

()

src/metrics.rs:6

↓ 7 callersFunctionwrite_framed

(stream: &mut W, payload: &[u8])

src/wire.rs:23

↓ 6 callersFunctiondrain_one_update

(poll: F, timeout: Duration)

tests/shm_flow.rs:42

↓ 6 callersMethodsubscribe

( &mut self, account_pubkeys: Vec<solana_pubkey::Pubkey>, account_owners: Vec<solana_p

src/consumer/shm.rs:120

↓ 6 callersFunctiontemp_ring_path

(name: &str)

src/shm/ring.rs:229

↓ 6 callersMethodtry_next_update

(&self)

src/consumer/shm.rs:199

↓ 5 callersMethodmaybe_cleanup_stale_slot

(&self, idx: usize, entry: &Arc<ManagedConnection>)

src/sender/mod.rs:260

↓ 5 callersFunctionsetup_shm_consumer

Connect to a sender's SHM control socket, perform the SHM handshake (send an empty subscribe → receive ConnectionReadyShm + ring-eventfd over SCM_RIGH

src/consumer/shm.rs:55

↓ 5 callersFunctiontake_exact

( bytes: &'a [u8], cursor: &mut usize, len: usize, context: &'static str, )

src/types.rs:1064

↓ 5 callersMethodtry_pop

Pop one frame from the queue, returning its body bytes without the length prefix. Returns `None` if the queue is empty or a close sentinel was consume

src/shm/ring.rs:192

↓ 4 callersFunctiondecode_server_frame

(bytes: &[u8])

src/types.rs:355

↓ 4 callersMethodis_empty

(&self)

src/types.rs:445

↓ 4 callersMethodpass_fd

(&self)

src/shm/eventfd.rs:69

↓ 4 callersMethodread_exact

src/sender/mod.rs:655

↓ 4 callersFunctionshm_config

(label: &str)

tests/shm_flow.rs:29

↓ 4 callersFunctiontake_u32_le

(bytes: &[u8], cursor: &mut usize)

src/types.rs:1084

↓ 4 callersFunctionwire_tag

(bytes: &[u8])

src/types.rs:338

↓ 4 callersMethodwith_request

(&self, req: &SubscriptionRequest)

src/sender/mod.rs:174

↓ 3 callersMethodclose

Mark the queue closed for the consumer by publishing a sentinel frame.

src/shm/ring.rs:140

↓ 3 callersFunctionconfigure_pipe_fd

(fd: RawFd)

src/shm/eventfd.rs:161

↓ 3 callersMethodencode_parts

(&self)

src/types.rs:565

↓ 3 callersMethodpush_to_entry

( &self, entry: &Arc<ManagedConnection>, frame: OutboundFrame, metrics: &Qlast

src/sender/mod.rs:430

↓ 3 callersFunctionrecord_decode_and_enqueue

( metrics: &QlasterConsumerMetrics, read_elapsed_us: u64, decode_start: Instant, sender_create

src/consumer/shm.rs:301

↓ 3 callersMethodslot_token

(&self)

src/consumer/shm.rs:190

↓ 3 callersFunctiontake_u8

(bytes: &[u8], cursor: &mut usize)

src/types.rs:1080

↓ 3 callersMethodwith_slot_token

(mut self, slot_token: Option<SlotToken>)

↓ 2 callersMethodas_slice

(&self)

src/types.rs:437

↓ 2 callersMethodclone_bytes

(&self)

src/types.rs:453

↓ 2 callersFunctiondrain_one_transaction

(poll: F, timeout: Duration)

tests/shm_flow.rs:58

↓ 2 callersMethodis_closed

(&self)

src/shm/ring.rs:185

↓ 2 callersMethodlookup_by_token

(&self, token: SlotToken)

src/sender/mod.rs:274

↓ 2 callersMethodmetrics

(&self)

src/sender/mod.rs:76

↓ 2 callersFunctionrecv_frame_with_fd

Receive a length-prefixed payload that was sent with an attached fd via `send_frame_with_fd`. Returns the payload bytes and the (received-side duplica

src/shm/uds.rs:86

↓ 2 callersFunctionsend_frame_with_fd

Send a length-prefixed `payload` and a single file descriptor in one `sendmsg` call. The receiver MUST call `recv_frame_with_fd` to retrieve the fd (a

src/shm/uds.rs:59

↓ 2 callersMethodsend_subscription

( &mut self, request: SubscriptionRequest, )

src/consumer/shm.rs:135

↓ 2 callersFunctionset_nosigpipe

Suppress SIGPIPE for writes on this socket. On Linux this is a no-op: each send already passes `MSG_NOSIGNAL`. On macOS/BSD that flag is not reliably

src/shm/uds.rs:31

↓ 2 callersFunctionsetup_sender

( config: SenderConfig, master_updates: broadcast::Sender<AccountUpdate>, bloom_updates_tx: Option

src/sender/mod.rs:550

↓ 2 callersFunctionsetup_sender_with_streams

( config: SenderConfig, master_updates: broadcast::Sender<AccountUpdate>, transaction_updates: Opt

src/sender/mod.rs:577

↓ 2 callersFunctionsetup_sender_with_transactions

( config: SenderConfig, master_updates: broadcast::Sender<AccountUpdate>, transaction_updates: Opt

src/sender/mod.rs:559

↓ 2 callersFunctiontake_array_32

(bytes: &[u8], cursor: &mut usize)

src/types.rs:1098

↓ 2 callersMethodtry_next_transaction

(&self)

src/consumer/shm.rs:203

↓ 2 callersMethodwait

Block until the eventfd is signaled, returning the accumulated notify count since the last call.

src/shm/eventfd.rs:338

↓ 1 callersFunctionbind_listener

Bind the UDS socket and prepare the per-process shm directory.

src/sender/shm.rs:26

↓ 1 callersMethodcleanup_if_same

(&self, slot_index: usize, connection_id: u64)

src/sender/mod.rs:246

↓ 1 callersFunctiondecode_client_frame

(bytes: &[u8])

src/types.rs:344

↓ 1 callersFunctiondecode_server_frame_owned

(bytes: Vec<u8>)

src/types.rs:371

↓ 1 callersFunctiondecode_server_frame_owned_with_meta

( bytes: Vec<u8>, )

src/types.rs:387

↓ 1 callersMethoddispatch_account_update

(&self, update: AccountUpdate, metrics: &QlasterSenderMetrics)

src/sender/mod.rs:315

↓ 1 callersMethoddispatch_slot_update

(&self, update: SlotUpdate, metrics: &QlasterSenderMetrics)

src/sender/mod.rs:395

↓ 1 callersMethoddispatch_transaction_update

( &self, update: TransactionUpdate, metrics: &QlasterSenderMetrics, )

src/sender/mod.rs:353

↓ 1 callersMethoddrain

Read and reset the counter. Returns `Ok(0)` if no wakeup is pending.

src/shm/eventfd.rs:106

↓ 1 callersFunctiondrain_one_slot

(poll: F, timeout: Duration)

tests/shm_flow.rs:74

↓ 1 callersFunctionelapsed_since_unix_time_nanos_us

(start_nanos: u64)

src/metrics.rs:14

↓ 1 callersFunctionencode_account_frame

(update: &AccountUpdate)

src/sender/mod.rs:520

↓ 1 callersFunctionencode_slot_frame

(update: &SlotUpdate)

src/sender/mod.rs:540

↓ 1 callersFunctionencode_transaction_frame

(update: &TransactionUpdate)

src/sender/mod.rs:530

↓ 1 callersMethodfind_free_slot

(&self)

src/sender/mod.rs:289

↓ 1 callersFunctionhandle_uds_connection

( state: Arc<SenderState>, mut stream: UnixStream, cfg: ShmTransportConfig, )

↓ 1 callersMethodmatches_account

(&self, update: &AccountUpdate)

src/sender/mod.rs:186

↓ 1 callersMethodmatches_transaction

(&self)

src/sender/mod.rs:214

↓ 1 callersMethodopen

Open an existing queue file.

src/shm/ring.rs:159

↓ 1 callersFunctionrecvmsg_with_fd

# Safety `sock` must be a valid open socket fd that the caller does not close concurrently for the duration of the call.

src/shm/uds.rs:177

↓ 1 callersFunctionrun_listener

( state: Arc<SenderState>, handle: ShmListenerHandle, )

src/sender/shm.rs:55

↓ 1 callersFunctionrun_reader

( ring: Arc<ShmRingConsumer>, updates: Arc<ArrayQueue<AccountUpdate>>, transactions: Arc<ArrayQueu

src/consumer/shm.rs:216

↓ 1 callersMethodsend_ping

(&mut self)

src/consumer/shm.rs:177

↓ 1 callersFunctionsendmsg_with_fd

# Safety `sock` must be a valid open socket fd and `fd` a valid open fd, neither closed concurrently for the duration of the call.

src/shm/uds.rs:119

↓ 1 callersFunctionsetup_shm_consumer_with_metrics

( uds_path: impl AsRef<Path>, metrics: Arc<QlasterConsumerMetrics>, )

src/consumer/shm.rs:61

↓ 1 callersFunctionshould_attempt_lz4

(payload: &[u8])

src/types.rs:26

↓ 1 callersMethodsubscribe_transactions

(&mut self)

src/consumer/shm.rs:130

↓ 1 callersFunctiontake_array_64

(bytes: &[u8], cursor: &mut usize)

src/types.rs:1104

↓ 1 callersMethodtouch_ping

(&self, ping: &PingRequest)

src/sender/mod.rs:305

↓ 1 callersMethodtry_next_slot

(&self)

src/consumer/shm.rs:207

↓ 1 callersFunctionunique_paths

(label: &str)

tests/shm_flow.rs:17

↓ 1 callersMethodupsert_shm

SHM provisioning info returned to the UDS handshake on first install.

src/sender/mod.rs:454

↓ 1 callersMethodwith_transactions

(mut self)

src/types.rs:124

Functionaccount_payload_rejects_oversized_data

()

src/types.rs:1420

Functionaccount_update_carries_sender_timestamp_metadata

()

src/types.rs:1234

Functionaccount_update_roundtrip

()

src/types.rs:1217

Functionadd_request_updates_existing_filter_contents

()

src/sender/mod.rs:705

Methodapply_request

(filter: &Arc<ArcSwap<SubscriptionFilter>>, request: &SubscriptionRequest)

src/sender/mod.rs:220

Functionasync_wait_resolves_after_notify

()

src/shm/eventfd.rs:375

next →1–100 of 169, ranked by callers