- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 343 for notifyCh (0.15 sec)
-
src/os/signal/example_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 18:38:23 UTC 2017 - 1001 bytes - Viewed (0) -
cmd/config-versions.go
Worm config.BoolFlag `json:"worm"` // Storage class configuration StorageClass storageclass.Config `json:"storageclass"` // Notification queue configuration. Notify notify.Config `json:"notify"` // Logger configuration Logger logger.Config `json:"logger"` // Compression configuration Compression compress.Config `json:"compress"` // OpenID configuration
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/batch-rotate.go
} // BatchJobKeyRotateFlags various configurations for replication job definition currently includes // - filter // - notify // - retry type BatchJobKeyRotateFlags struct { Filter BatchKeyRotateFilter `yaml:"filter" json:"filter"` Notify BatchJobNotification `yaml:"notify" json:"notify"` Retry BatchJobRetry `yaml:"retry" json:"retry"` } // BatchJobKeyRotateV1 v1 of batch key rotation job
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/batch-rotate_gen.go
case "Filter": err = z.Filter.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Filter") return } case "Notify": err = z.Notify.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Notify") return } case "Retry": err = z.Retry.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Retry") return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 02 10:51:33 UTC 2023 - 27.1K bytes - Viewed (0) -
.github/actions/notify-translations/action.yml
name: "Notify Translations" description: "Notify in the issue for a translation when there's a new PR available" author: "Sebastián RamÃrez <******@****.***>" inputs: token: description: 'Token, to read the GitHub API. Can be passed in using {{ secrets.GITHUB_TOKEN }}' required: true runs: using: 'docker'
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Aug 18 13:07:08 UTC 2021 - 346 bytes - Viewed (0) -
src/runtime/race/testdata/cgo_test_main.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 08 04:08:51 UTC 2014 - 415 bytes - Viewed (0) -
src/sync/cond.go
// // c.L.Lock() // for !condition() { // c.Wait() // } // ... make use of condition ... // c.L.Unlock() func (c *Cond) Wait() { c.checker.check() t := runtime_notifyListAdd(&c.notify) c.L.Unlock() runtime_notifyListWait(&c.notify, t) c.L.Lock() } // Signal wakes one goroutine waiting on c, if there is any. // // It is allowed but not required for the caller to hold c.L // during the call. //
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
will be explicitly unblocked as described above. If Notify is called for a blocked signal, it will be unblocked. If, later, Reset is called for that signal, or Stop is called on all channels passed to Notify for that signal, the signal will once again be blocked. # SIGPIPE When a Go program writes to a broken pipe, the kernel will raise a SIGPIPE signal. If the program has not called Notify to receive SIGPIPE signals, then
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
src/os/signal/signal.go
// // It is allowed to call Notify multiple times with the same channel: // each call expands the set of signals sent to that channel. // The only way to remove signals from the set is to call [Stop]. // // It is allowed to call Notify multiple times with different channels // and the same signals: each channel receives copies of incoming // signals independently. func Notify(c chan<- os.Signal, sig ...os.Signal) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/kubelet/container/cache.go
return d } // The pod status is not ready. return nil } // notify sends notifications for pod with the given id, if the requirements // are met. Note that the caller should acquire the lock. func (c *cache) notify(id types.UID, timestamp time.Time) { list, ok := c.subscribers[id] if !ok { // No one to notify. return } newList := []*subRecord{} for i, r := range list {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 07:37:01 UTC 2023 - 6.6K bytes - Viewed (0)