mydumper

Documentation

Index

• func ParseArgLikeBash(args []string) []string
• func RegisterMetrics(registry *prometheus.Registry)
• type Mydumper
  • func NewMydumper(cfg *config.SubTaskConfig) *Mydumper
  • func (m *Mydumper) Close()
  • func (m *Mydumper) Error() interface{}
  • func (m *Mydumper) Init(ctx context.Context) error
  • func (m *Mydumper) IsFreshTask(ctx context.Context) (bool, error)
  • func (m *Mydumper) Pause()
  • func (m *Mydumper) Process(ctx context.Context, pr chan pb.ProcessResult)
  • func (m *Mydumper) Resume(ctx context.Context, pr chan pb.ProcessResult)
  • func (m *Mydumper) Status() interface{}
  • func (m *Mydumper) Type() pb.UnitType
  • func (m *Mydumper) Update(cfg *config.SubTaskConfig) error

Functions

func ParseArgLikeBash

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

func RegisterMetrics(registry *prometheus.Registry)

RegisterMetrics registers metrics.

Types

type Mydumper

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

Mydumper is a simple wrapper for mydumper binary

func NewMydumper

func NewMydumper(cfg *config.SubTaskConfig) *Mydumper

NewMydumper creates a new Mydumper

func (*Mydumper) Close

func (m *Mydumper) Close()

Close implements Unit.Close

func (*Mydumper) Error

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

Error implements Unit.Error

func (*Mydumper) Init

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

Init implements Unit.Init

func (*Mydumper) IsFreshTask

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

IsFreshTask implements Unit.IsFreshTask

func (*Mydumper) Pause

func (m *Mydumper) Pause()

Pause implements Unit.Pause

func (*Mydumper) Process

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

Process implements Unit.Process

func (*Mydumper) Resume

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

Resume implements Unit.Resume

func (*Mydumper) Status

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

Status implements Unit.Status

func (*Mydumper) Type

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

Type implements Unit.Type

func (*Mydumper) Update

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

Update implements Unit.Update