Method encode

redis-server/src/codec.rs:250–309

(&mut self, msg: RedisServerMsg<'_>, buf: &mut BytesMut)

    type Error = io::Error;

    fn encode(&mut self, msg: RedisServerMsg<'_>, buf: &mut BytesMut) -> io::Result<()> {
        // error!("wframe - cap: {}: len: {}", buf.capacity(), buf.len());
        match msg {
            RedisServerMsg::Ok => {
                buf.put(&b"+OK\r\n"[..]);
            }
            RedisServerMsg::Pong => {
                buf.put(&b"+PONG\r\n"[..]);
            }
            RedisServerMsg::Null => {
                buf.put(&b"$-1\r\n"[..]);
            }
            RedisServerMsg::Info { used_memory } => {
                // Build the raw buffer.
                let r = format!("# Memory\r\nused_memory:{}\r\n", used_memory);
                let b = r.as_bytes();
                let bs_hdr = format!("${}\r\n", b.len());
                buf.put_slice(bs_hdr.as_bytes());
                buf.put_slice(b);
                buf.put(&b"\r\n"[..]);

                debug!("buf {:?}", String::from_utf8(buf.to_vec()));
            }
            RedisServerMsg::KvPair { k, v } => {
                // Identify our response has 2 values.
                buf.put(&b"*2\r\n"[..]);
                // How long is the key?
                let kb = k.as_bytes();
                let kbs_hdr = format!("${}\r\n", k.len());
                buf.put_slice(kbs_hdr.as_bytes());
                buf.put_slice(kb);
                buf.put(&b"\r\n"[..]);
                // Add the value
                let vb = v.as_bytes();
                let vbs_hdr = format!("${}\r\n", v.len());
                buf.put_slice(vbs_hdr.as_bytes());
                buf.put_slice(vb);
                buf.put(&b"\r\n"[..]);
            }
            // We split this up into "parts".
            RedisServerMsg::DataHdr { sz } => {
                let kbs_hdr = format!("${}\r\n", sz);
                buf.put_slice(kbs_hdr.as_bytes());
            }
            RedisServerMsg::DataChunk { slice } => {
                // extend from slice will auto-resize.
                buf.extend_from_slice(slice)
            }
            RedisServerMsg::DataEof => {
                buf.put(&b"\r\n"[..]);
            }
            RedisServerMsg::Error(err) => {
                buf.put(&b"-SERVER_ERROR "[..]);
                buf.put_slice(err.as_bytes());
                buf.put(&b"\r\n"[..]);
            }
        }