Method Upsert

enterprise/coderd/connectionlog/connectionlog.go:195–208

Upsert enqueues a connection log entry for batched writing. It blocks if the internal buffer is full, ensuring no logs are dropped. It returns an error if the batcher or caller context is canceled.

(ctx context.Context, clog database.UpsertConnectionLogParams)

// blocks if the internal buffer is full, ensuring no logs are dropped.
// It returns an error if the batcher or caller context is canceled.
func (b *DBBatcher) Upsert(ctx context.Context, clog database.UpsertConnectionLogParams) error {
	if b.ctx.Err() != nil {
		return b.ctx.Err()
	}

	select {
	case b.itemCh <- clog:
		return nil
	case <-b.ctx.Done():
		return b.ctx.Err()
	case <-ctx.Done():
		return ctx.Err()
	}
}

// Close cancels the batcher context, waits for the run loop and
// retry worker to exit.