Method reset

db/active_replicator_common.go:222–241

reset performs a reset on the replication by removing the local checkpoint document.

()

// reset performs a reset on the replication by removing the local checkpoint document.
func (arc *activeReplicatorCommon) reset() error {
	if arc.state != ReplicationStateStopped {
		return fmt.Errorf("reset invoked for replication %s when the replication was not stopped", arc.config.ID)
	}

	arc.lock.Lock()
	defer arc.lock.Unlock()

	if err := arc.forEachCollection(func(c *activeReplicatorCollection) error {
		if err := resetLocalCheckpoint(c.collectionDataStore, arc.CheckpointID); err != nil {
			return err
		}
		c.Checkpointer = nil
		return nil
	}); err != nil {
		return err
	}

	return removeLocalStatus(arc.ctx, arc.config.ActiveDB.MetadataStore, arc.statusKey)
}

// reconnect asynchronously calls replicatorConnectFn until successful, or times out trying. Retry loop can be stopped by cancelling ctx
func (arc *activeReplicatorCommon) reconnect() {