components/global/core/io.cellery.observability.api/src/main/java/io/cellery/observability/api/internal/ApiServiceComponent.java
@Activate
    protected void start(BundleContext bundleContext) throws Exception {
        try {
            Utils.disableSSLVerification();
            ServiceHolder.setOidcOauthManager(new OIDCOauthManager());
            ServiceHolder.setSiddhiManager(new SiddhiManager());

            // Starting the Siddhi Manager
            ServiceHolder.setSiddhiStoreQueryManager(new SiddhiStoreQueryManager());

            // Deploying the micro-services
            int offset = ServiceHolder.getCarbonRuntime().getConfiguration().getPortsConfig().getOffset();
            ServiceHolder.setMicroservicesRunner(new MicroservicesRunner(DEFAULT_OBSERVABILITY_API_PORT + offset)
                    .addGlobalRequestInterceptor(new CORSInterceptor(), new AuthInterceptor())
                    .addExceptionMapper(
                            new APIInvocationException.Mapper(), new InvalidParamException.Mapper(),
                            new UnexpectedException.Mapper()
                    )
                    .deploy(
                            new DependencyModelAPI(), new AggregatedRequestsAPI(), new DistributedTracingAPI(),
                            new KubernetesAPI(), new UserAuthenticationAPI(), new InstanceAPI()
                    )
            );
            ServiceHolder.getMicroservicesRunner().start();
        } catch (Throwable throwable) {
            log.error("Error occured while activating the Observability API bundle", throwable);
            throw throwable;
        }
    }
/**
     * This is the activation method of ObservabilityDS. This will be called when its references are
     * satisfied.
     *
     * @param bundleContext the bundle context instance of this bundle.
     * @throws Exception this will be thrown if an issue occurs while executing the activate method
     */
This is the activation method of ObservabilityDS. This will be called when its references are
satisfied.

@param bundleContext the bundle context instance of this bundle.
@throws Exception this will be thrown if an issue occurs while executing the activate method
This is the activation method of ObservabilityDS . This will be called when its references are satisfied . @param bundleContext the bundle context instance of this bundle . @throws Exception this will be thrown if an issue occurs while executing the activate method
@Activate
    protected void start(BundleContext bundleContext) throws Exception {
        try {
            Utils.disableSSLVerification();
            ServiceHolder.setOidcOauthManager(new OIDCOauthManager());
            ServiceHolder.setSiddhiManager(new SiddhiManager());
            ServiceHolder.setSiddhiStoreQueryManager(new SiddhiStoreQueryManager());
            int offset = ServiceHolder.getCarbonRuntime().getConfiguration().getPortsConfig().getOffset();
            ServiceHolder.setMicroservicesRunner(new MicroservicesRunner(DEFAULT_OBSERVABILITY_API_PORT + offset)
                    .addGlobalRequestInterceptor(new CORSInterceptor(), new AuthInterceptor())
                    .addExceptionMapper(
                            new APIInvocationException.Mapper(), new InvalidParamException.Mapper(),
                            new UnexpectedException.Mapper()
                    )
                    .deploy(
                            new DependencyModelAPI(), new AggregatedRequestsAPI(), new DistributedTracingAPI(),
                            new KubernetesAPI(), new UserAuthenticationAPI(), new InstanceAPI()
                    )
            );
            ServiceHolder.getMicroservicesRunner().start();
        } catch (Throwable throwable) {
            log.error("Error occured while activating the Observability API bundle", throwable);
            throw throwable;
        }
    }
@ Activate protected void start ( BundleContext bundleContext ) throws Exception { try { Utils . disableSSLVerification ( ) ; ServiceHolder . setOidcOauthManager ( new OIDCOauthManager ( ) ) ; ServiceHolder . setSiddhiManager ( new SiddhiManager ( ) ) ; ServiceHolder . setSiddhiStoreQueryManager ( new SiddhiStoreQueryManager ( ) ) ; int offset = ServiceHolder . getCarbonRuntime ( ) . getConfiguration ( ) . getPortsConfig ( ) . getOffset ( ) ; ServiceHolder . setMicroservicesRunner ( new MicroservicesRunner ( DEFAULT_OBSERVABILITY_API_PORT + offset ) . addGlobalRequestInterceptor ( new CORSInterceptor ( ) , new AuthInterceptor ( ) ) . addExceptionMapper ( new APIInvocationException . Mapper ( ) , new InvalidParamException . Mapper ( ) , new UnexpectedException . Mapper ( ) ) . deploy ( new DependencyModelAPI ( ) , new AggregatedRequestsAPI ( ) , new DistributedTracingAPI ( ) , new KubernetesAPI ( ) , new UserAuthenticationAPI ( ) , new InstanceAPI ( ) ) ) ; ServiceHolder . getMicroservicesRunner ( ) . start ( ) ; } catch ( Throwable throwable ) { log . error ( "Error occured while activating the Observability API bundle" , throwable ) ; throw throwable ; } }
This is the activation method of ObservabilityDS.
This is the activation method of ObservabilityDS .
// Starting the Siddhi Manager // Deploying the micro-services