(dt datatype.DataType, val interface{})
| 487 | } |
| 488 | |
| 489 | func (p *Proxy) encodeTypeFatal(dt datatype.DataType, val interface{}) []byte { |
| 490 | encoded, err := codecs.EncodeType(dt, p.cluster.NegotiatedVersion, val) |
| 491 | if err != nil { |
| 492 | p.logger.Fatal("unable to encode type", zap.Error(err)) |
| 493 | } |
| 494 | return encoded |
| 495 | } |
| 496 | |
| 497 | // isIdempotent checks whether a prepared ID is idempotent. |
| 498 | // If the proxy receives a query that it's never prepared then this will also return false. |
no test coverage detected