interceptors

type ACLConfig struct {
	// 默认策略
	DefaultPolicy string `json:"default_policy" yaml:"default_policy"` // "deny" or "allow"
	// 服务权限列表
	Services []*ServicePermissions `json:"services" yaml:"services"`
}

type ACLOption func(*aclOptions)

type APIKeyInfo struct {
	ServiceName string
	Permissions []string
	ExpiresAt   time.Time
	Revoked     bool
}

type APIKeyProvider struct {
	APIKey string
}

type APIKeyStore interface {
	// Get 根据 API Key 获取服务信息
	Get(ctx context.Context, apiKey string) (*APIKeyInfo, error)
}

type APIKeyValidator struct {
	KeyStore APIKeyStore
}

type AccessChecker interface {
	// CheckAccess 检查服务是否有权访问指定方法
	CheckAccess(serviceName, method string) error
}

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

type AlertRule struct {
	Name        string
	Description string
	Condition   func(metrics *AuthMetrics) bool
	Severity    string // critical, warning, info
}

type AuditEvent struct {
	// 时间信息
	Timestamp time.Time `json:"timestamp"`

	// 请求信息
	Method    string `json:"method"`
	RequestID string `json:"request_id,omitempty"`

	// 调用方信息
	ServiceName      string   `json:"service_name"`
	ServiceNamespace string   `json:"service_namespace,omitempty"`
	CertCN           string   `json:"cert_cn,omitempty"`
	CertOU           []string `json:"cert_ou,omitempty"`

	// 凭证信息
	CredentialType    string `json:"credential_type,omitempty"`
	CredentialSubject string `json:"credential_subject,omitempty"`

	// 结果信息
	StatusCode string        `json:"status_code"`
	StatusMsg  string        `json:"status_msg,omitempty"`
	Duration   time.Duration `json:"duration"`

	// 客户端信息
	ClientAddr string `json:"client_addr,omitempty"`

	// 错误信息
	Error string `json:"error,omitempty"`
}

type AuditLogger interface {
	// Log 记录审计事件
	Log(event *AuditEvent)
}

type AuditOption func(*auditOptions)

type AuthMetrics struct {
	// 认证统计
	AuthSuccess  uint64 // 认证成功次数
	AuthFailure  uint64 // 认证失败次数
	MTLSSuccess  uint64 // mTLS 认证成功
	MTLSFailure  uint64 // mTLS 认证失败
	TokenSuccess uint64 // Token 验证成功
	TokenFailure uint64 // Token 验证失败

	// 授权统计
	ACLAllowed uint64 // ACL 允许次数
	ACLDenied  uint64 // ACL 拒绝次数
	// contains filtered or unexported fields
}

type BearerTokenProvider struct {
	// 获取 token 的函数
	GetToken func() (string, error)
}

type ClientCredentialProvider interface {
	// GetMetadata 获取要附加到请求的 metadata
	GetMetadata(ctx context.Context) (map[string]string, error)
}

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

type CredentialExtractor interface {
	// Extract 从上下文提取凭证
	Extract(ctx context.Context) (*ServiceCredential, error)
}

type CredentialOption func(*credentialOptions)

type CredentialType string

type CredentialValidator interface {
	// Validate 验证凭证，返回验证后的凭证信息
	Validate(ctx context.Context, cred *ServiceCredential) (*ServiceCredential, error)
}

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

type HMACCredentialProvider struct {
	AccessKey string
	SecretKey string
}

type HMACValidator struct {
	// 获取服务密钥的回调
	GetSecretKey func(accessKey string) (string, error)
	// 时间戳有效期
	TimestampValidity time.Duration
	// Nonce 存储（防重放）
	NonceStore NonceStore
}

type IdentityExtractor interface {
	// Extract 从上下文提取服务身份
	Extract(ctx context.Context) (*ServiceIdentity, error)
}

type IdentityValidator interface {
	// Validate 验证服务身份
	Validate(identity *ServiceIdentity) error
}

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

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

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

type InterceptorLogger interface {
	LogInfo(msg string, fields map[string]interface{})
	LogError(msg string, fields map[string]interface{})
}

type LoggingOption func(*loggingOptions)

type MTLSOption func(*mtlsOptions)

type MetadataCredentialExtractor struct {
	// 支持的 header 名称
	AuthorizationHeader string // 默认 "authorization"
	APIKeyHeader        string // 默认 "x-api-key"
	SignatureHeader     string // 默认 "x-api-signature"
	TimestampHeader     string // 默认 "x-api-timestamp"
	NonceHeader         string // 默认 "x-api-nonce"
}

type MethodMatcher interface {
	// Match 检查方法是否匹配
	Match(method string) bool
}

type MethodPermission struct {
	Method      string   `json:"method" yaml:"method"`
	Permissions []string `json:"permissions" yaml:"permissions"`
	Description string   `json:"description" yaml:"description"`
}

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

type NonceStore interface {
	// Exists 检查 nonce 是否已存在
	Exists(ctx context.Context, nonce string) (bool, error)
	// Store 存储 nonce
	Store(ctx context.Context, nonce string, ttl time.Duration) error
}

type RecoveryOption func(*recoveryOptions)

type RequestIDOption func(*requestIDOptions)

type RetryOption struct {
	MaxRetries  int
	InitialWait time.Duration
	MaxWait     time.Duration
	Multiplier  float64
	// 判断是否应该重试的函数
	ShouldRetry func(err error) bool
}

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

type ServiceCredential struct {
	// 凭证类型
	Type CredentialType `json:"type"`

	// Bearer Token 相关
	Token     string `json:"token,omitempty"`
	TokenType string `json:"token_type,omitempty"` // jwt, opaque

	// HMAC 相关
	AccessKey string `json:"access_key,omitempty"`
	Signature string `json:"signature,omitempty"`
	Timestamp int64  `json:"timestamp,omitempty"`
	Nonce     string `json:"nonce,omitempty"`

	// 解析后的信息
	Subject     string            `json:"subject,omitempty"`     // 凭证主体（服务名）
	Permissions []string          `json:"permissions,omitempty"` // 权限列表
	ExpiresAt   time.Time         `json:"expires_at,omitempty"`  // 过期时间
	Claims      map[string]string `json:"claims,omitempty"`      // 额外声明
}

type ServiceIdentity struct {
	// 服务名称（从证书 CN 或 SAN 中的服务标识提取）
	ServiceName string `json:"service_name"`
	// 服务命名空间（如 production, staging）
	ServiceNamespace string `json:"service_namespace,omitempty"`
	// 证书通用名称
	CommonName string `json:"common_name,omitempty"`
	// 组织单元列表
	OrganizationalUnits []string `json:"organizational_units,omitempty"`
	// 证书序列号（用于追踪和撤销）
	CertSerialNumber string `json:"cert_serial_number,omitempty"`
	// DNS SANs
	DNSSANs []string `json:"dns_sans,omitempty"`
	// URI SANs
	URISANs []string `json:"uri_sans,omitempty"`
	// 证书有效期
	NotBefore time.Time `json:"not_before,omitempty"`
	NotAfter  time.Time `json:"not_after,omitempty"`
}

type ServiceMetrics struct {
	ServiceName   string
	RequestCount  uint64
	SuccessCount  uint64
	FailureCount  uint64
	TotalDuration int64 // 纳秒
	LastRequestAt int64 // Unix 时间戳
}

type ServicePermissions struct {
	// 服务名称
	ServiceName string `json:"service_name" yaml:"service_name"`
	// 允许调用的方法列表（支持通配符）
	AllowedMethods []string `json:"allowed_methods" yaml:"allowed_methods"`
	// 拒绝调用的方法列表（优先级高于允许）
	DeniedMethods []string `json:"denied_methods" yaml:"denied_methods"`
	// 方法级权限（更细粒度）
	MethodPermissions map[string][]string `json:"method_permissions" yaml:"method_permissions"`
	// 是否启用
	Enabled bool `json:"enabled" yaml:"enabled"`
	// 描述
	Description string `json:"description" yaml:"description"`
}

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

type WrappedServerStream struct {
	grpc.ServerStream
	Ctx context.Context
}