Skip to content

Changelog

Release notes for the Nexo broker and SDKs.

The format is based on Keep a Changelog and this project adheres to Semantic Versioning.

v5.0.3

Released: 2026-08-21

Download v5.0.3Docker tag v5.0.3npm v5.0.3PyPI v5.0.3

Changed

  • Align protocol and transport boundaries

v5.0.2

Released: 2026-08-19

Download v5.0.2Docker tag v5.0.2npm v5.0.2PyPI v5.0.2

Changed

  • Centralize protocol constants in protocol.json and extract protocol module from transport

v5.0.1

Released: 2026-07-29

Download v5.0.1Docker tag v5.0.1npm v5.0.1PyPI v5.0.1

Changed

  • Priority-queue per ConsumerGroup deadlines, rimosso delivered_at
  • Replace BTreeMap+LinkedHashSet with priority-queue

Removed

  • Remove examples/ and .idea/ from git tracking

v5.0.0

Released: 2026-07-27

Download v5.0.0Docker tag v5.0.0npm v5.0.0PyPI v5.0.0

Added

  • Bounded per-subscriber channel with slow-consumer disconnect
  • Replace unbounded channel with bounded channel for backpressure
  • Delivery token per ACK/NACK to prevent stale delivery races

Changed

  • Inline store CRUD and pubsub SUB/UNSUB; drop queue ACK/NACK from inline set
  • QUE-015 rename maxRetries to maxDeliveries across all layers

Fixed

  • QUE-014 stop() cancels in-flight long-poll and drains with timeout
  • QUE-017 retry shutdown flush up to 5x1s to prevent silent data loss
  • QUE-011 fail-fast on recovery error prevents silent data loss
  • QUE-006 cap push count before allocation to prevent OOM
  • QUE-003 idempotent MoveToDLQ/MoveToMain + discard batch on fatal constraint errors
  • QUE-007 persist ready_seq and dlq_seq in push/MoveTo* operations
  • QUE-001 delivery token in-flight check and requeue reset
  • QUE-008 lifecycle mutex for create/delete serialization
  • QUE-007 persistent FIFO ordering with ready_seq and dlq_seq
  • QUE-005 fail-fast on storage init errors
  • QUE-002 align RAM and storage operation order
  • QUE-003 rollback entire batch on first SQLite error
  • QUE-004 validate queue names to prevent path traversal
  • Inline ACK/LEAVE/SEEK/JOIN to preserve TCP arrival order (STR-009)

v4.1.5

Released: 2026-07-26

Download v4.1.5Docker tag v4.1.5npm v4.1.5PyPI v4.1.5

Changed

  • Propose architectural changes
  • Propose architectural changes

Fixed

  • Await individual consumer acknowledgements
  • Harden recovery and consumer commits
  • Confirm writes before publish ack

v4.1.4

Released: 2026-07-24

Download v4.1.4Docker tag v4.1.4npm v4.1.4PyPI v4.1.4

Added

  • Add clearAll + clearWithPrefix, revert inline store ops
  • Add INT data type (0x03) for typed integer storage
  • Add INCR command with signed i64 wire support

Changed

  • Unify ConsumerGroup state into MsgState + KeyState
  • Revert "perf(pubsub): reduce write lock scope for subscribe and disconnect"
  • Remove MessageState enum and unify StorageOp batch variants

Fixed

  • Remove unused parameter in mapClearAll

Performance

  • Reduce write lock scope for subscribe and disconnect
  • Parallelize ReadRange via tokio::spawn
  • Use Arc<str> for session_id to eliminate per-request heap allocation

v4.1.3

Released: 2026-07-24

Download v4.1.3Docker tag v4.1.3npm v4.1.3PyPI v4.1.3

Performance

  • Inline fast-path for store ops, avoid tokio task spawn

v4.1.2

Released: 2026-07-23

Download v4.1.2Docker tag v4.1.2npm v4.1.2PyPI v4.1.2

Changed

  • Change 1-global timeout with per-request tiemout
  • refactor(readme)

v4.1.1

Released: 2026-07-23

Download v4.1.1Docker tag v4.1.1npm v4.1.1PyPI v4.1.1

Added

  • Introduce Subscription class for uniform subscription handling

Changed

  • Update readme

v4.1.0

Released: 2026-07-23

Download v4.1.0Docker tag v4.1.0npm v4.1.0PyPI v4.1.0

Added

  • Add Python SDK publishing to PyPI in release workflow
  • Added python sdk

Changed

  • Add generics to py sdk
  • Add non blocking event-loop to avoid blocking read from socket
  • Graceful shutdown, config cleanup, dead code removal

v4.0.3

Released: 2026-07-19

Download v4.0.3Docker tag v4.0.3npm v4.0.3PyPI v4.0.3

Changed

  • BufReader once per segment in read_range, fix docs env vars
  • Clean up read_range and add fd cache regression test
  • Simplify to single Mutex<TopicState>
  • Remove lock_topic wrapper, use .lock() directly
  • Optimize ConsumerGroup data structures for O(log n) hot paths
  • Unified stress tests of all brokers

Fixed

  • Move next_seq to TopicState, fix parse_message truncation, split ReadOutcome
  • Fix 6 issues (P1-P6) in storage and manager
  • Fix 5 bugs from review

Performance

  • Unify fd cache for read and write in StorageManager
  • Batch Insert/UpdateState StorageOps with single-message fallback
  • Replace standard Mutex with parking_lot Mutex for improved performance

v4.0.2

Released: 2026-07-18

Download v4.0.2Docker tag v4.0.2npm v4.0.2PyPI v4.0.2

Changed

  • Bump stream eviction_interval_ms to 10s and ram_soft_limit to 10000

Fixed

  • WAL checkpoint on shutdown, persist failure_reason in main queue, remove no-op page_size pragma

v4.0.1

Released: 2026-07-17

Download v4.0.1Docker tag v4.0.1npm v4.0.1PyPI v4.0.1

Changed

  • Remove legacy groups.log compat, extract parse_message
  • Simplify MessageState by removing timestamp from InFlight
  • Eliminate MessageToAppend, use Message directly
  • Extract recompute_earliest_deadline helper

Performance

  • Skip O(n) pending scan in check_redelivery via earliest_deadline
  • Add early return in clamp_head when head_seq unchanged

v4.0.0

Released: 2026-07-14

Download v4.0.0Docker tag v4.0.0npm v4.0.0PyPI v4.0.0

Changed

  • Extract header constants to protocol.ts

Fixed

  • Queue stop() returns immediately and clean stale comment
  • Per-client signal listeners and remove process.exit
  • Reject pending requests on disconnect and clean test setup
  • Handle Uint8Array and ArrayBuffer as raw bytes in any() and anyWithLen()

Performance

  • Reuse TextEncoder singleton and eliminate Buffer.from wrapper in bytes()
  • Read frame header directly from buffer in handleFrame
  • Replace Array.shift() with index counter in runConcurrent
  • Avoid per-message Cursor allocation in consume/fetch paths
  • Eliminate double JSON serialization in queue/stream push

v3.0.0

Released: 2026-07-13

Download v3.0.0Docker tag v3.0.0npm v3.0.0PyPI v3.0.0

Added

  • Batch push for queue and stream publish
  • Add REQUEST_NO_RESPONSE frame type for fire-and-forget commands
  • Add clear functionality for retained messages and enforce TTL validation
  • Enhance configuration management with per-topic settings and environment variable support
  • Add Dead Letter Topic (DLT) with persistence and auto-unblock
  • Add per-key delivery ordering

Changed

  • Add nested StoreCommand per data structure, remove
  • Remove dead is_earliest/any_earliest code from pop/take_batch
  • Nested enum in store tcp, rename MapStore→Map, remove dead snapshot system
  • Enforce module encapsulation and deny warnings
  • Subscribe/publish return Result, make validate_* private
  • Remove dead code, simplify ClientId, and fix is_expired
  • Rename ai-overview-project.md to AGENTS.md and consolidate setup helpers into common module

Fixed

  • Node 22 + restore npm@latest for OIDC provenance publishing
  • Repair README ASCII architecture diagram and Docker image name
  • Bump Node 20 to 22, remove npm@latest update step
  • Truncate segment on corruption instead of skipping or losing data
  • Preserve batch on commit failure to prevent silent data loss
  • Remove exists() gate from subscribe() to stop masking connection errors
  • Stop consumer on non-retryable server errors instead of infinite loop
  • Remove nack on shutdown, validate batchSize=0, fix long-polling race
  • Reject zero batch size and concurrency in subscribe and consume_batch
  • Validate subscribe patterns and publish topics
  • Preserve per-key ordering on timeout redelivery, fix zombie member on stop, remove dead code in ack
  • Replace Notify with watch, fix ack-floor over parked, prevent cold reads under backpressure

v2.0.1

Released: 2026-06-12

Download v2.0.1Docker tag v2.0.1npm v2.0.1PyPI v2.0.1

v2.0.0

Released: 2026-06-12

Download v2.0.0Docker tag v2.0.0npm v2.0.0PyPI v2.0.0

Added

  • Add PROTOCOL_VERSION to each packet
  • Introduce dev/serve subcommands to gate dashboard

Changed

  • Removed dev dashboard
  • Add protocolWriter to unified decoding across broker
  • refactor(protocol)!: uniform binary flags-based wire for all brokers
  • Removed env single source of truth
  • Removed {} from hot path in all brokers, keep {} only in cold path (create/delete etc)
  • Removed cache to make all broker handler stateless
  • Reorganize stress test for throughput and latency
  • Removed delayed_messages feature

v1.0.2

Released: 2026-04-26

Download v1.0.2Docker tag v1.0.2npm v1.0.2PyPI v1.0.2

Changed

  • Add optional concurrency
  • Disk-source-of-truth, consumer_id sessions, ack-only+parked delivery

Fixed

  • Sdk long-polling timeout
  • Align dashboard pagination, sdk long-poll timeout, and simplify subscription layering

Performance

  • Single-pass FrameWriter, drop staging Buffers in request encoding

v1.0.1

Released: 2026-04-23

Download v1.0.1Docker tag v1.0.1npm v1.0.1PyPI v1.0.1

Changed

  • Add local-to-prod solutions sections
  • Optimize search topics pubsub
  • Disables Nagle's algorithm
  • Grouped business-logic inside domain/*
  • Align ai-project-overview to new design of project
  • Reordere dashboard and server under diferent transport/ folder
  • Rename managers
  • Wip refactor separate tcp controlelr by http
  • Cleanup code and optimize background task
  • Refator ascii diagram architecture
  • Removed ttl_ms queue
  • Removed dead_code

Fixed

  • Clean callback on evantually subscribe/unsubscribe error

v1.0.0

Released: 2026-04-02

Download v1.0.0Docker tag v1.0.0npm v1.0.0PyPI v1.0.0

Added

  • Add leave command to cancel in-flight fetches

Changed

  • Unified configs in one file
  • Remove PUSHTYPE, use PUSH_PUBSUB frame type only
  • Realign docs
  • Realign stream-docs
  • From bounded to unbounded channel to persistence layer (from 1.1M to 1.9M)
  • Replace actor pattern with shared state + mutex
  • Replace N actors with 1 sharedState + long polling

v0.6.3

Released: 2026-03-30

Download v0.6.3Docker tag v0.6.3npm v0.6.3PyPI v0.6.3

Added

  • Add logo nexo

Changed

  • Centralize broker payload parsing in dashboard layer
  • Centralize broker payload parsing in dashboard layer
  • Unified all map logic inside same file
  • Replace N root actors with single RadixTree + RwLock

v0.6.2

Released: 2026-03-28

Download v0.6.2Docker tag v0.6.2npm v0.6.2PyPI v0.6.2

Added

  • Rename environment variables for protocol clarity

Changed

  • Realign some env variables
  • Conversion UUID from text to blob on sqlite
  • Removed indexes idx_pop & idx_dlq_failed sqlite queue - that data are read from memory and not on db at runtime (not pay cost of sync idx every insert)
  • Cleaning code
  • Clean-wip
  • Ai-project-overview
  • Ai-project-overview
  • Stream & queue UI/UX graphic
  • Moved and renamed AGENTS.md to not attach to all prompt

Fixed

  • Queue wakeup min(expires_at) waiters timeout

v0.6.1

Released: 2026-03-13

Download v0.6.1Docker tag v0.6.1npm v0.6.1PyPI v0.6.1

v0.6.0

Released: 2026-03-13

Download v0.6.0Docker tag v0.6.0npm v0.6.0PyPI v0.6.0

Changed

  • Various refactor
  • Various refactor
  • Reorder TCP parallel events on connection_session
  • Encapsulate request routing in RequestHandler
  • Change default broker config, by clone+props drilling to arc pointer
  • Update stream docs to jetstream approach
  • Removed fsync persistence by Queue
  • Removed channel by communication with QueueManager - QueueActor

Fixed

  • Persist queue & stream config

v0.5.0

Released: 2026-02-27

Download v0.5.0Docker tag v0.5.0npm v0.5.0PyPI v0.5.0

Changed

  • Batch msgs on writer stream
  • Add routing on topic with dahmap on streamanagre
  • Removed tokio::spawn by every publish
  • Add global stream persister to avoid too much FD opened
  • Edit stream from kafka style (with partitions) to jetbrains style (1 big log) & unified persistency inside same actor of topic
  • Edit stream from kafka style (with partitions) to jetbrains style (1 big log)

Fixed

  • Add stream read cold from disk if evicted from RAM

v0.4.0

Released: 2026-02-23

Download v0.4.0Docker tag v0.4.0npm v0.4.0PyPI v0.4.0

Added

  • Change N scoped-request timeout with 1 global for all promises
  • Add MAX_PAYLOAD_SIZE to cap packet
  • Add pagination on queue page

Changed

  • Removed old dependencies
  • Unify error types, fix request handle memory leak
  • refactor(server)!: unify wire protocol headers and introduce meta byte
  • Move broker fetching into views, fix refresh on all cards
  • Removed old frame types from protocol
  • Removed useMemo optimization
  • Add pagination pubsub
  • Add debounce persistence retained pubsub
  • Add pagination on stream page
  • Unified logic http request inside 1file for broker
  • Removed docs link from release github

v0.3.9

Released: 2026-02-18

Download v0.3.9Docker tag v0.3.9npm v0.3.9PyPI v0.3.9

Changed

  • Add version on footer

v0.3.8

Released: 2026-02-18

Download v0.3.8Docker tag v0.3.8npm v0.3.8PyPI v0.3.8

Changed

  • Try to last version of npm

v0.3.7

Released: 2026-02-18

Download v0.3.7Docker tag v0.3.7npm v0.3.7PyPI v0.3.7

Changed

  • Remove envs to send to NPM for OIDC auth

v0.3.6

Released: 2026-02-18

Download v0.3.6Docker tag v0.3.6npm v0.3.6PyPI v0.3.6

Changed

  • Add envs to send to NPM for OIDC auth

v0.3.5

Released: 2026-02-18

Download v0.3.5Docker tag v0.3.5npm v0.3.5PyPI v0.3.5

Changed

  • Refactor scripts package.json
  • Refactor from nexo-docs to docs vitepress website

v0.3.4

Released: 2026-02-18

Download v0.3.4Docker tag v0.3.4npm v0.3.4PyPI v0.3.4

Fixed

  • Edit NPM step

v0.3.3

Released: 2026-02-18

Download v0.3.3Docker tag v0.3.3npm v0.3.3PyPI v0.3.3

Fixed

  • Removed registry-url to use OIDC auth

v0.3.2

Released: 2026-02-18

Download v0.3.2Docker tag v0.3.2npm v0.3.2PyPI v0.3.2

Fixed

  • Remove working-directory vercel cli

v0.3.1-test

Released: 2026-02-18

Download v0.3.1-testDocker tag v0.3.1-testnpm v0.3.1-testPyPI v0.3.1-test

Fixed

  • Add versioning of Cargo.lock

v0.3.1

Released: 2026-02-18

Download v0.3.1Docker tag v0.3.1npm v0.3.1PyPI v0.3.1

Changed

  • Add versioning explanation & link to dockerhub
  • Aligned root_path pubub with queue & streams
  • Aligned docs vitepress to advanced features
  • Aligned docs vitepress to advanced features

v0.3.0

Released: 2026-02-18

Download v0.3.0Docker tag v0.3.0npm v0.3.0PyPI v0.3.0

Added

  • Add scaffolding 4 brokers

Changed

  • [refactor-wip] readme & docs
  • [feat] add references to website-docs on sdk readme
  • [feat] draft release+deploy ci/cd
  • [feat] draft release+deploy ci/cd
  • [refactor] broker project organization
  • [refactor] add create TAG on script release.js
  • [refactor] script release.js & deploy.sh
  • [refactor(docs)] add AGENTS.md for docs-website rules
  • [feat(chore)] setup unified versioning and release scripts
  • [refactor(protocol)]: implement zero-copy header parsing via bytemuck
  • [refactor] moved socket tuning under config file
  • [refactor] moved utils dashboard isnide dashboard module
  • [test] refactor local ssh managing
  • [refactor] dashboad STORE pagination
  • [refactor] protocol
  • [refactor] persistence path pubsub
  • [refactor] edit dlq paylaod for dashboard fe
  • [refactor] moved rust test
  • [refactor] clean references to clinetIds zombie inside root
  • [feat] add test ro socket reconnect
  • [fix] race cond, send to zombie waiters queue
  • [refactor] skip to stress test
  • [refactor] moved subscribe before push on queue
  • [fix] path compiled binary nexo
  • [fix] typo fe dashboard
  • [refactor] clean dashboard web
  • [refactor] splitted broker sdk tests.ts
  • [refactor] moved ts test below sdk/ts
  • [refactor] README sdk
  • [feat] add AGENTS.md
  • [refactor] split message & dlqmessage in 2 type
  • [feat] implement nack for queue mex
  • [feat] implement dlq managing on sdk
  • [refactor] unified main queue & dlq inside same actor thread
  • [fix] delete msg from queue after send in dlq
  • [feat] add versions features sdk ts
  • [refactor] moved STATUS from payload to header (breaking change!)
  • [refactor] moved OPCODE from payload to header (breaking change!)
  • [refactor] cleanup timeouts stress tests
  • [feat] add pubsub persistence to readme example
  • [feat] add limit number partitions stream
  • [fix] race condition stream create on disk
  • [fix] race condition queue create on disk
  • [fix] read-write permissions sqlite
  • [feat] add script memory monitoring
  • [fix] scroll stres eventlog fe
  • [refactor] update readme
  • [refactor] edit store keys for fe
  • [refactor] add legend protocol and unified offset
  • [refactor] from string to json paylaod store & queue
  • [feat] add e2e stress test for all brokers
  • [feat] edited qlite settings for high throughput
  • [fix-wip] cleanup retained rootactor pubsub
  • [feat] add clear retained pubsub
  • [feat] add persistency retained pubsub
  • [feat] add ttl logic pubsub
  • [feat] cleanup empty rootactor pubsub
  • [refactor] update readme
  • [refactor] eviction RAM stream log
  • [refactor] decalre_queue to create_queue
  • [fix] recreate actor on warmstart
  • [refactor] add last fix readme
  • [feat] add NEXO_ENV to switch dev/prod behavior
  • [refactor] change FE dashboard from dark to light mode
  • [refactor] add dashboard image on readme
  • [refactor-wip] readme (queue)
  • [refactor-wip] readme (pubsub)
  • [refactor-wip] readme (architecture)
  • [refactor-wip] readme
  • [refactor] add prepare_cached sqlite query queue
  • [feat] edited pubsub logic & add tests
  • [feat-wip] test benchamrk
  • [feat] update readme
  • [feat] flushed on dysk on fsync mode
  • [refactor] unified module of rust tests
  • [refactor] aligned queue & stream models pattern
  • [refactor] externalized channel buffer sizes
  • [refactor] test vitest
  • [feat-PUBSUB] add reconnection on conn closed
  • [refactor] layout fe
  • [refactor] default partitions number
  • [refactor] add retention policy sdk readme
  • [refactor] request once broker at time on FE
  • [refactor] add deelte example to topic/stream
  • [refactor] utilities queue tests
  • [refactor] ever broker manager accept config on constructor
  • [feat] add editable config for queue on manager
  • [feat] revert comment test stream
  • [feat] add eviction RAM stream
  • [feat] add lazy loading stream
  • [feat] add delete topic
  • [feat-wip] add disk retention log file
  • [feat] add segmentation log file
  • [feat] cadd ompaction commits.log file
  • [refactor] pubsub logic
  • [feat] add persistency stream test
  • [feat] add persistency stream test
  • [feat] add persistency stream
  • [feat] add test rust stream
  • [feat] run concurrent partition evetns
  • [feat] add tests pubsub
  • [feat] add command delete queue
  • [refactor] test queue & store
  • [feat] add test longpolling queue
  • [refactor] deleted some queue tests
  • [refactor] moved lopp that move messages bewteen states inside actor queue
  • [feat] add test msg queues
  • [refactor] store with map inside them
  • [feat] implement Persister Queue inside queue actor
  • [refactor] revert timeout global to N timeout (1 for promise)
  • [refactor] readme sdk
  • [feat] add persistency flags to sdk
  • [refactor] readme sdk
  • [fix] fe stream list visualization
  • [refactor] example readme sdk
  • [refactor] make envs singleton
  • [refactor] optional parameter STORE
  • [refactor] optional parameter PUBSUBS
  • [refactor] optional parameter queue create
  • [feat] setNoDelay to default
  • [feat] add optional params createQueue
  • [feat] add file setup
  • [feat] add file setup
  • [refactor] unified commands on his broker & split busines logic from packet creations
  • [feat] add failfast if resource not exist
  • [refactor] clinet & connection
  • [refactor] moved consumerfrom stream to subscriber
  • [refactor] comehere, before starts refactor stream
  • [refactor] split models on each broker file
  • [refactor] clean test
  • [refactor] stress test socket
  • [fix] improve allocation memory on codec/connection
  • [fix] improve allocation memory on codec/connection
  • [refactor] dashboard STREAM
  • [refactor] dashboard PUBSUB
  • [refactor] dashboard PUBSUB
  • [refactor] dashboard PUBSUB
  • [refactor] update ai rules-project
  • [refactor-wip] dashboard PUBSUB
  • [refactor-wip] dashboard PUBSUB
  • [refactor-wip] dashboard PUBSUB
  • [refactor] ai-ruels & test dashboard
  • [feat] add gzip compression to http request
  • [refactor-wip] dashboard QUEUE
  • [refactor] dashboard QUEUE
  • [refactor] dashboard STORE
  • [refactor-wip] dashboard QUEUE
  • [refactor] dashboard QUEUE
  • [fix] layout store large paylod
  • [refactor] from value_preview to value
  • [refactor] add debounce + early exit list STORE
  • [refactor] virtualize list + useMemo STORE
  • [refactor] dashboard
  • [fix] dashboard STORE
  • [fix] dashboard STORE
  • [fix] layout dashboard
  • [refactor-wip] dashboard STORE
  • [refactor] add env to zod test suite
  • [refactor] dasboard web - dinamic height deatil view
  • [refactor] dasboard web - splitted 4 request broker status
  • [refactor] dasboard web
  • [feat] unified all logs & add dockerfile
  • [wip-dashboard] refactor dashboard datas
  • [refactor] stress test socket
  • [refactor] rename env variables
  • [refactor] tests suite
  • [refactor] split sdk entity o
  • [refactor] env variable name
  • [refactor] add env validation & pass queue from multithread to actor model
  • [feature] add docs to brokers
  • [feature] change pubsub from single-thread to multi (actor model 1 thread 1 tree)
  • [wip-feature] partitions on stream
  • [wip-feature] partitions on client sdk
  • [refactor] dashboard for local develop
  • [refactor] wip partitions on sdk
  • [refactor] add struct to PAYLOADS legend at every broker
  • [refactor] add struct to HEADER legend
  • [refactor] add partitions logic to stream server-side
  • refactor client sdk for maintenance
  • refactor topic from Vec to BTreeMap for efficient scan clients
  • refactor queue
  • card perfect!!
  • updated dashboard web
  • updated dashboard web
  • wip- from singelton to new instance every subscribe sdk
  • from sequential to Sliding Window in queue batch processing
  • kill while lopp subscrbe if disconnect socket
  • fix handle error in callback stream inside batch
  • change of Weak<Notify> of waiters on stream
  • change of Weak<Notify> of waiters on stream
  • implemented RAII pattern (clean on disconnect) on pubsub
  • add fail fast error if queeu not exist on subscribe
  • wip - split 2 task for queeu (1 fast for ack/scheduled, other for cleaner orphan uuid)
  • wip - consume queue from single request to batch
  • rollback stream (from multithread with partitions to single thread + actor model)
  • rollback stream (from multithread with partitions to single thread + actor model)
  • wip - rebalancing reject old epoch
  • update test stream
  • rollbakc cork()/uncork()
  • cork()/uncork()
  • add generics to topic pubsub
  • add snapshot on server
  • add test performance stream
  • WIP - implement consumerGrup- offset - rebalancing features
  • WIP - implement consumerGrup- offset - rebalancing features
  • implement consumerGrup- offset - rebalancing features
  • implement consumerGrup- offset - rebalancing features
  • wip - align queue & topics to intial create methods
  • wip - align queue & topics to intial create methods
  • draft stream
  • refactor client sdk for latency > throughput
  • refactor test file
  • fix subarry bug (copied instead view)
  • add expect on stress tests
  • add prefetch msgs on queue
  • add test under stress protocol
  • add 1hour default ttl server side for key in teh store
  • refacor performance test
  • refactor performance test
  • add 512MB Hard Limit to prevent OOM attacks
  • implemented resize buffer if not enough
  • update curorrules
  • unified performance test
  • add timeout clearing zombie request
  • add TYPE of data inside payload to improve deserialize non-json object on client.ts
  • renae TopicManager to PubSub Manager
  • add RETAIN lastvalue on mqtt [rust-ts]
  • add perforamcne test mqtt broker- wip
  • add perforamcne test mqtt broker
  • add mqtt broker
  • draft mqtt
  • refactor KV to implements different data-structure
  • add level trace to logger ts & rust
  • implemented logger [ts]
  • implemented logger [ts]
  • implemented logger [ts]
  • implemented logger [rust]
  • refactor Queue client
  • come back here
  • refactor pure factory sdk client.ts
  • new refactor client.ts
  • new refactor client.ts
  • refactor client.ts
  • add opcdode debug echo to rust
  • rename test cases
  • end queue feeatures
  • refactor Queue + InternalState
  • deep_cleanup repaer
  • added timeouts (sdk TS)
  • added timeouts (Rust)
  • pass to array to map to manage pending promise on sdk
  • wip test queue
  • implemented test describe 3
  • implemented test describe 1 e 2
  • implemented logic queue manager
  • optimize encode_response with pre-calculate exact size of memory allocation
  • optimizes performance
  • wip
  • implemented Buffer.allocUnsafe() to reduce number of allocations
  • implemented Zero-Copy (bytes:Bytes), Write batching
  • refactor flow server
  • add zod valdiation envs
  • add draft sdk & test
  • wip routing command 2
  • wip routing command
  • wip routing command
  • implement command pattern
  • mixin
  • refactor protocol from RESP to binary
  • refactor
  • add syntax example cheatsheet
  • avoid clone and use iterator
  • from if to matvh on routing
  • edit matchcase & incomplete/invalid payload
  • reorder project structure
  • unified dispatcher
  • add draft tcp socket, dispatcher and KV manager
  • add overview rust file

Removed

  • [refactor] removed git repo nested for docs
  • [refactor] removed readme test
  • [refactor] removed ai rules
  • [refactor] removed unused code dlq queue
  • [refactor] removed memory persistency from stream & queue
  • [refactor] removed old debug print
  • [refactor-wip] removed why nexo
  • [feat] removed fasync properties
  • [refactor] removed useless class for export sdk
  • [refactor] removed file 1 x broker test
  • [refactor] removed echo method sdk
  • [refactor] removed confgi passed on queue constructore insted of create
  • [refactor] removed default_delay_ms from queue
  • [refactor] remove "passive" flag queues
  • [fix] removed double lookup map queue
  • [fix] removed expired key from dashboard response
  • [refactor] removed unnecessary task::spawn tokio
  • [refactor] removed early retunrn OOM
  • removed key from stream
  • removed slower logging
  • removed scan O(n) from reaper every 50ms on queue

Performance

  • Avoid double UTF-8 encoding in writeString