Skip to content

Commit

Permalink
Made suggested PR fixups
Browse files Browse the repository at this point in the history
Signed-off-by: Corbin Phelps <corbin.phelps@bluemedora.com>
  • Loading branch information
Corbin Phelps committed Oct 7, 2022
1 parent d9eed26 commit fc3ffdf
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions service/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ func newService(set *settings) (*service, error) {
srv.telemetrySettings.MeterProvider = srv.telemetryInitializer.mp

// process the configuration and initialize the pipeline
if err := srv.initPipeline(set); err != nil {
if err = srv.initExtensionsAndPipeline(set); err != nil {
// If pipeline initialization fails then shut down the telemetry server
if shutdownErr := srv.telemetryInitializer.shutdown(); shutdownErr != nil {
err = multierr.Append(err, fmt.Errorf("failed to shutdown collector telemetry: %w", shutdownErr))
Expand Down Expand Up @@ -132,7 +132,7 @@ func (srv *service) Shutdown(ctx context.Context) error {
return errs
}

func (srv *service) initPipeline(set *settings) error {
func (srv *service) initExtensionsAndPipeline(set *settings) error {
var err error
extensionsSettings := extensions.Settings{
Telemetry: srv.telemetrySettings,
Expand Down

0 comments on commit fc3ffdf

Please sign in to comment.