Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 250 for eventbus (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. .github/workflows/multipart/nginx-site1.conf

    user  nginx;
    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Sep 30 10:13:56 GMT 2023
    - 1.7K bytes
    - Click Count (0)
  2. .github/workflows/multipart/nginx-site2.conf

    user  nginx;
    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Sep 30 10:13:56 GMT 2023
    - 1.7K bytes
    - Click Count (0)
  3. cmd/event-notification.go

    	"github.com/minio/minio/internal/event"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/pubsub"
    	"github.com/minio/pkg/v3/policy"
    )
    
    // EventNotifier - notifies external systems about events in MinIO.
    type EventNotifier struct {
    	sync.RWMutex
    	targetList     *event.TargetList
    	bucketRulesMap map[string]event.RulesMap
    }
    
    // NewEventNotifier - creates new event notification object.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 21 22:22:24 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  4. tests/test_tutorial/test_events/test_tutorial003.py

    from fastapi.testclient import TestClient
    
    from docs_src.events.tutorial003_py39 import (
        app,
        fake_answer_to_everything_ml_model,
        ml_models,
    )
    
    
    def test_events():
        assert not ml_models, "ml_models should be empty"
        with TestClient(app) as client:
            assert ml_models["answer_to_everything"] == fake_answer_to_everything_ml_model
            response = client.get("/predict", params={"x": 2})
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  5. tests/test_tutorial/test_events/test_tutorial001.py

    import pytest
    from fastapi import FastAPI
    from fastapi.testclient import TestClient
    
    
    @pytest.fixture(name="app", scope="module")
    def get_app():
        with pytest.warns(DeprecationWarning):
            from docs_src.events.tutorial001_py39 import app
        yield app
    
    
    def test_events(app: FastAPI):
        with TestClient(app) as client:
            response = client.get("/items/foo")
            assert response.status_code == 200, response.text
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  6. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelBuildingEventCatapult.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.model.building;
    
    /**
     * Assists in firing events from a generic method by abstracting from the actual callback method to be called on the
     * listener.
     *
     * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead
     */
    @Deprecated(since = "4.0.0")
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/NotifyResponse.java

    /**
     * Interface for SMB change notification response messages.
     * Handles responses from directory change notification requests, providing information
     * about file system changes such as file creation, deletion, or modification events.
     *
     * @author mbechler
     */
    public interface NotifyResponse extends CommonServerMessageBlockResponse {
    
        /**
         * Gets the file notification information from the response.
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/entity/SearchLogEvent.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.entity;
    
    import java.util.Map;
    
    /**
     * Interface for search log events in the Fess search system.
     *
     * This interface defines the contract for search log event objects that can be
     * written to log files or stored in the search index. Implementations include
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  9. cmd/batch-replicate_test.go

               value: "image/*" # match objects with 'content-type', with all values starting with 'image/'
    
    #    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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 01 12:53:30 GMT 2024
    - 7.9K bytes
    - Click Count (0)
  10. internal/event/target/webhook.go

    	if err != nil {
    		if xnet.IsNetworkOrHostDown(err, false) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	defer conn.Close()
    	return true, nil
    }
    
    // Save - saves the events to the store if queuestore is configured,
    // which will be replayed when the webhook connection is active.
    func (target *WebhookTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.8K bytes
    - Click Count (0)
Back to Top