()
| 2286 | } |
| 2287 | |
| 2288 | func (h *handler) putReplicationStatus() error { |
| 2289 | replicationID := mux.Vars(h.rq)["replicationID"] |
| 2290 | |
| 2291 | action := h.getQuery("action") |
| 2292 | if action == "" { |
| 2293 | return base.HTTPErrorf(http.StatusBadRequest, "Query parameter 'action' must be specified") |
| 2294 | } |
| 2295 | |
| 2296 | updatedStatus, auditEventID, err := h.db.SGReplicateMgr.PutReplicationStatus(h.ctx(), replicationID, action) |
| 2297 | if err != nil { |
| 2298 | return err |
| 2299 | } |
| 2300 | base.Audit(h.ctx(), auditEventID, base.AuditFields{base.AuditFieldReplicationID: replicationID}) |
| 2301 | h.writeJSON(updatedStatus) |
| 2302 | return nil |
| 2303 | } |
| 2304 | |
| 2305 | // Cluster information, returned by _cluster_info API request |
| 2306 | type ClusterInfo struct { |
nothing calls this directly
no test coverage detected