gateway

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

type BaseGatewayConfig struct {
	DiscoveryEndpoints []string `json:"discoveryEndpoints"` // 服务发现端点
	Routes             []*Route `json:"routes"`             // 路由配置
	EnableMetrics      bool     `json:"enableMetrics"`      // 是否启用指标
	EnableTracing      bool     `json:"enableTracing"`      // 是否启用追踪
}

type CacheItem struct {
	Data       []byte
	Timestamp  time.Time
	Expiration time.Time
}

type CompositeStep struct {
	Name         string       `json:"name"`         // 步骤名称
	ServiceName  string       `json:"serviceName"`  // 目标服务名称
	Path         string       `json:"path"`         // 请求路径
	Method       string       `json:"method"`       // HTTP方法
	Protocol     string       `json:"protocol"`     // 协议类型
	InputMapper  InputMapper  `json:"inputMapper"`  // 输入映射配置
	OutputMapper OutputMapper `json:"outputMapper"` // 输出映射配置
	DependsOn    []string     `json:"dependsOn"`    // 依赖的步骤名称

	// protobuf相关配置
	UseProtobuf       bool   `json:"useProtobuf"`       // 是否使用protobuf格式
	InputMessageType  string `json:"inputMessageType"`  // protobuf输入消息类型
	OutputMessageType string `json:"outputMessageType"` // protobuf输出消息类型
}

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

type ErrorCode string

type ErrorConfig struct {
	ShowDetailedErrors bool `json:"showDetailedErrors"` // 是否显示详细错误信息
	LogStackTraces     bool `json:"logStackTraces"`     // 是否记录堆栈跟踪
	EnableRequestID    bool `json:"enableRequestID"`    // 是否启用请求ID
}

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

type ErrorResponse struct {
	ErrorCode    string      `json:"error_code"`
	ErrorMessage string      `json:"error_message"`
	Details      interface{} `json:"details,omitempty"`
	RequestID    string      `json:"request_id,omitempty"`
	Timestamp    string      `json:"timestamp"`
}

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

type GRPCProxyConfig struct {
	Discovery      *discovery.Discovery // 服务发现接口
	Logger         *zap.Logger          // 日志记录器
	MaxConnections int                  // 最大连接数
	RequestTimeout time.Duration        // 请求超时时间
	RetryCount     int                  // 重试次数
	RetryDelay     time.Duration        // 重试延迟
}

type GRPCRequest struct {
	ServiceName string            `json:"service_name"`
	MethodName  string            `json:"method_name"`
	Message     interface{}       `json:"message"`
	Format      MessageFormat     `json:"format"`
	Metadata    map[string]string `json:"metadata"`
}

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

type GRPCResponse struct {
	Message interface{} `json:"message"`
	Status  codes.Code  `json:"status"`
	Error   string      `json:"error,omitempty"`
}

type GRPCResponseBuilder struct {
}

type Gateway struct {
	*BaseGateway
	// contains filtered or unexported fields
}

type GatewayConfig struct {
	Port               int      `json:"port"`               // 监听端口
	DiscoveryEndpoints []string `json:"discoveryEndpoints"` // 服务发现端点
	Routes             []*Route `json:"routes"`             // 路由配置
	EnableMetrics      bool     `json:"enableMetrics"`      // 是否启用指标
	EnableTracing      bool     `json:"enableTracing"`      // 是否启用追踪
}

type GatewayError struct {
	Code           ErrorCode
	Message        string
	HTTPStatusCode int
	OriginalError  error
}

type GinGateway struct {
	*BaseGateway
	// contains filtered or unexported fields
}

type GinGatewayConfig struct {
	Port               int      `json:"port"`               // 监听端口
	DiscoveryEndpoints []string `json:"discoveryEndpoints"` // 服务发现端点
	Routes             []*Route `json:"routes"`             // 路由配置
	EnableMetrics      bool     `json:"enableMetrics"`      // 是否启用指标
	EnableTracing      bool     `json:"enableTracing"`      // 是否启用追踪
	GinMode            string   `json:"ginMode"`            // Gin模式: debug, release, test
}

type HealthStatus struct {
	IsHealthy bool   `json:"is_healthy"`
	Message   string `json:"message"`
}

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

type InputMapper struct {
	Type     string                 `json:"type"`     // 映射类型: static, dynamic, template
	Template string                 `json:"template"` // 模板字符串
	Params   map[string]interface{} `json:"params"`   // 参数映射
}

type MessageFormat string

type OutputMapper struct {
	Type     string `json:"type"`     // 映射类型: json_path, template
	Path     string `json:"path"`     // JSON路径
	Template string `json:"template"` // 模板字符串
}

type PerformanceConfig struct {
	EnableCaching        bool          `json:"enableCaching"`        // 是否启用缓存
	CacheTTL             time.Duration `json:"cacheTTL"`             // 缓存生存时间
	MaxCacheSize         int64         `json:"maxCacheSize"`         // 最大缓存大小
	EnableConnectionPool bool          `json:"enableConnectionPool"` // 是否启用连接池
	MaxConnections       int           `json:"maxConnections"`       // 最大连接数
	ConnectionTimeout    time.Duration `json:"connectionTimeout"`    // 连接超时时间
	EnableCompression    bool          `json:"enableCompression"`    // 是否启用压缩
}

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

type ProtobufConfiguration struct {
	Enabled      bool
	Registry     *protoregistry.Types
	JSONOptions  protojson.MarshalOptions
	MessageTypes map[string]protoreflect.MessageType
}

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

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

type ProtobufHealthStatus struct {
	IsHealthy       bool   `json:"is_healthy"`
	Enabled         bool   `json:"enabled"`
	RegisteredTypes int    `json:"registered_types"`
	Message         string `json:"message"`
}

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

type ProtobufUtils struct{}

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

type ResponseMapper struct {
	Type     string            `json:"type"`     // 映射类型: merge, template
	Template string            `json:"template"` // 模板字符串
	Merge    map[string]string `json:"merge"`    // 合并配置
}

type Route struct {
	Name        string            `json:"name"`        // 路由名称
	Path        string            `json:"path"`        // 路径匹配规则
	ServiceName string            `json:"serviceName"` // 目标服务名称
	Protocol    string            `json:"protocol"`    // 目标服务协议: http, grpc, etc.
	Methods     []string          `json:"methods"`     // 支持的HTTP方法
	StripPrefix bool              `json:"stripPrefix"` // 是否去除前缀
	Metadata    map[string]string `json:"metadata"`    // 元数据

	// API组合相关字段
	IsComposite    bool            `json:"isComposite"`    // 是否为组合路由
	CompositeSteps []CompositeStep `json:"compositeSteps"` // 组合步骤配置
	ResponseMapper ResponseMapper  `json:"responseMapper"` // 响应映射配置
}

type SecurityConfig struct {
	EnableCORS          bool     `json:"enableCORS"`          // 是否启用CORS
	AllowedOrigins      []string `json:"allowedOrigins"`      // 允许的源
	EnableRateLimiting  bool     `json:"enableRateLimiting"`  // 是否启用限流
	EnableAuth          bool     `json:"enableAuth"`          // 是否启用认证
	APIKeys             []string `json:"apiKeys"`             // API密钥列表
	MaxRequestBodySize  int64    `json:"maxRequestBodySize"`  // 最大请求体大小
	EnableInputSanitize bool     `json:"enableInputSanitize"` // 是否启用输入清理
}

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

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

type ValidationError struct {
	Field   string `json:"field"`
	Message string `json:"message"`
}