(state InstanceState)
| 329 | } |
| 330 | |
| 331 | func (i *Lifecycler) setState(state InstanceState) { |
| 332 | i.stateMtx.Lock() |
| 333 | defer i.stateMtx.Unlock() |
| 334 | i.state = state |
| 335 | } |
| 336 | |
| 337 | func (i *Lifecycler) sendToLifecyclerLoop(fn func()) error { |
| 338 | sc := i.ServiceContext() |
no outgoing calls
no test coverage detected