fluidB
/
fluidb-old
1
0
Fork 0
Code Pull Requests Activity

Bring go mod import path into compliance

Browse Source
master
Philip O'Toole 9 months ago
parent dbb6dda957
commit ad916270d2
66 changed files with 3198 additions and 132 deletions
Show Stats Download Patch File Download Diff File

4
auto/backup/config.go
Unescape Escape View File

@ -5,8 +5,8 @@ import (
"io" "io"
"os" "os"
"github.com/rqlite/rqlite/auto" "github.com/rqlite/rqlite/v8/auto"
"github.com/rqlite/rqlite/aws" "github.com/rqlite/rqlite/v8/aws"
) )
// Config is the config file format for the upload service // Config is the config file format for the upload service

4
auto/backup/config_test.go
Unescape Escape View File

@ -9,8 +9,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/auto" "github.com/rqlite/rqlite/v8/auto"
"github.com/rqlite/rqlite/aws" "github.com/rqlite/rqlite/v8/aws"
) )
func Test_ReadConfigFile(t *testing.T) { func Test_ReadConfigFile(t *testing.T) {

2
auto/backup/uploader.go
Unescape Escape View File

@ -10,7 +10,7 @@ import (
"os" "os"
"time" "time"
"github.com/rqlite/rqlite/progress" "github.com/rqlite/rqlite/v8/progress"
) )
// StorageClient is an interface for uploading data to a storage service. // StorageClient is an interface for uploading data to a storage service.

4
auto/restore/config.go
Unescape Escape View File

@ -6,8 +6,8 @@ import (
"os" "os"
"time" "time"
"github.com/rqlite/rqlite/auto" "github.com/rqlite/rqlite/v8/auto"
"github.com/rqlite/rqlite/aws" "github.com/rqlite/rqlite/v8/aws"
) )
// Config is the config file format for the upload service // Config is the config file format for the upload service

4
auto/restore/config_test.go
Unescape Escape View File

@ -9,8 +9,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/auto" "github.com/rqlite/rqlite/v8/auto"
"github.com/rqlite/rqlite/aws" "github.com/rqlite/rqlite/v8/aws"
) )
func Test_ReadConfigFile(t *testing.T) { func Test_ReadConfigFile(t *testing.T) {

4
cluster/bootstrap.go
Unescape Escape View File

@ -8,8 +8,8 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/random" "github.com/rqlite/rqlite/v8/random"
) )
var ( var (

4
cluster/bootstrap_test.go
Unescape Escape View File

@ -8,8 +8,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster/servicetest" "github.com/rqlite/rqlite/v8/cluster/servicetest"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )

4
cluster/client.go
Unescape Escape View File

@ -11,8 +11,8 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/tcp/pool" "github.com/rqlite/rqlite/v8/tcp/pool"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )

4
cluster/client_test.go
Unescape Escape View File

@ -8,8 +8,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster/servicetest" "github.com/rqlite/rqlite/v8/cluster/servicetest"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )

2
cluster/join.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"os" "os"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
var ( var (

2
cluster/join_test.go
Unescape Escape View File

@ -5,7 +5,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster/servicetest" "github.com/rqlite/rqlite/v8/cluster/servicetest"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )

2
cluster/message.pb.go
Unescape Escape View File

@ -7,7 +7,7 @@
package cluster package cluster
import ( import (
command "github.com/rqlite/rqlite/command" command "github.com/rqlite/rqlite/v8/command"
protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl" protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect" reflect "reflect"

2
cluster/message.proto
Unescape Escape View File

@ -3,7 +3,7 @@ package cluster;
import "command/command.proto"; import "command/command.proto";
option go_package = "github.com/rqlite/rqlite/cluster"; option go_package = "github.com/rqlite/rqlite/v8/cluster";
message Credentials { message Credentials {
string username = 1; string username = 1;

2
cluster/remove.go
Unescape Escape View File

@ -5,7 +5,7 @@ import (
"os" "os"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
const ( const (

2
cluster/remove_test.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster/servicetest" "github.com/rqlite/rqlite/v8/cluster/servicetest"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )

4
cluster/service.go
Unescape Escape View File

@ -14,8 +14,8 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/auth" "github.com/rqlite/rqlite/v8/auth"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )

4
cluster/service_db_clstr_test.go
Unescape Escape View File

@ -10,8 +10,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/command/encoding" "github.com/rqlite/rqlite/v8/command/encoding"
) )
const shortWait = 1 * time.Second const shortWait = 1 * time.Second

6
cluster/service_mux_test.go
Unescape Escape View File

@ -8,9 +8,9 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
"github.com/rqlite/rqlite/tcp" "github.com/rqlite/rqlite/v8/tcp"
"github.com/rqlite/rqlite/testdata/x509" "github.com/rqlite/rqlite/v8/testdata/x509"
) )
func Test_NewServiceSetGetNodeAPIAddrMuxed(t *testing.T) { func Test_NewServiceSetGetNodeAPIAddrMuxed(t *testing.T) {

4
cluster/service_test.go
Unescape Escape View File

@ -10,8 +10,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/testdata/x509" "github.com/rqlite/rqlite/v8/testdata/x509"
) )
func Test_NewServiceOpenClose(t *testing.T) { func Test_NewServiceOpenClose(t *testing.T) {

2
cmd/rqlite/execute.go
Unescape Escape View File

@ -8,7 +8,7 @@ import (
"strings" "strings"
"github.com/mkideal/cli" "github.com/mkideal/cli"
cl "github.com/rqlite/rqlite/cmd/rqlite/http" cl "github.com/rqlite/rqlite/v8/cmd/rqlite/http"
) )
// Result represents execute result // Result represents execute result

8
cmd/rqlite/main.go
Unescape Escape View File

@ -18,10 +18,10 @@ import (
"github.com/Bowery/prompt" "github.com/Bowery/prompt"
"github.com/mkideal/cli" "github.com/mkideal/cli"
clix "github.com/mkideal/cli/ext" clix "github.com/mkideal/cli/ext"
"github.com/rqlite/rqlite/cmd" "github.com/rqlite/rqlite/v8/cmd"
"github.com/rqlite/rqlite/cmd/rqlite/history" "github.com/rqlite/rqlite/v8/cmd/rqlite/history"
httpcl "github.com/rqlite/rqlite/cmd/rqlite/http" httpcl "github.com/rqlite/rqlite/v8/cmd/rqlite/http"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
) )
const maxRedirect = 21 const maxRedirect = 21

2
cmd/rqlite/query.go
Unescape Escape View File

@ -8,7 +8,7 @@ import (
"github.com/mkideal/cli" "github.com/mkideal/cli"
"github.com/mkideal/pkg/textutil" "github.com/mkideal/pkg/textutil"
cl "github.com/rqlite/rqlite/cmd/rqlite/http" cl "github.com/rqlite/rqlite/v8/cmd/rqlite/http"
) )
// Rows represents query result // Rows represents query result

26
cmd/rqlited/main.go
Unescape Escape View File

@ -18,19 +18,19 @@ import (
"github.com/rqlite/rqlite-disco-clients/dns" "github.com/rqlite/rqlite-disco-clients/dns"
"github.com/rqlite/rqlite-disco-clients/dnssrv" "github.com/rqlite/rqlite-disco-clients/dnssrv"
etcd "github.com/rqlite/rqlite-disco-clients/etcd" etcd "github.com/rqlite/rqlite-disco-clients/etcd"
"github.com/rqlite/rqlite/auth" "github.com/rqlite/rqlite/v8/auth"
"github.com/rqlite/rqlite/auto/backup" "github.com/rqlite/rqlite/v8/auto/backup"
"github.com/rqlite/rqlite/auto/restore" "github.com/rqlite/rqlite/v8/auto/restore"
"github.com/rqlite/rqlite/aws" "github.com/rqlite/rqlite/v8/aws"
"github.com/rqlite/rqlite/cluster" "github.com/rqlite/rqlite/v8/cluster"
"github.com/rqlite/rqlite/cmd" "github.com/rqlite/rqlite/v8/cmd"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
"github.com/rqlite/rqlite/disco" "github.com/rqlite/rqlite/v8/disco"
"github.com/rqlite/rqlite/http" "github.com/rqlite/rqlite/v8/http"
httpd "github.com/rqlite/rqlite/http" httpd "github.com/rqlite/rqlite/v8/http"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
"github.com/rqlite/rqlite/tcp" "github.com/rqlite/rqlite/v8/tcp"
) )
const logo = ` const logo = `

2
command/chunking/chunker.go
Unescape Escape View File

@ -9,7 +9,7 @@ import (
"io" "io"
"sync" "sync"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
const ( const (

2
command/chunking/dechunker.go
Unescape Escape View File

@ -8,7 +8,7 @@ import (
"os" "os"
"sync" "sync"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
// Dechunker is a writer that writes chunks to a file and returns the file path when // Dechunker is a writer that writes chunks to a file and returns the file path when

2
command/chunking/dechunker_test.go
Unescape Escape View File

@ -10,7 +10,7 @@ import (
"strings" "strings"
"testing" "testing"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
func Test_SingleChunk(t *testing.T) { func Test_SingleChunk(t *testing.T) {

2
command/command.proto
Unescape Escape View File

@ -1,7 +1,7 @@
syntax = "proto3"; syntax = "proto3";
package command; package command;
option go_package = "github.com/rqlite/rqlite/command"; option go_package = "github.com/rqlite/rqlite/v8/command";
message Parameter { message Parameter {
oneof value { oneof value {

2
command/encoding/json.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"errors" "errors"
"fmt" "fmt"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
var ( var (

2
command/encoding/json_test.go
Unescape Escape View File

@ -3,7 +3,7 @@ package encoding
import ( import (
"testing" "testing"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
func Test_JSONNoEscaping(t *testing.T) { func Test_JSONNoEscaping(t *testing.T) {

2
db/db.go
Unescape Escape View File

@ -18,7 +18,7 @@ import (
"time" "time"
"github.com/rqlite/go-sqlite3" "github.com/rqlite/go-sqlite3"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
const ( const (

4
db/db_common_test.go
Unescape Escape View File

@ -7,8 +7,8 @@ import (
"strings" "strings"
"testing" "testing"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/testdata/chinook" "github.com/rqlite/rqlite/v8/testdata/chinook"
) )
func testCompileOptions(t *testing.T, db *DB) { func testCompileOptions(t *testing.T, db *DB) {

4
db/db_test.go
Unescape Escape View File

@ -10,8 +10,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/command/encoding" "github.com/rqlite/rqlite/v8/command/encoding"
) )
// Test_OpenNonExistentDatabase tests that opening a non-existent database // Test_OpenNonExistentDatabase tests that opening a non-existent database

2
db/wal/walr/main.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"io" "io"
"os" "os"
"github.com/rqlite/rqlite/db/wal" "github.com/rqlite/rqlite/v8/db/wal"
) )
const name = `walr` const name = `walr`

2
db/wal/writer_test.go
Unescape Escape View File

@ -9,7 +9,7 @@ import (
"testing" "testing"
_ "github.com/rqlite/go-sqlite3" _ "github.com/rqlite/go-sqlite3"
"github.com/rqlite/rqlite/random" "github.com/rqlite/rqlite/v8/random"
) )
func Test_Writer_FullScanner(t *testing.T) { func Test_Writer_FullScanner(t *testing.T) {

2
disco/service.go
Unescape Escape View File

@ -7,7 +7,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/random" "github.com/rqlite/rqlite/v8/random"
) )
const ( const (

2
go.mod
Unescape Escape View File

@ -1,4 +1,4 @@
module github.com/rqlite/rqlite module github.com/rqlite/rqlite/v8
go 1.21 go 1.21

2
http/nodes.go
Unescape Escape View File

@ -8,7 +8,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
) )
// Node represents a single node in the cluster and can include // Node represents a single node in the cluster and can include

2
http/nodes_test.go
Unescape Escape View File

@ -8,7 +8,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
) )
func Test_NewNodeFromServer(t *testing.T) { func Test_NewNodeFromServer(t *testing.T) {

2
http/preflight_test.go
Unescape Escape View File

@ -9,7 +9,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
) )
// Test_IsServingHTTP_HTTPServerOnly tests only HTTP server running. // Test_IsServingHTTP_HTTPServerOnly tests only HTTP server running.

2
http/query_params.go
Unescape Escape View File

@ -7,7 +7,7 @@ import (
"strings" "strings"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
// QueryParams represents the query parameters passed in an HTTP request. // QueryParams represents the query parameters passed in an HTTP request.

2
http/request_parser.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"errors" "errors"
"fmt" "fmt"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
var ( var (

16
http/service.go
Unescape Escape View File

@ -20,14 +20,14 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/auth" "github.com/rqlite/rqlite/v8/auth"
"github.com/rqlite/rqlite/cluster" "github.com/rqlite/rqlite/v8/cluster"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/command/encoding" "github.com/rqlite/rqlite/v8/command/encoding"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
"github.com/rqlite/rqlite/queue" "github.com/rqlite/rqlite/v8/queue"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
) )
var ( var (

6
http/service_test.go
Unescape Escape View File

@ -13,9 +13,9 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster" "github.com/rqlite/rqlite/v8/cluster"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
) )
func Test_ResponseJSONMarshal(t *testing.T) { func Test_ResponseJSONMarshal(t *testing.T) {

2
http/service_tls_test.go
Unescape Escape View File

@ -12,7 +12,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
"golang.org/x/net/http2" "golang.org/x/net/http2"
) )

2
queue/queue.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
// stats captures stats for the Queue. // stats captures stats for the Queue.

2
queue/queue_test.go
Unescape Escape View File

@ -5,7 +5,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
var ( var (

2
snapshot/sink.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"path/filepath" "path/filepath"
"github.com/hashicorp/raft" "github.com/hashicorp/raft"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
) )
// Sink is a sink for writing snapshot data to a Snapshot store. // Sink is a sink for writing snapshot data to a Snapshot store.

4
snapshot/sink_test.go
Unescape Escape View File

@ -9,8 +9,8 @@ import (
"testing" "testing"
"github.com/hashicorp/raft" "github.com/hashicorp/raft"
"github.com/rqlite/rqlite/command/encoding" "github.com/rqlite/rqlite/v8/command/encoding"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
) )
func Test_NewSinkCancel(t *testing.T) { func Test_NewSinkCancel(t *testing.T) {

2
snapshot/snapshot.go
Unescape Escape View File

@ -7,7 +7,7 @@ import (
"time" "time"
"github.com/hashicorp/raft" "github.com/hashicorp/raft"
"github.com/rqlite/rqlite/progress" "github.com/rqlite/rqlite/v8/progress"
) )
// Snapshot represents a snapshot of the database state. // Snapshot represents a snapshot of the database state.

2
snapshot/store.go
Unescape Escape View File

@ -15,7 +15,7 @@ import (
"time" "time"
"github.com/hashicorp/raft" "github.com/hashicorp/raft"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
) )
const ( const (

2
snapshot/upgrader.go
Unescape Escape View File

@ -11,7 +11,7 @@ import (
"sort" "sort"
"github.com/hashicorp/raft" "github.com/hashicorp/raft"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
) )
const ( const (

2
store/provider_test.go
Unescape Escape View File

@ -5,7 +5,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
// Test_SingleNodeProvide tests that the Store correctly implements // Test_SingleNodeProvide tests that the Store correctly implements

14
store/store.go
Unescape Escape View File

@ -20,13 +20,13 @@ import (
"time" "time"
"github.com/hashicorp/raft" "github.com/hashicorp/raft"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/command/chunking" "github.com/rqlite/rqlite/v8/command/chunking"
sql "github.com/rqlite/rqlite/db" sql "github.com/rqlite/rqlite/v8/db"
wal "github.com/rqlite/rqlite/db/wal" wal "github.com/rqlite/rqlite/v8/db/wal"
rlog "github.com/rqlite/rqlite/log" rlog "github.com/rqlite/rqlite/v8/log"
"github.com/rqlite/rqlite/progress" "github.com/rqlite/rqlite/v8/progress"
"github.com/rqlite/rqlite/snapshot" "github.com/rqlite/rqlite/v8/snapshot"
) )
var ( var (

2
store/store_restart_test.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
) )
func test_OpenStoreCloseStartup(t *testing.T, s *Store) { func test_OpenStoreCloseStartup(t *testing.T, s *Store) {

10
store/store_test.go
Unescape Escape View File

@ -13,11 +13,11 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/command/encoding" "github.com/rqlite/rqlite/v8/command/encoding"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
"github.com/rqlite/rqlite/random" "github.com/rqlite/rqlite/v8/random"
"github.com/rqlite/rqlite/testdata/chinook" "github.com/rqlite/rqlite/v8/testdata/chinook"
) )
// Test_StoreSingleNode tests that a single node basically operates. // Test_StoreSingleNode tests that a single node basically operates.

2
store/transport.go
Unescape Escape View File

@ -6,7 +6,7 @@ import (
"time" "time"
"github.com/hashicorp/raft" "github.com/hashicorp/raft"
"github.com/rqlite/rqlite/store/gzip" "github.com/rqlite/rqlite/v8/store/gzip"
) )
// Listener is the interface expected by the Store for Transports. // Listener is the interface expected by the Store for Transports.

12
system_test/cluster_test.go
Unescape Escape View File

@ -7,12 +7,12 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster" "github.com/rqlite/rqlite/v8/cluster"
"github.com/rqlite/rqlite/db" "github.com/rqlite/rqlite/v8/db"
"github.com/rqlite/rqlite/http" "github.com/rqlite/rqlite/v8/http"
"github.com/rqlite/rqlite/queue" "github.com/rqlite/rqlite/v8/queue"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
"github.com/rqlite/rqlite/tcp" "github.com/rqlite/rqlite/v8/tcp"
) )
// Test_JoinLeaderNode tests a join operation between a leader and a new node. // Test_JoinLeaderNode tests a join operation between a leader and a new node.

14
system_test/helpers.go
Unescape Escape View File

@ -18,13 +18,13 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster" "github.com/rqlite/rqlite/v8/cluster"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/command/encoding" "github.com/rqlite/rqlite/v8/command/encoding"
httpd "github.com/rqlite/rqlite/http" httpd "github.com/rqlite/rqlite/v8/http"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
"github.com/rqlite/rqlite/tcp" "github.com/rqlite/rqlite/v8/tcp"
rX509 "github.com/rqlite/rqlite/testdata/x509" rX509 "github.com/rqlite/rqlite/v8/testdata/x509"
) )
const ( const (

8
system_test/request_forwarding_test.go
Unescape Escape View File

@ -6,10 +6,10 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster" "github.com/rqlite/rqlite/v8/cluster"
"github.com/rqlite/rqlite/command" "github.com/rqlite/rqlite/v8/command"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
"github.com/rqlite/rqlite/tcp" "github.com/rqlite/rqlite/v8/tcp"
) )
const ( const (

8
system_test/single_node_test.go
Unescape Escape View File

@ -12,10 +12,10 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/cluster" "github.com/rqlite/rqlite/v8/cluster"
httpd "github.com/rqlite/rqlite/http" httpd "github.com/rqlite/rqlite/v8/http"
"github.com/rqlite/rqlite/store" "github.com/rqlite/rqlite/v8/store"
"github.com/rqlite/rqlite/tcp" "github.com/rqlite/rqlite/v8/tcp"
) )
func Test_SingleNodeBasicEndpoint(t *testing.T) { func Test_SingleNodeBasicEndpoint(t *testing.T) {

4
tcp/dialer_test.go
Unescape Escape View File

@ -9,8 +9,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
"github.com/rqlite/rqlite/testdata/x509" "github.com/rqlite/rqlite/v8/testdata/x509"
) )
func Test_NewDialer(t *testing.T) { func Test_NewDialer(t *testing.T) {

2
tcp/mux.go
Unescape Escape View File

@ -12,7 +12,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/rqlite/rqlite/rtls" "github.com/rqlite/rqlite/v8/rtls"
) )
const ( const (

2
tcp/mux_test.go
Unescape Escape View File

@ -13,7 +13,7 @@ import (
"testing/quick" "testing/quick"
"time" "time"
"github.com/rqlite/rqlite/testdata/x509" "github.com/rqlite/rqlite/v8/testdata/x509"
) )
// Ensure the muxer can split a listener's connections across multiple listeners. // Ensure the muxer can split a listener's connections across multiple listeners.

2
tcp/pool/channel_test.go
Unescape Escape View File

@ -7,7 +7,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/rqlite/rqlite/random" "github.com/rqlite/rqlite/v8/random"
) )
var ( var (

1223
v8/cluster/message.pb.go
View File

File diff suppressed because it is too large Load Diff

1843
v8/command/command.pb.go
View File

File diff suppressed because it is too large Load Diff
Write Preview
Loading…
Cancel
Save