Decouple data transfer with codecs

[licaonfee]

something like

type Codec interface {
    Encode(interface{}) []byte
    Decode([]byte) interface{}
}


input := Reader(Input(JSONCodec()))
// between DataProcessors there is a implicit codec like gob 
output := Writer(Output(CSVCodec()))