luchen

type AccessLog interface {
	Print(map[string]any)
}

type AccessLogOpt struct {
	ContextFields map[string]GetValueFromContext
	PrintResp     bool
	AccessLog     AccessLog
}

type Balancer[T any] interface {
	// Refresh 刷新服务节点
	Refresh(services []*T)
	// Pick 选择服务节点
	Pick() (*T, error)
}

type DataWrapper func(data any) any

type Endpoint = endpoint.Endpoint

type Errno struct {
	Code     int    // 自定义错误码
	HTTPCode int    // http 错误码
	Msg      string // 错误信息
}

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

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

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

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

type GRPCTransportServer = grpctransport.Server

type Gateway struct {
	*httputil.ReverseProxy
	// contains filtered or unexported fields
}

type GatewayConfig struct {
	ServerName      string  `json:"server-name"`             // 服务名
	Listen          string  `json:"listen"`                  // 监听地址
	WebsocketPrefix string  `json:"websocket-prefix-listen"` // websocket 连接路径
	DiscoveryPrefix string  `json:"discovery-prefix"`        // 自动服务发现路由前缀
	Routes          []Route `json:"routes"`                  // 静态路由
}

type GatewayOption func(*GatewayOptions)

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

type GatewayPlugin interface {
	// BeforeRoute 路由匹配前
	BeforeRoute(context.Context, *http.Request) (*http.Request, error)
	// AfterRoute 路由匹配后
	AfterRoute(context.Context, *http.Request) (*http.Request, error)
	// ModifyResponse 响应阶段处理
	ModifyResponse(context.Context, *http.Response) error
	// ErrorHandler 统一异常处理
	ErrorHandler(context.Context, http.ResponseWriter, *http.Request, error)
}

type GetValueFromContext func(ctx context.Context) any

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

type HTTPHandler interface {
	// Bind 绑定路由
	Bind(router *HTTPServeMux)
}

type HTTPMiddleware func(http.Handler) http.Handler

type HTTPRequest struct {
	Path   string
	Method string
	Header http.Header
	Params url.Values
	Form   url.Values
	Body   []byte
}

type HTTPResponse = httpc.Response

type HTTPServeMux struct {
	*http.ServeMux
	// contains filtered or unexported fields
}

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

type HTTPTransportServer = httptransport.Server

type HostPattern struct {
}

type LogGRPCErrorHandler struct {
}

type Middleware = endpoint.Middleware

type Pattern interface {
	// Name 匹配模式名称
	Name() string
	// Match 匹配路由
	Match(req *http.Request, route *httpRoute) bool
}

type PrefixPattern struct {
}

type Protocol string

type RegisterHandler func(grpcServer *grpc.Server)

type RoundRobinBalancer[T any] struct {
	// contains filtered or unexported fields
}

type Route struct {
	Protocol     string            `json:"protocol"`      // 协议，暂时只支持 http
	Pattern      string            `json:"pattern"`       // 匹配模式：path, host
	Prefix       string            `json:"prefix"`        // 匹配前缀
	Host         string            `json:"host"`          // 匹配 host
	ServiceName  string            `json:"service-name"`  // 注册的服务名
	Upstream     string            `json:"upstream"`      // 上游服务
	RewriteRegex string            `json:"rewrite-regex"` // url 重写正则
	Weight       int               `json:"weight"`        // 权重
	Ext          map[string]string `json:"ext"`           // 扩展信息
}

type Selector interface {
	Next() (*ServiceInfo, error)
}

type SelectorBuilder func(serviceName string) Selector

type Server interface {
	Start() error
	Stop() error
	GetServiceInfo() *ServiceInfo
}

type ServerOption func(*ServerOptions)

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

type ServiceInfo struct {
	ID       string         `json:"id"`
	Name     string         `json:"name"`
	Protocol Protocol       `json:"protocol"`
	Addr     string         `json:"addr"`
	Metadata map[string]any `json:"metadata,omitempty"`
}

type TraceGatewayPlugin struct {
	*UnimplementedGatewayPlugin
}

type UnimplementedGatewayPlugin struct {
}