- Sort Score
- Result 10 results
- Languages All
Results 1051 - 1060 of 1,341 for varr (0.08 sec)
-
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) -
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) -
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) -
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) -
okhttp/src/main/kotlin/okhttp3/Headers.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)