pipeline

type KeySpanPipeline interface {
	// ID returns the ID of source keyspan and mark keyspan
	ID() (keyspanID uint64)
	// Name returns the quoted schema and keyspan name
	Name() string
	// ResolvedTs returns the resolved ts in this keyspan pipeline
	ResolvedTs() model.Ts
	// CheckpointTs returns the checkpoint ts in this keyspan pipeline
	CheckpointTs() model.Ts
	// UpdateBarrierTs updates the barrier ts in this keyspan pipeline
	UpdateBarrierTs(ts model.Ts)
	// AsyncStop tells the pipeline to stop, and returns true is the pipeline is already stopped.
	AsyncStop(targetTs model.Ts) bool
	// Workload returns the workload of this keyspan
	Workload() model.WorkloadInfo
	// Status returns the status of this keyspan pipeline
	Status() KeySpanStatus
	// Cancel stops this keyspan pipeline immediately and destroy all resources created by this keyspan pipeline
	Cancel()
	// Wait waits for keyspan pipeline destroyed
	Wait()
}

type KeySpanStatus int32