(ns uint64)
| 941 | } |
| 942 | |
| 943 | func (as *adminServer) getGlobalEpoch(ns uint64) *uint64 { |
| 944 | e := as.globalEpoch[ns] |
| 945 | if e == nil { |
| 946 | e = new(uint64) |
| 947 | as.globalEpoch[ns] = e |
| 948 | } |
| 949 | return e |
| 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 |
no outgoing calls
no test coverage detected