Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- abstract class Sender {
- def send(event: ServingError): Unit
- }
- trait Log extends Sender {
- override def send(event: ServingError): Unit = {
- Logger.log(event.description)
- }
- }
- trait Metric extends Sender {
- override def send(event: ServingError): Unit = {
- Monitor.incrementCounter(event.getClass.getSimpleName/*this is not recommended...*/, "errorCode" ->
- event.code.toString)
- }
- }
- trait S3_Backup extends Sender {
- override def send(event: ServingError): Unit = {
- S3_Client.upload(event.content)
- }
- }
- trait Kafka extends Sender {
- def send(event: ServingError): Unit = {
- KafkaProducer.send(event.content) }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement