- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 343 for Ball (0.17 sec)
-
istioctl/pkg/waypoint/waypoint_test.go
}, expectedOutFile: "default-gateway", }, { name: "all namespaces gateways", args: strings.Split("list -A", " "), gateways: []*gateway.Gateway{ makeGateway(constants.DefaultNamespaceWaypoint, "default", true, true), makeGateway(constants.DefaultNamespaceWaypoint, "fake", true, true), }, expectedOutFile: "all-gateway", }, { name: "have both managed and unmanaged gateways",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 15:53:09 GMT 2024 - 4.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
} // addPodToHostNSIpset: // 1. get pod manifest // 2. Get all pod ips (might be several, v6/v4) // 3. update ipsets accordingly func addPodToHostNSIpset(pod *corev1.Pod, podIPs []netip.Addr, hostsideProbeSet *ipset.IPSet) error { // Add the pod UID as an ipset entry comment, so we can (more) easily find and delete // all relevant entries for a pod later. podUID := string(pod.ObjectMeta.UID)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/erasure-metadata.go
// remove to avoid it from appearing as part of // response headers. e.g, X-Minio-* or X-Amz-*. // Tags have also been extracted, we remove that as well. objInfo.UserDefined = cleanMetadata(fi.Metadata) // All the parts per object. objInfo.Parts = fi.Parts // Update storage class if fi.TransitionTier != "" { objInfo.StorageClass = fi.TransitionTier } else if sc, ok := fi.Metadata[xhttp.AmzStorageClass]; ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/leak-detect_test.go
return } // wait a test again will deadline. if UTCNow().Before(deadline) { time.Sleep(leakDetectPauseTimeMs * time.Millisecond) continue } // after the deadline time report all the difference in the latest snapshot compared with the initial one. for _, g := range leaked { t.Errorf("Leaked goroutine: %v", g) } return } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/consolelogger.go
sync.RWMutex pubsub *pubsub.PubSub[log.Info, madmin.LogMask] console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/metrics-realtime.go
} func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if !globalIsDistErasure { return } all := globalNotificationSys.GetMetrics(ctx, types, opts) for _, remote := range all { m.Merge(&remote) } return m
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/os-reliable.go
return err } // Reliably retries os.RemoveAll if for some reason os.RemoveAll returns // syscall.ENOTEMPTY (children has files). func reliableRemoveAll(dirPath string) (err error) { i := 0 for { // Removes all the directories and files. if err = RemoveAll(dirPath); err != nil { // Retry only for the first retryable error. if isSysErrNotEmpty(err) && i == 0 { i++ continue } } break }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
Short: "Retrieves the synchronization status of each Envoy in the mesh", Long: ` Retrieves last sent and last acknowledged xDS sync from Istiod to each Envoy in the mesh `, Example: ` # Retrieve sync status for all Envoys in a mesh istioctl proxy-status # Retrieve sync status for Envoys in a specific namespace istioctl proxy-status --namespace foo # Retrieve sync diff for a single Envoy and Istiod
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
tests/scopes_test.go
db := DB.Scopes(func(tx *gorm.DB) *gorm.DB { return tx.Table("custom_table") }).Session(&gorm.Session{}) db.AutoMigrate(&User{}) if db.Find(&User{}).Statement.Table != "custom_table" { t.Errorf("failed to call Scopes") } result := DB.Scopes(NameIn1And2, func(tx *gorm.DB) *gorm.DB { return tx.Session(&gorm.Session{}) }).Find(&users1) if result.RowsAffected != 2 {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
return } updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, configData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Call site replication hook. // // We encode the xml bytes as base64 to ensure there are no encoding // errors. cfgStr := base64.StdEncoding.EncodeToString(configData)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0)