Sends a message on a connected UDP socket. Returns number of bytes successfully sent.

RFC 2401 HMAC+Blake2s, not to be confused with *keyed* Blake2s

Receives a message on a connected UDP socket and returns its contents

* @param {Request<any, CfProperties<any>>} request * @param {{ PROXYIP: string; UUID: any; SCAMALYTICS_USERNAME: any; SCAMALYTICS_API_KEY: any; SCA

Parses the string(s) into IP addresses. Goes through all possible IP inputs (files or via argparsing). ```rust # use rustscan::input::Opts; # use ru

Like b2s_hmac, but chain data1 and data2 together

Run the DNS server

NOTE: Instead of using `&LANGUAGES[*self as usize]` directly, the `debug_assertion` gives better feedback should something has gone wrong badly.

Starts the tunnel

Returns a list of persisted shard ranges. :param marker: restricts the returned list to shard ranges whose namespace inc

Add a new known peer

* @param {import("@cloudflare/workers-types").Request} request * @param {{UUID: string, PROXYIP: string, DNS_RESOLVER_URL: string, NODE_ID: int, API

Get global data for the container. :returns: dict with keys: account, container, created_at, put_timestamp, delete

Parse a timestamp from a 12 byte u8 slice

Send buf to a remote address, returns 0 on error, or amount of data send on success # Panics When sending from an IPv4 socket to an IPv6 address and v

Get a DB broker for the container. :param drive: drive that holds the container :param part: partition the container is in

Connect a socket to a remote address, must call bind prior to connect # Panics When connecting an IPv4 socket to an IPv6 address and vice versa

Returns the current state of on disk db files.

Query the local port the socket is bound to # Panics If socket is IPv6

Set socket mode to non blocking

This wrapper involves an extra copy and MAY BE SLOWER

Add and enable a new event with the factory. The event is triggered when a Read operation on the provided trigger becomes available If the trigger fd

Register an event with this poll.

This wrapper involves an extra copy and MAY BE SLOWER

Bind the socket to a local port

Receives a UDP datagram from the network and parses it. Returns TunnResult. If the result is of type TunnResult::WriteToNetwork, should repeat the ca

Encapsulate a single packet from the tunnel interface. Returns TunnResult. # Panics Panics if dst buffer is too small. Size of dst should be at least

* Generates a random path string for WebSocket connection. * @param {number} length - Length of the random path part. * @param {string} [query] - Op

Validate that the index supplied maps to a policy. :returns: policy index from request, or None if not present :raises HTTPB

Return a list of brokers for component dbs. The list has two entries while the db state is sharding: the first entry is a broker for

Split and validate path for an object. :param req: a swob request :returns: a tuple of path parts as strings

Returns a shard range representing this broker's own shard range. If no such range has been persisted in the broker's shard ranges ta

Register an event with this poll.

Reloads the cached list of valid on disk db files for this broker.

* Safely closes a WebSocket connection. * @param {{ readyState: number; close: () => void; }} socket

* Normally, WebSocket will not has exceptions when close. * @param {import("@cloudflare/workers-types").WebSocket} socket

* Normally, WebSocket will not has exceptions when close. * @param {import("@cloudflare/workers-types").WebSocket} socket

Set the SO_REUSEPORT/SO_REUSEADDR option, so multiple sockets can bind on the same port

Migrate the container schema to support tracking objects from multiple storage policies. If the container_stat table has any

We don't really clear the timers, but we set them to the current time to so the reference time frame is the same

Disable and remove the event and associated handler, using the fd that was used to register it. # Safety This function is only safe to call when the

* @param {string} address * @param {number} port

Formats a new handshake initiation message and store it in dst. If force_resend is true will send a new handshake, even if a handshake is already in p

Convert container info dict to headers.

Derive a DNS resolver. 1. if the `resolver` parameter has been set: 1. assume the parameter is a path and attempt to read IPs. 2. parse the input as

Create a new interface for the tunnel with the given address

Returns True if this container is a root container, False otherwise. A root container is a container that is not a shard of another

Merge shard ranges into the shard range table. :param shard_ranges: a shard range or a list of shard ranges; each shard