Documentation
¶
Overview ¶
服务端, 实体结构定义
实现(Server)接口
服务端参数初始化
服务组件初始化启动相关实现
数据库操作, 及集群交互操作
队列操作, 文件信息入队及出队列
服务端, 组件服务实现
公共方法实现
Index ¶
- Constants
- Variables
- type Service
- func (server Service) AppendToDownloadQueue(fileInfo *en.FileInfo)
- func (server Service) AppendToQueue(fileInfo *en.FileInfo)
- func (server Service) AutoRepair(forceRepair bool)
- func (server Service) BackUpMetaDataByDate(date string)
- func (server *Service) BenchMark(w http.ResponseWriter, r *http.Request)
- func (server Service) CheckAuth(w http.ResponseWriter, r *http.Request) bool
- func (server Service) CheckFileAndSendToPeer(date string, filename string, isForceUpload bool)
- func (server Service) CheckPeerFileExist(peer string, md5sum string, fpath string) (*en.FileInfo, error)
- func (server Service) DownloadFromPeer(peer string, fileInfo *en.FileInfo)
- func (server Service) GetFileInfoFromLevelDB(key string) (*en.FileInfo, error)
- func (server Service) GetGroupRouteName() string
- func (server Service) GetHost() string
- func (server Service) GetLdb() *leveldb.DB
- func (server Service) GetMd5sByDate(date string, filename string) (mapset.Set, error)
- func (server Service) GetQueueFileLog() chan *en.FileLog
- func (server Service) GetQueueFromPeers() chan en.FileInfo
- func (server Service) GetQueueToPeers() chan en.FileInfo
- func (server Service) GetQueueUpload() chan en.WrapReqResp
- func (server Service) GetRequestURI(action string) string
- func (server Service) GetSceneMap() *goutil.CommonMap
- func (server Service) GetServerName() string
- func (server Service) GetStatMap() *goutil.CommonMap
- func (server Service) GetSumMap() *goutil.CommonMap
- func (server Service) NotPermit(w http.ResponseWriter, r *http.Request)
- func (server Service) Reload(w http.ResponseWriter, r *http.Request)
- func (server Service) RemoveKeyFromLevelDB(key string, db *leveldb.DB) error
- func (server Service) RepairFileInfoFromFile()
- func (server Service) RepairStatByDate(date string) en.StatDateFileInfo
- func (server Service) SaveFileInfoToLevelDB(key string, fileInfo *en.FileInfo, db *leveldb.DB) (*en.FileInfo, error)
- func (server Service) SaveFileMd5Log(fileInfo *en.FileInfo, filename string)
- func (server *Service) Start()
- func (server Service) Upload(w http.ResponseWriter, r *http.Request)
- func (server Service) VerifyGoogleCode(secret string, code string, discrepancy int64) bool
Constants ¶
View Source
const ( CONST_SMALL_FILE_SIZE = conf.CONST_SMALL_FILE_SIZE // 操作标识 CONST_FILE_Md5_FILE_NAME = conf.CONST_FILE_Md5_FILE_NAME CONST_Md5_ERROR_FILE_NAME = conf.CONST_Md5_ERROR_FILE_NAME CONST_Md5_QUEUE_FILE_NAME = conf.CONST_Md5_QUEUE_FILE_NAME CONST_REMOME_Md5_FILE_NAME = conf.CONST_REMOME_Md5_FILE_NAME // CONST_STAT_FILE_TOTAL_SIZE_KEY = conf.CONST_STAT_FILE_TOTAL_SIZE_KEY CONST_STAT_FILE_COUNT_KEY = conf.CONST_STAT_FILE_COUNT_KEY CONST_BIG_UPLOAD_PATH_SUFFIX = conf.CONST_BIG_UPLOAD_PATH_SUFFIX GO_FASTDFS_IP = conf.GO_FASTDFS_IP Go_FastDFS = conf.Go_FastDFS )
Variables ¶
View Source
var ( DOCKER_DIR = conf.DirDocker DATA_DIR = conf.DirData STORE_DIR = conf.DirStore LARGE_DIR_NAME = conf.DirLargeName STATIC_DIR = conf.DirStatic LARGE_DIR = conf.DirLarge LOG_DIR = conf.DirLog STORE_DIR_NAME = conf.STORE_DIR_NAME CONST_CONF_FILE_NAME = conf.CONSTConfFileName CONST_LEVELDB_FILE_NAME = conf.CONSTLevelDBFileName CONST_LOG_LEVELDB_FILE_NAME = conf.CONSTLevelDBFileNameLog CONST_SEARCH_FILE_NAME = conf.CONSTSearchFileName CONST_STAT_FILE_NAME = conf.CONSTStatFileName CONST_QUEUE_SIZE = conf.CONSTQueueSize CONST_UPLOAD_COUNTER_KEY = conf.CONSTUploadCounterKey )
项目应用目录
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
定义服务结构
func NewService ¶
func (Service) AppendToDownloadQueue ¶
func (Service) AppendToQueue ¶
func (Service) AutoRepair ¶
func (Service) BackUpMetaDataByDate ¶
func (*Service) BenchMark ¶
func (server *Service) BenchMark(w http.ResponseWriter, r *http.Request)
func (Service) CheckFileAndSendToPeer ¶
func (Service) CheckPeerFileExist ¶
func (server Service) CheckPeerFileExist(peer string, md5sum string, fpath string) (*en.FileInfo, error)
检测文件是否存在, 并获取文件信息
func (Service) DownloadFromPeer ¶
从集群(查找到文件的节点 peer)中下载文件
func (Service) GetFileInfoFromLevelDB ¶
func (Service) GetGroupRouteName ¶
获取访问路由名称, 未配置使用服务名称
func (Service) GetMd5sByDate ¶
func (Service) GetQueueFileLog ¶
func (Service) GetQueueFromPeers ¶
func (Service) GetQueueToPeers ¶
func (Service) GetQueueUpload ¶
func (server Service) GetQueueUpload() chan en.WrapReqResp
func (Service) GetRequestURI ¶
func (Service) GetSceneMap ¶
func (Service) GetStatMap ¶
func (Service) RemoveKeyFromLevelDB ¶
func (Service) RepairFileInfoFromFile ¶
func (server Service) RepairFileInfoFromFile()
func (Service) RepairStatByDate ¶
func (server Service) RepairStatByDate(date string) en.StatDateFileInfo
func (Service) SaveFileInfoToLevelDB ¶
func (Service) SaveFileMd5Log ¶
Source Files
Click to show internal directories.
Click to hide internal directories.