- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 797 for Kevent (0.17 sec)
-
src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java
* * Current strategy is based on failure count. In the future, this could be enhanced to consider: * - Recent event frequency (successful notifications) * - Time since last successful notification * - Events per unit time for more adaptive behavior * * @param handle notification handle * @return polling interval in milliseconds */Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 13.7K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/AllowConcurrentEvents.java
import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus * may invoke the event subscriber simultaneously from multiple threads. * * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}. * * @author Cliff BiffleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 1.2K bytes - Viewed (0) -
compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/DefaultArtifactDescriptorReaderTest.java
// execute reader.readArtifactDescriptor(session, request); // verify verify(eventDispatcher).dispatch(event.capture()); boolean missingArtifactDescriptor = false; for (RepositoryEvent evt : event.getAllValues()) { if (EventType.ARTIFACT_DESCRIPTOR_MISSING.equals(evt.getType())) { assertEquals(Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.2K bytes - Viewed (0) -
docs/lambda/README.md
import requests app = Flask(__name__) @app.route('/', methods=['POST']) def get_webhook(): if request.method == 'POST': # obtain the request event from the 'POST' call event = request.json object_context = event["getObjectContext"] # Get the presigned URL to fetch the requested # original object from MinIO s3_url = object_context["inputS3Url"]
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 7.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java
static final Object EVENT = new Object(); abstract H createSubscriber(); private @Nullable H subscriber; H getSubscriber() { return subscriber; } @Override protected void setUp() throws Exception { subscriber = createSubscriber(); EventBus bus = new EventBus(); bus.register(subscriber); bus.post(EVENT); } @Override
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
try { // Convert RPC message to WitnessNotification WitnessNotification notification = new WitnessNotification(); // Set event type based on message type WitnessEventType eventType = convertMessageTypeToEventType(message.getType()); notification.setEventType(eventType); notification.setTimestamp(message.getTimestamp());Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 20.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
} } } /** * Writes a search log event. * * @param event The search log event. */ public void writeSearchLogEvent(final SearchLogEvent event) { try { final Map<String, Object> source = toSource(event); searchLogLogger.info(objectMapper.writeValueAsString(source));Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/webapp/js/admin/bootstrap.min.js
_setListeners=function(){var t=this;this.config.trigger.split(" ").forEach((function(e){if("click"===e)o.default(t.element).on(t.constructor.Event.CLICK,t.config.selector,(function(e){return t.toggle(e)}));else if("manual"!==e){var n=e===Ft?t.constructor.Event.MOUSEENTER:t.constructor.Event.FOCUSIN,i=e===Ft?t.constructor.Event.MOUSELEAVE:t.constructor.Event.FOCUSOUT;o.default(t.element).on(n,t.config.selector,(function(e){return t._enter(e)})).on(i,t.config.selector,(function(e){return t._leave(...Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 61.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.16.md
- kube-scheduler - Migrate scheduler to use v1beta1 Event API. any tool targeting scheduler events needs to use v1beta1 Event API ([#78447](https://github.com/kubernetes/kubernetes/pull/78447), [@yastij](https://github.com/yastij)) - kubeadm
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Oct 23 20:13:20 UTC 2024 - 345.2K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
}, }) } lc := Lifecycle{ Rules: rules, } if event := lc.NoncurrentVersionsExpirationLimit(ObjectOpts{Name: "obj"}); event.RuleID != "1" || event.NoncurrentDays != 1 || event.NewerNoncurrentVersions != 1 { t.Fatalf("Expected (ruleID, days, lim) to be (\"1\", 1, 1) but got (%s, %d, %d)", event.RuleID, event.NoncurrentDays, event.NewerNoncurrentVersions) } }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 55.5K bytes - Viewed (0)