dumpling

Documentation

Index

• func RegisterMetrics(registry *prometheus.Registry)
• type Dumpling
  • func NewDumpling(cfg *config.SubTaskConfig) *Dumpling
  • func (m *Dumpling) Close()
  • func (m *Dumpling) Init(ctx context.Context) error
  • func (m *Dumpling) IsFreshTask(ctx context.Context) (bool, error)
  • func (m *Dumpling) Kill()
  • func (m *Dumpling) Pause()
  • func (m *Dumpling) Process(ctx context.Context, pr chan pb.ProcessResult)
  • func (m *Dumpling) Resume(ctx context.Context, pr chan pb.ProcessResult)
  • func (m *Dumpling) Status(_ *binlog.SourceStatus) interface{}
  • func (m *Dumpling) Type() pb.UnitType
  • func (m *Dumpling) Update(context.Context, *config.SubTaskConfig) error

Functions

func RegisterMetrics

func RegisterMetrics(registry *prometheus.Registry)

RegisterMetrics registers metrics and saves the given registry for later use.

Types

type Dumpling

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

Dumpling dumps full data from a MySQL-compatible database.

func NewDumpling

func NewDumpling(cfg *config.SubTaskConfig) *Dumpling

NewDumpling creates a new Dumpling.

func (*Dumpling) Close

func (m *Dumpling) Close()

Close implements Unit.Close.

func (*Dumpling) Init

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

Init implements Unit.Init.

func (*Dumpling) IsFreshTask

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

IsFreshTask implements Unit.IsFreshTask.

func (*Dumpling) Kill

func (m *Dumpling) Kill()

Kill implements Unit.Kill.

func (*Dumpling) Pause

func (m *Dumpling) Pause()

Pause implements Unit.Pause.

func (*Dumpling) Process

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

Process implements Unit.Process.

func (*Dumpling) Resume

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

Resume implements Unit.Resume.

func (*Dumpling) Status

func (m *Dumpling) Status(_ *binlog.SourceStatus) interface{}

Status implements Unit.Status.

func (*Dumpling) Type

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

Type implements Unit.Type.

func (*Dumpling) Update

func (m *Dumpling) Update(context.Context, *config.SubTaskConfig) error

Update implements Unit.Update.