Functions — github.com/arthurprs/floki

CodeHub MCPcopy Create free account

hub / github.com/arthurprs/floki / functions

Functions215 in github.com/arthurprs/floki

⨍ Functions 215◇ Types & classes 41

↓ 1 callersMethodpurge

src/queue_backend.rs:370

↓ 1 callersMethodpush_value

(&mut self, value: Value)

src/protocol.rs:108

↓ 1 callersMethodread_byte

src/protocol.rs:202

↓ 1 callersMethodrecover

src/queue.rs:478

↓ 1 callersMethodremaining

src/protocol.rs:112

↓ 1 callersMethodretry

(&mut self, request: Value, server: &mut Server, event_loop: &mut EventLoop<ServerHandler>)

src/server.rs:725

↓ 1 callersMethodserialize_to

(self, f: &mut Vec<u8>)

src/protocol.rs:35

↓ 1 callersMethodset_state

(&mut self, new_state: QueueState)

src/queue.rs:265

↓ 1 callersMethodsrem

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

src/server.rs:426

↓ 1 callersMethodstart_maintenance

(&mut self, _: &mut EventLoop<ServerHandler>)

src/server.rs:1017

↓ 1 callersMethodstart_monitor

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

src/server.rs:1038

↓ 1 callersMethodsync

(&mut self, full: bool)

src/queue_backend.rs:282

↓ 1 callersMethodtry_lock

src/tristate_lock.rs:115

↓ 1 callersMethodtry_parse_request

(&mut self, server: &mut Server, event_loop: &mut EventLoop<ServerHandler>)

src/server.rs:598

↓ 1 callersMethodtry_read

src/tristate_lock.rs:72

↓ 1 callersMethodtry_write

src/tristate_lock.rs:93

↓ 1 callersMethodwait_queue

(&mut self, request: Value, queue: Atom, channel: Atom, token: Token, required_tail: u64)

src/server.rs:801

src/offset_index.rs:31

Functionborrow_str_compatible

Functioncheck_identifier_str

(possibly_str: &[u8])

src/server.rs:192

(config: &QueueConfig, start_id: u64)

src/queue_backend.rs:152

Methodcreate_channel

(&self, q: &Queue, channel_name: &str, use_existing: bool)

src/server.rs:264

Methodcreate_queue

(&self, name: &str, use_existing: bool)

src/server.rs:207

src/tristate_lock.rs:141

src/queue_backend.rs:525

Methoddelete_channel

(&self, q: &Queue, channel_name: &str)

src/server.rs:251

Methoddelete_channel

(&self, channel_name: &str)

src/queue.rs:133

src/tristate_lock.rs:149

Methodderef_mut

src/tristate_lock.rs:159

src/queue_backend.rs:382

src/queue.rs:586

(&self, other: &Rev<T>)

src/queue_backend.rs:76

Methodfd_offset

src/queue_backend.rs:80

(&self, f: &mut fmt::Formatter)

src/cookie.rs:26

(&self, f: &mut fmt::Formatter)

src/protocol.rs:68

(&self, f: &mut fmt::Formatter)

src/tristate_lock.rs:130

(&self, f: &mut fmt::Formatter)

(from: &'static str)

src/protocol.rs:16

(from: io::Error)

src/queue_backend.rs:36

(from: QueueError)

src/server.rs:45

(from: QueueBackendError)

src/queue.rs:31

Methodfrom_bytes

(id_offset: u64, bytes: &[u8])

src/offset_index.rs:18

Methodgen_file_path

(config: &QueueConfig, start_id: u64, ext: &str)

src/queue_backend.rs:137

Methodget_clock_ms

src/server.rs:1084

Methodget_clock_s

src/server.rs:1089

Methodget_queue

(&self, name: &str)

src/server.rs:203

(&self, state: &mut H)

Methodhash_segment_message

(header: &MessageHeader)

src/queue_backend.rs:141

Methodinterrupted

(&mut self, _: &mut EventLoop<Self>)

src/server.rs:1160

examples/helloworld.rs:6

Functionmessage_response

src/protocol.rs:379

(token: Token, nonce: u64)

src/cookie.rs:9

(server_config: &ServerConfig, name: String)

src/config.rs:151

src/protocol.rs:101

src/tristate_lock.rs:52

(_: &QueueConfig, file: File, file_path: PathBuf, start_id: u64)

src/queue_backend.rs:181

(token: Token, stream: TcpStream)

src/server.rs:578

(id_offset: u64)

src/offset_index.rs:11

(config: QueueConfig, recover: bool)

src/queue.rs:107

(&mut self, server: &mut Server, event_loop: &mut EventLoop<ServerHandler>, notification: NotifyType)

src/server.rs:653

Functionoverflow

src/cookie.rs:50

Functionparse_duration

(duration_text: &str)

src/config.rs:44

Functionparse_error

src/protocol.rs:320

Functionparse_incomplete

src/protocol.rs:314

Functionparse_size

(size_text: &str)

src/config.rs:57

Functionparse_valid_array

src/protocol.rs:329

Functionparser_multiple2

src/protocol.rs:342

Methodpartial_cmp

(&self, other: &Rev<T>)

Methodpurge_channel

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

src/queue.rs:137

Methodpush_many

all calls are serialized internally

src/queue.rs:156

Functionput_get_like_crazy

(b: &mut test::Bencher)

src/queue.rs:748

Functionput_like_crazy

(b: &mut test::Bencher)

src/queue.rs:735

src/tristate_lock.rs:63

Methodread_queue_configs

(self: &ServerConfig)

src/config.rs:136

(&mut self, server: &mut Server, event_loop: &mut EventLoop<ServerHandler>, events: EventSet)

src/server.rs:615

Functionrequest_parse

src/protocol.rs:362

Functionround_trip

src/cookie.rs:40

Methodseek_channel_to_id

Set the channel tail to the specified id

src/queue.rs:178

Methodseek_channel_to_timestamp

Set the channel tail to the specified timestamp

src/queue.rs:183

Methodset_config

(&mut self, config: QueueConfig)

src/queue_backend.rs:406

Methodset_config

(&self, config: QueueConfig)

src/queue.rs:123

(mut tendril: ByteTendril, position: usize)

src/protocol.rs:223

Functiontest_backend_recover

src/queue.rs:677

Functiontest_config

src/tests/mod.rs:59

Functiontest_corrupt_files

src/queue_backend.rs:812

Functiontest_create_channel

src/queue.rs:644

Functiontest_eq

Functiontest_fill

src/queue.rs:624

Functiontest_find_timestamp

src/queue_backend.rs:711

Functiontest_find_timestamp2

src/queue_backend.rs:742

Functiontest_find_timestamp3

src/queue_backend.rs:758

Functiontest_hard_retention_period

src/queue_backend.rs:800

Functiontest_in_flight

src/queue.rs:656

Functiontest_in_flight_timeout

src/queue.rs:667

Functiontest_maintenance

src/queue.rs:716

← previous next →101–200 of 215, ranked by callers