Method retryBatch

enterprise/coderd/connectionlog/connectionlog.go:468–496

retryBatch retries writing a batch up to maxRetries times with a fixed delay between attempts. If the batcher context is canceled during a wait, one final attempt is made before returning.

(params database.BatchUpsertConnectionLogsParams)

// fixed delay between attempts. If the batcher context is canceled
// during a wait, one final attempt is made before returning.
func (b *DBBatcher) retryBatch(params database.BatchUpsertConnectionLogsParams) {
	count := len(params.ID)
	for attempt := range maxRetries {
		t := b.clock.NewTimer(retryInterval, "connectionLogBatcher", "retryBackoff")
		select {
		case <-b.ctx.Done():
			t.Stop()
			b.shutdownBatch(params)
			return
		case <-t.C:
		}

		//nolint:gocritic // System-level batch operation for connection logs.
		err := b.store.BatchUpsertConnectionLogs(dbauthz.AsConnectionLogger(b.ctx), params)
		if err == nil {
			return
		}

		b.log.Warn(b.ctx, "batch retry failed",
			slog.Error(err),
			slog.F("count", count),
			slog.F("attempt", attempt+1),
			slog.F("max_attempts", maxRetries),
		)
	}

	b.log.Error(b.ctx, "batch retries exhausted, dropping batch",
		slog.F("dropped", count))
}

// shutdownBatch makes a single write attempt during shutdown with a
// bounded timeout so it can't hang indefinitely.