- Sort Score
- Num 10 results
- Language All
Results 1911 - 1920 of 2,315 for A_value (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/logger/target/kafka/kafka.go
status int32 totalMessages int64 failedMessages int64 wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan any logChMu sync.RWMutex // store to persist and replay the logs to the target // to avoid missing events when the target is down.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
compat/maven-plugin-api/src/test/java/org/apache/maven/plugin/descriptor/PluginDescriptorBuilderTest.java
PlexusConfiguration pc = md.getMojoConfiguration().getChild(0); assertEquals("${jar.finalName}", pc.getValue()); assertEquals("${project.build.finalName}", pc.getAttribute("default-value")); assertEquals("java.lang.String", pc.getAttribute("implementation")); Parameter mp = md.getParameters().get(0); assertEquals("finalName", mp.getName());Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Sep 17 10:01:14 GMT 2025 - 6K bytes - Click Count (0) -
docs/en/docs/tutorial/body-updates.md
```Python { "name": "Barz", "price": 3, "description": None, } ``` because it doesn't include the already stored attribute `"tax": 20.2`, the input model would take the default value of `"tax": 10.5`. And the data would be saved with that "new" `tax` of `10.5`. ## Partial updates with `PATCH` { #partial-updates-with-patch }Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Dec 20 15:55:38 GMT 2025 - 4.1K bytes - Click Count (0) -
docs/en/docs/tutorial/security/index.md
* `apiKey`: an application specific key that can come from: * A query parameter. * A header. * A cookie. * `http`: standard HTTP authentication systems, including: * `bearer`: a header `Authorization` with a value of `Bearer ` plus a token. This is inherited from OAuth2. * HTTP Basic authentication. * HTTP Digest, etc. * `oauth2`: all the OAuth2 ways to handle security (called "flows").Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 10:49:48 GMT 2025 - 4.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/TestingCacheLoaders.java
} /** * Returns a {@code new Object()} for every request, and increments a counter for every request. * An {@code Integer} loader that returns the key for {@code load} requests, and increments the * old value on {@code reload} requests. The load counts are accessible via {@link #getLoadCount} * and {@link #getReloadCount}. */ static class IncrementingLoader extends CacheLoader<Integer, Integer> {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Aug 10 19:54:19 GMT 2025 - 5.1K bytes - Click Count (0) -
cmd/data-usage.go
if !ok { // Prefix usage is empty return map[string]uint64{}, nil } cache := dataUsageCache{} prefixUsageCache.InitOnce(30*time.Second, // No need to fail upon Update() error, fallback to old value. cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (map[string]uint64, error) { m := make(map[string]uint64) for _, pool := range z.serverPools { for _, er := range pool.sets {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu May 09 00:51:34 GMT 2024 - 5.6K bytes - Click Count (0) -
cmd/tier-sweeper.go
// removed from remote tier. If remote object is to be deleted, returns the // corresponding tier deletion journal entry and true. Otherwise returns empty // jentry value and false. func (os *objSweeper) shouldRemoveRemoteObject() (jentry, bool) { if os.TransitionStatus != lifecycle.TransitionComplete { return jentry{}, false }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Click Count (0) -
internal/crypto/error.go
// modified accidentally or maliciously. type Error struct { msg string cause error } // Errorf - formats according to a format specifier and returns // the string as a value that satisfies error of type crypto.Error func Errorf(format string, a ...any) error { e := fmt.Errorf(format, a...) ee := Error{} ee.msg = e.Error() ee.cause = errors.Unwrap(e) return ee }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.4K bytes - Click Count (0) -
src/bytes/reader.go
// [io.ByteScanner], and [io.RuneScanner] interfaces by reading from // a byte slice. // Unlike a [Buffer], a Reader is read-only and supports seeking. // The zero value for Reader operates like a Reader of an empty slice. type Reader struct { s []byte i int64 // current reading index prevRune int // index of previous rune; or < 0 }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Jul 16 18:17:37 GMT 2024 - 3.9K bytes - Click Count (0) -
cmd/encryption-v1_test.go
{ ObjectKey: [32]byte{}, ObjectInfo: ObjectInfo{ETag: "20000f00f27834c9a2654927546df57f9e998187496394d4ee80f3d9978f85f3c7d81f72600cdbe03d80dc5a13d6935"}, ETag: "", ShouldFail: true, // ETag is not a valid hex value }, { ObjectKey: [32]byte{}, ObjectInfo: ObjectInfo{ETag: "00000f00f27834c9a2654927546df57f9e998187496394d4ee80f3d9978f85f3c7d81f72600cdbe03d80dc5a13d69354"}, ETag: "",Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.9K bytes - Click Count (0)