The highest tagged major version is v5.

utils

package

v3.6.4 Latest Latest Go to latest Published: Nov 29, 2021 License: AGPL-3.0 Imports: 24 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

Repository

github.com/admpub/nging

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func All() map[OP]Exec
func Cancel(op OP, cacheKey string) error
func Export(ctx context.Context, noticer notice.Noticer, cfg *driver.DbAuth, ...) error
func Import(ctx context.Context, noticer *notice.NoticeAndProgress, cfg *driver.DbAuth, ...) error
func ResetAutoIncrement(sqlStructFile string) error
type BGExec
- func NewGBExec(c context.Context, opt echo.H) *BGExec
type Exec
- func ListBy(op OP) Exec
type FileInfo
type FileInfos
type OP
- func (t OP) String() string

Constants ¶

View Source

const (
	Importor = `mysql`
	Exportor = `mysqldump`
)

Variables ¶

View Source

var Backgrounds = sync.Map{} //后台导入导出任务

Backgrounds 后台任务集合(包含SQL导入和导出任务)

View Source

var Charsets = []string{
	"armscii8",
	"ascii",
	"big5",
	"binary",
	"cp1250",
	"cp1251",
	"cp1256",
	"cp1257",
	"cp850",
	"cp852",
	"cp866",
	"cp932",
	"dec8",
	"eucjpms",
	"euckr",
	"gb18030",
	"gb2312",
	"gbk",
	"geostd8",
	"greek",
	"hebrew",
	"hp8",
	"keybcs2",
	"koi8r",
	"koi8u",
	"latin1",
	"latin2",
	"latin5",
	"latin7",
	"macce",
	"macroman",
	"sjis",
	"swe7",
	"tis620",
	"ucs2",
	"ujis",
	"utf16",
	"utf16le",
	"utf32",
	"utf8",
	"utf8mb4",
}

Charsets MySQL 支持的字符集

View Source

var MySQLBinPaths = []string{`/usr/local/bin`, `/usr/bin`}

Functions ¶

func All ¶

func All() map[OP]Exec

All 所有任务

func Cancel ¶

func Cancel(op OP, cacheKey string) error

Cancel 取消执行

func Export ¶

func Export(ctx context.Context, noticer notice.Noticer,
	cfg *driver.DbAuth, tables []string, structWriter, dataWriter interface{},
	mysqlVersion string, hasGTID bool, resetAutoIncrements ...bool) error

Export 导出SQL文件

func Import ¶

func Import(ctx context.Context, noticer *notice.NoticeAndProgress, cfg *driver.DbAuth, cacheDir string, files []string) error

Import 导入SQL文件

func ResetAutoIncrement ¶

func ResetAutoIncrement(sqlStructFile string) error

ResetAutoIncrement 重置AUTO_INCREMENT值为0

Types ¶

type BGExec ¶

type BGExec struct {
	Options echo.H
	Started time.Time
	Procs   *FileInfos
	// contains filtered or unexported fields
}

BGExec 后台执行信息

func NewGBExec ¶

func NewGBExec(c context.Context, opt echo.H) *BGExec

NewGBExec 新建后台执行信息

func (*BGExec) AddFileInfo ¶

func (b *BGExec) AddFileInfo(fi *FileInfo)

AddFileInfo 添加文件信息

func (*BGExec) Cancel ¶

func (b *BGExec) Cancel() context.CancelFunc

Cancel 取消执行

func (*BGExec) Context ¶

func (b *BGExec) Context() context.Context

Context 暂存上下文信息

type Exec ¶

type Exec map[string]*BGExec

Exec 执行信息

func ListBy ¶

func ListBy(op OP) Exec

ListBy 获取某个操作的所有任务

func (*Exec) Add ¶

func (e *Exec) Add(op OP, cacheKey string, bgExec *BGExec)

Add 新增任务

func (*Exec) Cancel ¶

func (e *Exec) Cancel(cacheKey string)

Cancel 取消某个任务

func (*Exec) Exists ¶

func (e *Exec) Exists(cacheKey string) bool

Exists 任务是否存在

type FileInfo ¶

type FileInfo struct {
	Start      time.Time
	End        time.Time
	Elapsed    time.Duration
	Path       string
	Size       int64
	Compressed bool
	Error      string `json:",omitempty"`
}

FileInfo 文件信息

type FileInfos ¶

type FileInfos []*FileInfo

FileInfos 文件信息集合

type OP ¶

type OP string

OP 操作类型

const (
	// OpExport 导出操作
	OpExport OP = `export`
	// OpImport 导入操作
	OpImport OP = `import`
)

func (OP) String ¶

func (t OP) String() string

Source Files ¶

View all Source files

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