Skip to content
This repository has been archived by the owner on Jul 24, 2024. It is now read-only.

Commit

Permalink
fix fmt
Browse files Browse the repository at this point in the history
Signed-off-by: Little-Wallace <bupt2013211450@gmail.com>
  • Loading branch information
Little-Wallace committed May 31, 2021
1 parent 2dfebb0 commit bab4072
Show file tree
Hide file tree
Showing 10 changed files with 67 additions and 20 deletions.
3 changes: 2 additions & 1 deletion pkg/lightning/backend/kv/kv2sql.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,14 @@
package kv

import (
"github.com/pingcap/br/pkg/lightning/metric"
"github.com/pingcap/parser/model"
"github.com/pingcap/tidb/kv"
"github.com/pingcap/tidb/table"
"github.com/pingcap/tidb/table/tables"
"github.com/pingcap/tidb/tablecodec"
"github.com/pingcap/tidb/types"

"github.com/pingcap/br/pkg/lightning/metric"
)

type TableKVDecoder struct {
Expand Down
3 changes: 2 additions & 1 deletion pkg/lightning/backend/kv/types.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,10 @@
package kv

import (
"github.com/pingcap/tidb/types"

"github.com/pingcap/br/pkg/lightning/log"
"github.com/pingcap/br/pkg/lightning/verification"
"github.com/pingcap/tidb/types"
)

// Encoder encodes a row of SQL values into some opaque type which can be
Expand Down
46 changes: 41 additions & 5 deletions pkg/lightning/checkpoints/checkpointspb/file_checkpoints.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion pkg/lightning/common/conn.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,11 +15,12 @@ package common

import (
"context"
"sync"

"github.com/pingcap/br/pkg/lightning/log"
"github.com/pingcap/errors"
"go.uber.org/zap"
"google.golang.org/grpc"
"sync"
)

// connPool is a lazy pool of gRPC channels.
Expand Down
14 changes: 8 additions & 6 deletions pkg/lightning/restore/duplicate.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,13 @@ package restore
import (
"bytes"
"context"
"io"
"math"
"sort"
"strconv"
"sync"
"time"

"github.com/docker/go-units"
backendkv "github.com/pingcap/br/pkg/lightning/backend/kv"
"github.com/pingcap/br/pkg/lightning/common"
Expand All @@ -35,12 +42,6 @@ import (
"google.golang.org/grpc/backoff"
"google.golang.org/grpc/credentials"
"google.golang.org/grpc/keepalive"
"io"
"math"
"sort"
"strconv"
"sync"
"time"

"github.com/cockroachdb/pebble"
"github.com/pingcap/errors"
Expand Down Expand Up @@ -332,6 +333,7 @@ func (manager *DuplicateManager) getImportClient(ctx context.Context, peer *meta
}
return sst.NewImportSSTClient(conn), nil
}

func (manager *DuplicateManager) makeConn(ctx context.Context, storeID uint64) (*grpc.ClientConn, error) {
store, err := manager.pdClient.GetStore(ctx, storeID)
if err != nil {
Expand Down
6 changes: 4 additions & 2 deletions pkg/lightning/web/res_vfsdata.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion pkg/mock/glue.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion pkg/mock/glue_checkpoint.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion pkg/mock/kv.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion pkg/mock/storage.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

0 comments on commit bab4072

Please sign in to comment.