_stop aborts any replicator processes that run outside of a running replication connection (e.g: async reconnect handling, statsreporter)
()
| 401 | |
| 402 | // _stop aborts any replicator processes that run outside of a running replication connection (e.g: async reconnect handling, statsreporter) |
| 403 | func (arc *activeReplicatorCommon) _stop() { |
| 404 | if arc.ctxCancel != nil { |
| 405 | base.TracefCtx(arc.ctx, base.KeyReplicate, "cancelling context on activeReplicatorCommon in _stop()") |
| 406 | arc.ctxCancel() |
| 407 | } |
| 408 | } |
| 409 | |
| 410 | type ReplicatorCompleteFunc func() |
| 411 |
no test coverage detected