- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for isSnapshot (0.15 sec)
-
cmd/leak-detect_test.go
// 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 } // NewLeakDetect - Initialize a LeakDetector with the snapshot of relevant Go routines. func NewLeakDetect() LeakDetect { snapshot := LeakDetect{
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) -
cni/pkg/nodeagent/pod_cache.go
// 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() defer p.mu.Unlock() if existing := p.currentPodCache[uid]; existing.Netns != nil { if existing.Netns.Inode() == workload.Netns.Inode() { workload.Netns.Close()
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/nodeagent/net.go
log.Warnf("failed to construct initial ztunnel snapshot: %v", err) consErr = append(consErr, err) } return errors.Join(consErr...) } func (s *NetServer) buildZtunnelSnapshot(ambientPodUIDs map[types.UID]*corev1.Pod) error { // first add all the pods as empty: for uid := range ambientPodUIDs { s.currentPodSnapshot.Ensure(string(uid)) } // populate full pod snapshot from cgroups
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
log.Info("CNI ambient server kubeclient started") pods := s.handlers.GetAmbientPods() err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err) } log.Info("CNI ambient server marking ready") s.Ready() s.dataplane.Start(s.ctx) s.handlers.Start() } func (s *Server) Stop() {
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) -
internal/rest/client.go
} case *bytes.Reader: req.ContentLength = int64(v.Len()) snapshot := *v req.GetBody = func() (io.ReadCloser, error) { r := snapshot return io.NopCloser(&r), nil } case *strings.Reader: req.ContentLength = int64(v.Len()) snapshot := *v req.GetBody = func() (io.ReadCloser, error) { r := snapshot return io.NopCloser(&r), nil } default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
internal/kms/kms.go
// IsLocal returns true if the KMS is a local implementation IsLocal() bool // List returns an array of local KMS Names List() []kes.KeyInfo // Metrics returns a KMS metric snapshot. Metrics(ctx context.Context) (kes.Metric, error) // CreateKey creates a new key at the KMS with the given key ID. CreateKey(ctx context.Context, keyID string) error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
m, _, err := readProto[zdsapi.ZdsHello](conn.u, readWriteDeadline, nil) if err != nil { return err } log.Infof("received hello from ztunnel. %v", m.Version) log.Debug("sending snapshot to ztunnel") if err := z.sendSnapshot(ctx, conn); err != nil { return err } for { // listen for updates: select { case update, ok := <-conn.Updates: if !ok {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
).Return(nil) fixture.ipsetDeps.On("addIP", "foo-v4", netip.MustParseAddr("2.2.2.2"), ipProto, podUID, true, ).Return(nil) // List should return one IP not in our "pod snapshot", which means we prune fixture.ipsetDeps.On("listEntriesByIP", "foo-v4", ).Return([]netip.Addr{ netip.MustParseAddr("2.2.2.2"), netip.MustParseAddr("6.6.6.6"), netip.MustParseAddr("3.3.3.3"),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
// Snapshot charts are in testdata/manifest-generate/data-snapshot snapshotCharts = func() chartSourceType { d, err := os.MkdirTemp("", "data-snapshot-*") if err != nil { panic(fmt.Errorf("failed to make temp dir: %v", err)) } f, err := os.Open("testdata/manifest-generate/data-snapshot.tar.gz") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics_test.go
startTime time.Time, endTime time.Time, ) ([]prometheus_model.LabelSet, promv1.Warnings, error) { return nil, nil, nil } func (client mockPromAPI) Snapshot(ctx context.Context, skipHead bool) (promv1.SnapshotResult, error) { return promv1.SnapshotResult{}, nil } func (client mockPromAPI) Rules(ctx context.Context) (promv1.RulesResult, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 25 02:07:44 GMT 2023 - 7.9K bytes - Viewed (0)