server

Documentation

Index

• func EncodeResponse(rw http.ResponseWriter, statusCode int, data interface{}) error
• func HandleErrorResponse(w http.ResponseWriter, err error)
• type Handler
• type HandlerSpec
  • func NewHandlerSpec(method, path string, handler Handler) *HandlerSpec
• type PullPieceTaskResponseContinueData
• type RegisterResponseData
• type ResultInfo
  • func NewResultInfo(code int, msg string, data interface{}) ResultInfo
  • func NewResultInfoWithCode(code int) ResultInfo
  • func NewResultInfoWithCodeData(code int, data interface{}) ResultInfo
  • func NewResultInfoWithCodeError(code int, err error) ResultInfo
  • func NewResultInfoWithCodeMsg(code int, msg string) ResultInfo
  • func NewResultInfoWithError(err error) ResultInfo
  • func (r ResultInfo) Error() string
  • func (r ResultInfo) SuccessCode() bool
• type Server
  • func New(cfg *config.Config) (*Server, error)
  • func (s *Server) Start() error

Functions

func EncodeResponse

func EncodeResponse(rw http.ResponseWriter, statusCode int, data interface{}) error

EncodeResponse encodes response in json.

func HandleErrorResponse

func HandleErrorResponse(w http.ResponseWriter, err error)

HandleErrorResponse handles err from daemon side and constructs response for client side.

Types

type Handler

type Handler func(ctx context.Context, rw http.ResponseWriter, req *http.Request) error

Handler is the http request handler.

type HandlerSpec

type HandlerSpec struct {
	Method      string
	Path        string
	HandlerFunc Handler
}

HandlerSpec is used to describe a HTTP API.

func NewHandlerSpec

func NewHandlerSpec(method, path string, handler Handler) *HandlerSpec

NewHandlerSpec constructs a brand new HandlerSpec.

type PullPieceTaskResponseContinueData

type PullPieceTaskResponseContinueData struct {
	Range     string `json:"range"`
	PieceNum  int    `json:"pieceNum"`
	PieceSize int32  `json:"pieceSize"`
	PieceMd5  string `json:"pieceMd5"`
	Cid       string `json:"cid"`
	PeerIP    string `json:"peerIp"`
	PeerPort  int    `json:"peerPort"`
	Path      string `json:"path"`
	DownLink  int    `json:"downLink"`
}

PullPieceTaskResponseContinueData is the data when successfully pulling piece task and the task is continuing.

type RegisterResponseData

type RegisterResponseData struct {
	TaskID     string `json:"taskId"`
	FileLength int64  `json:"fileLength"`
	PieceSize  int32  `json:"pieceSize"`
}

RegisterResponseData is the data when registering supernode successfully.

type ResultInfo

type ResultInfo struct {
	// contains filtered or unexported fields
}

ResultInfo identify a struct that will returned to the client.

func NewResultInfo

func NewResultInfo(code int, msg string, data interface{}) ResultInfo

NewResultInfo returns a new ResultInfo.

func NewResultInfoWithCode

func NewResultInfoWithCode(code int) ResultInfo

NewResultInfoWithCode returns a new ResultInfo with code and it will get the default msg corresponding to the code as the value of ResultInfo.msg.

func NewResultInfoWithCodeData

func NewResultInfoWithCodeData(code int, data interface{}) ResultInfo

NewResultInfoWithCodeData returns a new ResultInfo with code and specified data.

func NewResultInfoWithCodeError

func NewResultInfoWithCodeError(code int, err error) ResultInfo

NewResultInfoWithCodeError returns a new ResultInfo with code and error. And it will get the err.Error() as the value of ResultInfo.msg.

func NewResultInfoWithCodeMsg

func NewResultInfoWithCodeMsg(code int, msg string) ResultInfo

NewResultInfoWithCodeMsg returns a new ResultInfo with code and specified msg.

func NewResultInfoWithError

func NewResultInfoWithError(err error) ResultInfo

NewResultInfoWithError returns a new ResultInfo with error only. And it will fill the result code according to the type of error.

func (ResultInfo) Error

func (r ResultInfo) Error() string

func (ResultInfo) SuccessCode

func (r ResultInfo) SuccessCode() bool

SuccessCode return whether the code equals SuccessCode.

type Server

type Server struct {
	Config       *config.Config
	PeerMgr      mgr.PeerMgr
	TaskMgr      mgr.TaskMgr
	DfgetTaskMgr mgr.DfgetTaskMgr
	ProgressMgr  mgr.ProgressMgr
}

Server is server instance.

func New

func New(cfg *config.Config) (*Server, error)

New creates a brand new server instance.

func (*Server) Start

func (s *Server) Start() error

Start runs