MCPcopy Create free account

hub / github.com/cabal-club/cable.rs / functions

Functions300 in github.com/cabal-club/cable.rs

⨍ Functions 300◇ Types & classes 56
↓ 48 callersFunctionlength
Determine the length of an unsigned 64 bit integer.
desert/src/varint.rs:42
↓ 45 callersFunctionencode
Encode an unsigned 64 bit integer as a varint and write the bytes to the given buffer, returning the byte length of the value.
desert/src/varint.rs:25
↓ 43 callersMethodto_bytes
Convert a `Post` data type to bytes.
cable/src/post.rs:354
↓ 42 callersFunctiondecode
Decode a varint into an unsigned 64 bit integer (includes offset in result).
desert/src/varint.rs:4
↓ 21 callersMethodraise
(self)
cable/src/error.rs:37
↓ 18 callersMethodread_message_from_stream
Read an encrypted message from the given stream and return it as a byte vector. This method essentially reads two messages from the stream: the unenc
handshake/src/post_handshake.rs:72
↓ 16 callersFunctioninit
Initialise the logger in test mode. Set `is_test()` to `false` if you wish to see logging output during the test run.
cable_core/tests/channel_state.rs:79
↓ 16 callersMethodraise
(self)
desert/src/error.rs:22
↓ 14 callersMethodnew_req_id
Generate a new request ID.
cable_core/src/manager.rs:161
↓ 14 callersMethodnext
(&mut self)
length_prefixed_stream/src/lib.rs:81
↓ 12 callersMethodsend
Send a message to a single peer identified by the given peer ID.
cable_core/src/manager.rs:759
↓ 11 callersMethodpost_text
Publish a new text post and return the hash.
cable_core/src/manager.rs:480
↓ 10 callersMethodget_public_key
Retrieve the public key of the local peer.
cable_core/src/manager.rs:147
↓ 10 callersFunctionvalidate_channel
Validate the length of a channel name (1 to 64 UTF-8 codepoints).
cable/src/validation.rs:6
↓ 10 callersMethodwrite_message_to_stream
Encrypt and write a message to the stream, returning the byte size of the written payload. This method essentially writes at least two messages to th
handshake/src/post_handshake.rs:190
↓ 8 callersFunctionclient
Initiate the handshake over a synchronous stream and run to completion.
handshake/src/sync/handshake.rs:16
↓ 8 callersMethodread_message_from_async_stream
Read an encrypted message from the given asynchronous stream and return it as a byte vector. This method essentially reads two messages from the stre
handshake/src/post_handshake.rs:104
↓ 8 callersFunctionserver
Respond to a handshake over a synchronous stream and run to completion.
handshake/src/sync/handshake.rs:60
↓ 8 callersMethodto_bytes
Convert a `Message` data type to bytes.
cable/src/message.rs:524
↓ 8 callersMethodwrite_eos_marker_to_stream
Write an end-of-stream marker (zero-length message) to the stream.
handshake/src/post_handshake.rs:205
↓ 7 callersMethodread_message
Read an encrypted message of the given length from the receive buffer, decrypt and return it as a byte vector. This method handles defragmentation of
handshake/src/post_handshake.rs:31
↓ 7 callersMethodsign
Sign a post using the given secret key.
cable/src/post.rs:300
↓ 7 callersMethodwrite_message
Encrypt and write a message to the send buffer, returning the total number of written bytes. This method handles message fragmentation in the case th
handshake/src/post_handshake.rs:143
↓ 6 callersFunctiondecode
( input: impl AsyncRead + Send + Sync + Unpin + 'static, )
length_prefixed_stream/src/lib.rs:26
↓ 6 callersMethodinsert_post_payload
(&mut self, hash: &Hash, payload: Payload)
cable_core/src/store.rs:967
↓ 6 callersMethodmajor
Return the major version identifier.
handshake/src/version.rs:26
↓ 6 callersMethodpost
Publish a post and return the hash.
cable_core/src/manager.rs:587
↓ 5 callersMethoddecrement_ttl_and_write_to_outbound
Decrement the TTL of a request message and write it to the outbound requests store.
cable_core/src/manager.rs:768
↓ 5 callersMethodget_timestamp
Return the timestamp of the post.
cable/src/post.rs:255
↓ 5 callersMethodlisten
Listen for incoming peer messages and respond with locally-generated messages. Decode each received message and pass it off to the handler.
cable_core/src/manager.rs:270
↓ 5 callersFunctionnow
Get the current system time in milliseconds since the UNIX epoch.
cable_core/tests/channel_time_range.rs:67
↓ 5 callersMethodrecv_client_version
Receive the version data from the client and validate it before advancing to the next client state.
handshake/src/lib.rs:396
↓ 5 callersMethodrecv_server_version
Receive the version data from the server and validate it before advancing to the next client state. Terminate the handshake with an error if the majo
handshake/src/lib.rs:240
↓ 5 callersMethodsend_client_version
Send the client version data to the server and advance to the next client state.
handshake/src/lib.rs:222
↓ 5 callersMethodsend_server_version
Send server version data to the client and advance to the next server state.
handshake/src/lib.rs:417
↓ 5 callersFunctionvalidate_topic
Validate the length of a topic name (1 to 512 UTF-8 codepoints).
cable/src/validation.rs:38
↓ 5 callersMethodwrite_bytes
(&self, dst: &mut [u8])
desert/src/lib.rs:326
↓ 4 callersMethodget_channel
Return the channel name associated with a post.
cable/src/post.rs:235
↓ 4 callersMethodpost_header_values
Post header value generator.
cable_core/src/manager.rs:464
↓ 4 callersMethodwrite_eos_marker_to_async_stream
Write an end-of-stream marker (zero-length message) to the asynchronous stream.
handshake/src/post_handshake.rs:235
↓ 4 callersMethodwrite_message_to_async_stream
Encrypt and write a message to the asynchronous stream, returning the byte size of the written payload. This method essentially writes at least two m
handshake/src/post_handshake.rs:219
↓ 3 callersMethodbroadcast
Broadcast a message to all peers.
cable_core/src/manager.rs:751
↓ 3 callersMethodbuild_client_noise_state_machine
Build the Noise handshake state machine for the client with the PSK and private key.
handshake/src/lib.rs:266
↓ 3 callersMethodbuild_server_noise_state_machine
Build the Noise handshake state machine for the server with the PSK and private key.
handshake/src/lib.rs:435
↓ 3 callersMethodcount_bytes
(&self)
desert/src/lib.rs:296
↓ 3 callersMethodcount_bytes_be
(&self)
desert/src/lib.rs:306
↓ 3 callersMethodcount_bytes_le
(&self)
desert/src/lib.rs:316
↓ 3 callersFunctiondecode_with_options
( input: impl AsyncRead + Send + Sync + Unpin + 'static, options: DecodeOptions, )
length_prefixed_stream/src/lib.rs:32
↓ 3 callersMethodinit_client_transport_mode
Complete the client handshake by initialising the encrypted transport.
handshake/src/lib.rs:361
↓ 3 callersFunctioninit_handshakers
( client_version: (u8, u8), server_version: (u8, u8), )
handshake/src/lib.rs:550
↓ 3 callersMethodinit_server_transport_mode
Complete the server handshake by initialising the encrypted transport.
handshake/src/lib.rs:528
↓ 3 callersFunctionnow
Generate a timestamp for the current time.
cable_core/src/manager.rs:84
↓ 3 callersMethodrecv_client_ephemeral_key
Receive the ephemeral key from the client and advance to the next server state.
handshake/src/lib.rs:454
↓ 3 callersMethodrecv_client_static_key
Receive the static key from the clientand advance to the next server state.
handshake/src/lib.rs:500
↓ 3 callersMethodrecv_server_ephemeral_and_static_key
Receive the ephemeral and static keys from the server and advance to the next client state.
handshake/src/lib.rs:310
↓ 3 callersMethodsend_client_ephemeral_key
Send the client ephemeral key to the server and advance to the next client state.
handshake/src/lib.rs:286
↓ 3 callersMethodsend_client_static_key
Send the client static key to the server and advance to the next client state.
handshake/src/lib.rs:338
↓ 3 callersMethodsend_server_ephemeral_and_static_key
Send the ephemeral and static keys to the client and advance to the next server state.
handshake/src/lib.rs:476
↓ 3 callersMethodto_bytes
(&self)
desert/src/lib.rs:322
↓ 3 callersMethodupdate_posts
( &mut self, post: &Post, channel: Option<Channel>, timestamp: &Timestamp,
cable_core/src/store.rs:914
↓ 3 callersMethodwrite_bytes_be
(&self, dst: &mut [u8])
desert/src/lib.rs:344
↓ 3 callersMethodwrite_bytes_le
(&self, dst: &mut [u8])
desert/src/lib.rs:354
↓ 2 callersFunctionbuild_noise_state_machine
Initialise the Noise handshake state machine according to the given role, ie. initiator or responder.
handshake/src/lib.rs:179
↓ 2 callersMethodget_channel_members
(&self, channel: &Channel)
cable_core/src/store.rs:344
↓ 2 callersMethodget_channel_membership_hashes
(&self, channel: &Channel)
cable_core/src/store.rs:386
↓ 2 callersMethodget_channel_topic_and_hash
(&self, channel: &Channel)
cable_core/src/store.rs:476
↓ 2 callersMethodget_channels
(&self)
cable_core/src/store.rs:329
↓ 2 callersMethodget_or_create_keypair
Retrieve the keypair associated with the store, creating a new keypair if one does not yet exist.
cable_core/src/store.rs:69
↓ 2 callersMethodget_peer_name_and_hash
(&self, public_key: &PublicKey)
cable_core/src/store.rs:606
↓ 2 callersMethodget_post_hashes
(&self, opts: &ChannelOptions)
cable_core/src/store.rs:764
↓ 2 callersMethodhash
Return the hash of the post.
cable/src/post.rs:262
↓ 2 callersFunctionhelp
()
handshake/examples/tcp.rs:16
↓ 2 callersFunctionhelp
()
handshake/examples/unix.rs:19
↓ 2 callersFunctionhelp
()
handshake/examples/async_tcp.rs:15
↓ 2 callersFunctionhelp
()
handshake/examples/cli.rs:14
↓ 2 callersMethodinsert_channel
(&mut self, channel: &Channel)
cable_core/src/store.rs:339
↓ 2 callersMethodinsert_post
(&mut self, post: &Post)
cable_core/src/store.rs:792
↓ 2 callersMethodmessage_type
Return the numeric type identifier for the message.
cable/src/message.rs:45
↓ 2 callersMethodpost_info_name
Publish a new info post with the given name and return the hash.
cable_core/src/manager.rs:525
↓ 2 callersMethodpost_topic
Publish a new topic post for the given channel and return the hash.
cable_core/src/manager.rs:540
↓ 2 callersMethodpost_type
Return the numeric type identifier for the post.
cable/src/post.rs:287
↓ 2 callersMethodraise
(self)
length_prefixed_stream/src/error.rs:21
↓ 2 callersMethodreq_id
(&self)
cable_core/src/manager.rs:57
↓ 2 callersMethodsend_post_hashes
Send post hashes matching peer request parameters for all live requests. Live requests may have originated from a ChannelTimeRange (`time_end` of 0)
cable_core/src/manager.rs:627
↓ 2 callersMethodsend_post_to_live_streams
(&self, post: &Post, channel: &Channel)
cable_core/src/store.rs:980
↓ 2 callersFunctionsetup
()
handshake/tests/async_handshake.rs:20
↓ 2 callersFunctionsetup
()
handshake/examples/tcp.rs:27
↓ 2 callersFunctionsetup
()
handshake/examples/unix.rs:30
↓ 2 callersFunctionsetup
()
handshake/examples/async_tcp.rs:26
↓ 2 callersFunctionsetup
()
handshake/examples/cli.rs:26
↓ 2 callersMethodto_bytes
(&self)
desert/tests/custom.rs:16
↓ 2 callersMethodupdate_channel_membership_hashes
( &mut self, channel: &Channel, public_key: &PublicKey, hash: &Hash, )
cable_core/src/store.rs:416
↓ 2 callersFunctionvalidate_text
Validate the length of a post's text (less than or equal to 4096 bytes).
cable/src/validation.rs:22
↓ 1 callersFunctioncleanup
()
handshake/benches/message_sync.rs:94
↓ 1 callersFunctioncleanup
()
handshake/benches/handshake_sync.rs:65
↓ 1 callersFunctionclient_handshake
()
handshake/tests/async_handshake.rs:35
↓ 1 callersMethodcount_bytes
Calculate the total number of bytes comprising the encoded message.
cable/src/message.rs:447
↓ 1 callersMethoddecrement_ttl
Decrement the TTL of a request-type message by one.
cable/src/message.rs:37
↓ 1 callersMethoddelete_post
(&mut self, hash: &Hash)
cable_core/src/store.rs:904
↓ 1 callersMethodget_delete_hashes
(&self, public_key: &PublicKey)
cable_core/src/store.rs:533
next →1–100 of 300, ranked by callers