()
| 226 | } |
| 227 | |
| 228 | func (c *cmdReadT) Exec() { |
| 229 | processor := newProcessor(&c.Config) |
| 230 | req := newSSRequest(proto.OpCodeRead, []byte(c.Namespace), c.key, nil, uint32(c.ttl)) |
| 231 | req.SetNewRequestID() |
| 232 | req.SetShardId(c.getShardId(c.key)) |
| 233 | if resp, err := processor.ProcessRequest(req); err == nil { |
| 234 | resp.PrettyPrint(os.Stdout) |
| 235 | } else { |
| 236 | } |
| 237 | } |
| 238 | |
| 239 | func (c *cmdPrepareUpdateT) Init(name string, desc string) { |
| 240 | c.ssClientCommandWithValueT.Init(name, desc) |
nothing calls this directly
no test coverage detected