Skip to content
This repository has been archived by the owner on Oct 9, 2023. It is now read-only.

Commit

Permalink
delete unnecessary comments
Browse files Browse the repository at this point in the history
Signed-off-by: Future Outlier <eric901201@gmai.com>
  • Loading branch information
Future Outlier committed Jul 27, 2023
1 parent b8706bb commit c4a0fcf
Showing 1 changed file with 0 additions and 10 deletions.
10 changes: 0 additions & 10 deletions pkg/async/notifications/factory.go
Original file line number Diff line number Diff line change
Expand Up @@ -121,12 +121,6 @@ func NewNotificationsProcessor(config runtimeInterfaces.NotificationsConfig, sco
emailer = GetEmailer(config, scope)
return implementations.NewGcpProcessor(sub, emailer, scope)
case common.Local:
// TODO: Implement local processor for sandbox image.
/*
emailer = GetEmailer(config, scope)
return implementations.NewSandboxProcessor(sub, emailer, scope)
*/
emailer = GetEmailer(config, scope)
return implementations.NewSandboxProcessor(emailer)
default:
Expand All @@ -136,7 +130,6 @@ func NewNotificationsProcessor(config runtimeInterfaces.NotificationsConfig, sco
}
}

// push notifications to a topic
func NewNotificationsPublisher(config runtimeInterfaces.NotificationsConfig, scope promutils.Scope) interfaces.Publisher {
reconnectAttempts := config.ReconnectAttempts
reconnectDelay := time.Duration(config.ReconnectDelaySeconds) * time.Second
Expand Down Expand Up @@ -180,9 +173,6 @@ func NewNotificationsPublisher(config runtimeInterfaces.NotificationsConfig, sco
}
return implementations.NewPublisher(publisher, scope)
case common.Local:
// push notifications to a topic
// use message queue to send notifications
// chan is pass by reference in golang
return implementations.NewSandboxPublisher()
default:
logger.Infof(context.Background(),
Expand Down

0 comments on commit c4a0fcf

Please sign in to comment.