()
| 367 | } |
| 368 | |
| 369 | func (ar *ActiveReplicator) purgeCheckpoints() { |
| 370 | if ar.Pull != nil { |
| 371 | _ = ar.Pull.reset() |
| 372 | } |
| 373 | |
| 374 | if ar.Push != nil { |
| 375 | _ = ar.Push.reset() |
| 376 | } |
| 377 | } |
| 378 | |
| 379 | // LoadReplicationStatus attempts to load both push and pull replication checkpoints, and constructs the combined status |
| 380 | func LoadReplicationStatus(ctx context.Context, dbContext *DatabaseContext, replicationID string) (status *ReplicationStatus, err error) { |
no test coverage detected