- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 105 for Petry (0.13 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil { panic("expected snapshot sent") } sendAck(ztunClient) ztunClient.Close() // this will retry for a bit, so shouldn't flake mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(0)) } func TestZtunnelRemovePod(t *testing.T) { ztunnelKeepAliveCheckInterval = time.Second / 10 mt := monitortest.New(t)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cmd/batch-job-common-types.go
} *b = BatchJobNotification(tmp) b.line, b.col = val.Line, val.Column return nil } // BatchJobRetry stores retry configuration used in the event of failures. type BatchJobRetry struct { line, col int Attempts int `yaml:"attempts" json:"attempts"` // number of retry attempts Delay time.Duration `yaml:"delay" json:"delay"` // delay between each retries }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 01 21:53:26 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/event/target/kafka.go
// These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 config.Producer.Retry.Max = 2 config.Producer.Retry.Backoff = (1 * time.Second) config.Producer.Return.Successes = true config.Producer.Return.Errors = true config.Producer.RequiredAcks = 1 config.Producer.Timeout = (5 * time.Second)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
bin/build_ztunnel.sh
DOWNLOAD_COMMAND="" function set_download_command () { # Try curl. if command -v curl > /dev/null; then if curl --version | grep Protocols | grep https > /dev/null; then DOWNLOAD_COMMAND="curl -fLSs --retry 5 --retry-delay 1 --retry-connrefused" return fi echo curl does not support https, will try wget for downloading files. else echo curl is not installed, will try wget for downloading files. fi
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 21:46:06 GMT 2024 - 5K bytes - Viewed (0) -
.teamcity/src/test/kotlin/ApplyDefaultConfigurationTest.kt
"GRADLE_RUNNER", "KILL_ALL_GRADLE_PROCESSES", "CLEAN_UP_GIT_UNTRACKED_FILES_AND_DIRECTORIES", "GRADLE_RETRY_RUNNER", "KILL_PROCESSES_STARTED_BY_GRADLE", "CHECK_CLEAN_M2_ANDROID_USER_HOME" ), steps.items.map(BuildStep::name) )
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 6.5K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/build.gradle.kts
implementation("org.jetbrains.kotlin:kotlin-gradle-plugin:1.9.23") implementation("org.gradle.kotlin:gradle-kotlin-dsl-conventions") implementation("org.gradle:test-retry-gradle-plugin:1.5.2")
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Mon Apr 22 05:34:03 GMT 2024 - 977 bytes - Viewed (1) -
bin/init.sh
DOWNLOAD_COMMAND="" function set_download_command () { # Try curl. if command -v curl > /dev/null; then if curl --version | grep Protocols | grep https > /dev/null; then DOWNLOAD_COMMAND="curl -fLSs --retry 5 --retry-delay 1 --retry-connrefused" return fi echo curl does not support https, will try wget for downloading files. else echo curl is not installed, will try wget for downloading files. fi
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 25 19:11:31 GMT 2024 - 6.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
* we must send a `CONNECT` request, and handle authorization challenges from the proxy. * * Optional [TLS handshake][connectTls]. * * Each step may fail. If a retry is possible, a new instance is created with the next plan, which * will be configured differently. */ class ConnectPlan( private val taskRunner: TaskRunner, private val connectionPool: RealConnectionPool,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
common/scripts/kind_provisioner.sh
function check_default_cluster_yaml() { if [[ -z "${DEFAULT_CLUSTER_YAML:-}" ]]; then echo 'DEFAULT_CLUSTER_YAML file must be specified. Exiting...' return 1 fi } function setup_kind_cluster_retry() { retry setup_kind_cluster "$@" } # setup_kind_cluster creates new KinD cluster with given name, image and configuration # 1. NAME: Name of the Kind cluster (optional) # 2. IMAGE: Node image used by KinD (optional)
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 08 19:12:55 GMT 2024 - 17.3K bytes - Viewed (1) -
cni/pkg/nodeagent/cni-watcher.go
for ambientPod, err = s.handlers.GetPodIfAmbient(addCmd.PodName, addCmd.PodNamespace); (ambientPod == nil) && (retries < maxStaleRetries); retries++ { if err != nil { return err } log.Warnf("got an event for pod %s in namespace %s not found in current pod cache, retry %d of %d",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0)