Search Options

Results per page
Sort
Preferred Languages
Advance

Results 601 - 610 of 2,181 for Next (0.03 sec)

  1. docs/en/docs/advanced/generate-clients.md

    But I'll show you how to improve that next. 🤓
    
    ## Custom Operation IDs and Better Method Names
    
    You can **modify** the way these operation IDs are **generated** to make them simpler and have **simpler method names** in the clients.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. cmd/bucket-stats.go

    func (l *ReplicationLastHour) forwardTo(t int64) {
    	if l.LastMin >= t {
    		return
    	}
    	if t-l.LastMin >= 60 {
    		l.Totals = [60]AccElem{}
    		return
    	}
    	for l.LastMin != t {
    		// Clear next element.
    		idx := (l.LastMin + 1) % 60
    		l.Totals[idx] = AccElem{}
    		l.LastMin++
    	}
    }
    
    // BucketStatsMap captures bucket statistics for all buckets
    type BucketStatsMap struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. internal/grid/handlers.go

    // If the context is canceled, the stream will be canceled.
    func (s *TypedStream[Req, Resp]) Results(next func(resp Resp) error) (err error) {
    	return s.responses.Results(func(b []byte) error {
    		resp := s.newResp()
    		_, err := resp.UnmarshalMsg(b)
    		if err != nil {
    			return err
    		}
    		return next(resp)
    	})
    }
    
    // Streamer creates a stream.
    type Streamer interface {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Cookie.kt

            set(Calendar.SECOND, second)
            set(Calendar.MILLISECOND, 0)
            return timeInMillis
          }
        }
    
        /**
         * Returns the index of the next date character in `input`, or if `invert` the index
         * of the next non-date character in `input`.
         */
        private fun dateCharacterOffset(
          input: String,
          pos: Int,
          limit: Int,
          invert: Boolean,
        ): Int {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:12:05 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    					z.mpCache.Delete(id)
    					// No need to notify to peers, each node will delete its own cache.
    				}
    				return true
    			})
    
    			// Reset for the next interval
    			timer.Reset(globalAPIConfig.getStaleUploadsCleanupInterval())
    		}
    	}
    }
    
    func (z *erasureServerPools) NewNSLock(bucket string, objects ...string) RWLocker {
    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. cmd/erasure-sets.go

    		select {
    		case <-ctx.Done():
    			return
    		case <-monitor.C:
    			if serverDebugLog {
    				console.Debugln("running drive monitoring")
    			}
    
    			s.connectDisks(true)
    
    			// Reset the timer for next interval
    			monitor.Reset(monitorInterval)
    		}
    	}
    }
    
    func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) {
    	return func() ([]dsync.NetLocker, string) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  7. common/scripts/metallb-native.yaml

                    type: integer
                  nodeSelectors:
                    description: NodeSelectors allows to limit the nodes to announce as
                      next hops for the LoadBalancer IP. When empty, all the nodes having  are
                      announced as next hops.
                    items:
                      description: A label selector is a label query over a set of resources.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Feb 23 23:56:31 UTC 2024
    - 63.9K bytes
    - Viewed (0)
  8. tensorflow/c/c_api_experimental.h

    // When `enable` is true, set
    // tensorflow.ConfigProto.OptimizerOptions.global_jit_level to ON_1, and also
    // set XLA flag values to prepare for XLA compilation. Otherwise set
    // global_jit_level to OFF.
    //
    // This and the next API are syntax sugar over TF_SetConfig(), and is used by
    // clients that cannot read/write the tensorflow.ConfigProto proto.
    // TODO: Migrate to TF_CreateConfig() below.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  9. cmd/format-erasure_test.go

    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		b.Fatal(err)
    	}
    
    	endpoints := mustGetNewEndpoints(0, 16, fsDirs...)
    	b.RunParallel(func(pb *testing.PB) {
    		endpoints := endpoints
    		for pb.Next() {
    			initStorageDisksWithErrors(endpoints, storageOpts{cleanUp: false, healthCheck: false})
    		}
    	})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/CommonsCliMavenOptions.java

                        List<String> values = option.getValuesList();
                        for (ListIterator<String> it = values.listIterator(); it.hasNext(); ) {
                            it.set(interpolator.interpolate(it.next()));
                        }
                    }
                    commandLineBuilder.addOption(option);
                }
                for (String arg : options.commandLine.getArgList()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 16K bytes
    - Viewed (0)
Back to top