Functions — github.com/arthurprs/floki

hub / github.com/arthurprs/floki / functions

Functions215 in github.com/arthurprs/floki

⨍ Functions 215◇ Types & classes 41

↓ 36 callersMethodget

get access is suposed to be thread-safe, even while writing

src/queue.rs:146

↓ 32 callersMethodread

()

src/config.rs:91

↓ 25 callersMethodlock

(&'a self)

src/tristate_lock.rs:105

↓ 24 callersMethodpush

all calls are serialized internally

src/queue.rs:151

↓ 23 callersFunctionassume_str

(possibly_str: &[u8])

src/server.rs:188

↓ 17 callersMethodname

(&self)

src/queue.rs:115

↓ 16 callersMethodwrite

(&'a self)

src/tristate_lock.rs:84

↓ 12 callersFunctiongen_message

()

src/queue.rs:619

↓ 11 callersMethodas_mut

(&self)

src/queue_backend.rs:376

↓ 10 callersFunctionget_queue

src/queue_backend.rs:59

↓ 9 callersMethodpush

(&mut self, body: &[u8], clock: u32)

src/queue_backend.rs:242

↓ 8 callersMethodcreate_channel

(&self, channel_name: &str, clock: u32)

src/queue.rs:129

↓ 8 callersFunctiongen_message

()

src/queue_backend.rs:706

↓ 8 callersMethodsegments_count

(&self)

src/queue_backend.rs:410

↓ 7 callersMethodcheckpoint

(&self, full: bool)

src/queue.rs:188

↓ 7 callersMethodgc

(&mut self, smallest_tail: u64, clock: u32)

src/queue_backend.rs:620

↓ 7 callersFunctionget_backend

()

src/queue_backend.rs:698

↓ 6 callersMethodget

(&self, id: u64)

src/queue_backend.rs:215

↓ 6 callersMethodnotify_server

(&self, notification: NotifyMessage)

src/server.rs:279

↓ 6 callersMethodparse

parses a single value out of the stream. If there are multiple values you can call this multiple times.

src/protocol.rs:190

↓ 4 callersMethodadvance

(&mut self, cnt: usize)

src/protocol.rs:116

↓ 4 callersMethodas_mut

(&self)

src/queue.rs:580

↓ 4 callersMethodinfo

(&self, args: &[&[u8]])

src/server.rs:518

↓ 4 callersFunctionparse

(slice: &[u8])

src/protocol.rs:309

↓ 4 callersMethodpop_value

(&mut self)

src/protocol.rs:147

↓ 4 callersMethodsend_response

(&mut self, value: Value, event_loop: &mut EventLoop<ServerHandler>)

src/server.rs:592

↓ 3 callersMethodack

ack access is suposed to be thread-safe, even while writing

src/queue.rs:161

↓ 3 callersMethodclock_ms

(&mut self)

src/server.rs:1072

↓ 3 callersFunctioncreate_dir_if_not_exist

(path: P)

src/utils.rs:33

↓ 3 callersMethoddel

(&self, args: &[&[u8]])

src/server.rs:410

↓ 3 callersFunctionget_backend_recover

()

src/queue_backend.rs:702

↓ 3 callersMethodhead

(&self)

src/queue_backend.rs:422

↓ 3 callersMethodmaintenance

(&self, clock: u32)

src/queue.rs:196

↓ 3 callersMethodmut_bytes

(&mut self)

src/protocol.rs:165

↓ 3 callersMethodnew_queue_config

(&self, queue_name: S)

src/config.rs:145

↓ 3 callersMethodnotify_client

(&self, notification: NotifyMessage)

src/server.rs:283

↓ 3 callersMethodread_int_line

(&mut self)

src/protocol.rs:252

↓ 3 callersMethodremove_client

(&mut self, token: Token, clients: &mut Slab<Client>, event_loop: &mut EventLoop<ServerHandler>)

src/server.rs:926

↓ 3 callersMethodrpush

(&self, args: &[&[u8]])

src/server.rs:366

↓ 3 callersMethodset

(&self, args: &[&[u8]])

src/server.rs:351

↓ 2 callersMethodcheckpoint

(&mut self, full: bool)

src/queue_backend.rs:356

↓ 2 callersMethodclock_s

(&mut self)

src/server.rs:1080

↓ 2 callersMethodconfig_cloned

(&self)

src/queue.rs:119

↓ 2 callersMethodconfig_queue_get

(&self, queue_prefix: &str)

src/server.rs:442

↓ 2 callersMethodconfig_set

(&self, args: &[&[u8]])

src/server.rs:468

↓ 2 callersMethoddispatch

(&self)

src/server.rs:539

↓ 2 callersMethodfind_id_for_timestamp

returns the smallest id that when requested will yield messages with timestamps >= the requested timestamp

src/queue_backend.rs:437

↓ 2 callersFunctionget_backend_opt

(name: &str, recover: bool)

src/queue_backend.rs:684

↓ 2 callersFunctionget_queue_opt

(name: &str, recover: bool)

src/queue.rs:600

↓ 2 callersFunctionget_queue_recover

()

src/queue.rs:615

↓ 2 callersMethodinfo

(&self, clock: u32)

src/queue.rs:169

↓ 2 callersMethodinfo_queue

(&self, queue_prefix: &str)

src/server.rs:508

↓ 2 callersMethodpurge

(&self)

src/queue.rs:165

↓ 2 callersMethodpush_offset

(&mut self, id: u64, offset: u32)

src/offset_index.rs:44

↓ 2 callersMethodread

(&mut self, bytes: usize)

src/protocol.rs:213

↓ 2 callersMethodread_line

(&mut self)

src/protocol.rs:231

↓ 2 callersMethodread_string_line

(&mut self)

src/protocol.rs:244

↓ 2 callersMethodreal_tail

(&self)

src/queue.rs:205

↓ 2 callersMethodrecover

(&mut self, checkpoint: &SegmentCheckpoint)

src/queue_backend.rs:298

↓ 2 callersFunctionremove_dir_if_exist

(path: P)

src/utils.rs:24

↓ 2 callersFunctionremove_file_if_exist

(path: P)

src/utils.rs:15

↓ 2 callersFunctionsplit_number_suffix

(s: &str)

src/config.rs:38

↓ 2 callersFunctionstart_test_server

()

src/tests/mod.rs:10

↓ 2 callersMethodtail

(&self)

src/queue_backend.rs:418

↓ 2 callersMethodtimestamp

(&self)

src/queue_backend.rs:63

↓ 2 callersMethodtoken

(self)

src/cookie.rs:15

↓ 2 callersMethodupdate_state

(&mut self, clock: u32)

src/queue.rs:214

↓ 1 callersMethodbody

(&self)

src/queue_backend.rs:67

↓ 1 callersMethodbytes

(&self)

src/protocol.rs:125

↓ 1 callersMethodconfig

(&self, args: &[&[u8]])

src/server.rs:491

↓ 1 callersMethodconfig_get

(&self, args: &[&[u8]])

src/server.rs:452

↓ 1 callersMethoddelete

(&self)

src/queue.rs:173

↓ 1 callersMethoddelete_queue

(&self, q: Arc<Queue>)

src/server.rs:230

↓ 1 callersMethoddisk_usage

(&self)

src/queue_backend.rs:414

↓ 1 callersMethodfind_segment

(&self, id: u64)

src/queue_backend.rs:426

↓ 1 callersMethodget_offset

(&self, id: u64)

src/offset_index.rs:39

↓ 1 callersMethodhdel

(&self, args: &[&[u8]])

src/server.rs:387

↓ 1 callersMethodhmget

(&self, args: &[&[u8]])

src/server.rs:311

↓ 1 callersMethodhmset

(&self, args: &[&[u8]])

src/server.rs:287

↓ 1 callersMethodin_flight_count

(&mut self, clock: u32)

src/queue.rs:227

↓ 1 callersMethodinfo_server

(&self)

src/server.rs:502

↓ 1 callersMethoditer_channels

(&self, clock: u32, cb: F)

src/queue.rs:141

↓ 1 callersMethodmake_cookie

(&mut self, token: Token)

src/server.rs:796

↓ 1 callersMethodmessages_available

(&self)

src/queue.rs:239

↓ 1 callersMethodnonce

(self)

src/cookie.rs:20

↓ 1 callersMethodnotify_channel

(&mut self, queue: Atom, channel: Atom, available: usize)

src/server.rs:838

↓ 1 callersMethodnotify_channel_created

(&mut self, queue: Atom, channel: Atom)

src/server.rs:896

↓ 1 callersMethodnotify_channel_deleted

(&mut self, queue: Atom, channel: Atom)

src/server.rs:883

↓ 1 callersMethodnotify_client_gone

(&mut self, client: &mut Client, event_loop: &mut EventLoop<ServerHandler>)

src/server.rs:906

↓ 1 callersMethodnotify_queue

(&mut self, queue: Atom, new_head: u64)

src/server.rs:820

↓ 1 callersMethodnotify_queue_created

(&mut self, queue: Atom)

src/server.rs:877

↓ 1 callersMethodnotify_queue_deleted

(&mut self, queue: Atom)

src/server.rs:866

↓ 1 callersMethodnotify_timeout

(&mut self, queue: Atom, channel: Atom, token: Token)

src/server.rs:852

↓ 1 callersMethodopen

(config: &QueueConfig, checkpoint: &SegmentCheckpoint)

src/queue_backend.rs:172

↓ 1 callersMethodparse_array

(&mut self)

src/protocol.rs:284

↓ 1 callersMethodparse_data

(&mut self)

src/protocol.rs:270

↓ 1 callersMethodparse_error

(&mut self)

src/protocol.rs:298

↓ 1 callersMethodparse_int

(&mut self)

src/protocol.rs:266

↓ 1 callersMethodparse_status

(&mut self)

src/protocol.rs:261

next →1–100 of 215, ranked by callers