local

package

v5.1.5+incompatible Latest Latest Go to latest Published: Dec 14, 2022 License: Apache-2.0 Imports: 61 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

ghproxy-9d2.pages.dev/pingcap/br

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Constants
func NewLocalBackend(ctx context.Context, tls *common.TLS, pdAddr string, cfg *config.TikvImporter, ...) (backend.Backend, error)
func VerifyRLimit(estimateMaxFiles Rlim_t) error
type File
type Range
type RangePropertiesCollector
type Rlim_t
- func GetSystemRLimit() (Rlim_t, error)
type Writer

Constants ¶

View Source

const (
	SplitRetryTimes = 8
)

Variables ¶

This section is empty.

Functions ¶

func NewLocalBackend ¶

func NewLocalBackend(
	ctx context.Context,
	tls *common.TLS,
	pdAddr string,
	cfg *config.TikvImporter,
	enableCheckpoint bool,
	g glue.Glue,
	maxOpenFiles int,
) (backend.Backend, error)

NewLocalBackend creates new connections to tikv.

func VerifyRLimit ¶

func VerifyRLimit(estimateMaxFiles Rlim_t) error

VerifyRLimit checks whether the open-file limit is large enough. In Local-backend, we need to read and write a lot of L0 SST files, so we need to check system max open files limit.

Types ¶

type File ¶

type File struct {
	UUID uuid.UUID
	// contains filtered or unexported fields
}

func (*File) Cleanup ¶

func (e *File) Cleanup(dataDir string) error

Cleanup remove meta and db files

func (*File) Close ¶

func (e *File) Close() error

func (*File) Exist ¶

func (e *File) Exist(dataDir string) error

Exist checks if db folder existing (meta sometimes won't flush before lightning exit)

type Range ¶

type Range struct {
	// contains filtered or unexported fields
}

Range record start and end key for localStoreDir.DB so we can write it to tikv in streaming

type RangePropertiesCollector ¶

type RangePropertiesCollector struct {
	// contains filtered or unexported fields
}

func (*RangePropertiesCollector) Add ¶

func (c *RangePropertiesCollector) Add(key pebble.InternalKey, value []byte) error

implement `pebble.TablePropertyCollector` implement `TablePropertyCollector.Add`

func (*RangePropertiesCollector) Finish ¶

func (c *RangePropertiesCollector) Finish(userProps map[string]string) error

func (*RangePropertiesCollector) Name ¶

func (c *RangePropertiesCollector) Name() string

The name of the property collector.

type Rlim_t ¶

type Rlim_t = uint64

func GetSystemRLimit ¶

func GetSystemRLimit() (Rlim_t, error)

type Writer ¶

type Writer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Writer) AppendRows ¶

func (w *Writer) AppendRows(ctx context.Context, tableName string, columnNames []string, ts uint64, rows kv.Rows) error

func (*Writer) Close ¶

func (w *Writer) Close(ctx context.Context) (backend.ChunkFlushStatus, error)

func (*Writer) IsSynced ¶

func (w *Writer) IsSynced() bool

Source Files ¶

local.go
local_unix.go
local_unix_generic.go
localhelper.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL