Class ServiceProducers
java.lang.Object
org.apache.polaris.service.config.ServiceProducers
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionauthenticator(AuthenticationRealmConfiguration config, jakarta.enterprise.inject.Instance<Authenticator> authenticators) clock()voidcloseEventListenerExecutor(Executor executor) voidcloseSdkHttpClient(software.amazon.awssdk.http.SdkHttpClient client) voidcloseTaskExecutor(org.eclipse.microprofile.context.ManagedExecutor executor) fileIOFactory(FileIOConfiguration config, jakarta.enterprise.inject.Instance<FileIOFactory> fileIOFactories) org.apache.polaris.service.catalog.api.IcebergRestOAuth2ApiServiceicebergRestOAuth2ApiService(AuthenticationRealmConfiguration config, jakarta.enterprise.inject.Instance<org.apache.polaris.service.catalog.api.IcebergRestOAuth2ApiService> services) voidmaybeBootstrap(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.org.apache.polaris.core.persistence.MetaStoreManagerFactorymetaStoreManagerFactory(PersistenceConfiguration config, jakarta.enterprise.inject.Instance<org.apache.polaris.core.persistence.MetaStoreManagerFactory> metaStoreManagerFactories) metricsReporter(MetricsReportingConfiguration config, jakarta.enterprise.inject.Instance<IcebergMetricsReporter> reporters) oidcTenantResolver(OidcConfiguration config, jakarta.enterprise.inject.Instance<OidcTenantResolver> resolvers) org.apache.polaris.core.auth.PolarisAuthorizerpolarisAuthorizer(org.apache.polaris.core.auth.PolarisAuthorizerFactory factory, org.apache.polaris.core.config.RealmConfig realmConfig) org.apache.polaris.core.auth.PolarisAuthorizerFactorypolarisAuthorizerFactory(AuthorizationConfiguration authorizationConfig, jakarta.enterprise.inject.Instance<org.apache.polaris.core.auth.PolarisAuthorizerFactory> authorizerFactories) org.apache.polaris.core.context.CallContextpolarisCallContext(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.config.RealmConfigurationSource configurationSource, org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory) org.apache.polaris.core.credentials.PolarisCredentialManagerpolarisCredentialManager(PolarisCredentialManagerConfiguration config, jakarta.enterprise.inject.Instance<org.apache.polaris.core.credentials.PolarisCredentialManager> credentialManagers) org.apache.polaris.core.PolarisDiagnosticsorg.apache.polaris.core.persistence.PolarisMetaStoreManagerpolarisMetaStoreManager(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory) rateLimiter(RateLimiterFilterConfiguration config, jakarta.enterprise.inject.Instance<RateLimiter> rateLimiters) realmAuthConfig(AuthenticationConfiguration config, org.apache.polaris.core.context.RealmContext realmContext) org.apache.polaris.core.config.RealmConfigrealmConfig(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.config.RealmConfigurationSource configurationSource) realmContextResolver(RealmContextConfiguration config, jakarta.enterprise.inject.Instance<RealmContextResolver> realmContextResolvers) org.apache.polaris.core.context.RequestIdSupplierProduces a RequestIdSupplier that retrieves the request ID from the current request context.org.apache.polaris.core.persistence.resolver.ResolutionManifestFactoryresolutionManifestFactory(org.apache.polaris.core.PolarisDiagnostics diagnostics, org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.persistence.resolver.ResolverFactory resolverFactory) org.apache.polaris.core.persistence.resolver.ResolverFactoryresolverFactory(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) org.apache.polaris.core.persistence.bootstrap.RootCredentialsSetrootCredentialsSet(Optional<String> credentials) software.amazon.awssdk.http.SdkHttpClientsdkHttpClient(S3AccessConfig config) org.apache.polaris.core.storage.cache.StorageCredentialCachestorageCredentialCache(org.apache.polaris.core.storage.cache.StorageCredentialCacheConfig storageCredentialCacheConfig) stsClientsPool(software.amazon.awssdk.http.SdkHttpClient httpClient, StorageConfiguration config, io.micrometer.core.instrument.MeterRegistry meterRegistry) org.eclipse.microprofile.context.ManagedExecutortaskExecutor(TaskHandlerConfiguration config) tokenBroker(AuthenticationRealmConfiguration config, jakarta.enterprise.inject.Instance<TokenBrokerFactory> tokenBrokerFactories, org.apache.polaris.core.persistence.PolarisMetaStoreManager polarisMetaStoreManager, org.apache.polaris.core.context.CallContext callContext) tokenBucketFactory(TokenBucketConfiguration config, jakarta.enterprise.inject.Instance<TokenBucketFactory> tokenBucketFactories) org.apache.polaris.core.secrets.UserSecretsManageruserSecretsManager(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.secrets.UserSecretsManagerFactory userSecretsManagerFactory) org.apache.polaris.core.secrets.UserSecretsManagerFactoryuserSecretsManagerFactory(SecretsManagerConfiguration config, jakarta.enterprise.inject.Instance<org.apache.polaris.core.secrets.UserSecretsManagerFactory> userSecretsManagerFactories)
-
Constructor Details
-
ServiceProducers
public ServiceProducers()
-
-
Method Details
-
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
-
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
RequestIdFilteron each incoming request. This producer provides access to that ID via theRequestIdSupplierinterface 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)
-