| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 149 retryOptions := RetryOptions{
157 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
159 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
160 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
162 NewRetryPolicyFactory(retryOptions),
177 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
182 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/Azure/azure-storage-blob-go/azure-storage-blob-go-6df5d9af221d/azblob/ |
| H A D | zt_policy_retry_test.go | 149 retryOptions := RetryOptions{
157 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
159 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
160 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
162 NewRetryPolicyFactory(retryOptions),
177 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
182 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/net/rclone/rclone-1.57.0/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 149 retryOptions := RetryOptions{
157 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
159 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
160 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
162 NewRetryPolicyFactory(retryOptions),
177 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
182 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 150 retryOptions := azblob.RetryOptions{
158 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
160 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
161 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
163 azblob.NewRetryPolicyFactory(retryOptions),
178 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
183 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/www/gohugo/hugo-0.91.2/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 150 retryOptions := azblob.RetryOptions{
158 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
160 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
161 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
163 azblob.NewRetryPolicyFactory(retryOptions),
178 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
183 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 150 retryOptions := azblob.RetryOptions{
158 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
160 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
161 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
163 azblob.NewRetryPolicyFactory(retryOptions),
178 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
183 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/databases/litestream/litestream-0.3.6/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 149 retryOptions := RetryOptions{
157 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
159 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
160 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
162 NewRetryPolicyFactory(retryOptions),
177 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
182 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/www/tusd/tusd-1.8.0/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 149 retryOptions := RetryOptions{
157 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
159 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
160 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
162 NewRetryPolicyFactory(retryOptions),
177 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
182 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/Azure/azure-storage-blob-go/azblob/ |
| H A D | zt_policy_retry_test.go | 149 retryOptions := RetryOptions{
157 …minExpectedTimeToMaxRetries := (retryOptions.MaxRetryDelay * time.Duration(retryOptions.MaxTries-3…
159 ctx, cancel := context.WithTimeout(ctx, 64 /*2^MaxTries(6)*/ *retryOptions.TryTimeout)
160 retrytestPolicyFactory := newRetryTestPolicyFactory(c, scenario, retryOptions.MaxTries, cancel)
162 NewRetryPolicyFactory(retryOptions),
177 …c.Assert(retrytestPolicyFactory.try, chk.Equals, retryOptions.MaxTries) // Ensure the operatio…
182 …c.Assert(retrytestPolicyFactory.try <= retryOptions.MaxTries, chk.Equals, true) // Ensure we didn'…
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/grpc-ecosystem/go-grpc-middleware/go-grpc-middleware-1.0.0/retry/ |
| H A D | options.go | 111 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
114 retryOptions = append(retryOptions, co)
119 return grpcOptions, retryOptions
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 133 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
136 retryOptions = append(retryOptions, co)
141 return grpcOptions, retryOptions
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 133 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
136 retryOptions = append(retryOptions, co)
141 return grpcOptions, retryOptions
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 131 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
134 retryOptions = append(retryOptions, co)
139 return grpcOptions, retryOptions
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 133 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
136 retryOptions = append(retryOptions, co)
141 return grpcOptions, retryOptions
|
| /dports/sysutils/nomad/nomad-1.1.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 133 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
136 retryOptions = append(retryOptions, co)
141 return grpcOptions, retryOptions
|
| /dports/www/tusd/tusd-1.8.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 133 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
136 retryOptions = append(retryOptions, co)
141 return grpcOptions, retryOptions
|
| /dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 133 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
136 retryOptions = append(retryOptions, co)
141 return grpcOptions, retryOptions
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/grpc-ecosystem/go-grpc-middleware/retry/ |
| H A D | options.go | 131 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
134 retryOptions = append(retryOptions, co)
139 return grpcOptions, retryOptions
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/clientv3/ |
| H A D | retry_interceptor.go | 362 func reuseOrNewWithCallOptions(opt *options, retryOptions []retryOption) *options {
363 if len(retryOptions) == 0 {
368 for _, f := range retryOptions {
374 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
377 retryOptions = append(retryOptions, co)
382 return grpcOptions, retryOptions
|
| /dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.etcd.io/etcd/clientv3/ |
| H A D | retry_interceptor.go | 359 func reuseOrNewWithCallOptions(opt *options, retryOptions []retryOption) *options {
360 if len(retryOptions) == 0 {
365 for _, f := range retryOptions {
371 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
374 retryOptions = append(retryOptions, co)
379 return grpcOptions, retryOptions
|
| /dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/client/v3/ |
| H A D | retry_interceptor.go | 381 func reuseOrNewWithCallOptions(opt *options, retryOptions []retryOption) *options {
382 if len(retryOptions) == 0 {
387 for _, f := range retryOptions {
393 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
396 retryOptions = append(retryOptions, co)
401 return grpcOptions, retryOptions
|
| /dports/misc/concourse/vault-bdd38fca2cff/vendor/go.etcd.io/etcd/clientv3/ |
| H A D | retry_interceptor.go | 365 func reuseOrNewWithCallOptions(opt *options, retryOptions []retryOption) *options {
366 if len(retryOptions) == 0 {
371 for _, f := range retryOptions {
377 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
380 retryOptions = append(retryOptions, co)
385 return grpcOptions, retryOptions
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/go.etcd.io/etcd/clientv3/ |
| H A D | retry_interceptor.go | 365 func reuseOrNewWithCallOptions(opt *options, retryOptions []retryOption) *options {
366 if len(retryOptions) == 0 {
371 for _, f := range retryOptions {
377 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
380 retryOptions = append(retryOptions, co)
385 return grpcOptions, retryOptions
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/go.etcd.io/etcd/client/v3/ |
| H A D | retry_interceptor.go | 381 func reuseOrNewWithCallOptions(opt *options, retryOptions []retryOption) *options {
382 if len(retryOptions) == 0 {
387 for _, f := range retryOptions {
393 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
396 retryOptions = append(retryOptions, co)
401 return grpcOptions, retryOptions
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/go.etcd.io/etcd/client/v3/ |
| H A D | retry_interceptor.go | 381 func reuseOrNewWithCallOptions(opt *options, retryOptions []retryOption) *options {
382 if len(retryOptions) == 0 {
387 for _, f := range retryOptions {
393 func filterCallOptions(callOptions []grpc.CallOption) (grpcOptions []grpc.CallOption, retryOptions …
396 retryOptions = append(retryOptions, co)
401 return grpcOptions, retryOptions
|