package
8.2.0+incompatible
Repository: https://github.com/pingcap/tiflow.git
Documentation: pkg.go.dev

# Functions

NewEpochClient news a EpochClient Make Sure to call 'InitEpochModel' to create backend table before calling 'NewEpochClient'.

# Constants

Defines all JobOpStatus.
Defines all JobOpStatus.
noop is reserved for some unexpected scenario, such as job operation of a nonexistent job.

# Variables

JobOpUpdateColumns is used in gorm update.

# Structs

Executor records the information of an executor.
JobOp stores job operation recoreds.
LogicEpoch is used to generate increasing epoch We use union columns <JobID, Epoch> as uk to achieve job-level isolation.
Model defines basic fileds used in gorm CreatedAt/UpdatedAt will autoupdate in the gorm lib, not in sql backend.
ProjectInfo for Multi-projects support.
ProjectOperation records each operation of a project.

# Interfaces

EpochClient defines the client to generate epoch.

# Type aliases

JobOpStatus represents the expected status of a job, note this status diffs from the worker status defined in framework model, the relationship of these two status system is as follows.
KeyValueMap alias to key value map when updating data in gorm.
LabelSet is a type alias for label.Set.