Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for parseEvent (0.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/internal/trace/traceviewer/static/trace_viewer_full.html

    if(this.is64bit_===undefined){throw Error('Cannot determine pointer size of the system trace.'+'Consider deselecting "System tracing" or disabling the "Paging '+'Executive" feature of Windows');}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 20:45:06 UTC 2023
    - 2.5M bytes
    - Viewed (0)
Back to top