Function openQueryLogDuckLakeDB

server/querylog.go:135–206

(cfg Config)

		if ql.cancel != nil {
			ql.cancel()
		}
		if ql.db != nil && ql.closeDB {
			_ = ql.db.Close()
		}
	})
	return stopErr
}

func queryLogStopContext(ctx context.Context, defaultTimeout time.Duration) (context.Context, context.CancelFunc) {
	if ctx == nil {
		ctx = context.Background()
	}
	if _, ok := ctx.Deadline(); ok {
		return ctx, func() {}
	}
	return context.WithTimeout(ctx, defaultTimeout)
}

func (ql *QueryLogger) flushLoop() {
	defer close(ql.done)
	defer observe.SetQueryLogBufferedEntries(0)

	batch := make([]QueryLogEntry, 0, ql.cfg.BatchSize)
	flushTicker := time.NewTicker(ql.cfg.FlushInterval)
	defer flushTicker.Stop()

	for {
		select {
		case entry, ok := <-ql.ch:
			if !ok {
				// Channel closed — drain and exit
				if len(batch) > 0 {
					ql.flushBatch(batch)
				}
				return
			}
			batch = append(batch, entry)
			if len(batch) >= ql.cfg.BatchSize {
				ql.flushBatch(batch)
				batch = batch[:0]
			}
		case <-flushTicker.C:
			if len(batch) > 0 {
				ql.flushBatch(batch)
				batch = batch[:0]
			}
		}
	}
}

func (ql *QueryLogger) addBufferedEntries(delta int64) {
	if ql == nil {
		return
	}
	buffered := ql.buffered.Add(delta)
	if buffered < 0 {
		ql.buffered.Store(0)
		buffered = 0