Documentation ¶
Index ¶
- type Job
- func (job Job) BeforeWindowMoveForward()
- func (job Job) DoneC() chan struct{}
- func (job Job) EventTime() time.Time
- func (job Job) Msg() core.Msg
- func (job Job) SequenceNumber() int64
- func (job Job) SkipDownStream() bool
- func (job Job) SlidingWindowKey() string
- func (job Job) TableKey() string
- func (job Job) WorkerKey() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Job ¶
func CreateJob ¶
func CreateJob(seqNum int64, srcId string, opType mysqlUtils.OperationType, jobMsg core.Msg, pos gomysql.Position, gtidSet gomysql.MysqlGTIDSet) Job
func (Job) BeforeWindowMoveForward ¶
func (job Job) BeforeWindowMoveForward()
func (Job) SequenceNumber ¶
func (Job) SkipDownStream ¶
func (Job) SlidingWindowKey ¶
Click to show internal directories.
Click to hide internal directories.