clock returns the quartz.Clock to use. Defaults to a real clock when not set.
()
| 133 | // clock returns the quartz.Clock to use. Defaults to a real clock |
| 134 | // when not set. |
| 135 | func (c MultiReplicaSubscribeConfig) clock() quartz.Clock { |
| 136 | if c.Clock != nil { |
| 137 | return c.Clock |
| 138 | } |
| 139 | return quartz.NewReal() |
| 140 | } |
| 141 | |
| 142 | // NewMultiReplicaSubscribeFn returns a SubscribeFn that manages |
| 143 | // relay connections to remote replicas and returns relay |
no outgoing calls
no test coverage detected