Versions in this module Expand all Collapse all v0 v0.1.1 Jun 3, 2019 v0.1.0 May 27, 2019 Changes in this version + func KeyBuilderNames() []string + type KeyBuilder func([]string, []interface{}) []byte + type KeyValue struct + Key []byte + Value []byte + type StreamQuery struct + GroupByKey bool + KeyBuilder string + KeyColumns []string + Query string + func (sq *StreamQuery) BindFlags(flags *pflag.FlagSet) + func (sq *StreamQuery) StreamTo(output chan KeyValue)
Go to main page