Skip to content
Snippets Groups Projects
Select Git revision
  • 67f634be9b312a5c35bf48b79634f043d07152da
  • master default protected
  • feature/PRXS-3156-SaveRevision
  • feature/PRXS-3421-RecursiveReferences
  • feature/PRXS-3043-NewURLFormat
  • feature/PRXS-3170-TemplateFuncsFix
  • docs/PRXS-2995-MailtoActions
  • docs/PRXS-2972-HugoModules
  • docs/PRXS-3127-NotificationsDataProcessor
  • feature/PRXS-3127-RevertTestify
  • feature/PRXS-3127-TempatesFakeData
  • feature/PRXS-3127-TempatesFakeData2
  • refactor/PRXS-3053-FilesFixSubmodule
  • docs/3247-PerxisWebCDN
  • docs/3247-СDNReleaseNotes
  • feature/3146-UpdateItemStorageInterface
  • feature/3180-RemoveOldHugo
  • feature/3264-FixExtracTranslationsArrays
  • feature/3274-ObjectIndexesFixes
  • feature/2931-AllowPartialDecode
  • feature/3055-ItemsRestAPI
  • v0.27.0
  • v0.21.0
  • v0.19.0
  • v0.20.0
25 results

environments.proto

Blame
  • config.go 1.29 KiB
    package zap
    
    import (
    	"time"
    )
    
    const (
    	defaultMaxBufferSize    = 1000
    	defaultMaxSyncQueueSize = 16
    	defaultFlushInterval    = 5 * time.Second
    )
    
    type config struct {
    	flushInterval    time.Duration
    	maxBufferSize    int
    	maxSyncQueueSize int
    }
    
    func newConfig(options []Option) *config {
    	cfg := new(config)
    	for _, option := range options {
    		option(cfg)
    	}
    
    	if cfg.flushInterval == 0 {
    		cfg.flushInterval = defaultFlushInterval
    	}
    
    	if cfg.maxBufferSize == 0 {
    		cfg.maxBufferSize = defaultMaxBufferSize
    	}
    
    	if cfg.maxSyncQueueSize == 0 {
    		cfg.maxSyncQueueSize = defaultMaxSyncQueueSize
    	}
    
    	return cfg
    }
    
    type Option func(config *config)
    
    // WithFlushInterval устанавливает значение для BufferedWriteSyncer.FlushInterval
    func WithFlushInterval(interval time.Duration) Option {
    	return func(config *config) {
    		config.flushInterval = interval
    	}
    }
    
    // WithMaxBufferSize устанавливает значение для BufferedWriteSyncer.MaxBufferSize
    func WithMaxBufferSize(size int) Option {
    	return func(config *config) {
    		config.maxBufferSize = size
    	}
    }
    
    // WithMaxSyncQueueSize устанавливает значение для BufferedWriteSyncer.MaxSyncQueueSize
    func WithMaxSyncQueueSize(size int) Option {
    	return func(config *config) {
    		config.maxSyncQueueSize = size
    	}
    }