- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for AddEvent (0.43 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/envelope.go
} */ ) defer span.End(500 * time.Millisecond) span.AddEvent("About to decode encrypted object") // Deserialize the EncryptedObject from the data. encryptedObject, err := t.doDecode(data) if err != nil { span.AddEvent("Decoding encrypted object failed") span.RecordError(err) return nil, false, err } span.AddEvent("Decoded encrypted object")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 00:23:50 UTC 2023 - 18.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/get.go
} // Log only long List requests (ignore Watch). defer span.End(500 * time.Millisecond) span.AddEvent("About to List from storage") result, err := r.List(ctx, &opts) if err != nil { scope.err(err, w, req) return } span.AddEvent("Listing from storage done") defer span.AddEvent("Writing http response done", attribute.Int("count", meta.LenList(result)))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:22:16 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
return fmt.Errorf("PrepareObjectForStorage failed: %v", err) } span.AddEvent("About to Encode") data, err := runtime.Encode(s.codec, obj) if err != nil { span.AddEvent("Encode failed", attribute.Int("len", len(data)), attribute.String("err", err.Error())) return err } span.AddEvent("Encode succeeded", attribute.Int("len", len(data))) opts, err := s.ttlOpts(ctx, int64(ttl))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
} fun wrap(eventListener: EventListener) = EventListener.Factory { ClientRuleEventListener(eventListener, ::addEvent) } fun wrap(eventListenerFactory: EventListener.Factory) = EventListener.Factory { call -> ClientRuleEventListener(eventListenerFactory.create(call), ::addEvent) } /** * Returns an OkHttpClient for tests to use as a starting point. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go
if err != nil { scope.err(err, w, req) return } span.AddEvent("Object stored in database") status := http.StatusOK if wasCreated { status = http.StatusCreated } span.AddEvent("About to write a response") defer span.AddEvent("Writing http response done") transformResponseObject(ctx, scope, req, w, status, outputMediaType, result) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 28.5K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
) type eventType int func (e eventType) String() string { switch e { case addEvent: return "add" case updateEvent: return "update" case deleteEvent: return "delete" default: return fmt.Sprintf("unknown(%d)", int(e)) } } const ( addEvent eventType = iota updateEvent deleteEvent ) type event struct { eventType eventType
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
addEvent("key2", 30, later) addEvent("key3", 40, later) // Force cache resize. addEvent("key4", 50, later.Add(time.Second)) _, err := store.getAllEventsSince(15, storage.ListOptions{}) if err == nil || !strings.Contains(err.Error(), "too old resource version") { t.Errorf("unexpected error: %v", err) } } func TestSuggestedWatchChannelSize(t *testing.T) { testCases := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
status = apierrors.NewBadRequest("error calling webhook") } return false, &webhookutil.ErrCallingWebhook{WebhookName: h.Name, Reason: fmt.Errorf("failed to call webhook: %w", err), Status: status} } span.AddEvent("Request completed") result, err := webhookrequest.VerifyAdmissionResponse(uid, true, response) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
} else { status = apierrors.NewBadRequest("error calling webhook") } return &webhookutil.ErrCallingWebhook{WebhookName: h.Name, Reason: fmt.Errorf("failed to call webhook: %w", err), Status: status} } span.AddEvent("Request completed") result, err := webhookrequest.VerifyAdmissionResponse(uid, false, response) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0)