gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2194 from nats-io/js-domains

Browse Source 
[added] filter system requests by JS domain
This commit is contained in:
Matthias Hanel
2021-05-07 19:06:37 -04:00
committed by GitHub
parent 346ce7539b 230128ed01
commit 4355e393ea
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
server/events.go
View File

@@ -1077,6 +1077,7 @@ type EventFilterOptions struct {
Cluster string `json:"cluster,omitempty"` // filter by cluster name
Host string `json:"host,omitempty"` // filter by host name
Tags []string `json:"tags,omitempty"` // filter by tags (must match all tags)
Domain string `json:"domain,omitempty"` // filter by JS domain
}
// StatszEventOptions are options passed to Statsz
@@ -1142,13 +1143,13 @@ type JszEventOptions struct {
// returns true if the request does NOT apply to this server and can be ignored.
// DO NOT hold the server lock when
func (s *Server) filterRequest(fOpts *EventFilterOptions) bool {
if fOpts.Name != "" && !strings.Contains(s.info.Name, fOpts.Name) {
if fOpts.Name != _EMPTY_ && !strings.Contains(s.info.Name, fOpts.Name) {
return true
}
if fOpts.Host != "" && !strings.Contains(s.info.Host, fOpts.Host) {
if fOpts.Host != _EMPTY_ && !strings.Contains(s.info.Host, fOpts.Host) {
return true
}
if fOpts.Cluster != "" {
if fOpts.Cluster != _EMPTY_ {
s.mu.Lock()
cluster := s.info.Cluster
s.mu.Unlock()
@@ -1164,6 +1165,9 @@ func (s *Server) filterRequest(fOpts *EventFilterOptions) bool {
}
}
}
if fOpts.Domain != _EMPTY_ && s.getOpts().JetStreamDomain != fOpts.Domain {
return true
}
return false
}