Skip to content

Instantly share code, notes, and snippets.

@kameshsampath
Last active June 28, 2017 08:50
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save kameshsampath/df0e1916433123dedc69154d9057f21c to your computer and use it in GitHub Desktop.
Save kameshsampath/df0e1916433123dedc69154d9057f21c to your computer and use it in GitHub Desktop.
ISTIO_MIXER_PORT_9094_TCP_PROTO=tcp
ISTIO_INGRESS_PORT_443_TCP=tcp://10.0.0.69:443
ISTIO_MIXER_PORT_9091_TCP_ADDR=10.0.0.204
ISTIO_PILOT_SERVICE_PORT_HTTP_DISCOVERY=8080
ISTIO_PILOT_PORT_8081_TCP_ADDR=10.0.0.94
ISTIO_INGRESS_PORT_80_TCP_PORT=80
ISTIO_MIXER_PORT_9094_TCP_PORT=9094
ISTIO_INGRESS_PORT_443_TCP_PORT=443
ISTIO_MIXER_SERVICE_PORT_PROMETHEUS=42422
ISTIO_PILOT_PORT_8081_TCP=tcp://10.0.0.94:8081
ISTIO_PILOT_SERVICE_HOST=10.0.0.94
ISTIO_INGRESS_PORT_80_TCP_PROTO=tcp
ISTIO_MIXER_PORT_9091_TCP_PROTO=tcp
ISTIO_MIXER_PORT_42422_TCP_PORT=42422
ISTIO_INGRESS_PORT_443_TCP_PROTO=tcp
ISTIO_PILOT_PORT=tcp://10.0.0.94:8080
ISTIO_EGRESS_SERVICE_HOST=10.0.0.159
ISTIO_MIXER_SERVICE_PORT_CONFIGAPI=9094
ISTIO_INGRESS_SERVICE_HOST=10.0.0.69
ISTIO_EGRESS_PORT_80_TCP_ADDR=10.0.0.159
ISTIO_MIXER_PORT_42422_TCP_PROTO=tcp
ISTIO_EGRESS_SERVICE_PORT=80
ISTIO_INGRESS_SERVICE_PORT_HTTP=80
ISTIO_MIXER_PORT_42422_TCP_ADDR=10.0.0.204
ISTIO_MIXER_SERVICE_PORT=9091
ISTIO_MIXER_PORT_9091_TCP_PORT=9091
ISTIO_PILOT_PORT_8081_TCP_PROTO=tcp
ISTIO_PILOT_PORT_8080_TCP=tcp://10.0.0.94:8080
ISTIO_INGRESS_PORT=tcp://10.0.0.69:80
ISTIO_MIXER_PORT_9094_TCP_ADDR=10.0.0.204
ISTIO_EGRESS_PORT_80_TCP=tcp://10.0.0.159:80
ISTIO_EGRESS_PORT=tcp://10.0.0.159:80
ISTIO_PILOT_PORT_8081_TCP_PORT=8081
ISTIO_MIXER_PORT_42422_TCP=tcp://10.0.0.204:42422
ISTIO_EGRESS_PORT_80_TCP_PROTO=tcp
ISTIO_PILOT_SERVICE_PORT_HTTP_APISERVER=8081
ISTIO_MIXER_PORT_9094_TCP=tcp://10.0.0.204:9094
ISTIO_MIXER_SERVICE_HOST=10.0.0.204
ISTIO_PILOT_PORT_8080_TCP_PORT=8080
ISTIO_PILOT_PORT_8080_TCP_PROTO=tcp
ISTIO_EGRESS_PORT_80_TCP_PORT=80
ISTIO_INGRESS_PORT_80_TCP=tcp://10.0.0.69:80
ISTIO_INGRESS_SERVICE_PORT_HTTPS=443
ISTIO_INGRESS_SERVICE_PORT=80
ISTIO_MIXER_PORT_9091_TCP=tcp://10.0.0.204:9091
ISTIO_PILOT_SERVICE_PORT=8080
ISTIO_MIXER_PORT=tcp://10.0.0.204:9091
ISTIO_MIXER_SERVICE_PORT_TCP=9091
ISTIO_PILOT_PORT_8080_TCP_ADDR=10.0.0.94
ISTIO_INGRESS_PORT_80_TCP_ADDR=10.0.0.69
ISTIO_INGRESS_PORT_443_TCP_ADDR=10.0.0.69
httpClientBuilder.addInterceptor(new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
//TODO get it form config
int maxRetries = 5;
Response response = null;
int retries = 0;
Request request = chain.request();
do {
try {
if (isNotNullOrEmpty(config.getUsername()) && isNotNullOrEmpty(config.getPassword())) {
Request authReq = chain.request().newBuilder().addHeader("Authorization", Credentials.basic(config.getUsername(), config.getPassword())).build();
response = chain.proceed(authReq);
} else if (isNotNullOrEmpty(config.getOauthToken())) {
Request authReq = chain.request().newBuilder().addHeader("Authorization", "Bearer " + config.getOauthToken()).build();
response = chain.proceed(authReq);
} else {
response = chain.proceed(request);
}
} catch (IOException e) {
//TODO need to check if its specific exceptions which are OK to be retried
LOGGER.warn("Request failed retry {} ", retries);
} finally {
try {
SECONDS.sleep(7);
} catch (InterruptedException e) {
//dont worry
}
retries++;
}
} while ((response == null || !response.isSuccessful()) && retries < maxRetries);
return response == null?chain.proceed(request):response;
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment