Function NewFileAccessLogger

internal/logging/accesslog/file_access_logger.go:76–114

(parent task.Parent, file File, anyCfg AnyConfig)

)

func NewFileAccessLogger(parent task.Parent, file File, anyCfg AnyConfig) AccessLogger {
	cfg := anyCfg.ToConfig()
	if cfg.RotateInterval == 0 {
		cfg.RotateInterval = defaultRotateInterval
	}

	name := file.Name()
	l := &fileAccessLogger{
		task:           parent.Subtask("accesslog."+name, true),
		cfg:            cfg,
		bufSize:        InitialBufferSize,
		errRateLimiter: rate.NewLimiter(rate.Every(errRateLimit), errBurst),
		logger:         log.With().Str("file", name).Logger(),
	}

	l.writeLock, _ = writerLocks.LoadOrStore(name, &sync.Mutex{})

	l.writer = ioutils.NewBufferedWriter(file, InitialBufferSize)
	l.file = file
	if _, ok := file.(activeLogRotater); ok {
		registerFileLogger(name, l)
	}

	if cfg.req != nil {
		switch cfg.req.Format {
		case FormatCommon:
			l.RequestFormatter = CommonFormatter{cfg: &cfg.req.Fields}
		case FormatCombined:
			l.RequestFormatter = CombinedFormatter{CommonFormatter{cfg: &cfg.req.Fields}}
		case FormatJSON:
			l.RequestFormatter = JSONFormatter{cfg: &cfg.req.Fields}
		default: // should not happen, validation has done by validate tags
			panic("invalid access log format")
		}
	}

	go l.start()
	return l
}

func (l *fileAccessLogger) Config() *Config {
	return l.cfg