Running returns whether replication is currently running
()
| 394 | |
| 395 | // Running returns whether replication is currently running |
| 396 | func (r *LogicalReplicator) Running() bool { |
| 397 | r.mu.Lock() |
| 398 | defer r.mu.Unlock() |
| 399 | return r.running |
| 400 | } |
| 401 | |
| 402 | // Stop stops the replication process and blocks until clean shutdown occurs. |
| 403 | func (r *LogicalReplicator) Stop() { |