streamquery

type KeyBuilder func([]string, []interface{}) []byte

type KeyValue struct {
	Key, Value []byte
}

type StreamQuery struct {
	// The query to synchronize
	Query string
	// The key builder to use ("json-object", "json-array", etc.)
	KeyBuilder string
	// The key columns
	KeyColumns []string
	// Group the objects by key
	GroupByKey bool
}