standalone/src/test/java/io/pravega/local/PravegaEmulatorResource.java
/*
     * Wait until Pravega standalone is up and running.
     */
Wait until Pravega standalone is up and running.
Wait until Pravega standalone is up and running .
private void waitUntilHealthy() {
        ClientConfig clientConfig = getClientConfig();
        ControllerImplConfig controllerConfig = ControllerImplConfig.builder()
                .clientConfig(clientConfig)
                .retryAttempts(20)
                .initialBackoffMillis(1000)
                .backoffMultiple(2)
                .maxBackoffMillis(10000)
                .build();
        @Cleanup
        StreamManager streamManager = new StreamManagerImpl(clientConfig, controllerConfig);
        assertNotNull(streamManager);
        boolean isScopeCreated = streamManager.createScope("healthCheck-scope");
        log.debug("Health check scope creation is successful {}", isScopeCreated);
    }
private void waitUntilHealthy ( ) { ClientConfig clientConfig = getClientConfig ( ) ; ControllerImplConfig controllerConfig = ControllerImplConfig . builder ( ) . clientConfig ( clientConfig ) . retryAttempts ( 20 ) . initialBackoffMillis ( 1000 ) . backoffMultiple ( 2 ) . maxBackoffMillis ( 10000 ) . build ( ) ; @ Cleanup StreamManager streamManager = new StreamManagerImpl ( clientConfig , controllerConfig ) ; assertNotNull ( streamManager ) ; boolean isScopeCreated = streamManager . createScope ( "healthCheck-scope" ) ; log . debug ( "Health check scope creation is successful {}" , isScopeCreated ) ; }
Wait until Pravega standalone is up and running.
Wait until Pravega standalone is up and running .
// Try creating a scope. This will retry based on the provided retry configuration. // If all the retries fail a RetriesExhaustedException will be thrown failing the tests.