Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for BatchSize (0.06 sec)

  1. internal/logger/config.go

    			return cfg, err
    		}
    		if queueSize <= 0 {
    			return cfg, errInvalidQueueSize
    		}
    		batchSizeCfgVal := getCfgVal(EnvLoggerWebhookBatchSize, k, kv.Get(BatchSize))
    		batchSize, err := strconv.Atoi(batchSizeCfgVal)
    		if err != nil {
    			return cfg, err
    		}
    		if batchSize <= 0 {
    			return cfg, errInvalidBatchSize
    		}
    		maxRetryCfgVal := getCfgVal(EnvLoggerWebhookMaxRetry, k, kv.Get(MaxRetry))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. internal/event/target/kafka.go

    	QueueDir           string        `json:"queueDir"`
    	QueueLimit         uint64        `json:"queueLimit"`
    	Version            string        `json:"version"`
    	BatchSize          uint32        `json:"batchSize"`
    	BatchCommitTimeout time.Duration `json:"batchCommitTimeout"`
    	TLS                struct {
    		Enable        bool               `json:"enable"`
    		RootCAs       *x509.CertPool     `json:"-"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. finisher_api.go

    		} else if result.Error != nil {
    			tx.AddError(result.Error)
    		}
    
    		if tx.Error != nil || int(result.RowsAffected) < batchSize {
    			break
    		}
    
    		if totalSize > 0 {
    			if totalSize <= int(rowsAffected) {
    				break
    			}
    			if totalSize/batchSize == batch {
    				batchSize = totalSize % batchSize
    			}
    		}
    
    		// Optimize for-break
    		resultsValue := reflect.Indirect(reflect.ValueOf(dest))
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    func New(config Config) (*Target, error) {
    	maxWorkers := maxWorkers
    	if config.BatchSize > 100 {
    		maxWorkers = maxWorkersWithBatchEvents
    	} else if config.BatchSize <= 0 {
    		config.BatchSize = 1
    	}
    
    	h := &Target{
    		logCh:       make(chan interface{}, config.QueueSize),
    		config:      config,
    		batchSize:   config.BatchSize,
    		maxWorkers:  int64(maxWorkers),
    		httpTimeout: config.HTTPTimeout,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb1/trans2/Trans2FindNext2.java

        /**
         * 
         * @param config
         * @param sid
         * @param resumeKey
         * @param filename
         * @param batchCount
         * @param batchSize
         */
        public Trans2FindNext2 ( Configuration config, int sid, int resumeKey, String filename, int batchCount, int batchSize ) {
            super(config, SMB_COM_TRANSACTION2, TRANS2_FIND_NEXT2);
            this.sid = sid;
            this.resumeKey = resumeKey;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb1/trans2/Trans2FindFirst2.java

         * @param config
         * @param filename
         * @param wildcard
         * @param searchAttributes
         * @param batchCount
         * @param batchSize
         */
        public Trans2FindFirst2 ( Configuration config, String filename, String wildcard, int searchAttributes, int batchCount, int batchSize ) {
            super(config, SMB_COM_TRANSACTION2, TRANS2_FIND_FIRST2);
            if ( filename.equals("\\") ) {
                this.path = filename;
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

            final SearchLogBhv searchLogBhv = ComponentUtil.getComponent(SearchLogBhv.class);
            final int batchSize = ComponentUtil.getFessConfig().getSearchlogProcessBatchSizeAsInteger();
            final int totalSize = searchLogList.size();
            for (int i = 0; i < totalSize; i += batchSize) {
                final int end = Math.min(totalSize, i + batchSize);
                if (logger.isDebugEnabled()) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jul 22 02:07:37 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  8. internal/logger/help.go

    			Key:         ClientKey,
    			Description: "mTLS certificate key for webhook authentication",
    			Optional:    true,
    			Type:        "string",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         BatchSize,
    			Description: "Number of events per HTTP send to webhook target",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueSize,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. cmd/encryption-v1.go

    	const BatchSize = 250 // We process the objects in batches - 250 is a reasonable default.
    	var (
    		metadata = make([]map[string]string, 0, BatchSize)
    		buckets  = make([]string, 0, BatchSize)
    		names    = make([]string, 0, BatchSize)
    	)
    	for len(objects) > 0 {
    		N := BatchSize
    		if len(objects) < BatchSize {
    			N = len(objects)
    		}
    		batch := objects[:N]
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  10. internal/config/notify/parse.go

    			QueueDir:           env.Get(queueDirEnv, kv.Get(target.KafkaQueueDir)),
    			QueueLimit:         queueLimit,
    			Version:            env.Get(versionEnv, kv.Get(target.KafkaVersion)),
    			BatchSize:          uint32(batchSize),
    			BatchCommitTimeout: batchCommitTimeout,
    		}
    
    		tlsEnableEnv := target.EnvKafkaTLS
    		if k != config.Default {
    			tlsEnableEnv = tlsEnableEnv + config.Default + k
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
Back to top