server

package

Go to main page

Versions in this module

v1

v1.4.6

Sep 19, 2024

Changes in this version

type Server

+ func (c *Server) CleanEmptyFolders()

+ func (c *Server) GetRealIp(r *http.Request) string

v1.4.5

Apr 20, 2023

Changes in this version

type GlobalConfig

+ AdminKey string

type Server

+ func (c *Server) TrimFileNameSpecialChar(str string) string

v1.4.4

Feb 9, 2023 GO-2023-1713

GO-2023-1713: Path traversal in github.com/sjqzhang/go-fastdfs

v1.4.3

Feb 22, 2022 GO-2023-1713

GO-2023-1713: Path traversal in github.com/sjqzhang/go-fastdfs

Changes in this version

+ const CONF_DIR_NAME

+ const CONST_BIG_UPLOAD_PATH_SUFFIX

+ const CONST_FILE_Md5_FILE_NAME

+ const CONST_MESSAGE_CLUSTER_IP

+ const CONST_Md5_ERROR_FILE_NAME

+ const CONST_Md5_QUEUE_FILE_NAME

+ const CONST_REMOME_Md5_FILE_NAME

+ const CONST_SMALL_FILE_SIZE

+ const CONST_STAT_FILE_COUNT_KEY

+ const CONST_STAT_FILE_TOTAL_SIZE_KEY

+ const DATA_DIR_NAME

+ const LOG_DIR_NAME

+ const STATIC_DIR_NAME

+ const STORE_DIR_NAME

+ var BUILD_TIME string

+ var CONF_DIR = CONF_DIR_NAME

+ var CONST_CONF_FILE_NAME = CONF_DIR + "/cfg.json"

+ var CONST_LEVELDB_FILE_NAME = DATA_DIR + "/fileserver.db"

+ var CONST_LOG_LEVELDB_FILE_NAME = DATA_DIR + "/log.db"

+ var CONST_QUEUE_SIZE = 10000

+ var CONST_SEARCH_FILE_NAME = DATA_DIR + "/search.txt"

+ var CONST_SERVER_CRT_FILE_NAME = CONF_DIR + "/server.crt"

+ var CONST_SERVER_KEY_FILE_NAME = CONF_DIR + "/server.key"

+ var CONST_STAT_FILE_NAME = DATA_DIR + "/stat.json"

+ var CONST_UPLOAD_COUNTER_KEY = "__CONST_UPLOAD_COUNTER_KEY__"

+ var DATA_DIR = DATA_DIR_NAME

+ var DOCKER_DIR = ""

+ var FOLDERS = []string

+ var FileName string

+ var GIT_VERSION string

+ var GO_VERSION string

+ var LARGE_DIR = STORE_DIR + "/haystack"

+ var LARGE_DIR_NAME = "haystack"

+ var LOG_DIR = LOG_DIR_NAME

+ var STATIC_DIR = STATIC_DIR_NAME

+ var STORE_DIR = STORE_DIR_NAME

+ var VERSION string

+ func InitServer()

+ func ParseConfig(filePath string)

+ func Start()

+ type FileInfo struct

+ Md5 string

+ Name string

+ OffSet int64

+ Path string

+ Peers []string

+ ReName string

+ Scene string

+ Size int64

+ TimeStamp int64

+ type FileInfoResult struct

+ IsDir bool

+ Md5 string

+ ModTime int64

+ Name string

+ Path string

+ Size int64

+ type FileLog struct

+ FileInfo *FileInfo

+ FileName string

+ type FileResult struct

+ Domain string

+ Md5 string

+ ModTime int64

+ Path string

+ RetCode int

+ RetMsg string

+ Scene string

+ Scenes string

+ Size int64

+ Src string

+ Url string

+ type GlobalConfig struct

+ Addr string

+ AdminIps []string

+ AlarmReceivers []string

+ AlarmUrl string

+ AuthUrl string

+ AutoRepair bool

+ ConnectTimeout bool

+ DefaultDownload bool

+ DefaultScene string

+ DownloadDomain string

+ DownloadTokenExpire int

+ DownloadUseToken bool

+ EnableCrossOrigin bool

+ EnableCustomPath bool

+ EnableDiskCache bool

+ EnableDistinctFile bool

+ EnableDownloadAuth bool

+ EnableFsNotify bool

+ EnableGoogleAuth bool

+ EnableHttps bool

+ EnableMergeSmallFile bool

+ EnableMigrate bool

+ EnablePprofDebug bool

+ EnableTus bool

+ EnableWebUpload bool

+ Extensions []string

+ FileSumArithmetic string

+ Group string

+ Host string

+ IdleTimeout int

+ ImageMaxHeight int

+ ImageMaxWidth int

+ Mail Mail

+ PeerId string

+ Peers []string

+ Proxies []Proxy

+ QueueSize int

+ ReadHeaderTimeout int

+ ReadOnly bool

+ ReadTimeout int

+ RefreshInterval int

+ RenameFile bool

+ RetryCount int

+ Scenes []string

+ ShowDir bool

+ SupportGroupManage bool

+ SyncDelay int64

+ SyncTimeout int64

+ SyncWorker int

+ UploadQueueSize int

+ UploadWorker int

+ WatchChanSize int

+ WriteTimeout int

+ func Config() *GlobalConfig

+ type HttpHandler struct

+ func (HttpHandler) ServeHTTP(res http.ResponseWriter, req *http.Request)

+ type HttpProxyHandler struct

+ Proxy Proxy

+ func (h *HttpProxyHandler) ServeHTTP(res http.ResponseWriter, req *http.Request)

+ type JsonResult struct

+ Data interface{}

+ Message string

+ Status string

+ type Mail struct

+ Host string

+ Password string

+ User string

+ type Proxy struct

+ Addr string

+ Dir string

+ Origin string

+ type Server struct

+ func NewServer() *Server

+ func (c *Server) AppendToDownloadQueue(fileInfo *FileInfo)

+ func (c *Server) AppendToQueue(fileInfo *FileInfo)

+ func (c *Server) AutoRepair(forceRepair bool)

+ func (c *Server) BackUp(w http.ResponseWriter, r *http.Request)

+ func (c *Server) BackUpMetaDataByDate(date string)

+ func (c *Server) BenchMark(w http.ResponseWriter, r *http.Request)

+ func (c *Server) BuildFileResult(fileInfo *FileInfo, r *http.Request) FileResult

+ func (c *Server) CheckAuth(w http.ResponseWriter, r *http.Request) bool

+ func (c *Server) CheckClusterStatus()

+ func (c *Server) CheckDownloadAuth(w http.ResponseWriter, r *http.Request) (bool, error)

+ func (c *Server) CheckFileAndSendToPeer(date string, filename string, isForceUpload bool)

+ func (c *Server) CheckFileExist(w http.ResponseWriter, r *http.Request)

+ func (c *Server) CheckFileExistByInfo(md5s string, fileInfo *FileInfo) bool

+ func (c *Server) CheckFilesExist(w http.ResponseWriter, r *http.Request)

+ func (c *Server) CheckScene(scene string) (bool, error)

+ func (c *Server) CleanAndBackUp()

+ func (c *Server) CleanLogLevelDBByDate(date string, filename string)

+ func (c *Server) ConsumerDownLoad()

+ func (c *Server) ConsumerLog()

+ func (c *Server) ConsumerPostToPeer()

+ func (c *Server) ConsumerUpload()

+ func (c *Server) CrossOrigin(w http.ResponseWriter, r *http.Request)

+ func (c *Server) Download(w http.ResponseWriter, r *http.Request)

+ func (c *Server) DownloadFileToResponse(url string, w http.ResponseWriter, r *http.Request)

+ func (c *Server) DownloadFromPeer(peer string, fileInfo *FileInfo)

+ func (c *Server) DownloadNormalFileByURI(w http.ResponseWriter, r *http.Request) (bool, error)

+ func (c *Server) DownloadNotFound(w http.ResponseWriter, r *http.Request)

+ func (c *Server) DownloadSmallFileByURI(w http.ResponseWriter, r *http.Request) (bool, error)

+ func (c *Server) FormatStatInfo()

+ func (c *Server) GenGoogleCode(w http.ResponseWriter, r *http.Request)

+ func (c *Server) GenGoogleSecret(w http.ResponseWriter, r *http.Request)

+ func (c *Server) GetClusterNotPermitMessage(r *http.Request) string

+ func (c *Server) GetFileInfo(w http.ResponseWriter, r *http.Request)

+ func (c *Server) GetFileInfoFromLevelDB(key string) (*FileInfo, error)

+ func (c *Server) GetFilePathByInfo(fileInfo *FileInfo, withDocker bool) string

+ func (c *Server) GetFilePathFromRequest(w http.ResponseWriter, r *http.Request) (string, string)

+ func (c *Server) GetMd5File(w http.ResponseWriter, r *http.Request)

+ func (c *Server) GetMd5sByDate(date string, filename string) (mapset.Set, error)

+ func (c *Server) GetMd5sForWeb(w http.ResponseWriter, r *http.Request)

+ func (c *Server) GetMd5sMapByDate(date string, filename string) (*goutil.CommonMap, error)

+ func (c *Server) GetServerURI(r *http.Request) string

+ func (c *Server) GetSmallFileByURI(w http.ResponseWriter, r *http.Request) ([]byte, bool, error)

+ func (c *Server) GetStat() []StatDateFileInfo

+ func (c *Server) HeartBeat(w http.ResponseWriter, r *http.Request)

+ func (c *Server) Index(w http.ResponseWriter, r *http.Request)

+ func (c *Server) IsExistFromLevelDB(key string, db *leveldb.DB) (bool, error)

+ func (c *Server) IsPeer(r *http.Request) bool

+ func (c *Server) ListDir(w http.ResponseWriter, r *http.Request)

+ func (c *Server) LoadFileInfoByDate(date string, filename string) (mapset.Set, error)

+ func (c *Server) LoadQueueSendToPeer()

+ func (c *Server) LoadSearchDict()

+ func (c *Server) NotPermit(w http.ResponseWriter, r *http.Request)

+ func (c *Server) ParseSmallFile(filename string) (string, int64, int, error)

+ func (c *Server) ReceiveMd5s(w http.ResponseWriter, r *http.Request)

+ func (c *Server) RegisterExit()

+ func (c *Server) Reload(w http.ResponseWriter, r *http.Request)

+ func (c *Server) RemoveDownloading()

+ func (c *Server) RemoveEmptyDir(w http.ResponseWriter, r *http.Request)

+ func (c *Server) RemoveFile(w http.ResponseWriter, r *http.Request)

+ func (c *Server) RemoveKeyFromLevelDB(key string, db *leveldb.DB) error

+ func (c *Server) Repair(w http.ResponseWriter, r *http.Request)

+ func (c *Server) RepairFileInfo(w http.ResponseWriter, r *http.Request)

+ func (c *Server) RepairFileInfoFromFile()

+ func (c *Server) RepairStatByDate(date string) StatDateFileInfo

+ func (c *Server) RepairStatWeb(w http.ResponseWriter, r *http.Request)

+ func (c *Server) Report(w http.ResponseWriter, r *http.Request)

+ func (c *Server) ResizeImage(w http.ResponseWriter, fullpath string, width, height uint)

+ func (c *Server) ResizeImageByBytes(w http.ResponseWriter, data []byte, width, height uint)

+ func (c *Server) SaveFileInfoToLevelDB(key string, fileInfo *FileInfo, db *leveldb.DB) (*FileInfo, error)

+ func (c *Server) SaveFileMd5Log(fileInfo *FileInfo, filename string)

+ func (c *Server) SaveSearchDict()

+ func (c *Server) SaveSmallFile(fileInfo *FileInfo) error

+ func (c *Server) SaveStat()

+ func (c *Server) SaveUploadFile(file multipart.File, header *multipart.FileHeader, fileInfo *FileInfo, ...) (*FileInfo, error)

+ func (c *Server) Search(w http.ResponseWriter, r *http.Request)

+ func (c *Server) SearchDict(kw string) []FileInfo

+ func (c *Server) SendToMail(to, subject, body, mailtype string) error

+ func (c *Server) SetDownloadHeader(w http.ResponseWriter, r *http.Request)

+ func (c *Server) Start()

+ func (c *Server) Stat(w http.ResponseWriter, r *http.Request)

+ func (c *Server) Status(w http.ResponseWriter, r *http.Request)

+ func (c *Server) Sync(w http.ResponseWriter, r *http.Request)

+ func (c *Server) SyncFileInfo(w http.ResponseWriter, r *http.Request)

+ func (c *Server) Upload(w http.ResponseWriter, r *http.Request)

+ func (c *Server) VerifyGoogleCode(secret string, code string, discrepancy int64) bool

+ func (c *Server) WatchFilesChange()

+ type StatDateFileInfo struct

+ Date string

+ FileCount int64

+ TotalSize int64

+ type WrapReqResp struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL