pimp

package

v0.0.0-...-a83e6cb Latest Latest Go to latest Published: Sep 1, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func AutoIncrement(path string) (uint64, error)

type CreateTable struct {
	TableName     string
	Columns       []string
	AutoIncrement uint64
}

func ExtractTableDef(path string) (CreateTable, error)

func (v *CreateTable) Enter(node ast.Node) (ast.Node, bool)

func (v *CreateTable) Leave(node ast.Node) (ast.Node, bool)

type ImportData struct {
	DbName    string
	TableName string
	FileNum   int
	ImportCmd string
	AlterStmt string
}

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

func (plan *ImportPlan) Estimate() error

func (plan *ImportPlan) Execute() error

func (plan *ImportPlan) PrintCmd()

type Job struct {
	Task       func(string, *ImportData) error
	Length     int
	ResourceId string
	Data       *ImportData
}

type Plan interface {
	Estimate() error
	Execute() error
	PrintCmd()
}

func NewImportPlan(ctx context.Context, path string, concurrency int, dbConfig string) Plan

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

type WorkerPool interface {
	Run()
	AddTask(Job)
	Wait()
	Progress() (int, int)
}

func NewWorkerPool(maxWorker int, maxCPU int, maxThreadPerWorker int) WorkerPool