api

Documentation

Overview

package tracker core api

Index

• func BeforeUpload(c *gin.Context)
• func Create(c *gin.Context)
• func Dial(IpAddr string, fc func(client pb.StorageClient) (interface{}, error)) (interface{}, error)
• func Download() gin.HandlerFunc
• func HTTPProxy(c *gin.Context, Scheme, Host string) bool
• func HandleSync(c *gin.Context)
• func HanldeStorageServerReport(c *gin.Context)
• func ReUploadSession(c *gin.Context)
• func Upload(c *gin.Context)
• type BeforeUploadReq
• type CreateReq

Functions

func BeforeUpload

func BeforeUpload(c *gin.Context)

BeforeUpload

@param c

func Create

func Create(c *gin.Context)

func Dial

func Dial(IpAddr string, fc func(client pb.StorageClient) (interface{}, error)) (interface{}, error)

Dial gRpc server

@param IpAddr
@param fc
@return interface{}
@return error

func Download

func Download() gin.HandlerFunc

download logic get group ,token -> search db -> get link -> expire ? yes -> get group , Link() -> get link -> proxy

func HTTPProxy

func HTTPProxy(c *gin.Context, Scheme, Host string) bool

HTTPProxy ,http 反向代理

func HandleSync

func HandleSync(c *gin.Context)

func HanldeStorageServerReport

func HanldeStorageServerReport(c *gin.Context)

HanldeStorageServerReport

@param c

func ReUploadSession

func ReUploadSession(c *gin.Context)

ReUploadSession

@param c

func Upload

func Upload(c *gin.Context)

Types

type BeforeUploadReq

type BeforeUploadReq struct {
	Group     string   `json:"group"`
	Filename  string   `json:"filename"`
	Size      int64    `json:"size"`
	Md5       string   `json:"md5"`
	ModTime   int64    `json:"mod_time"`
	BlockSize int64    `json:"block_size"`
	BlockMd5  []string `json:"block_md5s"`
	Type      string   `json:"type"`
}

BeforeUploadReq

type CreateReq

type CreateReq struct {
	SessionID string `json:"session_id"`
	Size      int64  `json:"size"`
	BlockSize int64  `json:"block_size"`
}

MergeReq