job_processor

Documentation

Index

• type Job
  • func CreateJob(seqNum int64, srcId string, opType string, jobMsg core.Msg, ...) 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

Types

type Job

type Job struct {
	JobMsg core.Msg
	// contains filtered or unexported fields
}

func CreateJob

func CreateJob(seqNum int64, srcId string, opType string, jobMsg core.Msg, pos gomysql.Position, gtidSet gomysql.MysqlGTIDSet) Job

func (Job) BeforeWindowMoveForward

func (job Job) BeforeWindowMoveForward()

func (Job) DoneC

func (job Job) DoneC() chan struct{}

func (Job) EventTime

func (job Job) EventTime() time.Time

func (Job) Msg

func (job Job) Msg() core.Msg

func (Job) SequenceNumber

func (job Job) SequenceNumber() int64

func (Job) SkipDownStream

func (job Job) SkipDownStream() bool

func (Job) SlidingWindowKey

func (job Job) SlidingWindowKey() string

func (Job) TableKey

func (job Job) TableKey() string

func (Job) WorkerKey

func (job Job) WorkerKey() string