- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 104 for Ebeling (0.18 sec)
-
cmd/metrics-v3-cluster-notification.go
notificationEventsSkippedTotalMD = NewCounterMD(notificationEventsSkippedTotal, "Events that were skipped to be sent to the targets due to the in-memory queue being full") ) // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics. func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { if globalEventNotifier == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/s3select/message.go
// Progress message payload is an XML document containing information about the progress of a request. // - BytesScanned => Number of bytes that have been processed before being uncompressed (if the file is compressed). // - BytesProcessed => Number of bytes that have been processed after being uncompressed (if the file is compressed). // - BytesReturned => Current number of bytes of records payload data returned by S3. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/erasure-common.go
if err != nil || di.Healing { // - Do not consume disks which are not reachable // unformatted or simply not accessible for some reason. // // - Do not consume disks which are being healed // // - Future: skip busy disks return } mu.Lock() newDisks = append(newDisks, disks[i]) mu.Unlock() }() } wg.Wait() return newDisks }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/data-scanner_test.go
close(workers[0]) wg.Wait() for _, obj := range expired { switch obj.ObjectV.VersionID { case uuids[2].String(), uuids[3].String(), uuids[4].String(): default: t.Errorf("Unexpected versionID being expired: %#v\n", obj) } } } func TestEvalActionFromLifecycle(t *testing.T) { // Tests cover only ExpiredObjectDeleteAllVersions and DelMarkerExpiration actions obj := ObjectInfo{ Name: "foo",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/signature-v2_test.go
}{ // Test case - 1. // Case with empty V2AuthString. { authString: "", expectedError: ErrAuthHeaderEmpty, }, // Test case - 2. // Test case with `signV2Algorithm` ("AWS") not being the prefix. { authString: "NoV2Prefix", expectedError: ErrSignatureVersionNotSupported, }, // Test case - 3. // Test case with missing parts in the Auth string.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 8K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
opts.Versioned = versioned opts.VersionSuspended = suspended // First, we compute the ETag of the multipart object. // The ETag of a multi-part object is always: // ETag := MD5(ETag_p1, ETag_p2, ...)+"-N" (N being the number of parts) // // This is independent of encryption. An encrypted multipart // object also has an ETag that is the MD5 of its part ETags. // The fact the in case of encryption the ETag of a part is
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
}, } createCmd.PersistentFlags().StringVar(&name, "name", "", "The name of the workload group") createCmd.PersistentFlags().StringVarP(&namespace, "namespace", "n", "", "The namespace that the workload instances will belong to") createCmd.PersistentFlags().StringSliceVarP(&resourceLabels, "labels", "l", nil, "The labels to apply to the workload instances; e.g. -l env=prod,vers=2")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/signature-v4-utils.go
// // Expect = "Expect" ":" 1#expectation // expectation = "100-continue" | expectation-extension // // So it safe to assume that '100-continue' is what would // be sent, for the time being keep this work around. // Adding a *TODO* to remove this later when Golang server // doesn't filter out the 'Expect' header. extractedSignedHeaders.Set(header, "100-continue") case "host":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
src/cmd/asm/internal/lex/input.go
case "line": in.line() case "undef": in.undef() default: in.Error("unexpected token after '#':", in.Stack.Text()) } return true } // macroName returns the name for the macro being referenced. func (in *Input) macroName() string { // We use the Stack's input method; no macro processing at this stage. tok := in.Stack.Next() if tok != scanner.Ident {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 12.6K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
func setupZtunnelLogs(kubeClient kube.CLIClient, param, podName, podNamespace string, port int) (string, error) { path := "logging" if param != "" { path = path + "?" + param } // "Envoy" applies despite this being ztunnel result, err := kubeClient.EnvoyDoWithPort(context.TODO(), podName, podNamespace, "POST", path, port) if err != nil { return "", fmt.Errorf("failed to execute command on Ztunnel: %v", err) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0)