Merge multiple aggregation results together.

Merge multiple results together.

TODO: take context MergeResultStreams is responsible to (1) merge result streams and (2) maintain sort order (if sorted) from the streams (each stream is assumed to be in-order already).

MergeResultStreams is responsible to (1) merge result streams uniquely based on pkey and (2) maintain sort order (if sorted) from the streams (each stream is assumed to be in-order already).

Stream types: responses that will return a stream of results.

Query is the struct which contains the entire query to run, this includes both the function to run and the args associated.

TODO: add meta TODO: func to validate the mix of arguments.

Encapsulate a result from the datastore.

Encapsulate a streaming result from the datastore.

TODO: method to know if it is stream or not QueryType is the list of all query functions dataman supports.

Function to transform a given record argument *must* be a pointer, otherwise you are passed a copy which you cannot replace directly.