- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for lastUpdated (0.27 sec)
-
istioctl/pkg/util/configdump/route.go
drLastUpdated := drc[i].LastUpdated.AsTime() if drLastUpdated.After(lastUpdated) { lastUpdated = drLastUpdated } } } if lastUpdated.After(time.Unix(0, 0)) { // if a timestamp was obtained from a drc return &lastUpdated, nil } return nil, nil } // GetDynamicRouteDump retrieves a route dump with just dynamic active routes in it
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 3.2K bytes - Viewed (0) -
istioctl/pkg/writer/compare/route.go
if err != nil { return err } lastUpdatedStr := "" if lastUpdated, err := c.envoy.GetLastUpdatedDynamicRouteTime(); err != nil { return err } else if lastUpdated != nil { loc, err := time.LoadLocation(c.location) if err != nil { loc, _ = time.LoadLocation("UTC") } lastUpdatedStr = fmt.Sprintf(" (RDS last loaded at %s)", lastUpdated.In(loc).Format(time.RFC1123)) } if text != "" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 2.3K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
err = dac[j].Cluster.UnmarshalTo(cluster) if err != nil { return false } return name < cluster.Name }) if stripVersions { for i := range dac { dac[i].VersionInfo = "" dac[i].LastUpdated = nil } } return &admin.ClustersConfigDump{DynamicActiveClusters: dac}, nil } // GetClusterConfigDump retrieves the cluster config dump from the ConfigDump
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer_test.go
VersionInfo: "2023-06-20T09:07:41Z/3", Listener: &anypb.Any{ TypeUrl: "type.googleapis.com/envoy.config.listener.v3.Listener", }, LastUpdated: timestamppb.Now(), }, ClientStatus: 453, }, }, }, } tests := []struct { name string input *envoy_admin.ListenersConfigDump_DynamicListener }{ { name: "Test2",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/util/configdump/listener.go
if err != nil { return false } return name < l.Name }) if stripVersions { for i := range dal { dal[i].ActiveState.VersionInfo = "" dal[i].ActiveState.LastUpdated = nil dal[i].Name = "" // In Istio 1.5, Envoy creates this; suppress it } } return &admin.ListenersConfigDump{DynamicListeners: dal}, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.5K bytes - Viewed (1) -
cmd/metacache_test.go
recursive: false, status: scanStateSuccess, fileNotFound: false, error: "", started: metaCacheTestsetTimestamp, ended: metaCacheTestsetTimestamp.Add(time.Minute), lastUpdate: metaCacheTestsetTimestamp.Add(time.Minute), lastHandout: metaCacheTestsetTimestamp, dataVersion: metacacheStreamVersion, }, 1: { id: "case-2-recursive", bucket: "bucket",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 08 18:06:45 GMT 2021 - 6.8K bytes - Viewed (0) -
cmd/site-replication.go
} var ( latestID, latestPeerName string lastUpdate time.Time latestPeers map[string]madmin.PeerInfo ) for dID, ps := range info.PeerStates { if lastUpdate.IsZero() { lastUpdate = ps.UpdatedAt latestID = dID latestPeers = ps.Peers } if ps.UpdatedAt.After(lastUpdate) { lastUpdate = ps.UpdatedAt latestID = dID latestPeers = ps.Peers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/metacache_gen.go
return } case "lh": z.lastHandout, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "lastHandout") return } case "u": z.lastUpdate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "lastUpdate") return } case "b": z.bucket, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "bucket") return } case "flt":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 08 18:26:08 GMT 2021 - 10K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops_gen.go
return } case "Started": z.Started, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "Started") return } case "LastUpdate": z.LastUpdate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "LastUpdate") return } case "ObjectsTotalCount": z.ObjectsTotalCount, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "ObjectsTotalCount")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 21.5K bytes - Viewed (0) -
cmd/metacache-manager.go
exit = true } m.mu.RLock() for _, v := range m.buckets { if !exit { v.cleanup() } } m.mu.RUnlock() m.mu.Lock() for k, v := range m.trash { if time.Since(v.lastUpdate) > metacacheMaxRunningAge { v.delete(context.Background()) delete(m.trash, k) } } m.mu.Unlock() } }() } // updateCacheEntry will update non-transient state.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0)