- Sort Score
- Num 10 results
- Language All
Results 241 - 250 of 326 for atomic (0.04 seconds)
-
cmd/api-resources.go
if values.Get("max-parts") != "" { if maxParts, err = strconv.Atoi(values.Get("max-parts")); err != nil { errCode = ErrInvalidMaxParts return uploadID, partNumberMarker, maxParts, encodingType, errCode } } else { maxParts = maxPartsList } if values.Get("part-number-marker") != "" { if partNumberMarker, err = strconv.Atoi(values.Get("part-number-marker")); err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.2K bytes - Click Count (0) -
internal/s3select/sql/jsondata/books.json
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.9K bytes - Click Count (0) -
okhttp/build.gradle.kts
named("main") { manifest.srcFile("src/androidMain/AndroidManifest.xml") assets.srcDir("src/androidMain/assets") } } } // From https://github.com/Kotlin/kotlinx-atomicfu/blob/master/atomicfu/build.gradle.kts val compileJavaModuleInfo by tasks.registering(JavaCompile::class) { val moduleName = "okhttp3" val compilation = kotlin.targets["jvm"].compilations["main"]
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 12.3K bytes - Click Count (0) -
docs/bucket/notifications/README.md
``` KEY: notify_mqtt[:name] publish bucket notifications to MQTT endpoints ARGS: broker* (uri) MQTT server endpoint e.g. `tcp://localhost:1883` topic* (string) name of the MQTT topic to publish username (string) MQTT username password (string) MQTT password qos (number) set the quality of service priority, defaults to '0'
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0) -
internal/config/notify/legacy.go
brokers = append(brokers, broker.String()) } return strings.Join(brokers, config.ValueSeparator) }(), }, config.KV{ Key: target.KafkaTopic, Value: cfg.Topic, }, config.KV{ Key: target.KafkaQueueDir, Value: cfg.QueueDir, }, config.KV{ Key: target.KafkaClientTLSCert, Value: cfg.TLS.ClientTLSCert, }, config.KV{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.3K bytes - Click Count (0) -
internal/config/api/api.go
if err = config.CheckValidKeys(config.APISubSys, kvs, DefaultKVS, deprecatedKeys...); err != nil { return cfg, err } // Check environment variables parameters requestsMax, err := strconv.Atoi(env.Get(EnvAPIRequestsMax, kvs.GetWithDefault(apiRequestsMax, DefaultKVS))) if err != nil { return cfg, err } cfg.RequestsMax = requestsMax if requestsMax < 0 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.5K bytes - Click Count (1) -
internal/config/ilm/ilm.go
} if err = config.CheckValidKeys(config.ILMSubSys, kvs, DefaultKVS); err != nil { return cfg, err } tw, err := strconv.Atoi(env.Get(EnvILMTransitionWorkers, kvs.GetWithDefault(transitionWorkers, DefaultKVS))) if err != nil { return cfg, err } ew, err := strconv.Atoi(env.Get(EnvILMExpirationWorkers, kvs.GetWithDefault(expirationWorkers, DefaultKVS))) if err != nil { return cfg, err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 1.9K bytes - Click Count (0) -
internal/event/config_test.go
<Cloudcode>arn:aws:lambda:us-west-2:444455556666:cloud-function-A</Cloudcode> <Event>s3:ObjectCreated:Put</Event> </CloudFunctionConfiguration> <TopicConfiguration> <Topic>arn:aws:sns:us-west-2:444455556666:sns-notification-one</Topic> <Event>s3:ObjectCreated:*</Event> </TopicConfiguration> </NotificationConfiguration> `)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 28.9K bytes - Click Count (0) -
schema/index.go
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Wed May 21 02:35:56 GMT 2025 - 3.8K bytes - Click Count (0) -
internal/config/notify/help.go
Key: target.KafkaBrokers, Description: "comma separated list of Kafka broker addresses", Type: "csv", }, config.HelpKV{ Key: target.KafkaTopic, Description: "Kafka topic used for bucket notifications", Optional: true, Type: "string", }, config.HelpKV{ Key: target.KafkaSASLUsername, Description: "username for SASL/PLAIN or SASL/SCRAM authentication",
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 19.2K bytes - Click Count (0)