arugal
commented
3 years ago package main
import (
"encoding/json"
"fmt"
"io/ioutil"
"log"
"net/http"
"strconv"
"github.com/SkyAPM/go2sky"
httpPlugin "github.com/SkyAPM/go2sky/plugins/http"
"github.com/SkyAPM/go2sky/reporter"
"github.com/gorilla/mux"
"github.com/jinzhu/gorm"
_ "github.com/jinzhu/gorm/dialects/mysql"
_ "github.com/jinzhu/gorm/dialects/postgres"
)
var db *gorm.DB
var err error
type Booking struct {
Id int `json:"id"`
User string `json:"user"`
Members int `json:"members"`
}
func homePage(w http.ResponseWriter, r *http.Request) {
fmt.Fprintf(w, "Welcome to HomePage!")
fmt.Println("Endpoint Hit: HomePage")
}
func main() {
database, err := gorm.Open("mysql", "user:password@/test?charset=utf8&parseTime=True&loc=Local")
if err != nil {
panic("Failed to connect to database!")
}
database.AutoMigrate(&Booking{})
db = database
re, err := reporter.NewGRPCReporter("localhost:11800")
if err != nil {
log.Fatalf("new reporter error %v \n", err)
}
defer re.Close()
// re, err := reporter.NewLogReporter()
// if err != nil {
// log.Fatalf("new reporter error %v \n", err)
// }
// defer re.Close()
tracer, err := go2sky.NewTracer("go-http-client", go2sky.WithReporter(re))
if err != nil {
log.Fatalf("create tracer error %v \n", err)
}
sm, err := httpPlugin.NewServerMiddleware(tracer)
if err != nil {
log.Fatalf("create server middleware error %v \n", err)
}
// span, ctx, err := tracer.CreateLocalSpan(context.Background())
// go2sky.TraceID(ctx)
// subSpan, newCtx, err := tracer.CreateLocalSpan(ctx)
// fmt.Println(newCtx)
// subSpan.End()
// span.End()
log.Println("Starting development server at http://127.0.0.1:10000/")
log.Println("Quit the server with CONTROL-C.")
// creates a new instance of a mux router
myRouter := mux.NewRouter().StrictSlash(true)
myRouter.HandleFunc("/", homePage)
myRouter.HandleFunc("/new-booking", createNewBooking).Methods("POST")
myRouter.HandleFunc("/all-bookings", returnAllBookings)
myRouter.HandleFunc("/booking/{id}", returnSingleBooking)
log.Fatal(http.ListenAndServe(":10000", sm(myRouter)))
}
func createNewBooking(w http.ResponseWriter, r *http.Request) {
// get the body of our POST request
// return the string response containing the request body
reqBody, _ := ioutil.ReadAll(r.Body)
var booking Booking
json.Unmarshal(reqBody, &booking)
db.Create(&booking)
fmt.Println("Endpoint Hit: Creating New Booking")
json.NewEncoder(w).Encode(booking)
}
func returnAllBookings(w http.ResponseWriter, r *http.Request) {
bookings := []Booking{}
db.Find(&bookings)
fmt.Println("Endpoint Hit: returnAllBookings")
json.NewEncoder(w).Encode(bookings)
}
func returnSingleBooking(w http.ResponseWriter, r *http.Request) {
vars := mux.Vars(r)
key := vars["id"]
bookings := []Booking{}
db.Find(&bookings)
for _, booking := range bookings {
// string to int
s, err := strconv.Atoi(key)
if err == nil {
if booking.Id == s {
fmt.Println(booking)
fmt.Println("Endpoint Hit: Booking No:", key)
json.NewEncoder(w).Encode(booking)
}
}
}
}Hi @Saicasm, currently go2sky does not have gorm plugin.
Saicasm
wu-sheng
Describe the bug Database metrics are not getting generated when the agent is connected to OAP backend
To Reproduce
Expected behavior
Screenshots
Code main file of demo app `package main
import ( "encoding/json" "fmt" "io/ioutil" "log" "net/http" "strconv"
)
var db *gorm.DB var err error
type Booking struct { Id int
json:"id"User stringjson:"user"Members intjson:"members"}func homePage(w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Welcome to HomePage!") fmt.Println("Endpoint Hit: HomePage") }
func main() {
} func createNewBooking(w http.ResponseWriter, r http.Request) { // get the body of our POST request // return the string response containing the request body reqBody, _ := ioutil.ReadAll(r.Body) var booking Booking json.Unmarshal(reqBody, &booking) db.Create(&booking) fmt.Println("Endpoint Hit: Creating New Booking") json.NewEncoder(w).Encode(booking) } func returnAllBookings(w http.ResponseWriter, r http.Request) { bookings := []Booking{} db.Find(&bookings) fmt.Println("Endpoint Hit: returnAllBookings") json.NewEncoder(w).Encode(bookings) } func returnSingleBooking(w http.ResponseWriter, r *http.Request) { vars := mux.Vars(r) key := vars["id"] bookings := []Booking{} db.Find(&bookings) for _, booking := range bookings { // string to int s, err := strconv.Atoi(key) if err == nil { if booking.Id == s { fmt.Println(booking) fmt.Println("Endpoint Hit: Booking No:", key) json.NewEncoder(w).Encode(booking) } } } } `
Desktop (please complete the following information):
Additional context I'm fairly new to agent side connections ,please let me know if there is anomaly in the agent connection i followed the steps shown on the go2Sky repo