31 Commits

Author SHA1 Message Date
c512f51a57 Resolve "Deprecate Providers package in favor of Worker" 2025-10-09 15:53:02 +00:00
b77efe8e55 Updating router to provide new advanced routing logic 2025-09-27 11:07:43 +00:00
f9e2bca7a1 Added registry to setup in main.go 2025-09-23 02:12:16 +08:00
775853cef8 Started worker instruction handling via Execute() method 2025-09-23 02:08:03 +08:00
740d9e3af6 Moved Manager API interfaces to consumers; Changed session logic to allow a for a 0 idle timeout session 2025-09-23 01:53:34 +08:00
9051fb7b6e Added worker registry in registry.go 2025-09-22 22:13:15 +08:00
ba650785bc Adding IsRunning() method to Worker interface; Minor fixes to BaseWorker methods 2025-09-21 18:14:47 +00:00
4e52950458 go.mod cleanup; made worker's Stop() method return an error 2025-09-21 14:22:19 +00:00
4e0aa3244c Added BaseStatefulWorker in worker package. Added package comments to manager and worker. 2025-09-20 17:31:14 +00:00
56a36283e5 Add session and provider controller interfaces. Begun designing worker system. 2025-09-18 04:00:41 +00:00
7109acc207 Refactor Binance Futures Websocket: enhance configuration management, implement shard handling, and improve subscription logic 2025-09-17 10:57:21 +00:00
78c7632394 Implement socket streaming server and optimize connection handling; adjust test provider timing 2025-09-12 03:47:30 +00:00
924187b2f5 Begun redesign of binance futures websocket. Added test provider for testing purposes. 2025-09-11 08:29:12 +00:00
e56bb210f8 Refactor command handling: rename types.go to commands.go, update command response types, and streamline session management logic 2025-09-10 13:05:34 +00:00
6ebc541de0 Refactor FuturesWebsocket: implement batch subscription handling, enhance connection management, and improve logging 2025-09-09 00:08:57 +00:00
70f3714d2f Manager paradigm change to an event-loop concurrency style, begun implementing batching in binance futures_websocket.go 2025-09-07 12:01:36 +00:00
40fda456eb Updated grpc servers to support new Manager API 2025-09-05 07:07:33 +00:00
582759bb3b Small session management change: enhance ChannelOpts with inbound drop control, improve session struct for client attachment handling, and streamline message forwarding logic 2025-08-24 08:09:43 +00:00
Phillip Michelsen
40e5ce9708 Refactor session management: enhance session struct with internal channels, implement client attachment handling, and improve idle session management 2025-08-24 14:02:21 +07:00
60a11baeee Refactor session management: introduce session struct, enhance session handling methods, and improve error handling for session operations 2025-08-21 15:26:47 +00:00
6ad3deb5fc Refactor stream management: rename stream methods to use 'Client' prefix for clarity and update related logic in gRPC and manager files 2025-08-21 12:53:20 +00:00
2484a33945 Refactor identifier handling: replace Provider and Subject fields with a single Key field in Identifier struct, update related message structures, and adjust parsing logic 2025-08-17 06:16:49 +00:00
ef4a28fb29 Update Dockerfile and main.go: upgrade Go version, optimize build stages, and adjust binary output path 2025-08-09 15:42:32 +00:00
dec67f2565 Refactor socket streaming server: improve connection handling, switch to protobuf for message encoding, and optimize write operations 2025-08-09 14:45:05 +00:00
d1369643d2 Update Message structure: change Payload type to bytes and add Encoding field 2025-08-09 13:45:45 +00:00
351a10bf0b Refactor data service: rename streaming files, update gRPC service methods, and enhance stream management 2025-08-09 13:07:17 +00:00
Phillip Michelsen
f4333fc30a Update dependencies in go.mod and go.sum; refactor gRPC server initialization in main.go 2025-08-04 19:43:46 +07:00
5be0d4db06 Add Dockerfile and Makefile for building and generating Protobuf code 2025-06-27 18:36:51 +08:00
b9cd25e9b4 Major update to the data service. Added gRPC and socket servers. Switched to using only a single go.mod at the root. 2025-06-27 18:24:10 +08:00
Phillip Michelsen
b017291a5a Add Manager and Provider structures with streaming capabilities 2025-06-13 16:09:35 +07:00
Phillip Michelsen
c6986c2828 Project scaffold and general layout. Monorepo. 2025-04-28 05:08:52 +08:00