Method PutReplicationStatus

db/sg_replicate_cfg.go:1499–1539

PutReplicationStatus updates the state of a replication.

(ctx context.Context, replicationID, action string)

// PutReplicationStatus updates the state of a replication.
func (m *sgReplicateManager) PutReplicationStatus(ctx context.Context, replicationID, action string) (status *ReplicationStatus, auditEvent base.AuditID, err error) {

	targetState := ""
	switch action {
	case "reset":
		auditEvent = base.AuditIDISGRReset
		targetState = ReplicationStateResetting
	case "stop":
		auditEvent = base.AuditIDISGRStop
		targetState = ReplicationStateStopped
	case "start":
		auditEvent = base.AuditIDISGRStart
		targetState = ReplicationStateRunning
	default:
		return nil, 0, base.HTTPErrorf(http.StatusBadRequest, "Unrecognized action %q.  Valid values are start/stop/reset.", action)
	}

	err = m.UpdateReplicationState(replicationID, targetState)
	if err != nil {
		return nil, auditEvent, err
	}

	updatedStatus, err := m.GetReplicationStatus(ctx, replicationID, DefaultReplicationStatusOptions())
	if err != nil {
		// Not found is expected when adhoc replication is stopped, return removed status instead of error
		// since UpdateReplicationState was successful
		if err == base.ErrNotFound {
			replicationStatus := &ReplicationStatus{
				ID:     replicationID,
				Status: "removed",
			}
			return replicationStatus, auditEvent, nil
		} else {
			return nil, auditEvent, err
		}
	}

	// Modify the returned replication state to align with the requested state
	updatedStatus.Status = transitionStateName(updatedStatus.Status, targetState)
	return updatedStatus, auditEvent, nil
}

func (m *sgReplicateManager) GetReplicationStatusAll(ctx context.Context, options ReplicationStatusOptions) ([]*ReplicationStatus, error) {