helper

Aug 25, 2020

Changes in this version

type MockSupernodeAPI

+ func (m *MockSupernodeAPI) ApplyForSeedNode(node string, req *types.RegisterRequest) (resp *types.RegisterResponse, err error)

+ func (m *MockSupernodeAPI) FetchP2PNetworkInfo(node string, start int, limit int, req *api_types.NetworkInfoFetchRequest) (resp *api_types.NetworkInfoFetchResponse, e error)

+ func (m *MockSupernodeAPI) HeartBeat(node string, req *api_types.HeartBeatRequest) (resp *types.HeartBeatResponse, err error)

+ func (m *MockSupernodeAPI) ReportResource(node string, req *types.RegisterRequest) (resp *types.RegisterResponse, err error)

+ func (m *MockSupernodeAPI) ReportResourceDeleted(node string, taskID string, cid string) (resp *types.BaseResponse, err error)

Apr 29, 2020

Changes in this version

+ type MockFileServer struct

+ Port int

+ func NewMockFileServer() *MockFileServer

+ func (fs *MockFileServer) MockResp(resp http.ResponseWriter, mf *mockFile, rangeSt *httputils.RangeStruct)

+ func (fs *MockFileServer) RegisterFile(path string, size int64, repeatStr string) error

+ func (fs *MockFileServer) ServeHTTP(resp http.ResponseWriter, req *http.Request)

+ func (fs *MockFileServer) StartServer(ctx context.Context, port int) error

+ func (fs *MockFileServer) UnRegisterFile(path string)

Nov 19, 2019

Changes in this version

type MockSupernodeAPI

+ ReportMetricsFunc ReportMetricsFuncType

+ func (m *MockSupernodeAPI) ReportMetrics(ip string, req *api_types.TaskMetricsRequest) (resp *types.BaseResponse, e error)

+ type ReportMetricsFuncType func(node string, req *api_types.TaskMetricsRequest) (*types.BaseResponse, error)

Jun 6, 2019

Changes in this version

+ type ClientErrorFuncType func(ip string, req *types.ClientErrorRequest) (*types.BaseResponse, error)

type MockSupernodeAPI

+ ClientErrorFunc ClientErrorFuncType

+ func (m *MockSupernodeAPI) ReportClientError(ip string, req *types.ClientErrorRequest) (resp *types.BaseResponse, e error)

Mar 4, 2019

Changes in this version

+ func CreateConfig(writer io.Writer, workHome string) *config.Config

+ func CreateRandomString(cap int) string

+ func CreateTestFile(path string, content string) error

+ func CreateTestFileWithMD5(path string, content string) string

+ func GetServiceFile(taskFileName, dataDir string) string

+ func GetTaskFile(taskFileName, dataDir string) string

+ func GetTaskName(serviceFile string) string

+ func IsCDN(pattern string) bool

+ func IsP2P(pattern string) bool

+ func IsSource(pattern string) bool

+ type MockSupernodeAPI struct

+ PullFunc PullFuncType

+ RegisterFunc RegisterFuncType

+ ReportFunc ReportFuncType

+ ServiceDownFunc ServiceDownFuncType

+ func (m *MockSupernodeAPI) PullPieceTask(ip string, req *types.PullPieceTaskRequest) (*types.PullPieceTaskResponse, error)

+ func (m *MockSupernodeAPI) Register(ip string, req *types.RegisterRequest) (*types.RegisterResponse, error)

+ func (m *MockSupernodeAPI) ReportPiece(ip string, req *types.ReportPieceRequest) (*types.BaseResponse, error)

+ func (m *MockSupernodeAPI) ServiceDown(ip string, taskID string, cid string) (*types.BaseResponse, error)

+ type PullFuncType func(ip string, req *types.PullPieceTaskRequest) (*types.PullPieceTaskResponse, error)

+ type RegisterFuncType func(ip string, req *types.RegisterRequest) (*types.RegisterResponse, error)

+ func CreateRegisterFunc() RegisterFuncType

+ type ReportFuncType func(ip string, req *types.ReportPieceRequest) (*types.BaseResponse, error)

+ type ServiceDownFuncType func(ip string, taskID string, cid string) (*types.BaseResponse, error)