Troy Chiu de4c3dba24 ateapi/controlapi: process syncer events via rate-limiting workqueue (#674) ...

Refactors `WorkerPoolSyncer` to process events through a rate-limiting
workqueue instead of processing them synchronously inline.

Previously, store errors during Informer event handling, such as 
- optimistic locking version conflicts (`store.ErrVersionConflict`)
- create races (`store.ErrAlreadyExists`)
- `WorkerPool` not yet present in the lister cache

were logged and dropped, leaving store state out of sync until a
subsequent pod event occurred.

- [x] Tests pass
- [ ] Appropriate changes to documentation are included in the PR

2026-08-05 10:49:29 -04:00

..

actor_snapshot.go

ateapi: add ActorSnapshot lifecycle APIs

2026-07-30 19:40:59 -07:00

converter_test.go

DurableDir support (#295)

2026-06-26 20:05:03 -07:00

converter.go

ateapi: add ActorSnapshot lifecycle APIs

2026-07-30 19:40:59 -07:00

crash_test.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

crash.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

create_actor_test.go

ateapi: add ActorSnapshot lifecycle APIs

2026-07-30 19:40:59 -07:00

create_actor.go

feat(otel): add actor lifecycle + scheduler duration metrics (#514)

2026-08-04 13:57:55 -04:00

create_atespace_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

create_atespace.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

delete_actor_test.go

Handle partial volume creation failures (#527)

2026-07-30 14:21:45 -04:00

delete_actor.go

feat(otel): add actor lifecycle + scheduler duration metrics (#514)

2026-08-04 13:57:55 -04:00

delete_atespace_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

delete_atespace.go

ateapi: add ActorSnapshot lifecycle APIs

2026-07-30 19:40:59 -07:00

dialer_test.go

Added mTLS between ate system components (#237)

2026-07-24 15:43:03 -07:00

dialer.go

Added mTLS between ate system components (#237)

2026-07-24 15:43:03 -07:00

functional_test.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

get_actor_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

get_actor.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

get_atespace_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

get_atespace.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

informer.go

Fix boilerplate in go files

2026-05-31 19:45:36 -07:00

list_actors_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

list_actors.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

list_atespaces_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

list_atespaces.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

list_workers_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

list_workers.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

metrics_test.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

metrics.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

pause_actor_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

pause_actor.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

resume_actor_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

resume_actor.go

feat: extend edge routing telemetry with resume and outcome labels (#591)

2026-07-31 13:41:56 -04:00

sandbox_assets.go

Decouple ActorTemplates from WorkerPools. (#270)

2026-06-18 10:58:34 -07:00

service.go

feat(otel): add actor lifecycle + scheduler duration metrics (#514)

2026-08-04 13:57:55 -04:00

span_identity_test.go

Introduce an ActorRef type to bundle actor atespace and name.

2026-07-28 12:33:23 -07:00

span_identity.go

Introduce an ActorRef type to bundle actor atespace and name.

2026-07-28 12:33:23 -07:00

suspend_actor_test.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

suspend_actor.go

ateapi: add ActorSnapshot lifecycle APIs

2026-07-30 19:40:59 -07:00

syncer_test.go

ateapi/controlapi: process syncer events via rate-limiting workqueue (#674)

2026-08-05 10:49:29 -04:00

syncer.go

ateapi/controlapi: process syncer events via rate-limiting workqueue (#674)

2026-08-05 10:49:29 -04:00

update_actor_test.go

[minor] stamp OpenTelemetry span attributes in UpdateActor (#512)

2026-07-29 15:06:31 -04:00

update_actor.go

[minor] stamp OpenTelemetry span attributes in UpdateActor (#512)

2026-07-29 15:06:31 -04:00

validate.go

Add unit tests for request validators in ate-apiserver. (#590)

2026-07-29 13:45:37 -04:00

volumes_test.go

Handle partial volume creation failures (#527)

2026-07-30 14:21:45 -04:00

volumes.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

workflow_delete_test.go

Handle partial volume creation failures (#527)

2026-07-30 14:21:45 -04:00

workflow_delete.go

Handle partial volume creation failures (#527)

2026-07-30 14:21:45 -04:00

workflow_pause_test.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

workflow_pause.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

workflow_resume_test.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

workflow_resume.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

workflow_suspend_test.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

workflow_suspend.go

Wrap worker pod metadata into a WorkerAssignment message. (#737)

2026-08-04 17:08:58 -07:00

workflow_test.go

rename ErrPersistenceRetry to ErrVersionConflict to reflect the actual behavior (#560)

2026-07-28 10:00:32 -04:00

workflow_testutil_test.go

feat(otel): add actor lifecycle + scheduler duration metrics (#514)

2026-08-04 13:57:55 -04:00

workflow.go

feat(otel): add actor lifecycle + scheduler duration metrics (#514)

2026-08-04 13:57:55 -04:00

workload_spec_test.go

feat: readyz: make the overall wait timeout configurable per template (#487)

2026-08-04 07:07:41 -07:00

workload_spec.go

feat: readyz: make the overall wait timeout configurable per template (#487)

2026-08-04 07:07:41 -07:00