(data []byte)
| 275 | } |
| 276 | |
| 277 | func stripCacheTrackingFields(data []byte) ([]byte, error) { |
| 278 | fields := jsn.Get(data, [][]byte{[]byte("__gj_id")}) |
| 279 | if len(fields) == 0 { |
| 280 | return data, nil |
| 281 | } |
| 282 | |
| 283 | to := make([]jsn.Field, len(fields)) |
| 284 | var buf bytes.Buffer |
| 285 | buf.Grow(len(data)) |
| 286 | if err := jsn.Replace(&buf, data, fields, to); err != nil { |
| 287 | return nil, err |
| 288 | } |
| 289 | return buf.Bytes(), nil |
| 290 | } |
| 291 | |
| 292 | func (rp *ResponseProcessor) processNode( |
| 293 | tableName string, |