- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 64 for probes (0.14 sec)
-
cmd/site-replication.go
// finally convert it back to the server type (again via xml). // This is needed as there is no add-rule function in the server // yet. // Though we do not check if the rule already exists, this is // not a problem as we are always using the same replication // rule ID - if the rule already exists, it is just replaced. replicationConfigS, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/warm-backend.go
type remoteVersionID string // newWarmBackend instantiates the tier type specific WarmBackend, runs // checkWarmBackend on it. func newWarmBackend(ctx context.Context, tier madmin.TierConfig, probe bool) (d WarmBackend, err error) { switch tier.Type { case madmin.S3: d, err = newWarmBackendS3(*tier.S3, tier.Name) case madmin.Azure: d, err = newWarmBackendAzure(*tier.Azure, tier.Name) case madmin.GCS:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/iptables/iptables_test.go
tt.config(cfg) ext := &dep.DependenciesStub{} iptConfigurator, _ := NewIptablesConfigurator(cfg, ext, EmptyNlDeps()) var probeIP *netip.Addr if ipv6 { probeIP = &probeSNATipv6 } else { probeIP = &probeSNATipv4 } err := iptConfigurator.CreateInpodRules(probeIP) if err != nil { t.Fatal(err) } compareToGolden(t, ipv6, tt.name, ext.ExecutedAll) }) } } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
}, { Name: "foo-2-port", ContainerPort: 8020, }, }, LivenessProbe: &corev1.Probe{ ProbeHandler: corev1.ProbeHandler{ HTTPGet: &corev1.HTTPGetAction{ Port: intstr.FromString("foo-2-port"), }, }, }, StartupProbe: &corev1.Probe{ ProbeHandler: corev1.ProbeHandler{ HTTPGet: &corev1.HTTPGetAction{ Port: intstr.FromInt(7777), }, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
internal/lock/lock_windows.go
return nil } err := lockFileEx(fd, flags, 1, 0, &syscall.Overlapped{}) if err == nil || err == errLockViolation { return nil } if err.Error() == "The process cannot access the file because another process has locked a portion of the file." { return ErrAlreadyLocked } return err } func lockFileEx(h syscall.Handle, flags, locklow, lockhigh uint32, ol *syscall.Overlapped) (err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/grid/stream.go
// Requests sent to the server. // If the handler is defined with 0 incoming capacity this will be nil. // Channel *must* be closed to signal the end of the stream. // If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/signature-v4-parser.go
// Verify if region is valid. sRegion := cred.scope.region // Region is set to be empty, we use whatever was sent by the // request and proceed further. This is a work-around to address // an important problem for ListBuckets() getting signed with // different regions. if region == "" { region = sRegion } // Should validate region, only if region is set. if !isValidRegion(sRegion, region) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/rest/client.go
switch atomic.LoadInt32(&c.connected) { case closed: // client closed, this is usually a manual process // so return a local error as client is closed return nil, &NetworkError{Err: ErrClientClosed} case offline: // client offline, return last error captured. return nil, &NetworkError{Err: c.LastError()} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/encryption-v1.go
// is more efficient than decrypting ETags sequentually. func DecryptETags(ctx context.Context, k kms.KMS, objects []ObjectInfo) error { const BatchSize = 250 // We process the objects in batches - 250 is a reasonable default. var ( metadata = make([]map[string]string, 0, BatchSize) buckets = make([]string, 0, BatchSize) names = make([]string, 0, BatchSize) )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
openBrowser(fmt.Sprintf(urlFormat, fw.Address()), writer, browser) // Wait for stop fw.WaitForStop() return nil } return fmt.Errorf("failure running port forward process: %v", err) } func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) { go func() { signals := make(chan os.Signal, 1) signal.Notify(signals, os.Interrupt) defer signal.Stop(signals) <-signals
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0)