code: func NewForwarder(cfg ForwarderConfig) (*Forwarder, error) {
  	if err := cfg.CheckAndSetDefaults(); err != nil {
  		return nil, trace.Wrap(err)
  	}
  	diskLogger, err := NewDiskSessionLogger(DiskSessionLoggerConfig{
  		SessionID:      cfg.SessionID,
  		DataDir:        cfg.DataDir,
  		RecordSessions: cfg.RecordSessions,
  		Namespace:      cfg.Namespace,
  		ServerID:       cfg.ServerID,
  		Clock:          cfg.Clock,
  	})
  	if err != nil {
  		return nil, trace.Wrap(err)
  	}
  	return &Forwarder{
  		ForwarderConfig: cfg,
  		sessionLogger:   diskLogger,
  	}, nil
  }
docs: // NewForwarder returns a new instance of session forwarder