Method Start

db/active_replicator.go:68–93

(ctx context.Context)

}

func (ar *ActiveReplicator) Start(ctx context.Context) error {

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

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

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

	if pushErr != nil {
		return pushErr
	}

	if pullErr != nil {
		return pullErr
	}

	return nil
}

func (ar *ActiveReplicator) Stop() error {