| 166 | } |
| 167 | |
| 168 | func (c *partialExecuteCodec) EncodedLength(msg message.Message, version primitive.ProtocolVersion) (size int, err error) { |
| 169 | switch execute := msg.(type) { |
| 170 | case *PartialExecute: |
| 171 | length := primitive.LengthOfShortBytes(execute.QueryId) |
| 172 | if version >= primitive.ProtocolVersion5 { |
| 173 | length += primitive.LengthOfShortBytes(execute.ResultMetadataId) |
| 174 | } |
| 175 | length += primitive.LengthOfShort |
| 176 | length += len(execute.Parameters) |
| 177 | return length, nil |
| 178 | default: |
| 179 | return builtinExecuteCodec.EncodedLength(msg, version) |
| 180 | } |
| 181 | } |
| 182 | |
| 183 | func (c *partialExecuteCodec) Decode(source io.Reader, version primitive.ProtocolVersion) (msg message.Message, err error) { |
| 184 | var ( |