- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 576 for event (0.13 sec)
-
common-protos/k8s.io/api/events/v1/generated.proto
repeated Event items = 2; } // EventSeries contain information on series of events, i.e. thing that was/is happening // continuously for some time. How often to update the EventSeries is up to the event reporters. // The default event reporter in "k8s.io/client-go/tools/events/event_broadcaster.go" shows // how this struct is updated on heartbeats and can guide customized reporter implementations. message EventSeries {
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 5.5K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
}, }, Timeout: 1000 * time.Millisecond, } eventC := CNIEventClient{ client: c, url: "http://unix" + path, } return eventC } func PushCNIEvent(cniClient CNIEventClient, event *skel.CmdArgs, prevResIps []*cniv1.IPConfig, podName, podNamespace string) error { if event == nil { return fmt.Errorf("unable to push CNI event, CmdArgs event was nil") } var ncconfigs []nodeagent.IPConfig
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt
override fun closes(event: CallEvent): Boolean = event is CallStart && call == event.call } data class CallFailed( override val timestampNs: Long, override val call: Call, val ioe: IOException, ) : CallEvent() { override fun closes(event: CallEvent): Boolean = event is CallStart && call == event.call } data class Canceled( override val timestampNs: Long,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
event := input.(controllers.Event) switch event.Latest().(type) { case *corev1.Namespace: return s.reconcileNamespace(input) case *corev1.Pod: return s.reconcilePod(input) default: return fmt.Errorf("unexpected event type: %+v", input) } } func (s *InformerHandlers) reconcileNamespace(input any) error { event := input.(controllers.Event) ns := event.Latest().(*corev1.Namespace)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
return msg, nil } func (s *CniPluginServer) ReconcileCNIAddEvent(ctx context.Context, addCmd CNIPluginAddEvent) error { log := log.WithLabels("cni-event", addCmd) log.Debugf("netns: %s", addCmd.Netns) // The CNI node plugin should have already checked the pod against the k8s API before forwarding us the event,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} fun assertExhausted() { assertThat(events).isEmpty() } fun assertOpen(): WebSocket { val event = nextEvent() as Open return event.webSocket } fun assertFailure(t: Throwable?) { val event = nextEvent() as Failure assertThat(event.response).isNull() assertThat(event.t).isSameAs(t) } fun assertFailure(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
} else { eventSequence.forEach loop@{ when (e.closes(it)) { null -> return // no open event true -> return // found open event false -> return@loop // this is not the open event so continue } } fail<Any>("event $e without matching start event") } } override fun proxySelectStart( call: Call, url: HttpUrl,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9K bytes - Viewed (1) -
maven-core/src/main/java/org/apache/maven/execution/AbstractExecutionListener.java
// default does nothing } public void projectSucceeded(ExecutionEvent event) { // default does nothing } public void projectFailed(ExecutionEvent event) { // default does nothing } public void forkStarted(ExecutionEvent event) { // default does nothing } public void forkSucceeded(ExecutionEvent event) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 2.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
) : ConnectionEvent() { override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route } data class ConnectEnd( override val timestampNs: Long, override val connection: Connection, val route: Route, val call: Call, ) : ConnectionEvent() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultModelBuildingListener.java
@Override public void buildExtensionsAssembled(ModelBuildingEvent event) { Model model = new Model(event.model()); try { pluginRepositories = projectBuildingHelper.createArtifactRepositories( model.getPluginRepositories(), pluginRepositories, projectBuildingRequest); } catch (Exception e) { event.problems() .add(
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 5.1K bytes - Viewed (0)