(ns uint64)
| 950 | } |
| 951 | |
| 952 | func (as *adminServer) incrementSchemaUpdateCounter(ns uint64) { |
| 953 | // Increment the Epoch when you get a new schema. So, that subscription's local epoch |
| 954 | // will match against global epoch to terminate the current subscriptions. |
| 955 | atomic.AddUint64(as.getGlobalEpoch(ns), 1) |
| 956 | } |
| 957 | |
| 958 | func (as *adminServer) resetSchema(ns uint64, gqlSchema schema.Schema) { |
| 959 | // set status as updating schema |
no test coverage detected