- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 106 for Watch (0.15 sec)
-
common/scripts/metallb-native.yaml
- list - watch - apiGroups: - metallb.io resources: - bgppeers verbs: - get - list - watch - apiGroups: - metallb.io resources: - l2advertisements verbs: - get - list - watch - apiGroups: - metallb.io resources: - bgpadvertisements verbs: - get - list - watch - apiGroups:
Others - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Feb 23 23:56:31 GMT 2024 - 63.9K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
// // This field is not supported when watch is true. Clients may start a watch from the last // resourceVersion value returned by the server and not miss any modifications. optional string continue = 8; // `sendInitialEvents=true` may be set together with `watch=true`. // In that case, the watch stream will begin with synthetic events to
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 53.3K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.3.md
* AWS kube-up: Allow VPC CIDR to be specified (experimental) ([#23362](https://github.com/kubernetes/kubernetes/pull/23362), [@miguelfrde](https://github.com/miguelfrde)) * Return "410 Gone" errors via watch stream when using watch cache ([#25369](https://github.com/kubernetes/kubernetes/pull/25369), [@liggitt](https://github.com/liggitt))
Plain Text - Registered: Fri Apr 26 09:05:10 GMT 2024 - Last Modified: Thu Dec 24 02:28:26 GMT 2020 - 84K bytes - Viewed (0) -
cmd/iam.go
} func (sys *IAMSys) periodicRoutines(ctx context.Context, baseInterval time.Duration) { // Watch for IAM config changes for iamStorageWatcher. watcher, isWatcher := sys.store.IAMStorageAPI.(iamStorageWatcher) if isWatcher { go func() { ch := watcher.watch(ctx, iamConfigPrefix) for event := range ch { if err := sys.loadWatchedEvent(ctx, event); err != nil { // we simply log errors
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/iam-store.go
} // iamStorageWatcher is implemented by `IAMStorageAPI` implementers that // additionally support watching storage for changes. type iamStorageWatcher interface { watch(ctx context.Context, keyPath string) <-chan iamWatchEvent } // Set default canned policies only if not already overridden by users. func setDefaultCannedPolicies(policies map[string]PolicyDoc) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
* * ```java * HttpUrl base = HttpUrl.parse("https://www.youtube.com/user/WatchTheDaily/videos"); * HttpUrl link = base.resolve("../../watch?v=cbP2N1BQdYc"); * System.out.println(link); * ``` * * which prints: * * ``` * https://www.youtube.com/watch?v=cbP2N1BQdYc * ``` * * ## What's in a URL? * * A URL has several components. * * ### Scheme *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
src/main/java/jcifs/smb/SmbFile.java
* If any of the above fail, isExists will not be set true */ this.isExists = true; } catch ( UnknownHostException uhe ) { log.debug("Unknown host", uhe); } catch ( SmbException se ) { log.trace("exists:", se); switch ( se.getNtStatus() ) { case NtStatus.NT_STATUS_NO_SUCH_FILE:
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon Mar 13 12:00:57 GMT 2023 - 81.6K bytes - Viewed (0) -
docs/bucket/notifications/README.md
channel.basic_consume(callback, queue=queue_name, no_ack=False) channel.start_consuming() ``` Execute this example python program to watch for RabbitMQ events on the console. ```py python rabbit.py ``` Open another terminal and upload a JPEG image into `images` bucket. ``` mc cp myphoto.jpg myminio/images ```
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
cmd/batch-handlers.go
continue } batch = append(batch, obj) if len(batch) < *r.Source.Snowball.Batch { continue } writeFn(batch) batch = batch[:0] } writeFn(batch) xioutil.SafeClose(slowCh) }() } else { slowCh = walkCh } workerSize, err := strconv.Atoi(env.Get("_MINIO_BATCH_REPLICATION_WORKERS", strconv.Itoa(runtime.GOMAXPROCS(0)/2)))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
}, executor); fail(); } catch (IllegalStateException expected2) { } try { ClosingFuture.whenAllComplete(asList(closingFuture)); fail(); } catch (IllegalStateException expected1) { } try { ClosingFuture.whenAllSucceed(asList(closingFuture)); fail(); } catch (IllegalStateException expected) { } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0)