Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 25 for publisher (0.09 seconds)

  1. cmd/peer-rest-server.go

    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  2. docs/bucket/notifications/README.md

    notify_webhook        publish bucket notifications to webhook endpoints
    notify_amqp           publish bucket notifications to AMQP endpoints
    notify_kafka          publish bucket notifications to Kafka endpoints
    notify_mqtt           publish bucket notifications to MQTT endpoints
    notify_nats           publish bucket notifications to NATS endpoints
    notify_nsq            publish bucket notifications to NSQ endpoints
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  3. cmd/batch-handlers.go

    		if globalTrace.NumSubscribers(madmin.TraceBatch) > 0 {
    			globalTrace.Publish(batchJobTrace(d, job, startTime, duration, info, attempts, err))
    			return
    		}
    		switch d {
    		case batchJobMetricReplication:
    			if globalTrace.NumSubscribers(madmin.TraceBatchReplication) > 0 {
    				globalTrace.Publish(batchJobTrace(d, job, startTime, duration, info, attempts, err))
    			}
    		case batchJobMetricKeyRotation:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  4. cmd/api-errors.go

    //
    // This file is part of MinIO Object Storage stack
    //
    // This program is free software: you can redistribute it and/or modify
    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 16 07:34:24 GMT 2025
    - 93K bytes
    - Click Count (3)
  5. fess-crawler-lasta/src/main/resources/crawler/extractor.xml

    				"application/vnd.powerbuilder75",
    				"application/vnd.powerbuilder75-s",
    				"application/vnd.preminet",
    				"application/vnd.previewsystems.box",
    				"application/vnd.proteus.magazine",
    				"application/vnd.publishare-delta-tree",
    				"application/vnd.pvi.ptid1",
    				"application/vnd.pwg-multiplexed",
    				"application/vnd.pwg-xhtml-print+xml",
    				"application/vnd.qualcomm.brew-app-res",
    				"application/vnd.quark.quarkxpress",
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Feb 11 01:15:55 GMT 2026
    - 50.4K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/SmbSessionImpl.java

     * Copyright (C) 2000  "Michael B. Allen" <jcifs at samba dot org>
     *
     * This library is free software; you can redistribute it and/or
     * modify it under the terms of the GNU Lesser General Public
     * License as published by the Free Software Foundation; either
     * version 2.1 of the License, or (at your option) any later version.
     *
     * This library is distributed in the hope that it will be useful,
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 68.9K bytes
    - Click Count (0)
  7. internal/bucket/lifecycle/lifecycle_test.go

    //
    // This file is part of MinIO Object Storage stack
    //
    // This program is free software: you can redistribute it and/or modify
    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 55.5K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb/SmbTransportImpl.java

     *                  "Eric Glass" <jcifs at samba dot org>
     *
     * This library is free software; you can redistribute it and/or
     * modify it under the terms of the GNU Lesser General Public
     * License as published by the Free Software Foundation; either
     * version 2.1 of the License, or (at your option) any later version.
     *
     * This library is distributed in the hope that it will be useful,
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 69.8K bytes
    - Click Count (0)
  9. cmd/bucket-handlers.go

    //
    // This file is part of MinIO Object Storage stack
    //
    // This program is free software: you can redistribute it and/or modify
    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

            //
            // This is not ideal but there are events specifically for configuration from the CLI which I don't
            // believe are really valid but there are ITs which assert the right events are published so this
            // needs to be supported so the EventSpyDispatcher needs to be put in the CliRequest so that
            // it can be accessed by configuration processors.
            //
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Oct 27 13:24:03 GMT 2025
    - 78.1K bytes
    - Click Count (0)
Back to Top