Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 196 for send0 (0.71 sec)

  1. src/main/java/org/codelibs/fess/helper/NotificationHelper.java

        /** Line feed character for message formatting. */
        protected static final char LF = '\n';
    
        /**
         * Sends notifications to configured platforms.
         *
         * @param cardView the card view for the notification
         * @param discloser the mail posting discloser
         */
        public void send(final CardView cardView, final SMailPostingDiscloser discloser) {
            sendToSlack(cardView, discloser);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  2. internal/event/target/mqtt.go

    }
    
    func (target *MQTTTarget) isActive() (bool, error) {
    	if !target.client.IsConnectionOpen() {
    		return false, store.ErrNotConnected
    	}
    	return true, nil
    }
    
    // send - sends an event to the mqtt.
    func (target *MQTTTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. internal/event/target/nsq.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 NSQ.
    func (target *NSQTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbTreeInternal.java

        /**
         * Sends an SMB request and returns the response
         * @param <T> the response type
         * @param request the request to send
         * @param params optional request parameters
         * @return response message
         * @throws CIFSException if an error occurs sending the request
         */
        <T extends CommonServerMessageBlockResponse> T send(Request<T> request, RequestParam... params) throws CIFSException;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  5. internal/event/target/webhook.go

    		return err
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	err := target.send(eventData)
    	if err != nil {
    		if xnet.IsNetworkOrHostDown(err, false) {
    			return store.ErrNotConnected
    		}
    	}
    	return err
    }
    
    // send - sends an event to the webhook.
    func (target *WebhookTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. 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.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  7. internal/grid/muxserver.go

    	go func() {
    		wg.Wait()
    		defer xioutil.SafeClose(send)
    		err := m.handleRequests(ctx, msg, send, handler, handlerIn)
    		if err != nil {
    			handlerErr.Store(err)
    		}
    	}()
    
    	// Response sender goroutine...
    	go func(outBlock <-chan struct{}) {
    		wg.Wait()
    		defer m.parent.deleteMux(true, m.ID)
    		m.sendResponses(ctx, send, c, &handlerErr, outBlock)
    	}(m.outBlock)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  8. cmd/event-notification.go

    	evnot.targetList.Remove(targetIDSet)
    }
    
    // Send - sends the event to all registered notification targets
    func (evnot *EventNotifier) Send(args eventArgs) {
    	evnot.RLock()
    	targetIDSet := evnot.bucketRulesMap[args.BucketName].Match(args.EventName, args.Object.Name)
    	evnot.RUnlock()
    
    	if len(targetIDSet) == 0 {
    		return
    	}
    
    	// If MINIO_API_SYNC_EVENTS is set, send events synchronously.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  9. internal/event/targetlist_test.go

    func (target ExampleTarget) ID() TargetID {
    	return target.id
    }
    
    // Save - Sends event directly without persisting.
    func (target ExampleTarget) Save(eventData Event) error {
    	return target.send(eventData)
    }
    
    // Store - Returns a nil store.
    func (target ExampleTarget) Store() TargetStore {
    	return nil
    }
    
    func (target ExampleTarget) send(eventData Event) error {
    	b := make([]byte, 1)
    	if _, err := rand.Read(b); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 6K bytes
    - Viewed (0)
  10. internal/event/target/redis.go

    		return err
    	}
    	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 redis.
    func (target *RedisTarget) send(eventData event.Event) error {
    	conn := target.pool.Get()
    	defer conn.Close()
    
    	if target.args.Format == event.NamespaceFormat {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 9.1K bytes
    - Viewed (0)
Back to top