Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for noWait (0.1 sec)

  1. internal/event/target/amqp.go

    	Mandatory         bool     `json:"mandatory"`
    	Immediate         bool     `json:"immediate"`
    	Durable           bool     `json:"durable"`
    	Internal          bool     `json:"internal"`
    	NoWait            bool     `json:"noWait"`
    	AutoDeleted       bool     `json:"autoDeleted"`
    	PublisherConfirms bool     `json:"publisherConfirms"`
    	QueueDir          string   `json:"queueDir"`
    	QueueLimit        uint64   `json:"queueLimit"`
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    	h.currentStatus.Items = nil
    
    	return jbytes, ErrNone
    }
    
    // healSource denotes single entity and heal option.
    type healSource struct {
    	bucket    string
    	object    string
    	versionID string
    	noWait    bool             // a non blocking call, if task queue is full return right away.
    	opts      *madmin.HealOpts // optional heal option overrides default setting
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    func (f *folderScanner) scanFolder(ctx context.Context, folder cachedFolder, into *dataUsageEntry) error {
    	done := ctx.Done()
    	scannerLogPrefix := color.Green("folder-scanner:")
    
    	noWait := func() {}
    
    	thisHash := hashPath(folder.name)
    	// Store initial compaction state.
    	wasCompacted := into.Compacted
    
    	for {
    		select {
    		case <-done:
    			return ctx.Err()
    		default:
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  4. internal/config/notify/parse.go

    			Durable:           env.Get(durableEnv, kv.Get(target.AmqpDurable)) == config.EnableOn,
    			Internal:          env.Get(internalEnv, kv.Get(target.AmqpInternal)) == config.EnableOn,
    			NoWait:            env.Get(noWaitEnv, kv.Get(target.AmqpNoWait)) == config.EnableOn,
    			AutoDeleted:       env.Get(autoDeletedEnv, kv.Get(target.AmqpAutoDeleted)) == config.EnableOn,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    func (z *erasureServerPools) ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error) {
    	if opts.Cached {
    		listBucketsCache.InitOnce(time.Second,
    			cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    			func(ctx context.Context) ([]BucketInfo, error) {
    				ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    				defer cancel()
    
    				buckets, err = z.s3Peer.ListBuckets(ctx, opts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. docs/nl/docs/python-types.md

    **FastAPI** is helemaal gebaseerd op deze type hints, ze geven veel voordelen.
    
    Maar zelfs als je **FastAPI** nooit gebruikt, heb je er baat bij om er iets over te leren.
    
    /// note
    
    Als je een Python expert bent en alles al weet over type hints, sla dan dit hoofdstuk over.
    
    ///
    
    ## Motivatie
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 18.3K bytes
    - Viewed (0)
Back to top