Method processUpdate

coderd/agentapi/metadatabatcher/metadata_batcher.go:240–260

processUpdate adds a metadata update to the batch with deduplication based on timestamp.

(update update)

// processUpdate adds a metadata update to the batch with deduplication based on timestamp.
func (b *Batcher) processUpdate(update update) {
	ck := compositeKey{
		agentID: update.agentID,
		key:     update.key,
	}

	// Check if key already exists and only update if new value is newer.
	existing, exists := b.batch[ck]
	if exists && update.collectedAt.Before(existing.collectedAt) {
		return
	}

	b.batch[ck] = value{
		v:           update.v,
		error:       update.error,
		collectedAt: update.collectedAt,
	}
	if !exists {
		b.currentBatchLen.Add(1)
	}
}

// run runs the batcher loop, reading from the update channel and flushing
// periodically or when the batch reaches capacity.