Skip to content

Commit

Permalink
Review PR
Browse files Browse the repository at this point in the history
  • Loading branch information
antonjim-te committed Sep 6, 2023
1 parent 9540c55 commit 20536a1
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
6 changes: 3 additions & 3 deletions exporter/exporterhelper/queued_retry.go
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ type queuedRetrySender struct {
}

func newQueuedRetrySender(id component.ID, signal component.DataType, queue internal.ProducerConsumerQueue,
rCfg RetrySettings, nextSender requestSender, sampledLogger *zap.Logger) *queuedRetrySender {
rCfg RetrySettings, nextSender requestSender, logger *zap.Logger) *queuedRetrySender {
retryStopCh := make(chan struct{})
traceAttr := attribute.String(obsmetrics.ExporterKey, id.String())

Expand All @@ -88,7 +88,7 @@ func newQueuedRetrySender(id component.ID, signal component.DataType, queue inte
queue: queue,
retryStopCh: retryStopCh,
traceAttribute: traceAttr,
logger: sampledLogger,
logger: logger,
// TODO: this can be further exposed as a config param rather than relying on a type of queue
requeuingEnabled: queue != nil && queue.IsPersistent(),
}
Expand All @@ -98,7 +98,7 @@ func newQueuedRetrySender(id component.ID, signal component.DataType, queue inte
cfg: rCfg,
nextSender: nextSender,
stopCh: retryStopCh,
logger: sampledLogger,
logger: logger,
// Following three functions actually depend on queuedRetrySender
onTemporaryFailure: qrs.onTemporaryFailure,
}
Expand Down
4 changes: 2 additions & 2 deletions service/telemetry/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ type LogsConfig struct {
// (default = false)
DisableStacktrace bool `mapstructure:"disable_stacktrace"`

// Sampling sets a sampling policy for the extra sampled logger.
// Sampling sets a sampling policy for the more efficient sampled logger.
// Default:
// initial: 1
// thereafter: 100
Expand Down Expand Up @@ -92,7 +92,7 @@ type LogsConfig struct {
InitialFields map[string]any `mapstructure:"initial_fields"`
}

// LogsSamplingConfig sets a sampling strategy for the extra sampled logger. Sampling caps the
// LogsSamplingConfig sets a sampling strategy for the more efficient sampled logger. Sampling caps the
// global CPU and I/O load that logging puts on your process while attempting
// to preserve a representative subset of your logs.
type LogsSamplingConfig struct {
Expand Down

0 comments on commit 20536a1

Please sign in to comment.