Skip to content

Commit

Permalink
Fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
ravishankar15 committed Jan 17, 2025
1 parent 29db3b4 commit 9ad3c23
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions internal/component/prometheus/remotewrite/remote_write.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ func New(o component.Options, c Arguments) (*Component, error) {
storage: storage.NewFanout(o.Logger, walStorage, remoteStore),
debugDataPublisher: debugDataPublisher.(livedebugging.DebugDataPublisher),
}
componenentID := livedebugging.ComponentID(res.opts.ID)
componentID := livedebugging.ComponentID(res.opts.ID)
res.receiver = prometheus.NewInterceptor(
res.storage,
ls,
Expand All @@ -129,8 +129,8 @@ func New(o component.Options, c Arguments) (*Component, error) {
if localID == 0 {
ls.GetOrAddLink(res.opts.ID, uint64(newRef), l)
}
if res.debugDataPublisher.IsActive(componenentID) {
res.debugDataPublisher.Publish(componenentID, fmt.Sprintf("ts=%d, labels=%s, value=%f", t, l, v))
if res.debugDataPublisher.IsActive(componentID) {
res.debugDataPublisher.Publish(componentID, fmt.Sprintf("ts=%d, labels=%s, value=%f", t, l, v))
}
return globalRef, nextErr
}),
Expand All @@ -144,7 +144,7 @@ func New(o component.Options, c Arguments) (*Component, error) {
if localID == 0 {
ls.GetOrAddLink(res.opts.ID, uint64(newRef), l)
}
if res.debugDataPublisher.IsActive(componenentID) {
if res.debugDataPublisher.IsActive(componentID) {
var data string
if h != nil {
data = fmt.Sprintf("ts=%d, labels=%s, histogram=%s", t, l, h.String())
Expand All @@ -153,7 +153,7 @@ func New(o component.Options, c Arguments) (*Component, error) {
} else {
data = fmt.Sprintf("ts=%d, labels=%s, no_value", t, l)
}
res.debugDataPublisher.Publish(componenentID, data)
res.debugDataPublisher.Publish(componentID, data)
}
return globalRef, nextErr
}),
Expand All @@ -167,8 +167,8 @@ func New(o component.Options, c Arguments) (*Component, error) {
if localID == 0 {
ls.GetOrAddLink(res.opts.ID, uint64(newRef), l)
}
if res.debugDataPublisher.IsActive(componenentID) {
res.debugDataPublisher.Publish(componenentID, fmt.Sprintf("labels=%s, type=%s, unit=%s, help=%s", l, m.Type, m.Unit, m.Help))
if res.debugDataPublisher.IsActive(componentID) {
res.debugDataPublisher.Publish(componentID, fmt.Sprintf("labels=%s, type=%s, unit=%s, help=%s", l, m.Type, m.Unit, m.Help))
}
return globalRef, nextErr
}),
Expand All @@ -182,8 +182,8 @@ func New(o component.Options, c Arguments) (*Component, error) {
if localID == 0 {
ls.GetOrAddLink(res.opts.ID, uint64(newRef), l)
}
if res.debugDataPublisher.IsActive(componenentID) {
res.debugDataPublisher.Publish(componenentID, fmt.Sprintf("ts=%d, labels=%s, exemplar_labels=%s, value=%f", e.Ts, l, e.Labels, e.Value))
if res.debugDataPublisher.IsActive(componentID) {
res.debugDataPublisher.Publish(componentID, fmt.Sprintf("ts=%d, labels=%s, exemplar_labels=%s, value=%f", e.Ts, l, e.Labels, e.Value))
}
return globalRef, nextErr
}),
Expand Down

0 comments on commit 9ad3c23

Please sign in to comment.