summaryrefslogtreecommitdiffhomepage
path: root/pkg/server/mrt.go
diff options
context:
space:
mode:
authorAlistair King <alistair@kentik.com>2020-11-03 11:44:13 -0500
committerFUJITA Tomonori <fujita.tomonori@gmail.com>2020-11-06 21:08:55 +0900
commit5c979fea68b6000ec5339fe85dfbf21bc3977921 (patch)
treec88af87aa4d69931e1ec9829e53bdafd63503520 /pkg/server/mrt.go
parent7ce0dddd4f49307540b13024168310c237d28c2f (diff)
Use MonitorTableRequest.Name to filter by peer
Filter returned Paths based on provided peer address (similar to GetTable). This should improve performance when using MonitorTable with ADJ_IN and Current for a single peer.
Diffstat (limited to 'pkg/server/mrt.go')
-rw-r--r--pkg/server/mrt.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/pkg/server/mrt.go b/pkg/server/mrt.go
index 773f0ea5..6ce64c14 100644
--- a/pkg/server/mrt.go
+++ b/pkg/server/mrt.go
@@ -51,7 +51,7 @@ func (m *mrtWriter) loop() error {
ops := []watchOption{}
switch m.c.DumpType {
case config.MRT_TYPE_UPDATES:
- ops = append(ops, watchUpdate(false))
+ ops = append(ops, watchUpdate(false, ""))
case config.MRT_TYPE_TABLE:
if len(m.c.TableName) > 0 {
ops = append(ops, watchTableName(m.c.TableName))