Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for BatchSize (0.12 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/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)
  6. 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)
  7. 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)
  8. 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)
  9. tests/query_test.go

    	}
    
    	targetUsers := users[3:8]
    	for i := 0; i < len(targetUsers); i++ {
    		AssertEqual(t, results[i], targetUsers[i])
    	}
    
    	var sub1 []User
    	// limit < batchSize
    	if result := DB.Limit(5).Where("name = ?", users[0].Name).FindInBatches(&sub1, 10, func(tx *gorm.DB, batch int) error {
    		return nil
    	}); result.Error != nil || result.RowsAffected != 5 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 50.4K bytes
    - Viewed (0)
Back to top