- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 330 for Messages (0.23 sec)
-
internal/config/notify/help.go
formatComment = `'namespace' reflects current bucket/object list and 'access' reflects a journal of object operations, defaults to 'namespace'` queueDirComment = `staging dir for undelivered messages e.g. '/home/events'` queueLimitComment = `maximum limit for undelivered messages, defaults to '100000'` ) // Help template inputs for all notification targets var ( HelpWebhook = config.HelpKVS{ config.HelpKV{ Key: target.WebhookEndpoint,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
} return nil } // Cancel - cancels the target. // All queued messages are flushed and the function returns afterwards. // All messages sent to the target after this function has been called will be dropped. func (h *Target) Cancel() { atomic.StoreInt32(&h.status, statusClosed) h.storeCtxCancel() // Wait for messages to be sent... h.wg.Wait() // Set logch to nil and close it.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
public boolean isChangedClusterState(final int status) { return previousClusterState.getAndSet(status) != status; } public ActionValidator<FessMessages> createValidator(final RequestManager requestManager, final UserMessagesCreator<FessMessages> messagesCreator, final Class<?>[] runtimeGroups) { return new FessActionValidator<>(requestManager, messagesCreator, runtimeGroups); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sat Apr 13 11:43:03 GMT 2024 - 26.5K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
// Empty server to client message. val message3 = "" server.send(message3) clientListener.assertTextMessage(message3) // Empty client to server message. val message4 = "" client.send(message4) serverListener.assertTextMessage(message4) // Server to client message that shares context with message1. val message5 = message1 + message1
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
guava-tests/test/com/google/common/graph/AbstractGraphTest.java
static final Integer NODE_NOT_IN_GRAPH = 1000; // TODO(user): Consider separating Strings that we've defined here to capture // identifiable substrings of expected error messages, from Strings that we've defined // here to provide error messages. // TODO(user): Some Strings used in the subclasses can be added as static Strings // here too. static final String ERROR_MODIFIABLE_SET = "Set returned is unexpectedly modifiable";
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Jan 22 17:29:38 GMT 2024 - 16.6K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
|:----------------------------------|:----------------------------------------------------------| | `minio_audit_failed_messages` | Total number of messages that failed to send since start. | | `minio_audit_target_queue_length` | Number of unsent messages in queue for target. | | `minio_audit_total_messages` | Total number of messages sent since start. | ## Cluster Capacity Metrics
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
android/guava-tests/test/com/google/common/graph/AbstractGraphTest.java
static final Integer NODE_NOT_IN_GRAPH = 1000; // TODO(user): Consider separating Strings that we've defined here to capture // identifiable substrings of expected error messages, from Strings that we've defined // here to provide error messages. // TODO(user): Some Strings used in the subclasses can be added as static Strings // here too. static final String ERROR_MODIFIABLE_SET = "Set returned is unexpectedly modifiable";
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jan 22 17:29:38 GMT 2024 - 16.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/CollectionRetainAllTester.java
} private void expectReturnsTrue(Target target) { String message = Platform.format("retainAll(%s) should return true", target); assertTrue(message, collection.retainAll(target.toRetain)); } private void expectReturnsFalse(Target target) { String message = Platform.format("retainAll(%s) should return false", target); assertFalse(message, collection.retainAll(target.toRetain)); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 10.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultMavenPluginManager.java
} } catch (ComponentConfigurationException e) { String message = "Unable to parse configuration of mojo " + mojoDescriptor.getId(); if (e.getFailedConfiguration() != null) { message += " for parameter " + e.getFailedConfiguration().getName(); } message += ": " + e.getMessage();
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 42.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionRetainAllTester.java
} private void expectReturnsTrue(Target target) { String message = Platform.format("retainAll(%s) should return true", target); assertTrue(message, collection.retainAll(target.toRetain)); } private void expectReturnsFalse(Target target) { String message = Platform.format("retainAll(%s) should return false", target); assertFalse(message, collection.retainAll(target.toRetain)); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 10.5K bytes - Viewed (0)