@@ -21,19 +21,23 @@ import (
21
21
"github.com/open-telemetry/opentelemetry-operator/cmd/otel-allocator/target"
22
22
)
23
23
24
- type RelabelConfigTargetFilter struct {
24
+ const (
25
+ relabelConfigTargetFilterName = "relabel-config"
26
+ )
27
+
28
+ type relabelConfigTargetFilter struct {
25
29
log logr.Logger
26
30
relabelCfg map [string ][]* relabel.Config
27
31
}
28
32
29
- func NewRelabelConfigTargetFilter (log logr.Logger ) Hook {
30
- return & RelabelConfigTargetFilter {
33
+ func newRelabelConfigTargetFilter (log logr.Logger ) Hook {
34
+ return & relabelConfigTargetFilter {
31
35
log : log ,
32
36
relabelCfg : make (map [string ][]* relabel.Config ),
33
37
}
34
38
}
35
39
36
- func (tf * RelabelConfigTargetFilter ) Apply (targets map [string ]* target.Item ) map [string ]* target.Item {
40
+ func (tf * relabelConfigTargetFilter ) Apply (targets map [string ]* target.Item ) map [string ]* target.Item {
37
41
numTargets := len (targets )
38
42
39
43
// need to wait until relabelCfg is set
@@ -58,7 +62,7 @@ func (tf *RelabelConfigTargetFilter) Apply(targets map[string]*target.Item) map[
58
62
return targets
59
63
}
60
64
61
- func (tf * RelabelConfigTargetFilter ) SetConfig (cfgs map [string ][]* relabel.Config ) {
65
+ func (tf * relabelConfigTargetFilter ) SetConfig (cfgs map [string ][]* relabel.Config ) {
62
66
relabelCfgCopy := make (map [string ][]* relabel.Config )
63
67
for key , val := range cfgs {
64
68
relabelCfgCopy [key ] = tf .replaceRelabelConfig (val )
@@ -71,7 +75,7 @@ func (tf *RelabelConfigTargetFilter) SetConfig(cfgs map[string][]*relabel.Config
71
75
// for why SHARD == 0 is a necessary substitution. Otherwise the keep action that uses this env variable,
72
76
// would not match the regex and all targets end up dropped. Also note, $(SHARD) will always be 0 and it
73
77
// does not make sense to read from the environment because it is never set in the allocator.
74
- func (tf * RelabelConfigTargetFilter ) replaceRelabelConfig (cfg []* relabel.Config ) []* relabel.Config {
78
+ func (tf * relabelConfigTargetFilter ) replaceRelabelConfig (cfg []* relabel.Config ) []* relabel.Config {
75
79
for i := range cfg {
76
80
str := cfg [i ].Regex .String ()
77
81
if str == "$(SHARD)" {
@@ -82,7 +86,7 @@ func (tf *RelabelConfigTargetFilter) replaceRelabelConfig(cfg []*relabel.Config)
82
86
return cfg
83
87
}
84
88
85
- func (tf * RelabelConfigTargetFilter ) GetConfig () map [string ][]* relabel.Config {
89
+ func (tf * relabelConfigTargetFilter ) GetConfig () map [string ][]* relabel.Config {
86
90
relabelCfgCopy := make (map [string ][]* relabel.Config )
87
91
for k , v := range tf .relabelCfg {
88
92
relabelCfgCopy [k ] = v
0 commit comments