Function removeLocalStatus

db/active_replicator_common.go:573–589

removeLocalStatus removes a replication status from the given metadataStore. This is done when a replication is reset.

(ctx context.Context, metadataStore base.DataStore, statusKey string)

// removeLocalStatus removes a replication status from the given metadataStore. This is done when a replication is reset.
func removeLocalStatus(ctx context.Context, metadataStore base.DataStore, statusKey string) (err error) {
	base.TracefCtx(ctx, base.KeyReplicate, "removeLocalStatus() for %q", statusKey)

	// obtain current rev
	currentStatus, err := getLocalStatusDoc(ctx, metadataStore, statusKey)
	if err != nil {
		base.WarnfCtx(ctx, "Unable to retrieve local status doc for %s, status not removed", statusKey)
		return nil
	}
	if currentStatus == nil {
		// nothing to do - status already doesn't exist
		return nil
	}

	_, _, err = putDocWithRevision(metadataStore, statusKey, currentStatus.Rev, nil, 0)
	return err
}

// registerFunctions must be called once after immediately after newActiveReplicatorCommon to set the functions that require a circular definition from parent (ActiveReplicatorPush/ActiveReplicatorPull) and activeReplicatorCommon.
func (arc *activeReplicatorCommon) registerFunctions(getStatusFn func() *ReplicationStatus, connectFn func() error, registerCheckpointerCallbacksFn func(*activeReplicatorCollection) error) {