mydumper

package

v1.0.7 Latest Latest Go to latest Published: Jun 21, 2021 License: Apache-2.0 Imports: 25 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

This section is empty.

This section is empty.

func ParseArgLikeBash(args []string) []string

ParseArgLikeBash parses list arguments like bash, which helps us to run executable command via os/exec more likely running from bash

func RegisterMetrics(registry *prometheus.Registry)

RegisterMetrics registers metrics.

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

Mydumper is a simple wrapper for mydumper binary

func NewMydumper(cfg *config.SubTaskConfig) *Mydumper

NewMydumper creates a new Mydumper

func (m *Mydumper) Close()

Close implements Unit.Close

func (m *Mydumper) Error() interface{}

Error implements Unit.Error

func (m *Mydumper) Init(ctx context.Context) error

Init implements Unit.Init

func (m *Mydumper) IsFreshTask(ctx context.Context) (bool, error)

IsFreshTask implements Unit.IsFreshTask

func (m *Mydumper) Pause()

Pause implements Unit.Pause

func (m *Mydumper) Process(ctx context.Context, pr chan pb.ProcessResult)

Process implements Unit.Process

func (m *Mydumper) Resume(ctx context.Context, pr chan pb.ProcessResult)

Resume implements Unit.Resume

func (m *Mydumper) Status() interface{}

Status implements Unit.Status

func (m *Mydumper) Type() pb.UnitType

Type implements Unit.Type

func (m *Mydumper) Update(cfg *config.SubTaskConfig) error

Update implements Unit.Update