Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
thampiotr committed Dec 10, 2024
1 parent 6bdd276 commit 065d098
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion internal/component/otelcol/connector/connector.go
Original file line number Diff line number Diff line change
Expand Up @@ -214,7 +214,7 @@ func (p *Connector) Update(args component.Arguments) error {
return errors.New("unsupported connector type")
}

// Pause the consumer, because we need to scheduler to run the new components before they receive any traffic.
// Pause the consumer, because we need the scheduler to run the new components before they receive any traffic.
p.consumer.Pause()
p.consumer.SetConsumers(tracesConnector, metricsConnector, logsConnector)
// Schedule the components. The scheduler will resume the consumer once the components are running.
Expand Down
2 changes: 1 addition & 1 deletion internal/component/otelcol/exporter/exporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -242,7 +242,7 @@ func (e *Exporter) Update(args component.Arguments) error {
}
}

// Pause the consumer, because we need to scheduler to run the new components before they receive any traffic.
// Pause the consumer, because we need the scheduler to run the new components before they receive any traffic.
e.consumer.Pause()
e.consumer.SetConsumers(tracesExporter, metricsExporter, logsExporter)
// Schedule the components. The scheduler will resume the consumer once the components are running.
Expand Down
2 changes: 1 addition & 1 deletion internal/component/otelcol/processor/processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,7 @@ func (p *Processor) Update(args component.Arguments) error {
}
}

// Pause the consumer, because we need to scheduler to run the new components before they receive any traffic.
// Pause the consumer, because we need the scheduler to run the new components before they receive any traffic.
p.consumer.Pause()
p.consumer.SetConsumers(tracesProcessor, metricsProcessor, logsProcessor)
// Schedule the components. The scheduler will resume the consumer once the components are running.
Expand Down

0 comments on commit 065d098

Please sign in to comment.