Package google.registry.beam.common

Interface RegistryPipelineComponent

@Singleton
@Component(modules={ConfigModule.class,CredentialModule.class,PersistenceModule.class,SecretManagerModule.class,UtilsModule.class})
public interface RegistryPipelineComponent

Component that provides everything needed on a Pipeline worker.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	RegistryPipelineComponent.Builder

Method Summary

Modifier and Type	Method	Description
dagger.Lazy<JpaTransactionManager>	getJpaTransactionManager()	Returns the regular JpaTransactionManager for general use.
String	getProjectId()	Returns the GCP project ID.
dagger.Lazy<JpaTransactionManager>	getReadOnlyReplicaJpaTransactionManager()	A JpaTransactionManager that uses the Postgres read-only replica if configured (uses the standard DB otherwise).

Method Details

getProjectId

@Config("projectId")
String getProjectId()

Returns the GCP project ID.

getJpaTransactionManager

@BeamJpaTm
dagger.Lazy<JpaTransactionManager> getJpaTransactionManager()

Returns the regular JpaTransactionManager for general use.

getReadOnlyReplicaJpaTransactionManager

@BeamReadOnlyReplicaJpaTm
dagger.Lazy<JpaTransactionManager> getReadOnlyReplicaJpaTransactionManager()

A JpaTransactionManager that uses the Postgres read-only replica if configured (uses the standard DB otherwise).