Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for queueMsg (0.23 sec)

  1. internal/grid/connection.go

    	select {
    	case <-ctx.Done():
    		// Returning error here is too noisy.
    		return nil
    	case c.outQueue <- msg:
    		return nil
    	}
    }
    
    // queueMsg queues a message, with an optional payload.
    // sender should not reference msg.Payload
    func (c *Connection) queueMsg(msg message, payload sender) error {
    	// Add baseflags.
    	msg.Flags.Set(c.baseFlags)
    	// This cannot encode subroute.
    	msg.Flags.Clear(FlagSubroute)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    	m.sendMu.Lock()
    	defer m.sendMu.Unlock()
    	msg.MuxID = m.ID
    	msg.Seq = m.SendSeq
    	m.SendSeq++
    	if debugPrint {
    		fmt.Printf("Mux %d, Sending %+v\n", m.ID, msg)
    	}
    	gridLogIf(m.ctx, m.parent.queueMsg(msg, nil))
    }
    
    func (m *muxServer) close() {
    	m.cancel()
    	m.recvMu.Lock()
    	defer m.recvMu.Unlock()
    
    	if m.inbound != nil {
    		xioutil.SafeClose(m.inbound)
    		m.inbound = nil
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  3. docs/bucket/replication/DESIGN.md

    ### Existing object replication
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  4. cmd/global-heal.go

    					madmin.HealOpts{
    						ScanMode: scanMode,
    						Remove:   healDeleteDangling,
    					})
    				if err != nil {
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// queueing happens across namespace, ignore
    						// objects that are not found.
    						return
    					}
    					result = healEntryFailure(0)
    					healingLogIf(ctx, fmt.Errorf("unable to heal object %s/%s: %w", bucket, entry.name, err))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  5. docs/bucket/notifications/README.md

    MinIO also sends with the notifications two headers: `minio-bucket` and `minio-event`. An exchange using the type "headers" can use this information to route the notifications to proper queues.
    
    Note that, you can add as many AMQP server endpoint configurations as needed by providing an identifier (like "1" in the example above) for the AMQP instance and an object of per-server configuration parameters.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  6. cmd/bucket-notification-handlers.go

    	if err = config.Validate(globalSite.Region, globalEventNotifier.targetList); err != nil {
    		arnErr, ok := err.(*event.ErrARNNotFound)
    		if ok {
    			for i, queue := range config.QueueList {
    				// Remove ARN not found queues, because we previously allowed
    				// adding unexpected entries into the config.
    				//
    				// With newer config disallowing changing / turning off
    				// notification targets without removing ARN in notification
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 5.1K bytes
    - Viewed (0)
Back to top