зеркало из https://github.com/github/vitess-gh.git
Replace code.google.com with github.com/youtube/vitess.
This commit is contained in:
Родитель
92a8715746
Коммит
0d046a5984
2
README
2
README
|
@ -1,6 +1,6 @@
|
|||
This the source code repository for the vitess project.
|
||||
For documentation on how install and use vitess,
|
||||
visit http://code.google.com/p/vitess/.
|
||||
visit http://github.com/youtube/vitess/.
|
||||
|
||||
Unless otherwise noted, the vitess source files are distributed
|
||||
under the BSD-style license found in the LICENSE file.
|
||||
|
|
2
dev.env
2
dev.env
|
@ -6,7 +6,7 @@ export VTTOP=$(pwd)
|
|||
export VTROOT="${VTROOT:-${VTTOP/\/src\/code.google.com\/p\/vitess/}}"
|
||||
# VTTOP sanity check
|
||||
if [[ "$VTTOP" == "${VTTOP/\/src\/code.google.com\/p\/vitess/}" ]]; then
|
||||
echo "WARNING: VTTOP($VTTOP) does not contain src/code.google.com/p/vitess"
|
||||
echo "WARNING: VTTOP($VTTOP) does not contain src/github.com/youtube/vitess"
|
||||
fi
|
||||
export GOTOP=$VTTOP/go
|
||||
export PYTOP=$VTTOP/py
|
||||
|
|
|
@ -9,7 +9,7 @@ import (
|
|||
"testing"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/bytes2"
|
||||
"github.com/youtube/vitess/go/bytes2"
|
||||
)
|
||||
|
||||
func TestVariety(t *testing.T) {
|
||||
|
|
|
@ -11,7 +11,7 @@ import (
|
|||
"strconv"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/bytes2"
|
||||
"github.com/youtube/vitess/go/bytes2"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package bson
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/bytes2"
|
||||
"github.com/youtube/vitess/go/bytes2"
|
||||
)
|
||||
|
||||
func EncodeStringArray(buf *bytes2.ChunkedWriter, name string, values []string) {
|
||||
|
|
|
@ -12,7 +12,7 @@ import (
|
|||
"strconv"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/hack"
|
||||
"github.com/youtube/vitess/go/hack"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -8,7 +8,7 @@
|
|||
package bytes2
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/hack"
|
||||
"github.com/youtube/vitess/go/hack"
|
||||
"fmt"
|
||||
"io"
|
||||
"unicode/utf8"
|
||||
|
|
|
@ -11,10 +11,10 @@ import (
|
|||
"os"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/dbconfigs"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/dbconfigs"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
)
|
||||
|
||||
var port = flag.Int("port", 6612, "vtocc port")
|
||||
|
|
|
@ -15,8 +15,8 @@ import (
|
|||
"strconv"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/bson"
|
||||
"code.google.com/p/vitess/go/vt/sqlparser"
|
||||
"github.com/youtube/vitess/go/bson"
|
||||
"github.com/youtube/vitess/go/vt/sqlparser"
|
||||
)
|
||||
|
||||
type NormalizedQuery struct {
|
||||
|
|
|
@ -7,5 +7,5 @@ package main
|
|||
// Imports and register the Zookeeper TopologyServer
|
||||
|
||||
import (
|
||||
_ "code.google.com/p/vitess/go/vt/zktopo"
|
||||
_ "github.com/youtube/vitess/go/vt/zktopo"
|
||||
)
|
||||
|
|
|
@ -9,10 +9,10 @@ import (
|
|||
"os"
|
||||
"sync"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/tb"
|
||||
"code.google.com/p/vitess/go/vt/concurrency"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/tb"
|
||||
"github.com/youtube/vitess/go/vt/concurrency"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
)
|
||||
|
||||
var fromTopo = flag.String("from", "", "topology to copy data from")
|
||||
|
|
|
@ -8,12 +8,12 @@ import (
|
|||
"os"
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"code.google.com/p/vitess/go/vt/zktopo"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"code.google.com/p/vitess/go/zk/fakezk"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/zktopo"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/zk/fakezk"
|
||||
"launchpad.net/gozk/zookeeper"
|
||||
)
|
||||
|
||||
|
|
|
@ -22,15 +22,15 @@ import (
|
|||
"syscall"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/mysql"
|
||||
"code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/stats"
|
||||
"code.google.com/p/vitess/go/umgmt"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/servenv"
|
||||
"github.com/youtube/vitess/go/mysql"
|
||||
"github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/stats"
|
||||
"github.com/youtube/vitess/go/umgmt"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/servenv"
|
||||
)
|
||||
|
||||
var stdout *bufio.Writer
|
||||
|
|
|
@ -20,16 +20,16 @@ import (
|
|||
"syscall"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap"
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
_ "code.google.com/p/vitess/go/snitch"
|
||||
"code.google.com/p/vitess/go/stats"
|
||||
"code.google.com/p/vitess/go/umgmt"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/servenv"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
_ "github.com/youtube/vitess/go/snitch"
|
||||
"github.com/youtube/vitess/go/stats"
|
||||
"github.com/youtube/vitess/go/umgmt"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/servenv"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -7,5 +7,5 @@ package main
|
|||
// Imports and register the Zookeeper TopologyServer
|
||||
|
||||
import (
|
||||
_ "code.google.com/p/vitess/go/vt/zktopo"
|
||||
_ "github.com/youtube/vitess/go/vt/zktopo"
|
||||
)
|
||||
|
|
|
@ -12,17 +12,17 @@ import (
|
|||
_ "net/http/pprof"
|
||||
"os"
|
||||
|
||||
"code.google.com/p/vitess/go/jscfg"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
"code.google.com/p/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "code.google.com/p/vitess/go/snitch"
|
||||
"github.com/youtube/vitess/go/jscfg"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
"github.com/youtube/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "github.com/youtube/vitess/go/snitch"
|
||||
|
||||
"code.google.com/p/vitess/go/vt/dbconfigs"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/tabletmanager"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/dbconfigs"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/tabletmanager"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
)
|
||||
|
||||
var port = flag.Int("port", 0, "port for debug http server")
|
||||
|
|
|
@ -13,9 +13,9 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/db"
|
||||
_ "code.google.com/p/vitess/go/vt/client2"
|
||||
_ "code.google.com/p/vitess/go/vt/client2/tablet"
|
||||
"github.com/youtube/vitess/go/db"
|
||||
_ "github.com/youtube/vitess/go/vt/client2"
|
||||
_ "github.com/youtube/vitess/go/vt/client2/tablet"
|
||||
)
|
||||
|
||||
var usage = `
|
||||
|
|
|
@ -15,13 +15,13 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
tm "code.google.com/p/vitess/go/vt/tabletmanager"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"code.google.com/p/vitess/go/vt/wrangler"
|
||||
"code.google.com/p/vitess/go/vt/zktopo"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
tm "github.com/youtube/vitess/go/vt/tabletmanager"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/wrangler"
|
||||
"github.com/youtube/vitess/go/vt/zktopo"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
"launchpad.net/gozk/zookeeper"
|
||||
)
|
||||
|
||||
|
|
|
@ -18,15 +18,15 @@ import (
|
|||
"syscall"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/tb"
|
||||
"code.google.com/p/vitess/go/vt/client2"
|
||||
hk "code.google.com/p/vitess/go/vt/hook"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
tm "code.google.com/p/vitess/go/vt/tabletmanager"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"code.google.com/p/vitess/go/vt/wrangler"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/tb"
|
||||
"github.com/youtube/vitess/go/vt/client2"
|
||||
hk "github.com/youtube/vitess/go/vt/hook"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
tm "github.com/youtube/vitess/go/vt/tabletmanager"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/wrangler"
|
||||
)
|
||||
|
||||
var noWaitForAction = flag.Bool("no-wait", false, "don't wait for action completion, detach")
|
||||
|
|
|
@ -7,5 +7,5 @@ package main
|
|||
// Imports and register the Zookeeper TopologyServer
|
||||
|
||||
import (
|
||||
_ "code.google.com/p/vitess/go/vt/zktopo"
|
||||
_ "github.com/youtube/vitess/go/vt/zktopo"
|
||||
)
|
||||
|
|
|
@ -14,11 +14,11 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"code.google.com/p/vitess/go/vt/wrangler"
|
||||
"code.google.com/p/vitess/go/vt/zktopo" // FIXME(alainjobart) to be removed
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/wrangler"
|
||||
"github.com/youtube/vitess/go/vt/zktopo" // FIXME(alainjobart) to be removed
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -14,16 +14,16 @@ import (
|
|||
"os/signal"
|
||||
"syscall"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/auth"
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
"code.google.com/p/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "code.google.com/p/vitess/go/snitch"
|
||||
"code.google.com/p/vitess/go/umgmt"
|
||||
"code.google.com/p/vitess/go/vt/dbconfigs"
|
||||
"code.google.com/p/vitess/go/vt/servenv"
|
||||
ts "code.google.com/p/vitess/go/vt/tabletserver"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/auth"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
"github.com/youtube/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "github.com/youtube/vitess/go/snitch"
|
||||
"github.com/youtube/vitess/go/umgmt"
|
||||
"github.com/youtube/vitess/go/vt/dbconfigs"
|
||||
"github.com/youtube/vitess/go/vt/servenv"
|
||||
ts "github.com/youtube/vitess/go/vt/tabletserver"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -7,5 +7,5 @@ package main
|
|||
// Imports and register the Zookeeper TopologyServer
|
||||
|
||||
import (
|
||||
_ "code.google.com/p/vitess/go/vt/zktopo"
|
||||
_ "github.com/youtube/vitess/go/vt/zktopo"
|
||||
)
|
||||
|
|
|
@ -21,23 +21,23 @@ import (
|
|||
"syscall"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/cgzip"
|
||||
"code.google.com/p/vitess/go/jscfg"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/auth"
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
"code.google.com/p/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "code.google.com/p/vitess/go/snitch"
|
||||
"code.google.com/p/vitess/go/umgmt"
|
||||
"code.google.com/p/vitess/go/vt/dbconfigs"
|
||||
vtenv "code.google.com/p/vitess/go/vt/env"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/servenv"
|
||||
"code.google.com/p/vitess/go/vt/sqlparser"
|
||||
tm "code.google.com/p/vitess/go/vt/tabletmanager"
|
||||
ts "code.google.com/p/vitess/go/vt/tabletserver"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/cgzip"
|
||||
"github.com/youtube/vitess/go/jscfg"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/auth"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
"github.com/youtube/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "github.com/youtube/vitess/go/snitch"
|
||||
"github.com/youtube/vitess/go/umgmt"
|
||||
"github.com/youtube/vitess/go/vt/dbconfigs"
|
||||
vtenv "github.com/youtube/vitess/go/vt/env"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/servenv"
|
||||
"github.com/youtube/vitess/go/vt/sqlparser"
|
||||
tm "github.com/youtube/vitess/go/vt/tabletmanager"
|
||||
ts "github.com/youtube/vitess/go/vt/tabletserver"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -16,8 +16,8 @@ import (
|
|||
"time"
|
||||
|
||||
opts "code.google.com/p/opts-go"
|
||||
"code.google.com/p/vitess/go/terminal"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/terminal"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
|
||||
"launchpad.net/gozk/zookeeper"
|
||||
)
|
||||
|
|
|
@ -11,10 +11,10 @@ import (
|
|||
"os"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
)
|
||||
|
||||
var usage = `
|
||||
|
|
|
@ -12,8 +12,8 @@ import (
|
|||
"os"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/zk/zkctl"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/zk/zkctl"
|
||||
)
|
||||
|
||||
var usage = `
|
||||
|
|
|
@ -22,10 +22,10 @@ import (
|
|||
"path"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/netutil"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"code.google.com/p/vitess/go/zk/zkns"
|
||||
"github.com/youtube/vitess/go/netutil"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/zk/zkns"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -6,8 +6,8 @@ import (
|
|||
"os"
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/netutil"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/netutil"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
"launchpad.net/gozk/zookeeper"
|
||||
)
|
||||
|
||||
|
|
|
@ -10,15 +10,15 @@ import (
|
|||
_ "net/http/pprof"
|
||||
"os"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
"code.google.com/p/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "code.google.com/p/vitess/go/snitch"
|
||||
"code.google.com/p/vitess/go/umgmt"
|
||||
"code.google.com/p/vitess/go/vt/servenv"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"code.google.com/p/vitess/go/zk/zkocc"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
"github.com/youtube/vitess/go/rpcwrap/jsonrpc"
|
||||
_ "github.com/youtube/vitess/go/snitch"
|
||||
"github.com/youtube/vitess/go/umgmt"
|
||||
"github.com/youtube/vitess/go/vt/servenv"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/zk/zkocc"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -12,7 +12,7 @@ import (
|
|||
"fmt"
|
||||
"io/ioutil"
|
||||
|
||||
"code.google.com/p/vitess/go/ioutil2"
|
||||
"github.com/youtube/vitess/go/ioutil2"
|
||||
)
|
||||
|
||||
func ToJson(val interface{}) string {
|
||||
|
|
|
@ -15,10 +15,10 @@ import (
|
|||
"fmt"
|
||||
"unsafe"
|
||||
|
||||
"code.google.com/p/vitess/go/hack"
|
||||
"code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/hack"
|
||||
"github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -7,9 +7,9 @@ package proto
|
|||
import (
|
||||
"bytes"
|
||||
|
||||
"code.google.com/p/vitess/go/bson"
|
||||
"code.google.com/p/vitess/go/bytes2"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/bson"
|
||||
"github.com/youtube/vitess/go/bytes2"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
func MarshalFieldBson(field Field, buf *bytes2.ChunkedWriter) {
|
||||
|
|
|
@ -7,8 +7,8 @@ package proto
|
|||
import (
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/bson"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/bson"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
type TestCase struct {
|
||||
|
|
|
@ -5,7 +5,7 @@
|
|||
package proto
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
type Field struct {
|
||||
|
|
|
@ -10,7 +10,7 @@ import (
|
|||
"fmt"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -9,7 +9,7 @@ import (
|
|||
"testing"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
)
|
||||
|
||||
var lastId, count sync2.AtomicInt64
|
||||
|
|
|
@ -5,7 +5,7 @@
|
|||
package jsonrpc
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcplus"
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"fmt"
|
||||
|
|
|
@ -13,7 +13,7 @@ import (
|
|||
"net"
|
||||
"sync"
|
||||
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
)
|
||||
|
||||
type clientCodec struct {
|
||||
|
|
|
@ -10,7 +10,7 @@ import (
|
|||
"io"
|
||||
"sync"
|
||||
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
)
|
||||
|
||||
type serverCodec struct {
|
||||
|
|
|
@ -7,9 +7,9 @@ import (
|
|||
"io/ioutil"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/proto"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/proto"
|
||||
)
|
||||
|
||||
// UnusedArgument is a type used to indicate an argument that is
|
||||
|
|
|
@ -8,10 +8,10 @@ import (
|
|||
"io"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/bson"
|
||||
"code.google.com/p/vitess/go/bytes2"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap"
|
||||
"github.com/youtube/vitess/go/bson"
|
||||
"github.com/youtube/vitess/go/bytes2"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -6,9 +6,9 @@ package bsonrpc
|
|||
|
||||
import (
|
||||
"bytes"
|
||||
"code.google.com/p/vitess/go/bson"
|
||||
"code.google.com/p/vitess/go/bytes2"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/bson"
|
||||
"github.com/youtube/vitess/go/bytes2"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
)
|
||||
|
||||
type RequestBson struct {
|
||||
|
|
|
@ -7,9 +7,9 @@ package jsonrpc
|
|||
import (
|
||||
"time"
|
||||
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
oldjson "code.google.com/p/vitess/go/rpcplus/jsonrpc"
|
||||
"code.google.com/p/vitess/go/rpcwrap"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
oldjson "github.com/youtube/vitess/go/rpcplus/jsonrpc"
|
||||
"github.com/youtube/vitess/go/rpcwrap"
|
||||
)
|
||||
|
||||
func DialHTTP(network, address string, connectTimeout time.Duration) (*rpc.Client, error) {
|
||||
|
|
|
@ -12,10 +12,10 @@ import (
|
|||
"net/http"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
rpc "code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/auth"
|
||||
"code.google.com/p/vitess/go/rpcwrap/proto"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
rpc "github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/auth"
|
||||
"github.com/youtube/vitess/go/rpcwrap/proto"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -5,7 +5,7 @@
|
|||
package snitch
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"fmt"
|
||||
"net/http"
|
||||
"runtime"
|
||||
|
|
|
@ -13,7 +13,7 @@ import (
|
|||
"strconv"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/hack"
|
||||
"github.com/youtube/vitess/go/hack"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -7,8 +7,8 @@ import (
|
|||
"net/url"
|
||||
"sync"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
)
|
||||
|
||||
var droppedMessages = expvar.NewMap("streamlog-dropped-messages")
|
||||
|
|
|
@ -30,7 +30,7 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
)
|
||||
|
||||
// Out-of-band messages
|
||||
|
|
|
@ -9,7 +9,7 @@ import (
|
|||
"net"
|
||||
"net/rpc"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
type Client struct {
|
||||
|
|
|
@ -14,7 +14,7 @@ import (
|
|||
"strings"
|
||||
"sync"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
var connectionCount = expvar.NewInt("connection-count")
|
||||
|
|
|
@ -26,7 +26,7 @@ import (
|
|||
"syscall"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
type Request struct{}
|
||||
|
|
|
@ -7,7 +7,7 @@ package umgmt
|
|||
import (
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
var ready = make(chan bool)
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
package main
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/umgmt"
|
||||
"github.com/youtube/vitess/go/umgmt"
|
||||
"flag"
|
||||
)
|
||||
|
||||
|
|
|
@ -11,18 +11,18 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/db"
|
||||
"github.com/youtube/vitess/go/db"
|
||||
// FIXME(msolomon) needed for the field mapping. Probably should be part of
|
||||
// tablet, or moved.
|
||||
mproto "code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/vt/client2/tablet"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
mproto "github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/vt/client2/tablet"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
// FIXME(msolomon) zk indirect dependency
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
// FIXME(msolomon) seems like a subpackage
|
||||
"code.google.com/p/vitess/go/vt/sqlparser"
|
||||
"code.google.com/p/vitess/go/vt/zktopo"
|
||||
"code.google.com/p/vitess/go/zk"
|
||||
"github.com/youtube/vitess/go/vt/sqlparser"
|
||||
"github.com/youtube/vitess/go/vt/zktopo"
|
||||
"github.com/youtube/vitess/go/zk"
|
||||
)
|
||||
|
||||
// The sharded client handles writing to multiple shards across the
|
||||
|
|
|
@ -10,7 +10,7 @@ package client2
|
|||
// "testing"
|
||||
// _ "time"
|
||||
|
||||
// _ "code.google.com/p/vitess/go/zk"
|
||||
// _ "github.com/youtube/vitess/go/zk"
|
||||
// )
|
||||
|
||||
// // This is more of an example code than a real test
|
||||
|
|
|
@ -15,12 +15,12 @@ import (
|
|||
"net/url"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/db"
|
||||
mproto "code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/rpcplus"
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
tproto "code.google.com/p/vitess/go/vt/tabletserver/proto"
|
||||
"github.com/youtube/vitess/go/db"
|
||||
mproto "github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/rpcplus"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
tproto "github.com/youtube/vitess/go/vt/tabletserver/proto"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -12,8 +12,8 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/db"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/db"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -9,7 +9,7 @@ import (
|
|||
"strings"
|
||||
"sync"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
// ErrorRecorder offers a way to record errors during complex
|
||||
|
|
|
@ -8,7 +8,7 @@ import (
|
|||
"fmt"
|
||||
"sync"
|
||||
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
)
|
||||
|
||||
// ResourceConstraint combines 3 different features:
|
||||
|
|
|
@ -10,10 +10,10 @@ import (
|
|||
"encoding/json"
|
||||
"flag"
|
||||
|
||||
"code.google.com/p/vitess/go/jscfg"
|
||||
"code.google.com/p/vitess/go/mysql"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/jscfg"
|
||||
"github.com/youtube/vitess/go/mysql"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
)
|
||||
|
||||
// Offer a sample config - probably should load this when file isn't set.
|
||||
|
|
|
@ -13,9 +13,9 @@ import (
|
|||
"strings"
|
||||
"syscall"
|
||||
|
||||
"code.google.com/p/vitess/go/jscfg"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
vtenv "code.google.com/p/vitess/go/vt/env"
|
||||
"github.com/youtube/vitess/go/jscfg"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
vtenv "github.com/youtube/vitess/go/vt/env"
|
||||
)
|
||||
|
||||
type Hook struct {
|
||||
|
|
|
@ -16,10 +16,10 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/bson"
|
||||
"code.google.com/p/vitess/go/bytes2"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
parser "code.google.com/p/vitess/go/vt/sqlparser"
|
||||
"github.com/youtube/vitess/go/bson"
|
||||
"github.com/youtube/vitess/go/bytes2"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
parser "github.com/youtube/vitess/go/vt/sqlparser"
|
||||
)
|
||||
|
||||
/*
|
||||
|
|
|
@ -11,7 +11,7 @@ condition is if EOF is reached *and* the next file has appeared.
|
|||
*/
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"encoding/binary"
|
||||
"fmt"
|
||||
"io"
|
||||
|
|
|
@ -14,9 +14,9 @@ import (
|
|||
"path/filepath"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/ioutil2"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/hook"
|
||||
"github.com/youtube/vitess/go/ioutil2"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/hook"
|
||||
)
|
||||
|
||||
// These methods deal with cloning a running instance of mysql.
|
||||
|
|
|
@ -6,7 +6,7 @@ import (
|
|||
"io"
|
||||
"strconv"
|
||||
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
)
|
||||
|
||||
type KeyspaceCSVReader struct {
|
||||
|
|
|
@ -5,7 +5,7 @@ import (
|
|||
"os"
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
)
|
||||
|
||||
type pair struct {
|
||||
|
|
|
@ -22,9 +22,9 @@ import (
|
|||
"strings"
|
||||
"sync"
|
||||
|
||||
"code.google.com/p/vitess/go/cgzip"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/cgzip"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
)
|
||||
|
||||
// Use this to simulate failures in tests
|
||||
|
|
|
@ -13,7 +13,7 @@ import (
|
|||
"path"
|
||||
"text/template"
|
||||
|
||||
"code.google.com/p/vitess/go/vt/env"
|
||||
"github.com/youtube/vitess/go/vt/env"
|
||||
)
|
||||
|
||||
type VtReplParams struct {
|
||||
|
|
|
@ -9,7 +9,7 @@ import (
|
|||
"path"
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/vt/env"
|
||||
"github.com/youtube/vitess/go/vt/env"
|
||||
)
|
||||
|
||||
var MYCNF_PATH = "/tmp/my.cnf"
|
||||
|
@ -25,9 +25,9 @@ func TestMycnf(t *testing.T) {
|
|||
t.Errorf("err: %v", err)
|
||||
}
|
||||
cnfTemplatePaths := []string{
|
||||
path.Join(root, "src/code.google.com/p/vitess/config/mycnf/default.cnf"),
|
||||
path.Join(root, "src/code.google.com/p/vitess/config/mycnf/replica.cnf"),
|
||||
path.Join(root, "src/code.google.com/p/vitess/config/mycnf/master.cnf"),
|
||||
path.Join(root, "src/github.com/youtube/vitess/config/mycnf/default.cnf"),
|
||||
path.Join(root, "src/github.com/youtube/vitess/config/mycnf/replica.cnf"),
|
||||
path.Join(root, "src/github.com/youtube/vitess/config/mycnf/master.cnf"),
|
||||
}
|
||||
data, err := MakeMycnf(tablet0.config, cnfTemplatePaths)
|
||||
if err != nil {
|
||||
|
|
|
@ -10,8 +10,8 @@ import (
|
|||
"os"
|
||||
"path"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
vtenv "code.google.com/p/vitess/go/vt/env"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
vtenv "github.com/youtube/vitess/go/vt/env"
|
||||
)
|
||||
|
||||
/*
|
||||
|
|
|
@ -22,11 +22,11 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/mysql"
|
||||
"code.google.com/p/vitess/go/netutil"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
vtenv "code.google.com/p/vitess/go/vt/env"
|
||||
"code.google.com/p/vitess/go/vt/hook"
|
||||
"github.com/youtube/vitess/go/mysql"
|
||||
"github.com/youtube/vitess/go/netutil"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
vtenv "github.com/youtube/vitess/go/vt/env"
|
||||
"github.com/youtube/vitess/go/vt/hook"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -9,9 +9,9 @@ import (
|
|||
"hash/crc64"
|
||||
"sort"
|
||||
|
||||
"code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"code.google.com/p/vitess/go/vt/concurrency"
|
||||
"github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/vt/concurrency"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -7,8 +7,8 @@ package mysqlctl
|
|||
import (
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
func mapToSqlResults(row map[string]string) ([]proto.Field, []sqltypes.Value) {
|
||||
|
|
|
@ -8,7 +8,7 @@ import (
|
|||
"fmt"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
// if the master is still alive, then we need to demote it gracefully
|
||||
|
|
|
@ -20,9 +20,9 @@ import (
|
|||
"text/template"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -12,9 +12,9 @@ import (
|
|||
"sort"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/jscfg"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/concurrency"
|
||||
"github.com/youtube/vitess/go/jscfg"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/concurrency"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -95,13 +95,13 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/bufio2"
|
||||
"code.google.com/p/vitess/go/cgzip"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"code.google.com/p/vitess/go/vt/concurrency"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl/csvsplitter"
|
||||
"github.com/youtube/vitess/go/bufio2"
|
||||
"github.com/youtube/vitess/go/cgzip"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/vt/concurrency"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl/csvsplitter"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -12,11 +12,11 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/rpcwrap"
|
||||
estats "code.google.com/p/vitess/go/stats" // stats is a private type defined somewhere else in this package, so it would conflict
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"code.google.com/p/vitess/go/vt/dbconfigs"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/rpcwrap"
|
||||
estats "github.com/youtube/vitess/go/stats" // stats is a private type defined somewhere else in this package, so it would conflict
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/vt/dbconfigs"
|
||||
)
|
||||
|
||||
/* API and config for UpdateStream Service */
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
package mysqlctl
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
type MapFunc func(index int) error
|
||||
|
|
|
@ -10,7 +10,7 @@ package schema
|
|||
import (
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
// Column categories
|
||||
|
|
|
@ -23,8 +23,8 @@ import (
|
|||
"syscall"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/logfile"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/logfile"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
@ -8,7 +8,7 @@ import (
|
|||
"bytes"
|
||||
"fmt"
|
||||
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
type ParserError struct {
|
||||
|
|
|
@ -8,9 +8,9 @@ import (
|
|||
"fmt"
|
||||
"strconv"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"code.google.com/p/vitess/go/vt/schema"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/vt/schema"
|
||||
)
|
||||
|
||||
type PlanType int
|
||||
|
|
|
@ -15,9 +15,9 @@ import (
|
|||
"strings"
|
||||
"testing"
|
||||
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/schema"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/schema"
|
||||
)
|
||||
|
||||
func TestGen(t *testing.T) {
|
||||
|
|
|
@ -9,7 +9,7 @@ import (
|
|||
"encoding/json"
|
||||
"strconv"
|
||||
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
type BindLocation struct {
|
||||
|
|
|
@ -7,7 +7,7 @@ package sqlparser
|
|||
import (
|
||||
"strconv"
|
||||
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -10,7 +10,7 @@ import (
|
|||
"io"
|
||||
"unicode"
|
||||
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
)
|
||||
|
||||
const EOFCHAR = 0x100
|
||||
|
|
|
@ -15,11 +15,11 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/jscfg"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/hook"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/jscfg"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/hook"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -17,13 +17,13 @@ import (
|
|||
"syscall"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/tb"
|
||||
"code.google.com/p/vitess/go/vt/hook"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"code.google.com/p/vitess/go/vt/zktopo"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/tb"
|
||||
"github.com/youtube/vitess/go/vt/hook"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/zktopo"
|
||||
)
|
||||
|
||||
// The actor applies individual commands to execute an action read
|
||||
|
|
|
@ -22,11 +22,11 @@ import (
|
|||
"strings"
|
||||
"sync"
|
||||
|
||||
"code.google.com/p/vitess/go/netutil"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/env"
|
||||
"code.google.com/p/vitess/go/vt/tabletserver"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/netutil"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/env"
|
||||
"github.com/youtube/vitess/go/vt/tabletserver"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
)
|
||||
|
||||
// Each TabletChangeCallback must be idempotent and "threadsafe". The
|
||||
|
|
|
@ -19,12 +19,12 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/rpcwrap/bsonrpc"
|
||||
"code.google.com/p/vitess/go/vt/hook"
|
||||
"code.google.com/p/vitess/go/vt/key"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/topo"
|
||||
"code.google.com/p/vitess/go/vt/zktopo"
|
||||
"github.com/youtube/vitess/go/rpcwrap/bsonrpc"
|
||||
"github.com/youtube/vitess/go/vt/hook"
|
||||
"github.com/youtube/vitess/go/vt/key"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/topo"
|
||||
"github.com/youtube/vitess/go/vt/zktopo"
|
||||
)
|
||||
|
||||
// The actor applies individual commands to execute an action read from a node
|
||||
|
|
|
@ -7,11 +7,11 @@ package tabletmanager
|
|||
import (
|
||||
"fmt"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/rpcwrap"
|
||||
rpcproto "code.google.com/p/vitess/go/rpcwrap/proto"
|
||||
"code.google.com/p/vitess/go/vt/mysqlctl"
|
||||
"code.google.com/p/vitess/go/vt/rpc"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/rpcwrap"
|
||||
rpcproto "github.com/youtube/vitess/go/rpcwrap/proto"
|
||||
"github.com/youtube/vitess/go/vt/mysqlctl"
|
||||
"github.com/youtube/vitess/go/vt/rpc"
|
||||
)
|
||||
|
||||
// we keep track of the agent so we can use its tabletAlias, ts, ...
|
||||
|
|
|
@ -8,10 +8,10 @@ import (
|
|||
"fmt"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/pools"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"code.google.com/p/vitess/go/timer"
|
||||
"github.com/youtube/vitess/go/pools"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/timer"
|
||||
)
|
||||
|
||||
type ActivePool struct {
|
||||
|
|
|
@ -10,12 +10,12 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/pools"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/stats"
|
||||
"code.google.com/p/vitess/go/streamlog"
|
||||
"code.google.com/p/vitess/go/sync2"
|
||||
"code.google.com/p/vitess/go/timer"
|
||||
"github.com/youtube/vitess/go/pools"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/stats"
|
||||
"github.com/youtube/vitess/go/streamlog"
|
||||
"github.com/youtube/vitess/go/sync2"
|
||||
"github.com/youtube/vitess/go/timer"
|
||||
)
|
||||
|
||||
/* Function naming convention:
|
||||
|
|
|
@ -9,10 +9,10 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/memcache"
|
||||
"code.google.com/p/vitess/go/pools"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/vt/dbconfigs"
|
||||
"github.com/youtube/vitess/go/memcache"
|
||||
"github.com/youtube/vitess/go/pools"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/vt/dbconfigs"
|
||||
)
|
||||
|
||||
const statsURL = "/debug/memcache/"
|
||||
|
|
|
@ -10,9 +10,9 @@ import (
|
|||
"fmt"
|
||||
"strings"
|
||||
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"code.google.com/p/vitess/go/vt/schema"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/vt/schema"
|
||||
)
|
||||
|
||||
// buildValueList builds the set of PK reference rows used to drive the next query.
|
||||
|
|
|
@ -5,7 +5,7 @@
|
|||
package tabletserver
|
||||
|
||||
import (
|
||||
"code.google.com/p/vitess/go/vt/tabletserver/proto"
|
||||
"github.com/youtube/vitess/go/vt/tabletserver/proto"
|
||||
)
|
||||
|
||||
const TRAILING_COMMENT = "_trailingComment"
|
||||
|
|
|
@ -8,7 +8,7 @@ import (
|
|||
"sync"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/pools"
|
||||
"github.com/youtube/vitess/go/pools"
|
||||
)
|
||||
|
||||
// ConnectionPool re-exposes ResourcePool as a pool of DBConnection objects
|
||||
|
|
|
@ -8,11 +8,11 @@ import (
|
|||
"strings"
|
||||
"time"
|
||||
|
||||
"code.google.com/p/vitess/go/mysql"
|
||||
"code.google.com/p/vitess/go/mysql/proto"
|
||||
"code.google.com/p/vitess/go/relog"
|
||||
"code.google.com/p/vitess/go/sqltypes"
|
||||
"code.google.com/p/vitess/go/stats"
|
||||
"github.com/youtube/vitess/go/mysql"
|
||||
"github.com/youtube/vitess/go/mysql/proto"
|
||||
"github.com/youtube/vitess/go/relog"
|
||||
"github.com/youtube/vitess/go/sqltypes"
|
||||
"github.com/youtube/vitess/go/stats"
|
||||
)
|
||||
|
||||
var mysqlStats *stats.Timings
|
||||
|
|
Некоторые файлы не были показаны из-за слишком большого количества измененных файлов Показать больше
Загрузка…
Ссылка в новой задаче