- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 126 for Leach (0.14 sec)
-
operator/cmd/mesh/manifest-diff.go
compareDir bool // verbose generates verbose output. verbose bool // selectResources constrains the list of resources to compare to only the ones in this list, ignoring all others. // The format of each list item is :: and the items are comma separated. The * character represents wildcard selection. // e.g. // Deployment:istio-system:* - compare all deployments in istio-system namespace
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
return svc.Name } return "NA" // Shouldn't normally reach here } func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string { if svc.Waypoint == nil { return "None" } if svc, ok := services[svc.Waypoint.Destination]; ok { return svc.Name } return "NA" // Shouldn't normally reach here
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 4K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
var multiXdsOpts multixds.Options statusCmd := &cobra.Command{ Use: "proxy-status [<type>/]<name>[.<namespace>]", 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
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) -
cni/pkg/log/uds_test.go
_ = log.Sync() // Restore os stdout. os.Stdout = stdout assert.NoError(t, log.Configure(loggingOptions)) assert.NoError(t, w.Close()) out, err := io.ReadAll(r) assert.NoError(t, err) // For each level, there should be two lines, one from direct log, // the other one from UDS server wantLevels := []string{"debug", "info", "warn", "error", "debug", "info", "warn", "error"} gotLogs := strings.Split(
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
sort.Slice(setCounts, func(i, j int) bool { return setCounts[i] < setCounts[j] }) return setCounts } // getSetIndexes returns list of indexes which provides the set size // on each index, this function also determines the final set size // The final set size has the affinity towards choosing smaller // indexes (total sets)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/leak-detect_test.go
"runtime/debug" "sort" "strings" "time" ) const ( // deadline (in seconds) up to which the go routine leak detection has to be retried. leakDetectDeadline = 5 // pause time (in milliseconds) between each snapshot at the end of the go routine leak detection. leakDetectPauseTimeMs = 50 ) // LeakDetect - type with methods for go routine leak detection. type LeakDetect struct { relevantRoutines map[string]bool }
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) -
internal/http/listener.go
acceptCh chan acceptResult // channel where all TCP listeners write accepted connection. ctx context.Context ctxCanceler context.CancelFunc } // start - starts separate goroutine for each TCP listener. A valid new connection is passed to httpListener.acceptCh. func (listener *httpListener) start() { // Closure to send acceptResult to acceptCh.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
} var _ error = ControlPlaneNotFoundError{} type Options struct { // MessageWriter is a writer for displaying messages to users. MessageWriter io.Writer // XdsViaAgents accesses Istiod via the tap service of each agent. // This is only used in `proxy-status` command. XdsViaAgents bool // XdsViaAgentsLimit is the maximum number of pods being visited by istioctl,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v1.go
if want != got { return fmt.Errorf("Invalid key checksum, want %x, got %x", want, got) } stream, err := sio.AES_256_GCM.Stream(key) if err != nil { return err } // Zero nonce, we only use each key once, and 32 bytes is plenty. nonce := make([]byte, stream.NonceSize()) encr := stream.DecryptReader(r, nonce, nil) _, err = io.Copy(w, encr) if err == nil { fmt.Println(okMsg) } return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 1.6K bytes - Viewed (0) -
cmd/metacache-entries.go
continue } } // Return dir entries, if enough... if selected != nil && selected.isDir() && dirExists >= r.dirQuorum { return selected, true } // If we would never be able to reach read quorum. if objsValid < r.objQuorum { return nil, false } // If all objects agree. if selected != nil && objsAgree == objsValid { return selected, true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0)