Merge pull request #71 from alexopryshko/multi

Reconnection strategy - round-robin between  instances #68

Author: funny-falcon

connection.go

@@ -111,6 +111,7 @@ func (d defaultLogger) Report(event ConnLogKind, conn *Connection, v ...interfac
 // always returns array of array (array of tuples for space related methods).
 // For Eval* and Call17* tarantool always returns array, but does not forces
 // array of arrays.
+
 type Connection struct {
 	addr  string
 	c     net.Conn
@@ -132,6 +133,8 @@ type Connection struct {
 	lenbuf  [PacketLengthBytes]byte
 }
 
+var _ = Connector(&Connection{}) // check compatibility with connector interface
+
 type connShard struct {
 	rmut     sync.Mutex
 	requests [requestsMap]struct {
@@ -224,7 +227,6 @@ type Opts struct {
 // - If opts.Reconnect is non-zero, then error will be returned only if authorization// fails. But if Tarantool is not reachable, then it will attempt to reconnect later
 // and will not end attempts on authorization failures.
 func Connect(addr string, opts Opts) (conn *Connection, err error) {
-
 	conn = &Connection{
 		addr:      addr,
 		requestId: 0,
@@ -307,6 +309,11 @@ func (conn *Connection) ConnectedNow() bool {
 	return atomic.LoadUint32(&conn.state) == connConnected
 }
 
+// ClosedNow reports if connection is closed by user or after reconnect.
+func (conn *Connection) ClosedNow() bool {
+	return atomic.LoadUint32(&conn.state) == connClosed
+}
+
 // Close closes Connection.
 // After this method called, there is no way to reopen this Connection.
 func (conn *Connection) Close() error {

connector.go

@@ -0,0 +1,40 @@
+package tarantool
+
+import "time"
+
+type Connector interface {
+	ConnectedNow() bool
+	Close() error
+	Ping() (resp *Response, err error)
+	ConfiguredTimeout() time.Duration
+
+	Select(space, index interface{}, offset, limit, iterator uint32, key interface{}) (resp *Response, err error)
+	Insert(space interface{}, tuple interface{}) (resp *Response, err error)
+	Replace(space interface{}, tuple interface{}) (resp *Response, err error)
+	Delete(space, index interface{}, key interface{}) (resp *Response, err error)
+	Update(space, index interface{}, key, ops interface{}) (resp *Response, err error)
+	Upsert(space interface{}, tuple, ops interface{}) (resp *Response, err error)
+	Call(functionName string, args interface{}) (resp *Response, err error)
+	Call17(functionName string, args interface{}) (resp *Response, err error)
+	Eval(expr string, args interface{}) (resp *Response, err error)
+
+	GetTyped(space, index interface{}, key interface{}, result interface{}) (err error)
+	SelectTyped(space, index interface{}, offset, limit, iterator uint32, key interface{}, result interface{}) (err error)
+	InsertTyped(space interface{}, tuple interface{}, result interface{}) (err error)
+	ReplaceTyped(space interface{}, tuple interface{}, result interface{}) (err error)
+	DeleteTyped(space, index interface{}, key interface{}, result interface{}) (err error)
+	UpdateTyped(space, index interface{}, key, ops interface{}, result interface{}) (err error)
+	CallTyped(functionName string, args interface{}, result interface{}) (err error)
+	Call17Typed(functionName string, args interface{}, result interface{}) (err error)
+	EvalTyped(expr string, args interface{}, result interface{}) (err error)
+
+	SelectAsync(space, index interface{}, offset, limit, iterator uint32, key interface{}) *Future
+	InsertAsync(space interface{}, tuple interface{}) *Future
+	ReplaceAsync(space interface{}, tuple interface{}) *Future
+	DeleteAsync(space, index interface{}, key interface{}) *Future
+	UpdateAsync(space, index interface{}, key, ops interface{}) *Future
+	UpsertAsync(space interface{}, tuple interface{}, ops interface{}) *Future
+	CallAsync(functionName string, args interface{}) *Future
+	Call17Async(functionName string, args interface{}) *Future
+	EvalAsync(expr string, args interface{}) *Future
+}

multi/config_m1.lua

@@ -0,0 +1,10 @@
+box.cfg {
+    listen = 3013,
+    wal_dir = 'm1/xlog',
+    snap_dir = 'm1/snap',
+}
+
+box.once("init", function()
+    box.schema.user.create('test', { password = 'test' })
+    box.schema.user.grant('test', 'read,write,execute', 'universe')
+end)

multi/config_m2.lua

@@ -0,0 +1,10 @@
+box.cfg {
+    listen = 3014,
+    wal_dir = 'm2/xlog',
+    snap_dir = 'm2/snap',
+}
+
+box.once("init", function()
+    box.schema.user.create('test', { password = 'test' })
+    box.schema.user.grant('test', 'read,write,execute', 'universe')
+end)