remove otel for now
This commit is contained in:
@@ -1,7 +1,6 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
@@ -207,15 +206,15 @@ func main() {
|
|||||||
done := make(chan bool, 1)
|
done := make(chan bool, 1)
|
||||||
signal.Notify(sigs, syscall.SIGTERM)
|
signal.Notify(sigs, syscall.SIGTERM)
|
||||||
|
|
||||||
otelShutdown, err := setupOTelSDK(context.Background())
|
// otelShutdown, err := setupOTelSDK(context.Background())
|
||||||
if err != nil {
|
// if err != nil {
|
||||||
log.Fatalf("Unable to start otel %v", err)
|
// log.Fatalf("Unable to start otel %v", err)
|
||||||
}
|
// }
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
sig := <-sigs
|
sig := <-sigs
|
||||||
fmt.Println("Shutting down due to signal:", sig)
|
fmt.Println("Shutting down due to signal:", sig)
|
||||||
otelShutdown(context.Background())
|
//otelShutdown(context.Background())
|
||||||
diskStorage.Close()
|
diskStorage.Close()
|
||||||
pool.Close()
|
pool.Close()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user