- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 157 for channel2 (0.15 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// an error event and close the result channel. Stop() // ResultChan returns a channel which will receive events from the event // producer. If an error occurs or Stop() is called, the producer must // close this channel and release any resources used by the watch. // Closing the result channel tells the consumer that no more events will be // sent. ResultChan() <-chan Event }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
releasenotes/notes/release-channels-remote-cluster.yaml
Whitney Griffith <******@****.***> 1716925617 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 19:46:57 UTC 2024 - 297 bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
w.channels = make(map[types.UID]*WorkChannelItem) } channel, ok := w.channels[uid] if !ok { channel = &WorkChannelItem{ out: make(chan struct{}, 1), } w.channels[uid] = channel } return channel } func (w *WorkChannel) Intercept(uid types.UID, ch chan struct{}) (outCh <-chan struct{}) { channel := w.Channel(uid) w.lock.Lock() defer w.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typeparams/coretype.go
return U } ch, ok := U.(*types.Chan) if !ok { return nil // no core type as identical < len(terms) and U is not a channel. } // https://go.dev/ref/spec#Core_types // "the type chan E if T contains only bidirectional channels, or the type chan<- E or // <-chan E depending on the direction of the directional channels present." for chans := identical; chans < len(terms); chans++ { curr, ok := terms[chans].Type().Underlying().(*types.Chan)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 5.3K bytes - Viewed (0) -
src/sync/cond.go
// a call to [Cond.Broadcast] or [Cond.Signal] “synchronizes before” any Wait call // that it unblocks. // // For many simple use cases, users will be better off using channels than a // Cond (Broadcast corresponds to closing a channel, and Signal corresponds to // sending on a channel). // // For more on replacements for [sync.Cond], see [Roberto Clapis's series on // advanced concurrency patterns], as well as [Bryan Mills's talk on concurrency
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4.1K bytes - Viewed (0) -
src/os/signal/doc.go
On Windows a ^C (Control-C) or ^BREAK (Control-Break) normally cause the program to exit. If Notify is called for [os.Interrupt], ^C or ^BREAK will cause [os.Interrupt] to be sent on the channel, and the program will not exit. If Reset is called, or Stop is called on all channels passed to Notify, then the default behavior will be restored. Additionally, if Notify is called, and Windows sends CTRL_CLOSE_EVENT,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
pkg/kubelet/config/config_test.go
config := NewPodConfig(mode, eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "kubelet"}), &mockPodStartupSLIObserver{}) channel := config.Channel(ctx, TestSource) ch := config.Updates() return channel, ch, config } func expectPodUpdate(t *testing.T, ch <-chan kubetypes.PodUpdate, expected ...kubetypes.PodUpdate) { for i := range expected { update := <-ch
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 17.1K bytes - Viewed (0) -
.teamcity/src/test/kotlin/PerformanceTestBuildTypeTest.kt
assertEquals( ( listOf( "clean", ":performance:largeTestProjectPerformanceTest --channel %performance.channel% ", ":performance:smallTestProjectPerformanceTest --channel %performance.channel% ", "extraParameters" ) + expectedRunnerParams ).joinToString(" "),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 06:42:07 UTC 2024 - 7.2K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/PerformanceTestSpec.kt
fun asConfigurationId(model: CIBuildModel, bucket: String): String fun channel(): String } interface PerformanceTestProjectSpec { val type: PerformanceTestType val failsStage: Boolean fun asConfigurationId(model: CIBuildModel): String fun asName(): String fun channel(): String } data class PerformanceTestPartialTrigger( val triggerName: String,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 03 03:39:03 UTC 2024 - 3.9K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/defaultrevisionvalidatingadmissionpolicy.yaml
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 19:46:57 UTC 2024 - 1.8K bytes - Viewed (0)