Skip to content

Commit 8ef1141

Browse files
rkannan82claude
andcommitted
Fix isSystemWorkerWorker typo in entry struct
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent 6342296 commit 8ef1141

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

service/matching/workers/registry_impl.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ type (
3434
hb *workerpb.WorkerHeartbeat
3535
lastSeen time.Time
3636
elem *list.Element
37-
isSystemWorkerWorker bool
37+
isSystemWorker bool
3838
}
3939
// bucket holds part of the keyspace: a map from namespace → (map of instanceKey → entry),
4040
// plus a recency list for eviction.
@@ -113,14 +113,14 @@ func (b *bucket) upsertHeartbeats(nsID namespace.ID, heartbeats []*workerpb.Work
113113
if e, exists := mp[key]; exists {
114114
e.hb = hb
115115
e.lastSeen = now
116-
e.isSystemWorkerWorker = isSystemWorker
116+
e.isSystemWorker = isSystemWorker
117117
b.order.MoveToBack(e.elem)
118118
} else {
119119
e = &entry{
120120
nsID: nsID,
121121
hb: hb,
122122
lastSeen: now,
123-
isSystemWorkerWorker: isSystemWorker,
123+
isSystemWorker: isSystemWorker,
124124
}
125125
e.elem = b.order.PushBack(e)
126126
mp[key] = e
@@ -148,7 +148,7 @@ func (b *bucket) filterWorkers(
148148
}
149149
out := make([]*workerpb.WorkerHeartbeat, 0, len(mp))
150150
for _, e := range mp {
151-
if !includeSystemWorkers && e.isSystemWorkerWorker {
151+
if !includeSystemWorkers && e.isSystemWorker {
152152
continue
153153
}
154154
if predicate(e.hb) {

0 commit comments

Comments
 (0)