sched

type BatchEntry struct {
	WriteTime time.Time
	Seq       uint32
}

type RowsBatchHandler interface {
	HandleBatch(shardID uint64, rows []cluster.ForwardRow, first bool) (int64, error)
}

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