Initial rstream logic#1

Merged

alanbchristie merged 61 commits intomainfrom

sc-3299-rstream

May 21, 2025

Commits on Apr 25, 2025

feat: Initial attempt at stream-based websocket logic
Alan Christie
committed
feat: Partial work on stream
Alan Christie
committed

Commits on Apr 30, 2025

fix: Now awaits _consume()
Alan Christie
committed
fix: Better log and load balancer mode
Alan Christie
committed
fix: Better log
Alan Christie
committed
fix: Avoid create stream, and use of decoder
Alan Christie
committed
fix: Messages now sent through socket (and attempt to stop consumer)
Alan Christie
committed
fix: Now closes consumer (when stopped)
Alan Christie
committed
feat: Better (?) shutdown
Alan Christie
committed
fix: Msg now sent as string (still locking up)
Alan Christie
committed
fix: Experiment with timestamp offset
Alan Christie
committed

Commits on May 1, 2025

build: Add python-dateutil
Alan Christie
committed
fix: Initial support for stream headers (offset specification)
Alan Christie
committed
fix: Log offset specification
Alan Christie
committed
build: Fix dateutil package
Alan Christie
committed
fix: Fix BAD_REQUEST
Alan Christie
committed
fix: Adjust log (offset and timestamp)
Alan Christie
committed
feat: Event stream now inserts offset and timestamp to generated messages
Alan Christie
committed
fix: Properties now at the end of the string and in maps using ess_ prefix
Alan Christie
committed
fix: Log header values
Alan Christie
committed
feat: Attempt of fix msg transmission
Alan Christie
committed
fix: Revert changes
Alan Christie
committed
fix: Attempt to fix timestamp from datetime
Alan Christie
committed
fix: Attempt to handle StreamDoesNotExist
Alan Christie
committed
feat: Faster handling of missing streams
Alan Christie
committed
feat: Attempt to append offset and timestamp message
Alan Christie
committed
feat: Attempt to detect encoding
Alan Christie
committed
fix: Attempt to fix message
Alan Christie
committed
fix: Remove msg type/encoding display
Alan Christie
committed
fix: Another attempt at message decoding
Alan Christie
committed
feat: Attempt to patch proto string
Alan Christie
committed
fix: Trim string
Alan Christie
committed
fix: Skip recoding
Alan Christie
committed
feat: Adds keys to json string (if used)
Alan Christie
committed
feat: Better ESS properties in protobuf string
Alan Christie
committed
feat: Reduce log (no offset/timestamp)
Alan Christie
committed

Commits on May 2, 2025

docs: Doc tweak
Alan Christie
committed
docs: Doc tweak (headers)
Alan Christie
committed
fix: Better close for websockets (close rather than exception)
Alan Christie
committed
style: Log tweak
Alan Christie
committed
style: Slimmer logging
Alan Christie
committed
style: Remove some log
Alan Christie
committed

Commits on May 21, 2025

feat: Initial memcached logic
Alan Christie
committed
fix: Fix deployment typos
Alan Christie
committed
fix: Use of KeepaliveOpts and memcached initialised on startup
Alan Christie
committed
fix: Better log location (memcached)
Alan Christie
committed
fix: Attempt to detect change of ES UUID
Alan Christie
committed
ci: Remove unused variable
Alan Christie
committed
style: Logging changes
Alan Christie
committed
style: Another log tweak
Alan Christie
committed
fix: Correct the memcache key value (unique to socket)
Alan Christie
committed
ci: Update memcached configuration
Alan Christie
committed
fix: Fix undefined variable
Alan Christie
committed
fix: Removed confusing global variables
Alan Christie
committed
fix: Fix messages and correct byte to string comparison
Alan Christie
committed
style: Logging corrections
Alan Christie
committed
style: More logging adjustments
Alan Christie
committed
fix: Fix decode of None
Alan Christie
committed
fix: Fix uuid4() to string
Alan Christie
committed
style: Log tweak
Alan Christie
committed
fix: Handle RuntimeError closing socket
Alan Christie
committed