- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Processing (0.2 sec)
-
cmd/callhome.go
for { if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false } select { case <-ctx.Done(): // indicates that we do not need to run callhome anymore return false case <-callhomeTimer.C: if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false } performCallhome(ctx)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
istioctl/pkg/root/root.go
o.SetDefaultOutputLevel("all", log.WarnLevel) // These scopes are too noisy even at warning level o.SetDefaultOutputLevel("validation", log.ErrorLevel) o.SetDefaultOutputLevel("processing", log.ErrorLevel) o.SetDefaultOutputLevel("kube", log.ErrorLevel) return o
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Mar 26 20:38:10 GMT 2024 - 1.5K bytes - Viewed (0) -
cmd/veeam-sos-api.go
// Agents to directly backup to object storage. // // An object storage system can implement one, multiple, or all functions. // // - Optional (mandatory if <IAMSTS> is true): Set Endpoints for IAM and STS processing. // // - Optional: Set server preferences for Backup & Replication parallel sessions, batch size of deletes, and block sizes (before
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 18:43:58 GMT 2024 - 8.2K bytes - Viewed (2) -
cmd/data-scanner-metric.go
// actions records actions performed. actions [lifecycle.ActionCount]uint64 actionsLatency [lifecycle.ActionCount]lockedLastMinuteLatency // currentPaths contains (string,*currentPathTracker) for each disk processing. // Alignment not required. currentPaths sync.Map cycleInfoMu sync.Mutex cycleInfo *currentScannerCycle } var globalScannerMetrics scannerMetrics const (
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 25 05:15:31 GMT 2023 - 9.1K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
return } received := string(b) if received != "message one\n" { t.Errorf(`server: expected: "message one\n", got: %v`, received) return } // Wait for more than read timeout to simulate processing. time.Sleep(3 * time.Second) _, terr = deadlineconn.Read(b) if terr != nil { t.Errorf("failed to read from client. %v", terr) return } received = string(b) if received != "message two\n" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
cmd/sts-handlers.go
token := r.Form.Get(stsToken) if token == "" { token = r.Form.Get(stsWebIdentityToken) } accessToken := r.Form.Get(stsWebIdentityAccessToken) // RoleARN parameter processing: If a role ARN is given in the request, we // use that and validate the authentication request. If not, we assume this // is an STS request for a claim based IDP (if one is present) and set // roleArn = openid.DummyRoleARN.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 18:36:18 GMT 2024 - 34.7K bytes - Viewed (2) -
istioctl/pkg/writer/envoy/configdump/configdump.go
"sigs.k8s.io/yaml" "istio.io/istio/istioctl/pkg/util/configdump" sdscompare "istio.io/istio/istioctl/pkg/writer/compare/sds" "istio.io/istio/pkg/util/protomarshal" ) // ConfigWriter is a writer for processing responses from the Envoy Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer configDump *configdump.Wrapper }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 29 20:46:41 GMT 2024 - 7.4K bytes - Viewed (0) -
src/cmd/cgo/ast.go
case *ast.Expr: switch (*x).(type) { case *ast.SelectorExpr: f.saveRef(x, context) } case *ast.CallExpr: f.saveCall(x, context) } } // Save references to C.xxx for later processing. func (f *File) saveRef(n *ast.Expr, context astContext) { sel := (*n).(*ast.SelectorExpr) // For now, assume that the only instance of capital C is when // used as the imported package identifier.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jun 07 16:54:27 GMT 2023 - 14.3K bytes - Viewed (0) -
src/cmd/asm/internal/lex/input.go
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 { in.expectText("expected identifier after # directive") } // Name is alphanumeric by definition. return in.Stack.Text() } // #define processing. func (in *Input) define() { name := in.macroName() args, tokens := in.macroDefinition(name)
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) -
cmd/object-lambda-handlers.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Sep 15 04:58:17 GMT 2023 - 10.2K bytes - Viewed (1)