- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for parseEvent (0.33 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/event.go
return &event{ key: string(kv.Key), value: kv.Value, prevValue: nil, rev: kv.ModRevision, isDeleted: false, isCreated: true, } } func parseEvent(e *clientv3.Event) (*event, error) { if !e.IsCreate() && e.PrevKv == nil { // If the previous value is nil, error. One example of how this is possible is if the previous value has been compacted already.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/event_test.go
prevValue: []byte("value"), rev: 2, isDeleted: true, isCreated: false, }, expectedErr: "", }, } { t.Run(tc.name, func(t *testing.T) { actualEvent, err := parseEvent(tc.etcdEvent) if tc.expectedErr != "" { require.Error(t, err) assert.Contains(t, err.Error(), tc.expectedErr) } else { require.NoError(t, err) assert.Equal(t, tc.expectedEvent, actualEvent)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 2.6K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
buf, err := p.readFull(int(sz)) if err != nil { return "", fmt.Errorf("failed to read trace: %w", err) } return string(buf), nil } // parseEvent transforms raw events into events. // It does analyze and verify per-event-type arguments. func (p *parser) parseEvent(raw *rawEvent, ev *Event) error { desc := &EventDescriptions[raw.typ] if desc.Name == "" { return fmt.Errorf("missing description for event type %d", raw.typ)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
continue } for _, e := range wres.Events { metrics.RecordEtcdEvent(wc.watcher.groupResource.String()) parsedEvent, err := parseEvent(e) if err != nil { logWatchChannelErr(err) wc.sendError(err) return } wc.sendEvent(parsedEvent) } } // When we come to this point, it's only possible that client side ends the watch. // e.g. cancel the context, close the client.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
src/cmd/internal/test2json/test2json_test.go
continue } events = append(events, e) lines = append(lines, string(line)) } } return events, lines } haveEvents, haveLines := parseEvents(have) wantEvents, wantLines := parseEvents(want) if t.Failed() { return } // Make sure the events we have match the events we want. // At each step we're matching haveEvents[i] against wantEvents[j].
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 26 19:50:36 UTC 2022 - 7.2K bytes - Viewed (0) -
src/go/printer/testdata/parser.go
} func (p *parser) parseIdentList() (list []*ast.Ident) { if p.trace { defer un(trace(p, "IdentList")) } list = append(list, p.parseIdent()) for p.tok == token.COMMA { p.next() list = append(list, p.parseIdent()) } return } // ---------------------------------------------------------------------------- // Common productions
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 20:19:51 UTC 2023 - 50.5K bytes - Viewed (0) -
src/go/parser/parser.go
} func (p *parser) parseIdentList() (list []*ast.Ident) { if p.trace { defer un(trace(p, "IdentList")) } list = append(list, p.parseIdent()) for p.tok == token.COMMA { p.next() list = append(list, p.parseIdent()) } return } // ---------------------------------------------------------------------------- // Common productions
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 08 20:07:50 UTC 2023 - 72.2K bytes - Viewed (0) -
src/internal/trace/traceviewer/static/trace_viewer_full.html
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2.5M bytes - Viewed (0)