- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 156 for correctly (0.17 sec)
-
cni/pkg/plugin/cnieventclient.go
} var ncconfigs []nodeagent.IPConfig for _, ipc := range prevResIps { ncconfigs = append(ncconfigs, nodeagent.IPConfig{Interface: ipc.Interface, Address: ipc.Address, Gateway: ipc.Gateway}) } // Currently we only use the netns from the original CNI event addEvent := nodeagent.CNIPluginAddEvent{Netns: event.Netns, PodName: podName, PodNamespace: podNamespace, IPs: ncconfigs} eventData, err := json.Marshal(addEvent) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config.go
) const ( // AES256 is used with SSE-S3 AES256 Algorithm = "AES256" // AWSKms is used with SSE-KMS AWSKms Algorithm = "aws:kms" ) // Algorithm - represents valid SSE algorithms supported; currently only AES256 is supported type Algorithm string // UnmarshalXML - Unmarshals XML tag to valid SSE algorithm func (alg *Algorithm) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { var s string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 4.9K bytes - Viewed (0) -
internal/config/etcd/etcd.go
if err != nil { return cfg, err } cfg.Enabled = true cfg.DialTimeout = defaultDialTimeout cfg.DialKeepAliveTime = defaultDialKeepAlive // Disable etcd client SDK logging, etcd client // incorrectly starts logging in unexpected data // format. cfg.LogConfig = &zap.Config{ Level: zap.NewAtomicLevelAt(zap.FatalLevel), Encoding: "console", } cfg.Endpoints = etcdEndpoints
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K bytes - Viewed (0) -
misc/ios/detect.go
// Copyright 2015 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build ignore // detect attempts to autodetect the correct // values of the environment variables // used by go_ios_exec. // detect shells out to ideviceinfo, a third party program that can // be obtained by following the instructions at // https://github.com/libimobiledevice/libimobiledevice.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 19 23:33:30 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2)) if len(offlineEndpoints) > 0 { logger.Info(fmt.Sprintf("Following servers are currently offline or unreachable %s", offlineEndpoints)) } if len(incorrectConfigs) > 0 { logger.Info(fmt.Sprintf("Following servers have mismatching configuration %s", incorrectConfigs)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/object-handlers.go
// while reading the object from another source. // Notice: The S3 client can send secret keys in headers for encryption related jobs, // the handler should ensure to remove these keys before sending them to the object layer. // Currently these keys are: // - X-Amz-Server-Side-Encryption-Customer-Key // - X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key func (api objectAPIHandlers) CopyObjectHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
// non-punctuation end of string, i.e., the container ID `(?P<containerid>[[:^punct:]]+)$`), // This regex applies for container runtimes, that won't put the PodUID into // the cgroup name. // Currently only cri-o in combination with kubeedge is known for this abnormally. regexp.MustCompile(`` + // intentionally empty poduid group `(?P<poduid>)` + // mustnotmatch group: cgroup path must not include a poduid
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
callbacks/create.go
pkField = db.Statement.Schema.PrioritizedPrimaryField pkFieldName = db.Statement.Schema.PrioritizedPrimaryField.DBName } // append @id column with value for auto-increment primary key // the @id value is correct, when: 1. without setting auto-increment primary key, 2. database AutoIncrementIncrement = 1 switch values := db.Statement.Dest.(type) { case map[string]interface{}: values[pkFieldName] = insertID
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 08 03:29:55 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
return fmt.Errorf("xlMetaInlineData: %w", err) } } return nil } // repair will copy all seemingly valid data entries from a corrupted set. // This does not ensure that data is correct, but will allow all operations to complete. func (x *xlMetaInlineData) repair() { data := *x if len(data) == 0 { return } if !data.versionOK() { *x = nil return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/metrics.go
float64(v), string(k), ) } for k, v := range bgSeq.getHealFailedItemsMap() { // healFailedItemsMap stores the endpoint and volume state separated by comma, // split the fields and pass to channel at correct index s := strings.Split(k, ",") ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(healMetricsNamespace, "objects", "heal_failed"),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0)