rename runPeriodicHealthChecksLeased

This commit is contained in:
Denis Mishin 2024-08-22 14:37:23 -04:00
parent 1ec9c53608
commit bd1377a5c7

View file

@ -158,7 +158,7 @@ func (c *controller) runZeroControlLoop(ctx context.Context) error {
WithLease( WithLease(
c.runReconcilerLeased, c.runReconcilerLeased,
c.runSessionAnalyticsLeased, c.runSessionAnalyticsLeased,
c.runPeriodicHealthChecksLeased, c.runHealthChecksLeased,
leaseStatus.MonitorLease, leaseStatus.MonitorLease,
), ),
) )
@ -194,7 +194,7 @@ func (c *controller) runSessionAnalyticsLeased(ctx context.Context, client datab
}) })
} }
func (c *controller) runPeriodicHealthChecksLeased(ctx context.Context, client databroker.DataBrokerServiceClient) error { func (c *controller) runHealthChecksLeased(ctx context.Context, client databroker.DataBrokerServiceClient) error {
return retry.WithBackoff(ctx, "zero-healthcheck", func(ctx context.Context) error { return retry.WithBackoff(ctx, "zero-healthcheck", func(ctx context.Context) error {
checker := healthcheck.NewChecker(c.bootstrapConfig, client) checker := healthcheck.NewChecker(c.bootstrapConfig, client)
eg, ctx := errgroup.WithContext(ctx) eg, ctx := errgroup.WithContext(ctx)