DeBros/orama
4
0
Fork 0
mirror of https://github.com/DeBrosOfficial/orama.git synced 2026-03-17 06:43:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed olric bug

Browse Source
This commit is contained in:
anonpenguin23 2026-01-31 13:11:26 +02:00
parent 8c392194bb
commit 16eaf9a129
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/namespace/cluster_manager.go
View File

@ -403,10 +403,14 @@ func (cm *ClusterManager) startOlricCluster(ctx context.Context, cluster *Namesp
func (cm *ClusterManager) startGatewayCluster(ctx context.Context, cluster *NamespaceCluster, nodes []NodeCapacity, portBlocks []*PortBlock, rqliteInstances []*rqlite.Instance, olricInstances []*olric.OlricInstance) ([]*gateway.GatewayInstance, error) {
instances := make([]*gateway.GatewayInstance, len(nodes))
// Build Olric server addresses
// Build Olric server addresses — use WireGuard IPs for remote instances
olricServers := make([]string, len(olricInstances))
for i, inst := range olricInstances {
olricServers[i] = inst.DSN()
if nodes[i].NodeID == cm.localNodeID {
olricServers[i] = inst.DSN() // localhost for local
} else {
olricServers[i] = inst.AdvertisedDSN() // WireGuard IP for remote
}
}
// Start all Gateway instances
@ -477,7 +481,13 @@ func (cm *ClusterManager) spawnOlricRemote(ctx context.Context, nodeIP string, c
if err != nil {
return nil, err
}
return &olric.OlricInstance{PID: resp.PID}, nil
return &olric.OlricInstance{
PID: resp.PID,
HTTPPort: cfg.HTTPPort,
MemberlistPort: cfg.MemberlistPort,
BindAddr: cfg.BindAddr,
AdvertiseAddr: cfg.AdvertiseAddr,
}, nil
}
// spawnResponse represents the JSON response from a spawn request