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<PubSubHealthIndicator,PubSubTemplate>

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

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

Since:

2.0.6

Constructor Summary

Constructors

Constructor and Description
PubSubSubscriptionHealthIndicatorAutoConfiguration(GcpPubSubProperties gcpPubSubProperties, GcpProjectIdProvider projectIdProvider)

Method Summary

Modifier and Type	Method and Description
com.google.api.gax.core.ExecutorProvider	healthCheckExecutorProvider(org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)
HealthTrackerRegistry	healthTrackerRegistry(MetricServiceClient metricServiceClient, com.google.api.gax.core.ExecutorProvider executorProvider)
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 Detail

PubSubSubscriptionHealthIndicatorAutoConfiguration

public PubSubSubscriptionHealthIndicatorAutoConfiguration(GcpPubSubProperties gcpPubSubProperties,
                                                          GcpProjectIdProvider projectIdProvider)

Method Detail

metricServiceClient

@Bean
 @ConditionalOnMissingBean
public 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(value="pubSubHealthThreadPool")
                                                                                                                                                 org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)

healthTrackerRegistry

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

pubSubSubscriptionHealthIndicator

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