in src/codec/memcache.rs [62:76]
fn encode(&mut self, buf: &mut Session) {
let keyspace = self.config.choose_keyspace(&mut self.rng);
let command = keyspace.choose_command(&mut self.rng);
match command.verb() {
Verb::Get => {
metrics::REQUEST_GET.increment();
Self::get(&mut self.rng, keyspace, buf)
}
Verb::Set => Self::set(&mut self.rng, keyspace, buf),
Verb::Delete => Self::delete(&mut self.rng, keyspace, buf),
_ => {
unimplemented!()
}
}
}