- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for where (0.22 sec)
-
istioctl/pkg/writer/ztunnel/configdump/certificates.go
} } } return w.Flush() } func valueOrNA(value string) string { if value == "" { return "NA" } return value } func certNotExpired(cert *Cert) bool { // case where cert state is in either Initializing or Unavailable state if cert.ExpirationTime == "" && cert.ValidFrom == "" { return false } today := time.Now() expDate, err := time.Parse(time.RFC3339, cert.ExpirationTime)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
"changed paths with the value changes shown as OLD-VALUE -> NEW-VALUE.\n" + "List order changes are shown as [OLD-INDEX->NEW-INDEX], with ? used where a list item is added or\n" + "removed.", Args: func(cmd *cobra.Command, args []string) error { if len(args) != 2 { return fmt.Errorf("diff requires two files or directories") } return nil },
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) -
operator/cmd/mesh/manifest-generate.go
EnableClusterSpecific bool // Set is a string with element format "path=value" where path is an IstioOperator path and the value is a // value to set the node at that path to. Set []string // Force proceeds even if there are validation errors Force bool // ManifestsPath is a path to a charts and profiles directory in the local filesystem with a release tgz.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
return nil, err } wl := WorkloadInfo{ Workload: podToWorkload(pod), Netns: newnetns, } return p.UpsertPodCacheWithNetns(string(pod.UID), wl), nil } // Update the cache with the given Netns. If there is already a Netns for the given uid, we return it, and close the one provided. func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns { // lock current snapshot pod map p.mu.Lock()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
// 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) -
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) -
cni/pkg/nodeagent/net.go
// in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created. // in this case the CNI will be invoked soon and provide us with the netns. openNetns = s.currentPodSnapshot.Get(string(pod.UID)) if openNetns == nil {
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) -
cni/pkg/nodeagent/server.go
// createHostsideProbeIpset creates an ipset. This is designed to be called from the host netns. // Note that if the ipset already exist by name, Create will not return an error. // // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/util/configdump/wrapper.go
} var nonStrictResolver = &resolver{protoregistry.GlobalTypes} func (r *resolver) FindMessageByURL(url string) (protoreflect.MessageType, error) { typ, err := r.Types.FindMessageByURL(url) if err != nil { // Here we ignore the error since we want istioctl to ignore unknown types due to the Envoy version change msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}} return msg.ProtoReflect().Type(), nil } return typ, nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 1.8K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
XdsViaAgents bool // XdsViaAgentsLimit is the maximum number of pods being visited by istioctl, // when `XdsViaAgents` is true. This is only used in `proxy-status` command. // 0 means that there is no limit. XdsViaAgentsLimit int } var DefaultOptions = Options{ MessageWriter: os.Stdout, XdsViaAgents: false, XdsViaAgentsLimit: 0, }
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)