Skip to content
This repository has been archived by the owner on Oct 17, 2018. It is now read-only.

Commit

Permalink
change rollupTargetViewsToTargets to newRollupTargetsFromView
Browse files Browse the repository at this point in the history
  • Loading branch information
Jake Skelcy committed Mar 16, 2018
1 parent d007f5c commit 7f1e4a4
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 10 deletions.
16 changes: 8 additions & 8 deletions rules/rollup.go
Original file line number Diff line number Diff line change
Expand Up @@ -44,14 +44,6 @@ var (
errNilRollupRuleSchema = errors.New("nil rollup rule schema")
)

func rollupTargetViewsToTargets(views []models.RollupTargetView) []rollupTarget {
targets := make([]rollupTarget, len(views))
for i, t := range views {
targets[i] = newRollupTargetFromView(t)
}
return targets
}

// RollupTarget dictates how to roll up metrics. Metrics associated with a rollup
// target will be grouped and rolled up across the provided set of tags, named
// with the provided name, and aggregated and retained under the provided policies.
Expand Down Expand Up @@ -79,6 +71,14 @@ func newRollupTarget(target *schema.RollupTarget) (rollupTarget, error) {
}, nil
}

func newRollupTargetsFromView(views []models.RollupTargetView) []rollupTarget {
targets := make([]rollupTarget, len(views))
for i, t := range views {
targets[i] = newRollupTargetFromView(t)
}
return targets
}

func newRollupTargetFromView(rtv models.RollupTargetView) rollupTarget {
return rollupTarget{
Name: []byte(rtv.Name),
Expand Down
4 changes: 2 additions & 2 deletions rules/ruleset.go
Original file line number Diff line number Diff line change
Expand Up @@ -808,7 +808,7 @@ func (rs *ruleSet) AddRollupRule(rrv models.RollupRuleView, meta UpdateMetadata)
if err != nil && err != errRuleNotFound {
return "", xerrors.Wrap(err, fmt.Sprintf(ruleActionErrorFmt, "add", rrv.Name))
}
targets := rollupTargetViewsToTargets(rrv.Targets)
targets := newRollupTargetsFromView(rrv.Targets)
if err == errRuleNotFound {
if r, err = newRollupRuleFromFields(
rrv.Name,
Expand Down Expand Up @@ -838,7 +838,7 @@ func (rs *ruleSet) UpdateRollupRule(rrv models.RollupRuleView, meta UpdateMetada
if err != nil {
return xerrors.Wrap(err, fmt.Sprintf(ruleActionErrorFmt, "update", rrv.ID))
}
targets := rollupTargetViewsToTargets(rrv.Targets)
targets := newRollupTargetsFromView(rrv.Targets)
if err = r.addSnapshot(
rrv.Name,
rrv.Filter,
Expand Down

0 comments on commit 7f1e4a4

Please sign in to comment.