(val interface{})
| 1494 | } |
| 1495 | |
| 1496 | func (d distributedCounterCodec) Encode(val interface{}) ([]byte, error) { |
| 1497 | buf := bytes.Buffer{} |
| 1498 | enc := gob.NewEncoder(&buf) |
| 1499 | err := enc.Encode(val) |
| 1500 | return buf.Bytes(), err |
| 1501 | } |
| 1502 | |
| 1503 | var _ codec.Codec = &distributedCounterCodec{} |
| 1504 |