Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 241 - 250 of 326 for atomic (0.04 seconds)

  1. 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)
  2. internal/s3select/sql/jsondata/books.json

                "pages": 432
            }
        ]
    }
    {
        "title": "Pigs Have Wings",
        "authorInfo": {
            "name": "P. G. Wodehouse",
            "yearRange": [1881, 1975]
        },
        "genre": "Comic novel",
        "publicationHistory": [
            {
                "year": 1952,
                "publisher": "Doubleday & Company",
                "type": "Hardcover"
            },
            {
                "year": 2000,
    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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. schema/index.go

    					idx        = strings.IndexByte(tag, ',')
    					tagSetting = strings.Join(strings.Split(tag, ",")[1:], ",")
    					settings   = ParseTagSetting(tagSetting, ",")
    					length, _  = strconv.Atoi(settings["LENGTH"])
    				)
    
    				if idx == -1 {
    					idx = len(tag)
    				}
    
    				name = tag[0:idx]
    				if name == "" {
    					subName := field.Name
    					const key = "COMPOSITE"
    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)
  10. 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)
Back to Top