I've looked at the examples folder and I saw how the connection is created:
con, err := goriak.Connect(goriak.ConnectOpts{Address: "127.0.0.1"})
Do we have to manage this somehow like defer conn.Close() (I have not seen such API call) or is it entirely managed via underlying riak-go-client?
Their (Basho's) code does something like this:
defer func() { stopping = true close(sc) if serr := c.Stop(); serr != nil { util.ErrExit(serr) } close(sdc) close(fdc) }()
Nice repo BTW, I'm playing with it right now, good work!
I've looked at the examples folder and I saw how the connection is created:
con, err := goriak.Connect(goriak.ConnectOpts{Address: "127.0.0.1"})Do we have to manage this somehow like
defer conn.Close()(I have not seen such API call) or is it entirely managed via underlying riak-go-client?Their (Basho's) code does something like this:
defer func() { stopping = true close(sc) if serr := c.Stop(); serr != nil { util.ErrExit(serr) } close(sdc) close(fdc) }()Nice repo BTW, I'm playing with it right now, good work!