- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 155 for notification (0.2 sec)
-
cmd/notification.go
"github.com/minio/minio/internal/bucket/bandwidth" "github.com/minio/minio/internal/logger" ) // This file contains peer related notifications. For sending notifications to // external systems, see event-notification.go // NotificationSys - notification system. type NotificationSys struct { peerClients []*peerRESTClient // Excludes self allPeerClients []*peerRESTClient // Includes nil client for self }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
// other operations, the cache and the removal queue won't change from this point on. // Verify that each received removal notification was valid for (RemovalNotification<String, String> notification : removalListener) { assertEquals("Invalid removal notification", notification.getKey(), notification.getValue()); } CacheStats stats = cache.stats(); assertEquals(removalListener.size(), stats.evictionCount());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
// other operations, the cache and the removal queue won't change from this point on. // Verify that each received removal notification was valid for (RemovalNotification<String, String> notification : removalListener) { assertEquals("Invalid removal notification", notification.getKey(), notification.getValue()); } CacheStats stats = cache.stats(); assertEquals(removalListener.size(), stats.evictionCount());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 25.5K bytes - Viewed (0) -
tests/test_sub_callbacks.py
* Collect the money from the client. * Send a notification back to the API user (the external developer), as a callback. * At this point is that the API will somehow send a POST request to the external API with the notification of the invoice event (e.g. "payment successful"). """ # Send the invoice, collect the money, send the notification (the callback) return {"msg": "Invoice received"}
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Fri Jul 07 17:12:13 GMT 2023 - 13.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/Constants.java
public static final String LDAP_MEMBEROF_ATTRIBUTE = "ldap.memberof.attribute"; public static final String NOTIFICATION_LOGIN = "notification.login"; public static final String NOTIFICATION_SEARCH_TOP = "notification.search.top"; public static final String NOTIFICATION_ADVANCE_SEARCH = "notification.advance.search"; public static final String STORAGE_ENDPOINT = "storage.endpoint";
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.4K bytes - Viewed (0) -
internal/config/notify/parse.go
var ErrTargetsOffline = errors.New("one or more targets are offline. Please use `mc admin info --json` to check the offline targets") // TestSubSysNotificationTargets - tests notification targets of given subsystem func TestSubSysNotificationTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) error { if err := checkValidNotificationKeysForSubSys(subSys, cfg[subSys]); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0) -
cmd/batch-rotate.go
// kmskey: "key-id" # match objects with KMS key-id (applicable only for sse-kms) // notify: // endpoint: "https://notify.endpoint" # notification endpoint to receive job status events // token: "Bearer xxxxx" # optional authentication token for the notification endpoint // retry: // attempts: 10 # number of retries for the job before giving up // delay: "500ms" # least amount of delay between each retry
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
/// The cache pruning thread that removes files with expired blocks. std::unique_ptr<TF_Thread, std::function<void(TF_Thread*)>> pruning_thread_; /// Notification for stopping the cache pruning thread. absl::Notification stop_pruning_thread_; /// Guards access to the block map, LRU list, and cached byte count. mutable absl::Mutex mu_; /// The block map (map from Key to Block).
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 04:46:34 GMT 2020 - 10.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
int num_requests = 0; Notification notification; auto fetcher = [&num_requests, ¬ification, block_size]( const string& filename, size_t offset, size_t n, char* buffer, TF_Status* status) -> int64_t { EXPECT_EQ(n, block_size); EXPECT_EQ(offset, 0); num_requests++; memset(buffer, 'x', n); notification.Notify();
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Oct 15 03:16:57 GMT 2021 - 23.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/search/SearchAction.java
return redirectToLogin(); } validate(form, messages -> {}, () -> asHtml(virtualHost(path_IndexJsp)).renderWith(data -> { buildInitParams(); RenderDataUtil.register(data, "notification", fessConfig.getNotificationSearchTop()); })); if (!form.hasConditionQuery()) { if (StringUtil.isNotBlank(form.q)) { form.as.put("q", new String[] { form.q });
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12.3K bytes - Viewed (0)