private fun recover(
    e: IOException,
    call: RealCall,
    userRequest: Request,
  ): Boolean {
    val requestSendStarted = e !is ConnectionShutdownException

    // The application layer has forbidden retries.
    if (!client.retryOnConnectionFailure) return false

    // We can't send the request body again.
    if (requestSendStarted && requestIsOneShot(e, userRequest)) return false

    // This exception is fatal.

        
        // Attempt recovery
        if (state.shouldRetry()) {
            scheduleRecovery(failedChannel, state);
        } else {
            // Remove channel after max retries
            removeChannel(failedChannel);
        }
    }
    
    private void redistributePendingOperations(ChannelInfo failedChannel) {
        // Get pending operations from failed channel

     *
     * The call timeout spans the entire call: resolving DNS, connecting, writing the request body,
     * server processing, and reading the response body. If the call requires redirects or retries
     * all must complete within one timeout period.
     *
     * The default value is 0 which imposes no timeout.
     */
    fun callTimeout(
      timeout: Long,
      unit: TimeUnit,

			return err
		}
	}
	return nil
}

func (ies *IAMEtcdStore) loadMappedPolicyWithRetry(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy], retries int) error {
	return ies.loadMappedPolicy(ctx, name, userType, isGroup, m)
}

        return searchEngineClient.deleteByQuery(index, queryBuilder);
    }

    /**
     * Retrieves a document from the search index by its ID.
     *
     * @param searchEngineClient the search engine client to use for retrieval
     * @param id the document ID to retrieve
     * @param fields the fields to include in the response (null for all fields)

//     endpoint: "https://notify.endpoint" # notification endpoint to receive job status events
//     token: "Bearer xxxxx" # optional authentication token for the notification endpoint

//   retry:
//     attempts: 10 # number of retries for the job before giving up
//     delay: "500ms" # least amount of delay between each retry

//go:generate msgp -file $GOFILE -unexported

// BatchKeyRotationType defines key rotation type

      fun run() {
        val request = Request.Builder()
            .url("http://publicobject.com/secrets/hellosecret.txt")
            .build()
      }
    ```

    To avoid making many retries when authentication isn't working, you can return null to give up. For example, you may want to skip the retry when these exact credentials have already been attempted:

    ```kotlin

//     token: Bearer xxxxx # optional authentication token for the notification endpoint
//
//   retry:
//     attempts: 10 # number of retries for the job before giving up
//     delay: 500ms # least amount of delay between each retry

//go:generate msgp -file $GOFILE

// BatchJobExpirePurge type accepts non-negative versions to be retained

     */
    int getNetbiosRetryTimeout();

    /**
     *
     * Property {@code jcifs.netbios.retryCount} (int, default 2)
     *
     * @return maximum number of retries for netbios requests
     */
    int getNetbiosRetryCount();

    /**
     *
     *
     * Property {@code jcifs.netbios.cachePolicy} in minutes (int, default 600)
     *

    /** Maximum number of entries to return in list operations */
    protected int smbListCount = 200;
    /** Time in milliseconds before cached file attributes expire */
    protected long smbAttributeExpiration = 5000L;
    /** Whether to ignore exceptions during file copy operations */
    protected boolean ignoreCopyToException = false;
    /** Maximum number of request retries on failure */