Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 646 for sends (0.02 seconds)

  1. internal/config/lambda/event/targetlist.go

    	maps.Copy(ntargets, list.targets)
    	return ntargets
    }
    
    // Send - sends events to targets identified by target IDs.
    func (list *TargetList) Send(event Event, id TargetID) (*http.Response, error) {
    	list.RLock()
    	target, ok := list.targets[id]
    	list.RUnlock()
    	if ok {
    		return target.Send(event)
    	}
    	return nil, ErrARNNotFound{}
    }
    
    // Stats returns stats for targets.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  2. internal/event/target/mysql.go

    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the mysql.
    func (target *MySQLTarget) send(eventData event.Event) error {
    	if target.args.Format == event.NamespaceFormat {
    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/filter/LoadControlFilter.java

            if (dotIndex >= 0) {
                final String extension = path.substring(dotIndex);
                return STATIC_EXTENSIONS.contains(extension);
            }
            return false;
        }
    
        /**
         * Sends a 429 JSON response for API requests.
         * @param response the HTTP response
         * @throws IOException if an I/O error occurs
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Tue Feb 10 04:24:02 GMT 2026
    - 4.8K bytes
    - Click Count (0)
  4. cmd/peer-rest-client.go

    	return nil
    }
    
    // CommitBinary - sends commit binary message to remote peers.
    func (client *peerRESTClient) CommitBinary(ctx context.Context) error {
    	respBody, err := client.callWithContext(ctx, peerRESTMethodCommitBinary, nil, nil, -1)
    	if err != nil {
    		return err
    	}
    	defer xhttp.DrainBody(respBody)
    	return nil
    }
    
    // SignalService - sends signal to peer nodes.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  5. docs/iam/access-management-plugin.md

    MinIO now includes support for using an Access Management Plugin. This is to allow object storage access control to be managed externally via a webhook.
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Dec 13 22:28:48 GMT 2022
    - 4.4K bytes
    - Click Count (1)
  6. internal/event/target/nats.go

    	}
    
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the Nats.
    func (target *NATSTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  7. fastapi/sse.py

                """
            ),
        ] = None
        raw_data: Annotated[
            str | None,
            Doc(
                """
                Raw string to send as the `data:` field **without** JSON encoding.
    
                Use this when you need to send pre-formatted text, HTML fragments,
                CSV lines, or any non-JSON payload. The string is placed directly
                into the `data:` field as-is.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 01 09:21:52 GMT 2026
    - 6.2K bytes
    - Click Count (0)
  8. internal/event/target/elasticsearch.go

    	err := target.checkAndInitClient(ctx)
    	if err != nil {
    		return err
    	}
    
    	err = target.send(eventData)
    	if xnet.IsNetworkOrHostDown(err, false) {
    		return store.ErrNotConnected
    	}
    	return err
    }
    
    // send - sends the event to the target.
    func (target *ElasticsearchTarget) send(eventData event.Event) error {
    	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    	defer cancel()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  9. docs/en/docs/tutorial/cors.md

    Then, the browser will send an HTTP `OPTIONS` request to the `:80`-backend, and if the backend sends the appropriate headers authorizing the communication from this different origin (`http://localhost:8080`) then the `:8080`-browser will let the JavaScript in the frontend send its request to the `:80`-backend.
    
    To achieve this, the `:80`-backend must have a list of "allowed origins".
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 5.2K bytes
    - Click Count (0)
  10. docs/en/docs/tutorial/server-sent-events.md

    `data` and `raw_data` are mutually exclusive. You can only set one of them on each `ServerSentEvent`.
    
    ///
    
    ## Resuming with `Last-Event-ID` { #resuming-with-last-event-id }
    
    When a browser reconnects after a connection drop, it sends the last received `id` in the `Last-Event-ID` header.
    
    You can read it as a header parameter and use it to resume the stream from where the client left off:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 4.6K bytes
    - Click Count (0)
Back to Top