Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 150 for channel2 (0.23 seconds)

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

  1. docs/bucket/notifications/README.md

    import pika
    
    connection = pika.BlockingConnection(pika.ConnectionParameters(
            host='localhost'))
    channel = connection.channel()
    
    channel.exchange_declare(exchange='bucketevents',
                             exchange_type='fanout')
    
    result = channel.queue_declare(exclusive=False)
    queue_name = result.method.queue
    
    channel.queue_bind(exchange='bucketevents',
                       queue=queue_name)
    
    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)
  2. internal/event/target/postgresql.go

    				return store.ErrNotConnected
    			}
    			return err
    		}
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  3. internal/dsync/drwmutex.go

    // does not exist in enough quorum nodes.
    func refreshLock(ctx context.Context, ds *Dsync, id, source string, quorum int) (bool, error) {
    	restClnts, _ := ds.GetLockers()
    
    	// Create buffered channel of size equal to total number of nodes.
    	ch := make(chan refreshResult, len(restClnts))
    	var wg sync.WaitGroup
    
    	args := LockArgs{
    		UID: id,
    	}
    
    	for index, c := range restClnts {
    		wg.Add(1)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  4. cmd/global-heal.go

    				}
    				return false
    			case results <- result:
    				bgSeq.countScanned(madmin.HealItemObject)
    				return true
    			}
    		}
    
    		// Note: updates from healEntry to tracker must be sent on results channel.
    		healEntry := func(bucket string, entry metaCacheEntry) {
    			defer jt.Give()
    
    			if entry.name == "" && len(entry.metadata) == 0 {
    				// ignore entries that don't have metadata.
    				return
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  5. internal/event/target/redis.go

    			}
    			return err
    		}
    		target.firstPing = true
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and would've been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  6. cmd/peer-rest-server.go

    	}
    
    	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())
    	err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
    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)
  7. internal/grid/README.md

    If the remote handler is blocked on a send, and the client is trying to send without the remote receiving,
    the operation would become deadlocked if the channels are full.
    
    ### Typed handlers
    
    Typed handlers are handlers that have a specific type for the request and response payloads.
    
    ```go
        // Create a typed handler.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  8. cmd/metacache-entries.go

    			m.o[i].metadata = nil
    		}
    	}
    	m.o = m.o[idx:]
    }
    
    // mergeEntryChannels will merge entries from in and return them sorted on out.
    // To signify no more results are on an input channel, close it.
    // The output channel will be closed when all inputs are emptied.
    // If file names are equal, compareMeta is called to select which one to choose.
    // The entry not chosen will be discarded.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  9. cmd/handler-api.go

    		t.staleUploadsCleanupInterval = cfg.StaleUploadsCleanupInterval
    
    		// signal that cleanup interval has changed
    		select {
    		case staleUploadsCleanupIntervalChangedCh <- struct{}{}:
    		default: // in case the channel is blocked...
    		}
    	}
    }
    
    func (t *apiConfig) odirectEnabled() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.enableODirect
    }
    
    func (t *apiConfig) shouldGzipObjects() bool {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  10. cmd/bucket-lifecycle.go

    	}
    }
    
    // globalExpiryState is the per-node instance which manages all ILM expiry tasks.
    var globalExpiryState *expiryState
    
    // newExpiryState creates an expiryState with buffered channels allocated for
    // each ILM expiry task type.
    func newExpiryState(ctx context.Context, objAPI ObjectLayer, n int) *expiryState {
    	es := &expiryState{
    		ctx:    ctx,
    		objAPI: objAPI,
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
Back to Top