Package com.google.cloud.spring.autoconfigure.pubsub.health

Class PubSubSubscriptionHealthIndicatorAutoConfiguration

java.lang.Object

org.springframework.boot.actuate.autoconfigure.health.AbstractCompositeHealthContributorConfiguration<org.springframework.boot.actuate.health.HealthContributor,I,B>

org.springframework.boot.actuate.autoconfigure.health.CompositeHealthContributorConfiguration<PubSubSubscriptionHealthIndicator,HealthTrackerRegistry>

com.google.cloud.spring.autoconfigure.pubsub.health.PubSubSubscriptionHealthIndicatorAutoConfiguration

@AutoConfiguration
@ConditionalOnClass({org.springframework.boot.actuate.health.HealthIndicator.class,com.google.cloud.monitoring.v3.MetricServiceClient.class})
@ConditionalOnEnabledHealthIndicator("pubsub-subscriber")
@ConditionalOnProperty({"spring.cloud.gcp.pubsub.health.lagThreshold","spring.cloud.gcp.pubsub.health.backlogThreshold"})
@AutoConfigureBefore(GcpPubSubAutoConfiguration.class)
@EnableConfigurationProperties(GcpPubSubProperties.class)
public class PubSubSubscriptionHealthIndicatorAutoConfiguration
extends org.springframework.boot.actuate.autoconfigure.health.CompositeHealthContributorConfiguration<PubSubSubscriptionHealthIndicator,HealthTrackerRegistry>

Since:

2.0.6

Constructor Summary

Constructors

Constructor	Description
PubSubSubscriptionHealthIndicatorAutoConfiguration(GcpPubSubProperties gcpPubSubProperties, GcpProjectIdProvider projectIdProvider)

Method Summary

Modifier and Type	Method	Description
com.google.api.gax.core.ExecutorProvider	healthCheckExecutorProvider(org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)
HealthTrackerRegistry	healthTrackerRegistry(com.google.cloud.monitoring.v3.MetricServiceClient metricServiceClient, com.google.api.gax.core.ExecutorProvider executorProvider)
com.google.cloud.monitoring.v3.MetricServiceClient	metricServiceClient()
org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler	pubSubHealthThreadPool()
PubSubSubscriptionHealthIndicator	pubSubSubscriptionHealthIndicator(HealthTrackerRegistry healthTrackerRegistry)

Methods inherited from class org.springframework.boot.actuate.autoconfigure.health.CompositeHealthContributorConfiguration

createComposite

Methods inherited from class org.springframework.boot.actuate.autoconfigure.health.AbstractCompositeHealthContributorConfiguration

createContributor, createIndicator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PubSubSubscriptionHealthIndicatorAutoConfiguration

public PubSubSubscriptionHealthIndicatorAutoConfiguration(GcpPubSubProperties gcpPubSubProperties,
 GcpProjectIdProvider projectIdProvider)

Method Details

metricServiceClient

@Bean
@ConditionalOnMissingBean
public com.google.cloud.monitoring.v3.MetricServiceClient metricServiceClient()
                                                                       throws IOException

Throws:

IOException

pubSubHealthThreadPool

@Bean
@ConditionalOnMissingBean(name="pubSubHealthThreadPool")
public org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler pubSubHealthThreadPool()

healthCheckExecutorProvider

@Bean
@ConditionalOnMissingBean(name="healthCheckExecutorProvider")
public com.google.api.gax.core.ExecutorProvider healthCheckExecutorProvider(@Qualifier("pubSubHealthThreadPool")
 org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)

healthTrackerRegistry

@Bean
@ConditionalOnMissingBean(name="healthTrackerRegistry")
public HealthTrackerRegistry healthTrackerRegistry(com.google.cloud.monitoring.v3.MetricServiceClient metricServiceClient,
 @Qualifier("healthCheckExecutorProvider")
 com.google.api.gax.core.ExecutorProvider executorProvider)

pubSubSubscriptionHealthIndicator

@Bean
@ConditionalOnMissingBean(name="pubSubSubscriptionHealthIndicator")
public PubSubSubscriptionHealthIndicator pubSubSubscriptionHealthIndicator(HealthTrackerRegistry healthTrackerRegistry)