(ctx context.Context)
| 85 | } |
| 86 | |
| 87 | func (s *statePersister) starting(ctx context.Context) error { |
| 88 | // Waits until the state replicator is settled, so that state is not |
| 89 | // persisted before obtaining some initial state. |
| 90 | return s.state.WaitReady(ctx) |
| 91 | } |
| 92 | |
| 93 | func (s *statePersister) iteration(ctx context.Context) error { |
| 94 | if err := s.persist(ctx); err != nil { |