ServerList
mu sync.RWMutex
addrs []net.Addr
conn
nc net.Conn
rw *bufio.ReadWriter
addr net.Addr
c *Client
New
ss=new(ServerList)
ss.SetServers(server...)
tcpaddr, err := net.ResolveTCPAddr("tcp", server)
naddr[i] = tcpaddr
&Client{selector: ss}
class Set
c.onItem(item, (*Client).set)
return c.populateOne(rw, "set", item)
c.onItem(item, (*Client).add)
return c.populateOne(rw, "add", item)
return c.onItem(item, (*Client).replace)
return c.populateOne(rw, "replace", item)
return c.onItem(item, (*Client).cas)
return c.populateOne(rw, "cas", item)
populateOne
<div>fmt.Fprintf(rw, "%s %s %d %d %d %d\r\n", </div><div>verb, item.Key, item.Flags, item.Expiration, len(item.Value), item.casid)</div>
rw.Write(item.Value);
rw.Flush()
rw.ReadSlice('\n')
