lightning

package

v0.0.0-...-41b4272 Latest Latest Go to latest Published: Feb 15, 2022 License: Apache-2.0, Apache-2.0 Imports: 40 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Rendered for

This section is empty.

This section is empty.

func CheckpointRemove(ctx context.Context, cfg *config.Config, tableName string) error

func CleanupEngine(ctx context.Context, cfg *config.Config, tls *common.TLS, engine string) error

func CleanupMetas(ctx context.Context, cfg *config.Config, tableName string) error

func SwitchMode(ctx context.Context, cfg *config.Config, tls *common.TLS, mode string) error

func UnsafeCloseEngine(ctx context.Context, importer backend.Backend, engine string) (*backend.ClosedEngine, error)

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

func New(globalCfg *config.GlobalConfig) *Lightning

func (l *Lightning) GoServe() error

func (l *Lightning) RunOnce(taskCtx context.Context, taskCfg *config.Config, glue glue.Glue) error

RunOnce is used by binary lightning and host when using lightning as a library.

for binary lightning, taskCtx could be context.Background which means taskCtx wouldn't be canceled directly by its cancel function, but only by Lightning.Stop or HTTP DELETE using l.cancel. and glue could be nil to let lightning use a default glue later.
for lightning as a library, taskCtx could be a meaningful context that get canceled outside, and glue could be a caller implemented glue.

func (l *Lightning) RunServer() error

func (l *Lightning) Status() (finished int64, total int64)

Status return the sum size of file which has been imported to TiKV and the total size of source file.

func (l *Lightning) Stop()