Skip to content

Commit

Permalink
[coordinator] Pass along instrument options into custom rule store fn
Browse files Browse the repository at this point in the history
  • Loading branch information
wesleyk committed Dec 17, 2020
1 parent 78c9122 commit ff89151
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/cmd/services/m3coordinator/downsample/options.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
2 changes: 1 addition & 1 deletion src/query/server/query.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
}
Expand Down

0 comments on commit ff89151

Please sign in to comment.