Versions in this module Expand all Collapse all v0 v0.3.1 Feb 19, 2020 v0.3.0 Jan 11, 2020 Changes in this version + func MapReduce(mr MapReducer) error + type Identifiable interface + ID func() string + type IdentifiableChan chan Identifiable + func (c IdentifiableChan) Close() + type MapReducer interface + Consume func(in IdentifiableChan) error + Input func() IdentifiableChan + Map func(in Identifiable, emit IdentifiableChan) + Reduce func(in, emit IdentifiableChan) Other modules containing this package tideland.dev/go