helper

Documentation

Index

• 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 ClientErrorFuncType
• type MockFileServer
  • 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)
• type MockSupernodeAPI
  • 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) ReportClientError(ip string, req *types.ClientErrorRequest) (resp *types.BaseResponse, e error)
  • func (m *MockSupernodeAPI) ReportMetrics(ip string, req *api_types.TaskMetricsRequest) (resp *types.BaseResponse, e 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
• type RegisterFuncType
  • func CreateRegisterFunc() RegisterFuncType
• type ReportFuncType
• type ReportMetricsFuncType
• type ServiceDownFuncType

Functions

func CreateConfig

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

CreateConfig creates a temporary config.

func CreateRandomString

func CreateRandomString(cap int) string

CreateRandomString creates a random string of specified length.

func CreateTestFile

func CreateTestFile(path string, content string) error

CreateTestFile creates a temp file and write a string.

func CreateTestFileWithMD5

func CreateTestFileWithMD5(path string, content string) string

CreateTestFileWithMD5 creates a temp file and write a string and return the md5 of the file.

func GetServiceFile

func GetServiceFile(taskFileName, dataDir string) string

GetServiceFile returns file path of service file.

func GetTaskFile

func GetTaskFile(taskFileName, dataDir string) string

GetTaskFile returns file path of task file.

func GetTaskName

func GetTaskName(serviceFile string) string

GetTaskName extracts and returns task name from serviceFile.

func IsCDN

func IsCDN(pattern string) bool

IsCDN returns whether the pattern is PatternCDN.

func IsP2P

func IsP2P(pattern string) bool

IsP2P returns whether the pattern is PatternP2P.

func IsSource

func IsSource(pattern string) bool

IsSource returns whether the pattern is PatternSource.

Types

type ClientErrorFuncType

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

ClientErrorFuncType function type of SupernodeAPI#ReportClientError

type MockFileServer

type MockFileServer struct {
	sync.Mutex
	Port int
	// contains filtered or unexported fields
}

MockFileServer mocks the file server.

func NewMockFileServer

func NewMockFileServer() *MockFileServer

func (*MockFileServer) MockResp

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

func (*MockFileServer) RegisterFile

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

func (*MockFileServer) ServeHTTP

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

func (*MockFileServer) StartServer

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

StartServer asynchronously starts the server, it will not be blocked.

func (*MockFileServer) UnRegisterFile

func (fs *MockFileServer) UnRegisterFile(path string)

type MockSupernodeAPI

type MockSupernodeAPI struct {
	RegisterFunc      RegisterFuncType
	PullFunc          PullFuncType
	ReportFunc        ReportFuncType
	ServiceDownFunc   ServiceDownFuncType
	ClientErrorFunc   ClientErrorFuncType
	ReportMetricsFunc ReportMetricsFuncType
}

MockSupernodeAPI mocks the SupernodeAPI.

func (*MockSupernodeAPI) PullPieceTask

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

PullPieceTask implements SupernodeAPI#PullPiece.

func (*MockSupernodeAPI) Register

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

Register implements SupernodeAPI#Register.

func (*MockSupernodeAPI) ReportClientError

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

ReportClientError implements SupernodeAPI#ReportClientError.

func (*MockSupernodeAPI) ReportMetrics

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

func (*MockSupernodeAPI) ReportPiece

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

ReportPiece implements SupernodeAPI#ReportPiece.

func (*MockSupernodeAPI) ServiceDown

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

ServiceDown implements SupernodeAPI#ServiceDown.

type PullFuncType

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

PullFuncType function type of SupernodeAPI#PullPiece

type RegisterFuncType

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

RegisterFuncType function type of SupernodeAPI#Register

func CreateRegisterFunc

func CreateRegisterFunc() RegisterFuncType

CreateRegisterFunc creates a mock register function.

type ReportFuncType

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

ReportFuncType function type of SupernodeAPI#ReportPiece

type ReportMetricsFuncType

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

ClientErrorFuncType function type of SupernodeAPI#ReportMetricsType

type ServiceDownFuncType

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

ServiceDownFuncType function type of SupernodeAPI#ServiceDown