Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1051 - 1060 of 1,341 for varr (0.02 sec)

  1. cmd/admin-heal-ops.go

    	// completes.
    	keepHealSeqStateDuration = time.Minute * 10
    
    	// nopHeal is a no operating healing action to
    	// wait for the current healing operation to finish
    	nopHeal = ""
    )
    
    var (
    	errHealIdleTimeout   = errors.New("healing results were not consumed for too long")
    	errHealStopSignalled = errors.New("heal stop signaled")
    
    	errFnHealFromAPIErr = func(ctx context.Context, err error) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        )
    }
    
    @Timeout(60)
    @Tag("Slow")
    class DiskLruCacheTest {
      private lateinit var filesystem: FaultyFileSystem
      private var windows: Boolean = false
    
      @TempDir lateinit var cacheDirFile: File
      lateinit var cacheDir: Path
      private val appVersion = 100
      private lateinit var journalFile: Path
      private lateinit var journalBkpFile: Path
      private val taskFaker = TaskFaker()
      private val taskRunner = taskFaker.taskRunner
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  3. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

     */
    class LoggingEventListener private constructor(
      private val logger: HttpLoggingInterceptor.Logger,
    ) : EventListener() {
      private var startNs: Long = 0
    
      override fun callStart(call: Call) {
        startNs = System.nanoTime()
    
        logWithTime("callStart: ${call.request()}")
      }
    
      override fun proxySelectStart(
        call: Call,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. cni/pkg/plugin/kubernetes.go

    	res = append(res, pod.Spec.InitContainers...)
    	res = append(res, pod.Spec.Containers...)
    	return res
    }
    
    func (pi PodInfo) String() string {
    	var b strings.Builder
    	b.WriteString(fmt.Sprintf("  Containers: %v\n", sets.SortedList(pi.Containers)))
    	b.WriteString(fmt.Sprintf("  Labels: %+v\n", pi.Labels))
    	b.WriteString(fmt.Sprintf("  Annotations: %+v\n", pi.Annotations))
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/Headers.kt

       */
      fun byteCount(): Long {
        // Each header name has 2 bytes of overhead for ': ' and every header value has 2 bytes of
        // overhead for '\r\n'.
        var result = (namesAndValues.size * 2).toLong()
    
        for (i in 0 until namesAndValues.size) {
          result += namesAndValues[i].length.toLong()
        }
    
        return result
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. docs/tr/docs/python-types.md

    **FastAPI' nin** tamamı bu tür tip belirteçleri ile donatılmıştır ve birçok avantaj sağlamaktadır.
    
    **FastAPI** kullanmayacak olsanız bile tür belirteçleri hakkında bilgi edinmenizde fayda var.
    
    /// note | "Not"
    
    Python uzmanıysanız ve tip belirteçleri ilgili her şeyi zaten biliyorsanız, sonraki bölüme geçin.
    
    ///
    
    ## Motivasyon
    
    Basit bir örnek ile başlayalım:
    
    ```Python
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. internal/config/identity/openid/jwt.go

    	"github.com/minio/pkg/v3/policy"
    )
    
    type publicKeys struct {
    	*sync.RWMutex
    
    	// map of kid to public key
    	pkMap map[string]interface{}
    }
    
    func (pk *publicKeys) parseAndAdd(b io.Reader) error {
    	var jwk JWKS
    	err := json.NewDecoder(b).Decode(&jwk)
    	if err != nil {
    		return err
    	}
    
    	for _, key := range jwk.Keys {
    		pkey, err := key.DecodePublicKey()
    		if err != nil {
    			return err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. internal/event/target/redis.go

    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = conn.Do("HDEL", target.args.Key, key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    				return err
    			}
    
    			_, err = conn.Do("HSET", target.args.Key, key, data)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. cmd/admin-handler-utils.go

    	StatusCode int
    }
    
    func (ae AdminError) Error() string {
    	return ae.Message
    }
    
    func toAdminAPIErr(ctx context.Context, err error) APIError {
    	if err == nil {
    		return noError
    	}
    
    	var apiErr APIError
    	switch e := err.(type) {
    	case policy.Error:
    		apiErr = APIError{
    			Code:           "XMinioMalformedIAMPolicy",
    			Description:    e.Error(),
    			HTTPStatusCode: http.StatusBadRequest,
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt

          HTTP_PERM_REDIRECT, HTTP_TEMP_REDIRECT, HTTP_MULT_CHOICE, HTTP_MOVED_PERM, HTTP_MOVED_TEMP, HTTP_SEE_OTHER -> true
          else -> false
        }
    
    val Response.commonCacheControl: CacheControl
      get() {
        var result = lazyCacheControl
        if (result == null) {
          result = CacheControl.parse(headers)
          lazyCacheControl = result
        }
        return result
      }
    
    fun Response.commonClose() {
      body.close()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top