Buffered writes Buffered writes The other half of the framing API is the write_frame(frame) function. This function writes an entire frame to the socket. In order to minimize ...

How to write a gRPC SDK for GreptimeDB How to use tokio-console in GreptimeDB How to trace GreptimeDB

Rust client Setup Connecting to OpenSearch Creating an index Indexing a document Performing bulk operations Searching for documents Deleting a document Deleting an index Sa...

Runtime Model Synchronous Model Non-blocking sockets Polling Model Executors Runtime Model Now we will go over the Tokio / futures runtime model. Tokio is built on top o...

Tasks, threads, and contention Tasks, threads, and contention Using a blocking mutex to guard short critical sections is an acceptable strategy when contention is minimal. When...

Framing Buffered reads The Buf trait Parsing Buffered writes Framing We will now apply what we just learned about I/O and implement the Mini-Redis framing layer. Framing i...

Rust client Setup Connecting to OpenSearch Connecting to Amazon OpenSearch Service Connecting to Amazon OpenSearch Serverless Creating an index Indexing a document Performing...

Futures Implementing Future Async fn as a Future Futures As a quick review, let’s take a very basic asynchronous function. This is nothing new compared to what the tutorial ...

Working with framed streams Writing a codec Using a codec Working with framed streams Tokio has helpers to transform a stream of bytes into a stream of frames. Examplesof ...

Rust client Setup Connecting to OpenSearch Connecting to Amazon OpenSearch Service Connecting to Amazon OpenSearch Serverless Creating an index Indexing a document Performing...