public GcpManagedChannel()

in grpc-gcp/src/main/java/com/google/cloud/grpc/GcpManagedChannel.java [185:215]

31 lines of code
4 McCabe index (conditional complexity)


  public GcpManagedChannel(
      ManagedChannelBuilder<?> delegateChannelBuilder,
      ApiConfig apiConfig,
      GcpManagedChannelOptions options) {
    loadApiConfig(apiConfig);
    this.delegateChannelBuilder = delegateChannelBuilder;
    this.options = options;
    logger.finer(
        log(
            "Created with api config: %s, and options: %s",
            apiConfig == null ? "null" : TextFormat.shortDebugString(apiConfig), options));
    initOptions();
    GcpResiliencyOptions resiliencyOptions = options.getResiliencyOptions();
    if (resiliencyOptions != null) {
      fallbackEnabled = resiliencyOptions.isNotReadyFallbackEnabled();
      unresponsiveDetectionEnabled = resiliencyOptions.isUnresponsiveDetectionEnabled();
      unresponsiveMs = resiliencyOptions.getUnresponsiveDetectionMs();
      unresponsiveDropCount = resiliencyOptions.getUnresponsiveDetectionDroppedCount();
    } else {
      fallbackEnabled = false;
      unresponsiveDetectionEnabled = false;
      unresponsiveMs = 0;
      unresponsiveDropCount = 0;
    }
    initMinChannels();
    GcpChannelPoolOptions channelPoolOptions = options.getChannelPoolOptions();
    if (channelPoolOptions != null) {
      affinityKeyLifetime = channelPoolOptions.getAffinityKeyLifetime();
      initCleanupTask(channelPoolOptions.getCleanupInterval());
    }
  }