app

Documentation

Index

• Variables
• type Addr
  • func (a *Addr) String() string
• type App
  • func New(options ...AppOption) *App
  • func (a *App) DELETE(path string, h http.Handler)
  • func (a *App) GET(path string, h http.Handler)
  • func (a *App) HEAD(path string, h http.Handler)
  • func (a *App) POST(path string, h http.Handler)
  • func (a *App) PUT(path string, h http.Handler)
  • func (a *App) RegisteGrpcService(desc *grpc.ServiceDesc, s any)
  • func (a *App) Run()
• type AppOption
  • func WihtGrpcWeb(open bool) AppOption
  • func WithAddr(ip string, p int) AppOption
  • func WithCorsOptions(opt *cors.Options) AppOption
  • func WithPromAddr(ip string, p int) AppOption
  • func WithSlogConfig(l *SLogConfig) AppOption
  • func WithTLSConfig(c *TLSConfig) AppOption
• type AppOptions
• type Middleware
• type PromMiddleWare
  • func MetricMiddle(name string, buckets ...float64) *PromMiddleWare
  • func (m *PromMiddleWare) Hander(h http.Handler) http.Handler
• type SLogConfig
• type StatusRecorder
  • func (r *StatusRecorder) WriteHeader(status int)
• type TLSConfig

Variables

var LogMidddle = func(h http.Handler) http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		start := time.Now()
		re := &StatusRecorder{ResponseWriter: w}
		h.ServeHTTP(re, r)

		slog.InfoContext(
			r.Context(),
			"http request",
			slog.Int("status", re.Status),
			slog.String("duration", time.Since(start).String()),
			slog.String("method", r.Method),
			slog.String("path", r.URL.Path),
		)
	})
}

var RecoveryMiddle = func(h http.Handler) http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		defer func() {
			if err := recover(); err != nil {
				w.WriteHeader(http.StatusInternalServerError)
				stack := make([]byte, 1024*8)
				stack = stack[:runtime.Stack(stack, false)]
				slog.ErrorContext(r.Context(), "panic",
					slog.String("path", r.URL.Path),
					slog.Any("error", err),
					slog.Any("stack", stack),
				)
			}
		}()

		h.ServeHTTP(w, r)

	})
}

Types

type Addr

type Addr struct {
	IP   string
	Port int
}

func (*Addr) String

func (a *Addr) String() string

type App

type App struct {
	// contains filtered or unexported fields
}

func New

func New(options ...AppOption) *App

func (*App) DELETE

func (a *App) DELETE(path string, h http.Handler)

func (*App) GET

func (a *App) GET(path string, h http.Handler)

func (*App) HEAD

func (a *App) HEAD(path string, h http.Handler)

func (*App) POST

func (a *App) POST(path string, h http.Handler)

func (*App) PUT

func (a *App) PUT(path string, h http.Handler)

func (*App) RegisteGrpcService

func (a *App) RegisteGrpcService(desc *grpc.ServiceDesc, s any)

func (*App) Run

func (a *App) Run()

type AppOption

type AppOption func(aos *AppOptions)

func WihtGrpcWeb

func WihtGrpcWeb(open bool) AppOption

func WithAddr

func WithAddr(ip string, p int) AppOption

func WithCorsOptions

func WithCorsOptions(opt *cors.Options) AppOption

func WithPromAddr

func WithPromAddr(ip string, p int) AppOption

func WithSlogConfig

func WithSlogConfig(l *SLogConfig) AppOption

func WithTLSConfig

func WithTLSConfig(c *TLSConfig) AppOption

type AppOptions

type AppOptions struct {
	// contains filtered or unexported fields
}

type Middleware

type Middleware func(h http.Handler) http.Handler

type PromMiddleWare

type PromMiddleWare struct {
	// contains filtered or unexported fields
}

func MetricMiddle

func MetricMiddle(name string, buckets ...float64) *PromMiddleWare

NewMiddleware returns a new prometheus Middleware handler.

func (*PromMiddleWare) Hander

func (m *PromMiddleWare) Hander(h http.Handler) http.Handler

type SLogConfig

type SLogConfig struct {
	Level      slog.Level
	JSONOutPut bool
	AddSource  bool
}

type StatusRecorder

type StatusRecorder struct {
	http.ResponseWriter
	Status int
}

func (*StatusRecorder) WriteHeader

func (r *StatusRecorder) WriteHeader(status int)

type TLSConfig

type TLSConfig struct {
	Addr
	KeyPath  string
	CertPath string
}