From ff8915154cde36f8df9a494fc0a035e687af677f Mon Sep 17 00:00:00 2001 From: Wesley Kim Date: Thu, 17 Dec 2020 12:21:08 -0500 Subject: [PATCH] [coordinator] Pass along instrument options into custom rule store fn --- src/cmd/services/m3coordinator/downsample/options.go | 2 +- src/query/server/query.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/cmd/services/m3coordinator/downsample/options.go b/src/cmd/services/m3coordinator/downsample/options.go index a6b05b1fa6..f55e1c4acb 100644 --- a/src/cmd/services/m3coordinator/downsample/options.go +++ b/src/cmd/services/m3coordinator/downsample/options.go @@ -103,7 +103,7 @@ var ( ) // CustomRuleStoreFn is a function to swap the backend used for the rule stores. -type CustomRuleStoreFn func(clusterclient.Client) (kv.TxnStore, error) +type CustomRuleStoreFn func(clusterclient.Client, instrument.Options) (kv.TxnStore, error) // DownsamplerOptions is a set of required downsampler options. type DownsamplerOptions struct { diff --git a/src/query/server/query.go b/src/query/server/query.go index b8c24c90e8..2f82d7373f 100644 --- a/src/query/server/query.go +++ b/src/query/server/query.go @@ -753,7 +753,7 @@ func newDownsampler( "cluster management config client") } } else { - kvStore, err = applyCustomRuleStore(clusterManagementClient) + kvStore, err = applyCustomRuleStore(clusterManagementClient, instrumentOpts) if err != nil { return nil, errors.Wrap(err, "unable to apply custom rule store") }