Class ServiceProducers

java.lang.Object
org.apache.polaris.service.config.ServiceProducers

public class ServiceProducers extends Object
  • Constructor Details

    • ServiceProducers

      public ServiceProducers()
  • Method Details

    • clock

      @Produces @ApplicationScoped public Clock clock()
    • storageCredentialCache

      @Produces @ApplicationScoped public org.apache.polaris.core.storage.cache.StorageCredentialCache storageCredentialCache(org.apache.polaris.core.storage.cache.StorageCredentialCacheConfig storageCredentialCacheConfig)
    • polarisDiagnostics

      @Produces @Singleton public org.apache.polaris.core.PolarisDiagnostics polarisDiagnostics()
    • rootCredentialsSet

      @Produces @ApplicationScoped public org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet rootCredentialsSet(Optional<String> credentials)
    • polarisCallContext

      @Produces @RequestScoped public org.apache.polaris.core.context.CallContext polarisCallContext(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.config.RealmConfigurationSource configurationSource, org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory)
    • realmConfig

      @Produces @RequestScoped public org.apache.polaris.core.config.RealmConfig realmConfig(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.config.RealmConfigurationSource configurationSource)
    • polarisAuthorizerFactory

      @Produces @ApplicationScoped public org.apache.polaris.core.auth.PolarisAuthorizerFactory polarisAuthorizerFactory(AuthorizationConfiguration authorizationConfig, @Any jakarta.enterprise.inject.Instance<org.apache.polaris.core.auth.PolarisAuthorizerFactory> authorizerFactories)
    • polarisAuthorizer

      @Produces @RequestScoped public org.apache.polaris.core.auth.PolarisAuthorizer polarisAuthorizer(org.apache.polaris.core.auth.PolarisAuthorizerFactory factory, org.apache.polaris.core.config.RealmConfig realmConfig)
    • resolverFactory

      @Produces @RequestScoped public org.apache.polaris.core.persistence.resolver.ResolverFactory resolverFactory(org.apache.polaris.core.PolarisDiagnostics diagnostics, org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.config.RealmConfig realmConfig, org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory, org.apache.polaris.core.context.CallContext callContext, org.apache.polaris.core.persistence.PolarisMetaStoreManager polarisMetaStoreManager)
    • resolutionManifestFactory

      @Produces @RequestScoped public org.apache.polaris.core.persistence.resolver.ResolutionManifestFactory resolutionManifestFactory(org.apache.polaris.core.PolarisDiagnostics diagnostics, org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.persistence.resolver.ResolverFactory resolverFactory)
    • realmContextResolver

      @Produces @Singleton public RealmContextResolver realmContextResolver(RealmContextConfiguration config, @Any jakarta.enterprise.inject.Instance<RealmContextResolver> realmContextResolvers)
    • fileIOFactory

      @Produces @RequestScoped public FileIOFactory fileIOFactory(FileIOConfiguration config, @Any jakarta.enterprise.inject.Instance<FileIOFactory> fileIOFactories)
    • metaStoreManagerFactory

      @Produces @Singleton public org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory(PersistenceConfiguration config, @Any jakarta.enterprise.inject.Instance<org.apache.polaris.core.persistence.MetaStoreManagerFactory> metaStoreManagerFactories)
    • polarisMetaStoreManager

      @Produces @RequestScoped public org.apache.polaris.core.persistence.PolarisMetaStoreManager polarisMetaStoreManager(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory)
    • userSecretsManagerFactory

      @Produces @ApplicationScoped public org.apache.polaris.core.secrets.UserSecretsManagerFactory userSecretsManagerFactory(SecretsManagerConfiguration config, @Any jakarta.enterprise.inject.Instance<org.apache.polaris.core.secrets.UserSecretsManagerFactory> userSecretsManagerFactories)
    • sdkHttpClient

      @Produces @Singleton @Identifier("aws-sdk-http-client") public software.amazon.awssdk.http.SdkHttpClient sdkHttpClient(S3AccessConfig config)
    • closeSdkHttpClient

      public void closeSdkHttpClient(@Disposes @Identifier("aws-sdk-http-client") software.amazon.awssdk.http.SdkHttpClient client)
    • stsClientsPool

      @Produces @ApplicationScoped public StsClientsPool stsClientsPool(@Identifier("aws-sdk-http-client") software.amazon.awssdk.http.SdkHttpClient httpClient, StorageConfiguration config, io.micrometer.core.instrument.MeterRegistry meterRegistry)
    • maybeBootstrap

      public void maybeBootstrap(@Observes jakarta.enterprise.event.Startup event, org.apache.polaris.service.config.Bootstrapper bootstrapper, PersistenceConfiguration config, RealmContextConfiguration realmContextConfiguration, org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet rootCredentialsSet)
      Eagerly initialize the in-memory default realm on startup, so that users can check the credentials printed to stdout immediately.
    • rateLimiter

      @Produces @ApplicationScoped public RateLimiter rateLimiter(RateLimiterFilterConfiguration config, @Any jakarta.enterprise.inject.Instance<RateLimiter> rateLimiters)
    • tokenBucketFactory

      @Produces @ApplicationScoped public TokenBucketFactory tokenBucketFactory(TokenBucketConfiguration config, @Any jakarta.enterprise.inject.Instance<TokenBucketFactory> tokenBucketFactories)
    • authenticator

      @Produces @RequestScoped public Authenticator authenticator(AuthenticationRealmConfiguration config, @Any jakarta.enterprise.inject.Instance<Authenticator> authenticators)
    • icebergRestOAuth2ApiService

      @Produces @RequestScoped public org.apache.polaris.service.catalog.api.IcebergRestOAuth2ApiService icebergRestOAuth2ApiService(AuthenticationRealmConfiguration config, @Any jakarta.enterprise.inject.Instance<org.apache.polaris.service.catalog.api.IcebergRestOAuth2ApiService> services)
    • tokenBroker

      @Produces @RequestScoped public TokenBroker tokenBroker(AuthenticationRealmConfiguration config, @Any jakarta.enterprise.inject.Instance<TokenBrokerFactory> tokenBrokerFactories, org.apache.polaris.core.persistence.PolarisMetaStoreManager polarisMetaStoreManager, org.apache.polaris.core.context.CallContext callContext)
    • taskExecutor

      @Produces @Singleton @Identifier("task-executor") public org.eclipse.microprofile.context.ManagedExecutor taskExecutor(TaskHandlerConfiguration config)
    • userSecretsManager

      @Produces @RequestScoped public org.apache.polaris.core.secrets.UserSecretsManager userSecretsManager(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.secrets.UserSecretsManagerFactory userSecretsManagerFactory)
    • realmAuthConfig

      @Produces @RequestScoped public AuthenticationRealmConfiguration realmAuthConfig(AuthenticationConfiguration config, org.apache.polaris.core.context.RealmContext realmContext)
    • oidcTenantResolver

      @Produces @ApplicationScoped public OidcTenantResolver oidcTenantResolver(OidcConfiguration config, @Any jakarta.enterprise.inject.Instance<OidcTenantResolver> resolvers)
    • polarisCredentialManager

      @Produces @RequestScoped public org.apache.polaris.core.credentials.PolarisCredentialManager polarisCredentialManager(PolarisCredentialManagerConfiguration config, @Any jakarta.enterprise.inject.Instance<org.apache.polaris.core.credentials.PolarisCredentialManager> credentialManagers)
    • closeTaskExecutor

      public void closeTaskExecutor(@Disposes @Identifier("task-executor") org.eclipse.microprofile.context.ManagedExecutor executor)
    • requestIdSupplier

      @Produces @RequestScoped public org.apache.polaris.core.context.RequestIdSupplier requestIdSupplier()
      Produces a RequestIdSupplier that retrieves the request ID from the current request context.

      The request ID is set by RequestIdFilter on each incoming request. This producer provides access to that ID via the RequestIdSupplier interface for components that need request correlation without direct dependency on JAX-RS types.

    • metricsReporter

      @Produces @ApplicationScoped public IcebergMetricsReporter metricsReporter(MetricsReportingConfiguration config, @Any jakarta.enterprise.inject.Instance<IcebergMetricsReporter> reporters)
    • eventListenerExecutor

      @Produces @Singleton @Identifier("event-listener-executor") public Executor eventListenerExecutor(PolarisEventListenerConfiguration config)
    • closeEventListenerExecutor

      public void closeEventListenerExecutor(@Disposes @Identifier("event-listener-executor") Executor executor)