(ctx context.Context, options ReplicationStatusOptions)
| 1539 | } |
| 1540 | |
| 1541 | func (m *sgReplicateManager) GetReplicationStatusAll(ctx context.Context, options ReplicationStatusOptions) ([]*ReplicationStatus, error) { |
| 1542 | |
| 1543 | statuses := make([]*ReplicationStatus, 0) |
| 1544 | |
| 1545 | // Include persisted replications |
| 1546 | persistedReplications, err := m.GetReplications() |
| 1547 | if err != nil { |
| 1548 | return nil, err |
| 1549 | } |
| 1550 | |
| 1551 | for replicationID, _ := range persistedReplications { |
| 1552 | status, err := m.GetReplicationStatus(ctx, replicationID, options) |
| 1553 | if err != nil { |
| 1554 | base.WarnfCtx(m.loggingCtx, "Unable to retrieve replication status for replication %s", replicationID) |
| 1555 | } |
| 1556 | if status != nil { |
| 1557 | statuses = append(statuses, status) |
| 1558 | } |
| 1559 | } |
| 1560 | |
| 1561 | return statuses, nil |
| 1562 | } |
| 1563 | |
| 1564 | // ImportHeartbeatListener uses replication cfg to manage node list |
| 1565 | type ReplicationHeartbeatListener struct { |
no test coverage detected