neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add ProcessGetNode function

Browse Source
This commit is contained in:
Ingo Oppermann 2024-07-17 16:47:00 +02:00
parent 88739e3f7f
commit 3df1075548
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cluster/store/process.go
View File

@ -251,6 +251,18 @@ func (s *store) ProcessGetNodeMap() map[string]string {
return m
}
func (s *store) ProcessGetNode(id app.ProcessID) (string, error) {
s.lock.RLock()
defer s.lock.RUnlock()
nodeid, hasProcess := s.data.ProcessNodeMap[id.String()]
if !hasProcess {
return "", ErrNotFound
}
return nodeid, nil
}
func (s *store) ProcessGetRelocateMap() map[string]string {
s.lock.RLock()
defer s.lock.RUnlock()

1
cluster/store/store.go
View File

@ -22,6 +22,7 @@ type Store interface {
ProcessList() []Process
ProcessGet(id app.ProcessID) (Process, error)
ProcessGetNode(id app.ProcessID) (string, error)
ProcessGetNodeMap() map[string]string
ProcessGetRelocateMap() map[string]string