/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
H A D | errors.py | 8 retriable = False variable in KafkaError 28 retriable = True variable in NoBrokersAvailable 33 retriable = True variable in NodeNotReadyError 37 retriable = True variable in KafkaProtocolError 41 retriable = True variable in CorrelationIdError 45 retriable = True variable in Cancelled 49 retriable = True variable in TooManyInFlightRequests 53 retriable = True variable in StaleMetadata 58 retriable = True variable in MetadataEmptyBrokerList 89 retriable = False variable in AuthenticationFailedError [all …]
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/dbapi/driver/ |
H A D | dbapi_driver_exception_storage.cpp | 126 ERetriable retriable = m_Retriable; in Handle() local 134 exc.SetRetriable(retriable); in Handle() 140 void CDBExceptionStorage::SetRetriable(ERetriable retriable) in SetRetriable() argument 144 m_Retriable = retriable; in SetRetriable()
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/dbapi/driver/ |
H A D | dbapi_driver_exception_storage.cpp | 126 ERetriable retriable = m_Retriable; in Handle() local 134 exc.SetRetriable(retriable); in Handle() 140 void CDBExceptionStorage::SetRetriable(ERetriable retriable) in SetRetriable() argument 144 m_Retriable = retriable; in SetRetriable()
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_error.c | 65 error->retriable = rd_false; in rd_kafka_error_new_v() 89 error->retriable = src->retriable; in rd_kafka_error_copy() 177 return error && error->retriable ? 1 : 0; in rd_kafka_error_is_retriable() 191 error->retriable = rd_true; in rd_kafka_error_set_retriable()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_error.c | 65 error->retriable = rd_false; in rd_kafka_error_new_v() 89 error->retriable = src->retriable; in rd_kafka_error_copy() 177 return error && error->retriable ? 1 : 0; in rd_kafka_error_is_retriable() 191 error->retriable = rd_true; in rd_kafka_error_set_retriable()
|
/dports/net/rclone/rclone-1.57.0/fs/fserrors/ |
H A D | error.go | 342 func Cause(cause error) (retriable bool, err error) { 348 retriable = true 355 retriable = true 403 retriable, err := Cause(err) 404 if retriable {
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/cloud.google.com/go/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/cloud.google.com/go/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/www/gohugo/google-cloud-go-storage-v1.10.0/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/sysutils/gomplate/google-cloud-go-storage-v1.12.0/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/sysutils/helmfile/google-cloud-go-storage-v1.10.0/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/devel/gitlab-runner/google-cloud-go-storage-v1.12.0/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/cloud.google.com/go/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/www/grafana8/google-cloud-go-storage-v1.14.0/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/sysutils/terraform/google-cloud-go-storage-v1.10.0/storage/ |
H A D | go110.go | 36 retriable := []string{"connection refused", "connection reset"} 37 for _, s := range retriable {
|
/dports/databases/litestream/google-cloud-go-storage-v1.15.0/storage/ |
H A D | go110.go | 40 retriable := []string{"connection refused", "connection reset"} 41 for _, s := range retriable {
|
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/python/redo/ |
H A D | README.md | 7 …able. Redo includes a plain function `(redo.retry)`, a decorator `(redo.retriable)`, and a context… 18 * retriable 94 ### retriable(*retry_args, **retry_kwargs) 95 A decorator factory for `retry()`. Wrap your function in `@retriable(...)` to give it retry powers! 107 >>> @retriable(sleeptime=0, jitter=0) 130 A context manager that returns `retriable(func)` on `__enter__`
|
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/redo/ |
H A D | README.md | 7 …able. Redo includes a plain function `(redo.retry)`, a decorator `(redo.retriable)`, and a context… 18 * retriable 94 ### retriable(*retry_args, **retry_kwargs) 95 A decorator factory for `retry()`. Wrap your function in `@retriable(...)` to give it retry powers! 107 >>> @retriable(sleeptime=0, jitter=0) 130 A context manager that returns `retriable(func)` on `__enter__`
|
/dports/sysutils/restic/google-cloud-go-storage-v1.16.0/storage/ |
H A D | go110.go | 40 retriable := []string{"connection refused", "connection reset"} 41 for _, s := range retriable {
|
/dports/net/gscloud/gscloud-0.11.0/vendor/k8s.io/client-go/util/retry/ |
H A D | util.go | 48 func OnError(backoff wait.Backoff, retriable func(error) bool, fn func() error) error { 55 case retriable(err):
|
/dports/security/vault/vault-1.8.2/vendor/k8s.io/client-go/util/retry/ |
H A D | util.go | 48 func OnError(backoff wait.Backoff, retriable func(error) bool, fn func() error) error { 55 case retriable(err):
|
/dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/k8s.io/client-go/util/retry/ |
H A D | util.go | 48 func OnError(backoff wait.Backoff, retriable func(error) bool, fn func() error) error { 55 case retriable(err):
|