Method GetReplicationStatus

db/sg_replicate_cfg.go:1436–1496

(ctx context.Context, replicationID string, options ReplicationStatusOptions)

}

func (m *sgReplicateManager) GetReplicationStatus(ctx context.Context, replicationID string, options ReplicationStatusOptions) (*ReplicationStatus, error) {

	// Check if replication is assigned locally
	m.activeReplicatorsLock.RLock()
	replication, isLocal := m.activeReplicators[replicationID]
	m.activeReplicatorsLock.RUnlock()

	if options.LocalOnly && !isLocal {
		return nil, nil
	}

	var status *ReplicationStatus
	var remoteCfg *ReplicationCfg
	if isLocal {
		status = replication.GetStatus(ctx)
	} else {
		// Attempt to retrieve persisted status
		var loadErr error
		status, loadErr = LoadReplicationStatus(m.loggingCtx, m.dbContext, replicationID)
		if loadErr != nil {
			// Unable to load persisted status.  Create status stub based on config
			var err error
			remoteCfg, err = m.GetReplication(replicationID)
			if err != nil {
				return nil, err
			}
			if remoteCfg.AssignedNode == "" {
				status = &ReplicationStatus{
					ID:     replicationID,
					Status: ReplicationStateUnassigned,
				}
			} else {
				status = &ReplicationStatus{
					ID:     replicationID,
					Status: remoteCfg.TargetState,
				}
			}
		}
	}

	// Add the replication config if requested
	if options.IncludeConfig {
		if remoteCfg == nil {
			var err error
			remoteCfg, err = m.GetReplication(replicationID)
			if err != nil {
				return nil, err
			}
		}
		status.Config = remoteCfg.ReplicationConfig.Redacted(ctx)
	}

	if !options.IncludeError && status.Status == ReplicationStateError {
		return nil, nil
	}
	if options.ActiveOnly && status.Status != ReplicationStateRunning {
		return nil, nil
	}