| 32 | var ErrNeedsImplementation = connect.NewError(connect.CodeUnimplemented, errors.New("needs implementation")) |
| 33 | |
| 34 | func main() { |
| 35 | addr := flag.String("listen", "127.0.0.1:8080", "listen to address on") |
| 36 | flag.Parse() |
| 37 | |
| 38 | log.Printf("Observability service starting") |
| 39 | |
| 40 | path, handler := apiv2connect.NewObservabilityServiceHandler(&service{}) |
| 41 | http.Handle(path, handler) |
| 42 | log.Printf("Handling connect service at prefix: %v", path) |
| 43 | |
| 44 | log.Printf("Listening on: %v", *addr) |
| 45 | err := http.ListenAndServe( |
| 46 | *addr, |
| 47 | h2c.NewHandler(http.DefaultServeMux, &http2.Server{}), |
| 48 | ) |
| 49 | |
| 50 | if err != http.ErrServerClosed { |
| 51 | log.Printf("Error running or stopping: %v", err) |
| 52 | } |
| 53 | } |
| 54 | |
| 55 | type service struct{} |
| 56 | |