Java 类org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnEnabledEndpoint 实例源码

@Bean
@ConditionalOnBean(ContextRefresher.class)
@ConditionalOnEnabledEndpoint
@ConditionalOnMissingBean
public RefreshEndpoint refreshEndpoint(ContextRefresher contextRefresher) {
    return new RefreshEndpoint(contextRefresher);
}

@Bean
@ConditionalOnEnabledEndpoint
@ConditionalOnMissingBean
public RestartEndpoint restartEndpoint() {
    RestartEndpoint endpoint = new RestartEndpoint();
    if (this.exporter != null) {
        endpoint.setIntegrationMBeanExporter(this.exporter);
    }
    return endpoint;
}

@Bean
@ConditionalOnBean(RestartEndpoint.class)
@ConditionalOnMissingBean
@ConditionalOnEnabledEndpoint
public RestartEndpoint.PauseEndpoint pauseEndpoint(RestartEndpoint restartEndpoint) {
    return restartEndpoint.getPauseEndpoint();
}

@Bean
@ConditionalOnBean(RestartEndpoint.class)
@ConditionalOnMissingBean
@ConditionalOnEnabledEndpoint
public RestartEndpoint.ResumeEndpoint resumeEndpoint(
        RestartEndpoint restartEndpoint) {
    return restartEndpoint.getResumeEndpoint();
}

@Bean
@ConditionalOnBean(EnvironmentEndpoint.class)
@ConditionalOnEnabledEndpoint
public EnvironmentWebEndpointExtension environmentWebEndpointExtension(
        EnvironmentManager environment) {
    return new EnvironmentWebEndpointExtension(environment);
}

@Bean
@ConditionalOnEnabledEndpoint
public ServiceRegistryEndpoint serviceRegistryEndpoint(ServiceRegistry serviceRegistry) {
    ServiceRegistryEndpoint endpoint = new ServiceRegistryEndpoint(serviceRegistry);
    endpoint.setRegistration(registration);
    return endpoint;
}

@Bean
@ConditionalOnEnabledEndpoint
public HystrixWebfluxEndpoint hystrixWebfluxController() {
    Observable<String> serializedDashboardData = HystrixDashboardStream.getInstance().observe()
            .concatMap(dashboardData -> Observable.from(SerialHystrixDashboardData.toMultipleJsonStrings(dashboardData)));
    Publisher<String> publisher = RxReactiveStreams.toPublisher(serializedDashboardData);
    return new HystrixWebfluxEndpoint(publisher);
}

@Bean
@ConditionalOnEnabledEndpoint
public EnvironmentBusEndpoint environmentBusEndpoint(
        ApplicationContext context, BusProperties bus) {
    return new EnvironmentBusEndpoint(context, bus.getId());
}

@Bean
@ConditionalOnEnabledEndpoint
@ConditionalOnMissingBean
public RestartEndpoint restartEndpointWithoutIntegration() {
    return new RestartEndpoint();
}

@Bean
@ConditionalOnEnabledEndpoint
public FeaturesEndpoint featuresEndpoint() {
    return new FeaturesEndpoint(this.hasFeatures);
}

@Bean
@ConditionalOnEnabledEndpoint
public RoutesEndpoint routesEndpoint(RouteLocator routeLocator) {
    return new RoutesEndpoint(routeLocator);
}

@ConditionalOnEnabledEndpoint
@Bean
public FiltersEndpoint filtersEndpoint() {
    FilterRegistry filterRegistry = FilterRegistry.instance();
    return new FiltersEndpoint(filterRegistry);
}

@Bean
@ConditionalOnEnabledEndpoint
protected ArchaiusEndpoint archaiusEndpoint() {
    return new ArchaiusEndpoint();
}

@Bean
@ConditionalOnEnabledEndpoint
public HystrixStreamEndpoint hystrixStreamEndpoint(HystrixProperties properties) {
    return new HystrixStreamEndpoint(properties.getConfig());
}

@Bean
@ConditionalOnMissingBean
@ConditionalOnEnabledEndpoint
public ConsulEndpoint consulEndpoint(ConsulClient consulClient) {
    return new ConsulEndpoint(consulClient);
}