node selector

This commit is contained in:
Mathew Kamkar
2021-10-28 20:00:02 -07:00
parent c37cd6c8c6
commit 9eee8299c4
+6
View File
@@ -47,6 +47,11 @@ func NewLocalRoomManager(conf *config.Config, rs RoomStore, router routing.Route
return nil, err
}
ns, err := selector.CreateNodeSelector(conf)
if err != nil {
return nil, err
}
r := &LocalRoomManager{
RoomStore: rs,
lock: sync.RWMutex{},
@@ -57,6 +62,7 @@ func NewLocalRoomManager(conf *config.Config, rs RoomStore, router routing.Route
currentNode: currentNode,
webhookPool: workerpool.New(1),
rooms: make(map[string]*rtc.Room),
selector: ns,
}
// hook up to router