Function LoadReplicationStatus

db/active_replicator.go:380–409

LoadReplicationStatus attempts to load both push and pull replication checkpoints, and constructs the combined status

(ctx context.Context, dbContext *DatabaseContext, replicationID string)

// LoadReplicationStatus attempts to load both push and pull replication checkpoints, and constructs the combined status
func LoadReplicationStatus(ctx context.Context, dbContext *DatabaseContext, replicationID string) (status *ReplicationStatus, err error) {

	status = &ReplicationStatus{
		ID: replicationID,
	}

	pullStatusKey := dbContext.MetadataKeys.ReplicationStatusKey(PullCheckpointID(replicationID))
	pullStatus, _ := getLocalStatus(ctx, dbContext.MetadataStore, pullStatusKey)
	if pullStatus != nil {
		status.PullReplicationStatus = pullStatus.PullReplicationStatus
		status.Status = pullStatus.Status
		status.ErrorMessage = pullStatus.ErrorMessage
		status.LastSeqPull = pullStatus.LastSeqPull
	}

	pushStatusKey := dbContext.MetadataKeys.ReplicationStatusKey(PushCheckpointID(replicationID))
	pushStatus, _ := getLocalStatus(ctx, dbContext.MetadataStore, pushStatusKey)
	if pushStatus != nil {
		status.PushReplicationStatus = pushStatus.PushReplicationStatus
		status.Status = pushStatus.Status
		status.ErrorMessage = pushStatus.ErrorMessage
		status.LastSeqPush = pushStatus.LastSeqPush
	}

	if pullStatus == nil && pushStatus == nil {
		return nil, errors.New("Replication status not found")
	}

	return status, nil
}

func PushCheckpointID(replicationID string) string {
	return "sgr2cp:push:" + replicationID