Method initializeAuthAndObservability

server/server.go:100–176

initializeAuthAndObservability initializes authentication and observability components

()

// initializeAuthAndObservability initializes authentication and observability components
func (s *Server) initializeAuthAndObservability() {
	// Initialize Auth Manager
	if s.config.Auth.APIKey.Enabled || s.config.Auth.JWT.Enabled {
		s.authManager = auth.NewManager(auth.AuthMethodAPIKey)

		// Register API Key authenticator
		if s.config.Auth.APIKey.Enabled {
			apiKeyStore := auth.NewMemoryAPIKeyStore()
			apiKeyAuth := auth.NewAPIKeyAuthenticator(apiKeyStore)
			s.authManager.Register(apiKeyAuth)
		}

		// Register JWT authenticator
		if s.config.Auth.JWT.Enabled {
			jwtAuth := auth.NewJWTAuthenticator(auth.JWTConfig{
				SecretKey:      s.config.Auth.JWT.Secret,
				Issuer:         "aster",
				ExpiryDuration: time.Duration(s.config.Auth.JWT.Expiry) * time.Second,
			})
			s.authManager.Register(jwtAuth)
		}

		// Initialize RBAC
		s.rbac = auth.NewRBAC()
	}

	// Initialize Metrics
	if s.config.Observability.Metrics.Enabled {
		s.metrics = observability.NewMetricsManager("aster")
	}

	// Initialize Health Checker
	if s.config.Observability.HealthCheck.Enabled {
		s.healthChecker = observability.NewHealthChecker(aster.Version)

		// Register store health check
		storeCheck := observability.NewStoreHealthCheck("store", func(ctx context.Context) error {
			// Simple ping check - try to list something
			_, err := s.store.List(ctx, "health_check")
			if err != nil && err.Error() != "bucket not found" && err.Error() != "not found" {
				return err
			}
			return nil
		})
		s.healthChecker.RegisterCheck(storeCheck)
	}

	// Initialize Rate Limiter
	if s.config.RateLimit.Enabled {
		s.rateLimiter = ratelimit.NewLimiterFromConfig(ratelimit.Config{
			Enabled:       s.config.RateLimit.Enabled,
			RequestsPerIP: s.config.RateLimit.RequestsPerIP,
			WindowSize:    s.config.RateLimit.WindowSize,
			BurstSize:     s.config.RateLimit.BurstSize,
			Algorithm:     "token_bucket", // 默认使用令牌桶
		})
	}