Functions — github.com/arthurprs/sucredb

CodeHub MCPcopy Create free account

hub / github.com/arthurprs/sucredb / functions

Functions434 in github.com/arthurprs/sucredb

⨍ Functions 434◇ Types & classes 100

Methodentry_with_timeout

(&mut self, key: K, expire: T)

src/inflightmap.rs:35

(&self, other: &Self)

src/version_vector.rs:382

(&self, other: &Pair<T, V>)

src/inflightmap.rs:102

src/version_vector.rs:903

src/database.rs:34

Methodexpecting

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

src/version_vector.rs:232

Methodfill_holes

src/version_vector.rs:114

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

src/types.rs:26

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

(result: Result<S, E>)

src/vnode_sync.rs:23

(from: &'static str)

(sb: StorageBatch<'a>)

src/storage.rs:74

(dot: (Id, Version))

src/version_vector.rs:638

src/types.rs:59

Methodfrom_version

(id: Id, bv: BitmappedVersion)

src/version_vector.rs:277

(vv: VersionVector)

src/version_vector.rs:401

Methodgenerate_id

src/vnode.rs:908

Methodhandler_dht_change

src/vnode.rs:204

Methodhandler_fabric_msg

(&self, from: NodeId, msg: FabricMsg)

Methodhandler_get_remote

(&mut self, db: &Database, from: NodeId, msg: MsgRemoteGet)

src/vnode.rs:592

Methodhandler_get_remote_ack

src/vnode.rs:588

Methodhandler_set_remote

(&mut self, db: &Database, from: NodeId, msg: MsgRemoteSet)

src/vnode.rs:622

Methodhandler_set_remote_ack

(&mut self, db: &Database, _from: NodeId, msg: MsgRemoteSetAck)

src/vnode.rs:669

Methodhandler_sync_ack

(&mut self, db: &Database, from: NodeId, msg: MsgSyncAck)

src/vnode.rs:723

Methodhandler_sync_fin

(&mut self, db: &Database, from: NodeId, msg: MsgSyncFin)

src/vnode.rs:736

Methodhandler_sync_send

(&mut self, db: &Database, from: NodeId, msg: MsgSyncSend)

src/vnode.rs:710

Methodhandler_sync_start

src/vnode.rs:674

Methodhandler_tick

src/vnode.rs:265

Methodhandshake

( socket: tokio::net::TcpStream, context: Arc<SharedContext>, )

src/fabric.rs:288

Methodin_domain

(&mut self, _key: &[u8])

src/storage.rs:16

( fabric: Arc<Fabric>, config: &Config, meta: T, ring: RingDescription,

( node: NodeId, config: Config, handle: tokio::reactor::Handle, )

src/fabric.rs:339

( handle: tokio::reactor::Handle, addr: SocketAddr, meta: T, callback: Gossipe

src/gossip.rs:175

scripts/sanity.py:47

(&mut self, key: K, value: V, expire: T)

src/inflightmap.rs:44

Methodint_to_bitmap

(base: Version, bitmap: u32)

src/version_vector.rs:55

src/fabric_msg.rs:149

Methodjoin_cluster

( fabric: Arc<Fabric>, config: &Config, meta: T, seeds: &[SocketAddr],

( listener: tokio::net::TcpListener, context: Arc<SharedContext>, handle: tokio::react

src/fabric.rs:218

Methodlog_get_vec

(&self, log_key: (u64, u64))

src/storage.rs:263

(&self, msg: &str)

src/utils.rs:112

src/main.rs:185

src/version_vector.rs:878

Functionmessage_response

src/resp.rs:360

src/utils.rs:29

(bvv: &BitmappedVersionVector)

src/cubes.rs:72

(name: String, thread_count: usize)

src/workers.rs:39

(base: Version, bitmap: u32)

src/version_vector.rs:67

(a: u64, b: u64)

src/types.rs:20

(replication_factor: u8, partitions: u16)

src/inflightmap.rs:19

( context: Rc<SharedContext>, token: Token, chan_tx: fmpsc::UnboundedSender<DbContext>

src/server.rs:71

(context: Context, nodes: usize, consistency: ConsistencyLevel)

src/vnode.rs:125

(dots_delta: BitmappedVersionVectorDelta)

src/vnode_sync.rs:109

(context: Arc<SharedContext>, peer: NodeId)

src/fabric.rs:175

src/database.rs:86

(status: NodeStatus, incarnation: Seq, meta: T)

src/gossip.rs:148

src/resp.rs:106

src/storage.rs:92

Methodnew_bootstrap_receiver

( _db: &Database, _state: &mut VNodeState, peer: NodeId, cookie: Cookie, )

src/vnode_sync.rs:152

Methodnew_bootstrap_sender

( _db: &Database, state: &mut VNodeState, peer: NodeId, msg: MsgSyncStart,

src/vnode_sync.rs:167

Methodnew_empty

(num: u16, db: &Database, status: VNodeStatus)

src/vnode.rs:941

Methodnew_sync_receiver

( _db: &Database, state: &mut VNodeState, peer: NodeId, cookie: Cookie, )

src/vnode_sync.rs:201

Methodnew_sync_sender

( db: &Database, state: &mut VNodeState, peer: NodeId, msg: MsgSyncStart,

src/vnode_sync.rs:218

src/fabric.rs:361

Methodnode_count

src/gossip.rs:699

src/version_vector.rs:819

Methodon_connection

(inner: &Inner<T>, from: NodeId)

Methodon_message

(inner: &mut Inner<T>, from: NodeId, msg: FabricMsg)

Methodon_msg_ack

(&mut self, db: &Database, state: &mut VNodeState, msg: MsgSyncAck)

src/vnode_sync.rs:589

Methodon_msg_send

(&mut self, db: &Database, state: &mut VNodeState, msg: MsgSyncSend)

src/vnode_sync.rs:549

Functionparse_duration

(duration_text: &str)

src/config.rs:100

Functionparse_error

src/resp.rs:314

Functionparse_incomplete

src/resp.rs:308

Functionparse_size

(size_text: &str)

src/config.rs:112

Functionparse_valid_array

src/resp.rs:327

Functionparser_multiple2

src/resp.rs:340

Methodpartial_cmp

(&self, other: &Pair<T, V>)

src/inflightmap.rs:110

Functionraw_hash

Methodremove_node

(&self, peer: NodeId)

src/fabric.rs:129

Functionrender_counter

src/cubes.rs:357

Functionrender_map

src/cubes.rs:377

Functionrender_set

src/cubes.rs:392

Functionrender_type

src/cubes.rs:365

Functionrender_value

src/cubes.rs:337

Methodreplication_factor

(&mut self, response: RespValue)

src/database.rs:107

Methodrespond_int

(&self, context: &mut Context, int: i64)

src/command.rs:513

( fabric: Arc<Fabric>, config: &Config, meta: T, serialized_ring: &[u8],

scripts/sanity.py:85

Methodserialize

(ring: &Ring<T>)

Methodserialize

(item: FabricMsgRef)

src/fabric.rs:56

Functionserialize_bitmap

(value: &RoaringTreemap, serializer: S)

src/version_vector.rs:197

Methodspeculate_buffer

Quickly speculate a buffer, checking whatever it has a complete resp objects or not. If succesfull returns the resp objects length in bytes.

src/resp.rs:116

Methodsteady_connection

( socket: tokio::net::TcpStream, peer: NodeId, context: Arc<SharedContext>, )

src/fabric.rs:311

Methodstrict_descends

(&self, other: &Self)

src/version_vector.rs:592

Methodsyncs_inflight

src/vnode.rs:185

src/fabric.rs:518

Functiontest_aae_converge_100

src/database.rs:1262

Functiontest_aae_converge_50

src/database.rs:1267

← previous next →301–400 of 434, ranked by callers