config

type CircuitBreakerConfig struct {
	FailureThreshold int
	OpenDuration     time.Duration
	HalfOpenRequests int
	SuccessThreshold int
}

type ClientOption func(*ClientOptions)

type ClientOptions struct {
	UnaryInterceptors  []grpc.UnaryClientInterceptor
	StreamInterceptors []grpc.StreamClientInterceptor
	DialOptions        []grpc.DialOption

	// TracingHook 用户提供的 Tracing 钩子
	TracingHook TracingHook

	// MetricsCollector 用户提供的 Metrics 收集器（覆盖默认）
	MetricsCollector MetricsCollector

	// DisableDefaultInterceptors 禁用默认拦截器
	DisableDefaultInterceptors bool
}

type Config struct {
	Endpoint string
	TLS      *TLSConfig

	Timeout     time.Duration
	DialTimeout time.Duration
	Keepalive   *KeepaliveConfig
	Retry       *RetryConfig

	JWKS           *JWKSConfig
	Metadata       map[string]string
	LoadBalancer   string
	CircuitBreaker *CircuitBreakerConfig
	Observability  *ObservabilityConfig
}

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

type JWKSConfig struct {
	URL             string
	GRPCEndpoint    string
	RefreshInterval time.Duration
	RequestTimeout  time.Duration
	CacheTTL        time.Duration
	HTTPClient      *http.Client
	CustomHeaders   map[string]string
	FallbackOnError bool
}

type KeepaliveConfig struct {
	Time                time.Duration
	Timeout             time.Duration
	PermitWithoutStream bool
}

type MetricsCollector interface {
	RecordRequest(method string, code string, duration time.Duration)
}

type ObservabilityConfig struct {
	EnableMetrics        bool
	EnableTracing        bool
	EnableCircuitBreaker bool
	EnableRequestID      bool
	MetricsNamespace     string
	MetricsSubsystem     string
	ServiceName          string
}

type RetryConfig struct {
	Enabled           bool
	MaxAttempts       int
	InitialBackoff    time.Duration
	MaxBackoff        time.Duration
	BackoffMultiplier float64
	RetryableCodes    []string
}

type ServiceAuthConfig struct {
	ServiceID      string
	TargetAudience []string
	TokenTTL       time.Duration
	RefreshBefore  time.Duration
}

type TLSConfig struct {
	Enabled bool

	CACert    string
	CACertPEM []byte

	ClientCert    string
	ClientCertPEM []byte
	ClientKey     string
	ClientKeyPEM  []byte

	ServerName         string
	InsecureSkipVerify bool
	MinVersion         uint16
}

type TokenVerifyConfig struct {
	AllowedAudience         []string
	AllowedIssuer           string
	ClockSkew               time.Duration
	RequireExpirationTime   bool
	ForceRemoteVerification bool
	RequiredClaims          []string
	Algorithms              []string
}

type TracingHook interface {
	StartSpan(ctx context.Context, name string) (context.Context, func())
	SetAttributes(ctx context.Context, attrs map[string]string)
	RecordError(ctx context.Context, err error)
}

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