Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 371 for levent (0.05 sec)

  1. cmd/globals.go

    	"github.com/minio/minio/internal/config/subnet"
    	xhttp "github.com/minio/minio/internal/http"
    	etcd "go.etcd.io/etcd/client/v3"
    
    	levent "github.com/minio/minio/internal/config/lambda/event"
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/pubsub"
    	"github.com/minio/pkg/v3/certs"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  2. src/test/java/org/codelibs/fess/entity/SearchLogEventTest.java

            // Create different implementations
            SearchLogEvent event1 = new TestSearchLogEvent("id1", 1L, "type1");
            SearchLogEvent event2 = new NullSearchLogEvent();
            SearchLogEvent event3 = new EmptySearchLogEvent();
    
            // Test polymorphic behavior
            SearchLogEvent[] events = { event1, event2, event3 };
    
            for (SearchLogEvent event : events) {
                // All methods should be callable without exceptions
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    	}
    	globalTransitionState.queueTransitionTask(obj, event, src)
    	return true
    }
    
    func applyExpiryOnTransitionedObject(ctx context.Context, objLayer ObjectLayer, obj ObjectInfo, lcEvent lifecycle.Event, src lcEventSrc) (ok bool) {
    	timeILM := globalScannerMetrics.timeILM(lcEvent.Action)
    	if err := expireTransitionedObject(ctx, objLayer, &obj, lcEvent, src); err != nil {
    		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/eventbus/EventBus.java

       *
       * @param event event to post.
       */
      public void post(Object event) {
        Iterator<Subscriber> eventSubscribers = subscribers.getSubscribers(event);
        if (eventSubscribers.hasNext()) {
          dispatcher.dispatch(event, eventSubscribers);
        } else if (!(event instanceof DeadEvent)) {
          // the event had no subscribers and was not itself a DeadEvent
          post(new DeadEvent(this, event));
        }
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/util/ErrorToWarnRewritePolicyTest.java

                    .setMessage(new SimpleMessage("test message 2"))
                    .build();
    
            LogEvent event3 = Log4jLogEvent.newBuilder()
                    .setLoggerName("third.logger")
                    .setLevel(Level.ERROR)
                    .setMessage(new SimpleMessage("test message 3"))
                    .build();
    
            LogEvent result1 = policy.rewrite(event1);
            LogEvent result2 = policy.rewrite(event2);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  6. cmd/bucket-lifecycle.go

    		es.stats.missedFreeVersTasks.Add(1)
    	}
    }
    
    // enqueueByDays enqueues object versions expired by days for expiry.
    func (es *expiryState) enqueueByDays(oi ObjectInfo, event lifecycle.Event, src lcEventSrc) {
    	task := expiryTask{objInfo: oi, event: event, src: src}
    	wrkr := es.getWorkerCh(task.OpHash())
    	if wrkr == nil {
    		es.stats.missedExpiryTasks.Add(1)
    		return
    	}
    	select {
    	case <-GlobalContext.Done():
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/util/GsaConfigParser.java

            globalParams.clear();
            tagQueue.clear();
        }
    
        /**
         * SAX event handler called when an XML start element is encountered.
         * Processes collection definitions and tracks the element hierarchy.
         *
         * @param uri the namespace URI, or empty string if none
         * @param localName the local name without prefix, or empty string if namespace processing is not performed
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  8. cmd/iam-etcd-store.go

    						// re-init the watch channel.
    						goto outerLoop
    					}
    					for _, event := range watchResp.Events {
    						isCreateEvent := event.IsModify() || event.IsCreate()
    						isDeleteEvent := event.Type == etcd.EventTypeDelete
    
    						switch {
    						case isCreateEvent:
    							ch <- iamWatchEvent{
    								isCreated: true,
    								keyPath:   string(event.Kv.Key),
    							}
    						case isDeleteEvent:
    							ch <- iamWatchEvent{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  9. cmd/object-handlers-common.go

    		}
    	}
    	cs, _ := objInfo.decryptChecksums(0, h)
    	hash.AddChecksumHeader(w, cs)
    }
    
    func deleteObjectVersions(ctx context.Context, o ObjectLayer, bucket string, toDel []ObjectToDelete, lcEvent []lifecycle.Event) {
    	for remaining := toDel; len(remaining) > 0; toDel = remaining {
    		if len(toDel) > maxDeleteList {
    			remaining = toDel[maxDeleteList:]
    			toDel = toDel[:maxDeleteList]
    		} else {
    			remaining = nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jul 23 12:36:06 UTC 2025
    - 15.2K bytes
    - Viewed (0)
  10. src/main/webapp/js/admin/plugins/form-validator/jquery.form-validator.min.js

    &&i.validateOnKeyUp(c,d),this},a.fn.validateOnKeyUp=function(b,c){return this.each(function(){var d=a(this);d.valAttr("has-keyup-event")||d.valAttr("has-keyup-event","true").bind("keyup.validation",function(a){9!==a.keyCode&&d.validateInputOnBlur(b,c,!1,"keyup")})}),this},a.fn.removeKeyUpValidation=function(){return this.each(function(){a(this).valAttr("has-keyup-event",!1).unbind("keyup.validation")}),this},a.fn.valAttr=function(a,b){return b===c?this.attr("data-validation-"+a):b===!1||null===b...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 32.8K bytes
    - Viewed (0)
Back to top