Method EncodedLength

codecs/partial_codecs.go:56–66

(msg message.Message, version primitive.ProtocolVersion)

}

func (c *partialQueryCodec) EncodedLength(msg message.Message, version primitive.ProtocolVersion) (int, error) {
	switch query := msg.(type) {
	case *PartialQuery:
		length := primitive.LengthOfLongString(query.Query)
		length += primitive.LengthOfShort
		length += len(query.Parameters)
		return length, nil
	default:
		return builtinQueryCodec.EncodedLength(msg, version)
	}
}

func (c *partialQueryCodec) Decode(source io.Reader, _ primitive.ProtocolVersion) (msg message.Message, err error) {
	var (