6 Commits

Include renames

Author	SHA1	Message	Date
HugoNijhuis	443425d6e3	fix cluster stubs: deterministic fallback, payload forwarding, and handler guards ... - Replace non-deterministic map range fallback with sorted node selection in PlaceActor and RebalanceShards - Add Body field to MessagePayload to preserve message data during cross-node routing - Forward actual message body in route_message handler instead of discarding it - Add self-message guard to route_message handler to prevent loops - Add nil guard for shardMap in handleRebalanceRequest - Add self-message guard to handleRebalanceRequest in DistributedVM	2026-07-30 18:23:48 +02:00
HugoNijhuis	70eddbc533	fix cluster: hashRing stale after rebalance, GetShardMap empty, loops, and migration no-op ... - GetShardMap: copy Shards and Nodes map contents before returning - hashRing: rebuild from shardMap.Nodes after every rebalance/shard_map update - DistributedVM.handleRebalanceRequest: add leader check and self-broadcast guard - route_message: add hop-count (MaxRouteHops=10) to prevent infinite loops - handleMigrationRequest: broadcast migration updates instead of setting local copy	2026-07-30 00:35:07 +02:00
HugoNijhuisandClaude Opus 4.5	b759c7fb97	Fix type assertion bug in handleClusterMessage ... JSON unmarshal produces map[string]interface{}, not concrete types. Added ModelPayload and MessagePayload concrete types that implement RuntimeModel and RuntimeMessage interfaces respectively. The handleClusterMessage now re-marshals and unmarshals the payload to convert from map[string]interface{} to the proper concrete type. Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-10 16:45:28 +01:00
HugoNijhuisandClaude Opus 4.5	eaff315782	Replace interface{} with properly defined interfaces ... - Add VirtualMachine interface with GetID(), GetActorID(), GetState() - Add VMState type with idle/running/paused/stopped states - Add RuntimeModel interface for event storming model contracts - Add RuntimeMessage interface for actor message contracts - Add VMProvider interface for decoupled VM access - Update VMRegistry.GetActiveVMs() to return map[string]VirtualMachine - Update Runtime interface to use RuntimeModel and RuntimeMessage - Update DistributedVMRegistry to use VMProvider instead of interface{} - Add SetVMProvider method to DistributedVM for dependency injection This improves type safety, makes contracts explicit, and enables better IDE support while avoiding import cycles through interface segregation. Closes #37 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-10 16:45:28 +01:00
HugoNijhuisandClaude Opus 4.5	c757bb76f3	Make configuration values injectable rather than hardcoded ... Add config structs with sensible defaults for tunable parameters: - JetStreamConfig for stream retention (1 year) and replica count (1) - HashRingConfig for virtual nodes per physical node (150) - ShardConfig for shard count (1024) and replication factor (1) Each component gets a new WithConfig constructor that accepts custom configuration, while the original constructors continue to work with defaults. Zero values in configs fall back to defaults for backward compatibility. Closes #38 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-10 15:33:56 +01:00
HugoNijhuisandClaude	e9e50c021f	Initial aether repository structure ... Distributed actor system with event sourcing for Go: - event.go - Event, ActorSnapshot, EventStore interface - eventbus.go - EventBus, EventBroadcaster for pub/sub - nats_eventbus.go - NATS-backed cross-node event broadcasting - store/ - InMemoryEventStore (testing), JetStreamEventStore (production) - cluster/ - Node discovery, leader election, shard distribution - model/ - EventStorming model types Extracted from arcadia as open-source infrastructure component. Co-Authored-By: Claude <noreply@anthropic.com>	2026-01-08 19:30:02 +01:00