matt d677cb2b08 feat: gzip compression for large payloads, persistent OLAP writes (#2368) ...

* debug: remove event pub

* add additional spans to publish message

* debug: don't publish payloads

* fix: persistent messages on olap

* add back other payloads

* remove pub buffers temporarily

* fix: correct queue

* hacky partitioning

* add back pub buffers to scheduler

* don't send no worker events

* add attributes for queue name and message id to publish

* add back pub buffers to grpc api

* remove pubs again, no worker writes though

* task processing queue hashes

* remove payloads again

* gzip compression over 5kb

* add back task controller payloads

* add back no worker requeueing event, with expirable lru cache

* add back pub buffers

* remove hash partitioned queues

* small fixes

* ignore lru cache top fn

* config vars for compression, disable by default

---------

Co-authored-by: Alexander Belanger <alexander@hatchet.run>

2025-10-08 11:44:04 -04:00

..

engine_test.go

revert: add back testing harness (#1659)

2025-05-01 15:22:30 -04:00

engine.go

feat: gzip compression for large payloads, persistent OLAP writes (#2368)

2025-10-08 11:44:04 -04:00