Method run

enterprise/coderd/connectionlog/connectionlog.go:282–324

(ctx context.Context)

}

func (b *DBBatcher) run(ctx context.Context) {
	//nolint:gocritic // System-level batch operation for connection logs.
	authCtx := dbauthz.AsConnectionLogger(ctx)
	for ctx.Err() == nil {
		select {
		case item := <-b.itemCh:
			b.addToBatch(item)

			if b.batchLen() >= b.maxBatchSize {
				b.flush(authCtx)
				b.timer.Reset(b.interval, "connectionLogBatcher", "capacityFlush")
			}

		case <-b.timer.C:
			b.flush(authCtx)
			b.timer.Reset(b.interval, "connectionLogBatcher", "scheduledFlush")

		case <-ctx.Done():
		}
	}

	b.log.Debug(ctx, "context done, flushing before exit")

	// Drain any remaining items from the channel.
	for {
		select {
		case item := <-b.itemCh:
			b.addToBatch(item)
		default:
			if b.batchLen() > 0 {
				b.shutdownBatch(b.buildParams())
			}
			// Signal the retry worker to skip delays and close
			// the channel so it exits after processing any
			// remaining items.
			// Mark the batcher as closed so that any subsequent
			// Upsert calls fail immediately instead of sending
			// into itemCh after the run loop has exited.
			close(b.retryCh)
			return
		}
	}
}

// batchEntry wraps a connection log event with explicit connect and
// disconnect times. When a connect and disconnect for the same session