Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v1

v1.5.0

Apr 28, 2022

v1.4.9

Apr 28, 2022

v1.4.8

Apr 19, 2022

v1.4.7

Apr 19, 2022

v1.4.6

Apr 19, 2022

Changes in this version

+ func ConfigServer(appDir string)

+ func StartServer(ctx context.Context)

v1.4.5

Apr 18, 2022

Changes in this version

type Server

+ func (s *Server) Stop(ctx context.Context)

v1.4.4

Apr 18, 2022

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) InitComponent(isReload bool)

+ 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