apm

package
v0.0.0-...-e4122db Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2025 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DBUtil = &dBUtil{}

DBUtil 是 dBUtil 类型的全局实例,提供数据库查询工具函数

View Source
var EndPoint = &endPoint{make(chan struct{}, 1)}
View Source
var GinStatus = &ginStatus{}
View Source
var HttpStatus = &httpStatus{}
View Source
var Infra = &infra{}
View Source
var Logger = &log{}

logger 是我们用来记录日志的全局实例

View Source
var Tracer trace.Tracer

Functions

This section is empty.

Types

type GinHttpServer

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

GinHttpServer 自定义的 Gin HTTP 服务器类型

func NewGinServer

func NewGinServer(addr string) *GinHttpServer

NewGinServer 创建一个新的 GinHttpServer 实例

func (*GinHttpServer) Close

func (g *GinHttpServer) Close()

Close 优雅关闭服务器

func (*GinHttpServer) Handle

func (g *GinHttpServer) Handle(method, pattern string, handler gin.HandlerFunc)

Handle 注册一个路由和对应的处理函数

func (*GinHttpServer) Start

func (g *GinHttpServer) Start()

Start 启动 HTTP 服务器

type GrpcClient

type GrpcClient struct {
	*grpc.ClientConn
}

GrpcClient 结构体封装了 *grpc.ClientConn,以便进行 gRPC 客户端操作

func NewGrpcClient

func NewGrpcClient(addr string) (*GrpcClient, error)

NewGrpcClient 创建并返回一个新的 gRPC 客户端,连接到指定的地址 参数 addr: 目标 gRPC 服务的地址

type GrpcServer

type GrpcServer struct {
	*grpc.Server // 继承 gRPC 服务器的功能
	// contains filtered or unexported fields
}

GrpcServer 结构体封装了 *grpc.Server 和地址信息 addr: 服务器监听的地址

func NewGrpcServer

func NewGrpcServer(addr string) *GrpcServer

NewGrpcServer 创建并返回一个新的 gRPC 服务器,指定了监听地址 参数 addr: gRPC 服务监听的地址

func (*GrpcServer) Close

func (g *GrpcServer) Close()

func (*GrpcServer) Start

func (g *GrpcServer) Start()

start 启动 gRPC 服务器并开始监听指定的地址 这个方法在 goroutine 中异步执行 gRPC 服务器的服务

type HttpServer

type HttpServer struct {
	*http.Server // 内嵌 http.Server,提供基础的 HTTP 服务器功能
	// contains filtered or unexported fields
}

HttpServer 自定义的 HTTP 服务器类型,它组合了 http.ServeMux 和 http.Server。 ServeMux 是 Go 的默认多路复用器(路由器),Server 是标准的 HTTP 服务器。 HttpServer 结构体封装了常见的 HTTP 服务器功能,并为路由注册和服务器启动提供了更简便的接口。

func NewHttpSever

func NewHttpSever(addr string) *HttpServer

NewHttpServer 是 HttpServer 的构造函数,创建一个新的 HttpServer 实例。 它初始化了一个 ServeMux 和一个 http.Server 实例,并将二者结合。 addr 是服务器监听的地址,通常是 "localhost:8080" 这样的格式。

func (*HttpServer) Close

func (h *HttpServer) Close()

close 优雅关闭 HTTP 服务器,调用 Shutdown 方法来停止服务器的运行。 通过 context.Background() 确保即使在没有超时的情况下,也能平滑关闭。 该方法返回服务器关闭时的错误信息。

func (*HttpServer) Handle

func (h *HttpServer) Handle(pattern string, handler http.Handler)

Handle 是 HttpServer 的一个方法,用于注册处理指定 pattern 的请求。 pattern 是 URL 路径模式,handler 是处理请求的具体函数。

func (*HttpServer) HandleFunc

func (h *HttpServer) HandleFunc(pattern string, handler func(w http.ResponseWriter, r *http.Request))

HandleFunc 是 HttpServer 的一个方法,简化了 Handle 的使用,直接传入一个函数。 handler 是一个函数,接收 http.ResponseWriter 和 http.Request 参数,处理请求并返回响应。

func (*HttpServer) Start

func (h *HttpServer) Start()

Start 启动 HTTP 服务器,它在一个 goroutine 中运行 ListenAndServe。 通过 goroutine 启动服务器,使得主线程不会阻塞,能够继续执行其他操作。 如果服务器启动失败,会触发 panic。

type InfraOption

type InfraOption func(*infra)

func InfraDbOption

func InfraDbOption(connectUrl string) InfraOption

"root:xinbingliang@tcp(127.0.0.1:3310)/fishline?charset=utf8mb4&parseTime=True&loc=Local"

func InfraEnableApm

func InfraEnableApm(otelEndpoint string) InfraOption

func InfraRDbOption

func InfraRDbOption(host string, port int) InfraOption

type Status

type Status struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Body    any    `json:"body"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL