| 23 | } |
| 24 | |
| 25 | type clusterWatcher struct { |
| 26 | db storage.IStorage |
| 27 | isRun bool |
| 28 | log zerolog.Logger |
| 29 | cfg *configuration.Config |
| 30 | patroniCli patroni.IClient |
| 31 | |
| 32 | ctx context.Context |
| 33 | done context.CancelFunc |
| 34 | wg sync.WaitGroup |
| 35 | } |
| 36 | |
| 37 | func NewServerWatcher(db storage.IStorage, patroniCli patroni.IClient, cfg *configuration.Config) ClusterWatcher { |
| 38 | return &clusterWatcher{ |
nothing calls this directly
no outgoing calls
no test coverage detected