Skip to content

Commit

Permalink
Fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
krebernisak committed Dec 20, 2021
1 parent a1cd214 commit c9f9d3f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/monitoring/feed_monitor.go
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ func (f *feedMonitor) processState(envelope StateEnvelope) error {
}
value, err := f.stateSchema.Encode(mapping)
if err != nil {
return fmt.Errorf("failed to enconde message %v: %w", envelope, err)
return fmt.Errorf("failed to encode message %v: %w", envelope, err)
}
var key = f.feedConfig.StateAccount.Bytes()
if err = f.producer.Produce(key, value, f.configSetTopic); err != nil {
Expand All @@ -148,7 +148,7 @@ func (f *feedMonitor) processTransmission(envelope TransmissionEnvelope) error {
}
value, err := f.transmissionSchema.Encode(mapping)
if err != nil {
return fmt.Errorf("failed to enconde message %v: %w", envelope, err)
return fmt.Errorf("failed to encode message %v: %w", envelope, err)
}
var key = f.feedConfig.StateAccount.Bytes()
if err = f.producer.Produce(key, value, f.transmissionTopic); err != nil {
Expand All @@ -165,7 +165,7 @@ func (f *feedMonitor) processConfigSetSimplified(envelope StateEnvelope) error {
}
value, err := f.configSetSimplifiedSchema.Encode(mapping)
if err != nil {
return fmt.Errorf("failed to enconde message %v: %w", envelope, err)
return fmt.Errorf("failed to encode message %v: %w", envelope, err)
}
var key = f.feedConfig.StateAccount.Bytes()
if err = f.producer.Produce(key, value, f.configSetSimplifiedTopic); err != nil {
Expand Down

0 comments on commit c9f9d3f

Please sign in to comment.