Method Stop

db/active_replicator.go:95–128

()

}

func (ar *ActiveReplicator) Stop() error {

	if ar.Push == nil && ar.Pull == nil {
		return fmt.Errorf("Attempted to stop activeReplicator for %s with neither Push nor Pull defined", base.UD(ar.ID))
	}

	var pushErr error
	if ar.Push != nil {
		pushErr = ar.Push.Stop()
	}

	var pullErr error
	if ar.Pull != nil {
		pullErr = ar.Pull.Stop()
	}

	if pushErr != nil {
		return pushErr
	}

	if pullErr != nil {
		return pullErr
	}

	if base.ValDefault(ar.config.reportHandlerPanicsOnStop, true) {
		if stats := ar.config.ReplicationStatsMap; stats != nil {
			if val := stats.NumHandlersPanicked.Value(); val > 0 {
				return fmt.Errorf("%d handlers panicked", val)
			}
		}
	}

	return nil
}

func (ar *ActiveReplicator) Reset() error {
	var pushErr error