One small nit on the Go example code:
func (wordTotals *WordTotals) Update(word string) {
total, found := wordTotals.WordTotals[word]
if !found {
total = 0
}
wordTotals.WordTotals[word] = total + 1
}
Can be done as: func (wordTotals *WordTotals) Update(word string) {
wordTotals.WordTotals[word] += 1
}
(thanks to Go default values)
I'm the VP of Engineering at Wallaroo Labs. Happy to answer questions. I worked with Andy on this preview release of our Go API. Andy will be on in a while and will also be answering any questions that might come up.
We are getting ready to start work on performance tuning soon. We have a lot of work already planned there.
If you play around with the Go API, we'd love to hear from you. We need your feedback to improve our Go offering.
You can reach us via our user mailing list:
https://groups.io/g/wallaroo
Or our IRC channel:
https://webchat.freenode.net/?channels=#wallaroo
We'd also love to do a short call with folks to discuss their Go stream processing use cases. If you email [email protected], we can set that up.
Thanks in advance!
HN was really helpful in helping us develop the new version of our Python API. We hope to get the same results with the Go API.