Method Encode

codecs/partial_codecs.go:38–54

(msg message.Message, dest io.Writer, version primitive.ProtocolVersion)

type partialQueryCodec struct{}

func (c *partialQueryCodec) Encode(msg message.Message, dest io.Writer, version primitive.ProtocolVersion) error {
	switch query := msg.(type) {
	case *PartialQuery:
		if err := primitive.WriteLongString(query.Query, dest); err != nil {
			return fmt.Errorf("cannot write QUERY query string: %w", err)
		}
		if err := primitive.WriteShort(uint16(query.Consistency), dest); err != nil {
			return fmt.Errorf("cannot write QUERY consistency level: %w", err)
		}
		if _, err := dest.Write(query.Parameters); err != nil {
			return fmt.Errorf("cannot write QUERY parameters: %w", err)
		}
		return nil
	default:
		return builtinQueryCodec.Encode(msg, dest, version)
	}
}

func (c *partialQueryCodec) EncodedLength(msg message.Message, version primitive.ProtocolVersion) (int, error) {
	switch query := msg.(type) {