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

Account subject mappings and full wildcard support for exports/imports

Browse Source 
The mappings enable traffic shaping functionality.
Also added a subject transform which can match any subject and transform to a new one, even re-ordering partial wildcards.

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-07-03 10:31:55 -07:00
parent fe7fd92c89
commit 6faf07d583
10 changed files with 1362 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
server/parser.go
View File

@@ -389,6 +389,17 @@ func (c *client) parse(buf []byte) error {
if err := c.processPub(arg); err != nil {
return err
}
// Check if we have and account mappings or tees or filters.
// FIXME(dlc) - Probably better way to do this.
// Could add in cache but will be tricky since results based on pub subject are dynamic
// due to wildcard matching and weight sets.
if c.kind == CLIENT && c.in.flags.isSet(hasMappings) {
old := c.pa.subject
changed := c.selectMappedSubject()
if trace && changed {
c.traceInOp("MAPPING", []byte(fmt.Sprintf("%s -> %s", old, c.pa.subject)))
}
}
c.drop, c.as, c.state = 0, i+1, MSG_PAYLOAD
// If we don't have a saved buffer then jump ahead with
// the index. If this overruns what is left we fall out