client

Nov 29, 2023

Changes in this version

+ const Remove

type Aria2Client

+ func (aria2Client *Aria2Client) RemoveDownload(gid string) (err error)

type Aria2DownloadOption

+ UserAgent string

+ type Aria2Resp struct

+ Error *Aria2Error

+ Id string

+ JsonRpc string

+ Result interface{}

Sep 16, 2022

Changes in this version

+ const CHANGE_GLOBAL_OPTION

+ type Aria2ChangeMaxConcurrentDownloads struct

+ Error *Aria2Error

+ Id string

+ JsonRpc string

+ Result interface{}

type Aria2Client

+ func (aria2Client *Aria2Client) ChangeMaxConcurrentDownloads(maxConcurrentDownloads string) *Aria2ChangeMaxConcurrentDownloads

+ type ChangeMaxConcurrentDownloads struct

+ MaxConcurrentDownloads string

Nov 2, 2021

Changes in this version

+ const ADD_URI

+ const STATUS

+ type Aria2Client struct

+ Host string

+ func GetAria2Client(aria2Host, aria2Secret string, aria2Port int) *Aria2Client

+ func (aria2Client *Aria2Client) DownloadFile(uri string, outDir, outFilename string) *Aria2Download

+ func (aria2Client *Aria2Client) GenPayload4Download(method string, uri string, outDir, outFilename string) Aria2Payload

+ func (aria2Client *Aria2Client) GenPayload4Status(gid string) Aria2Payload

+ func (aria2Client *Aria2Client) GetDownloadStatus(gid string) *Aria2Status

+ type Aria2Download struct

+ Error *Aria2Error

+ Gid string

+ Id string

+ JsonRpc string

+ type Aria2DownloadOption struct

+ Dir string

+ Out string

+ type Aria2Error struct

+ Code int

+ Message string

+ type Aria2Payload struct

+ Id string

+ JsonRpc string

+ Method string

+ Params []interface{}

+ type Aria2Status struct

+ Error *Aria2Error

+ Id string

+ JsonRpc string

+ Result *Aria2StatusResult

+ type Aria2StatusResult struct

+ Bitfield string

+ CompletedLength string

+ Connections string

+ Dir string

+ DownloadSpeed string

+ ErrorCode string

+ ErrorMessage string

+ Files []Aria2StatusResultFile

+ Gid string

+ NumPieces string

+ PieceLength string

+ Status string

+ TotalLength string

+ UploadLength string

+ UploadSpeed string

+ type Aria2StatusResultFile struct

+ CompletedLength string

+ Index string

+ Length string

+ Path string

+ Selected string

+ Uris []Aria2StatusResultFileUri

+ type Aria2StatusResultFileUri struct

+ Status string

+ Uri string

+ type JsonRpcParams struct

+ Id int

+ JsonRpc string

+ Method string

+ Params []interface{}

Nov 1, 2021

Changes in this version

+ func HttpUploadFileByStream(uri, filefullpath string) (string, error)

+ func IpfsUploadCarFileByWebApi(apiUrl, carFilePath string) (*string, error)

+ func LevelDbDelete(dbFilepath, key, value string) error

+ func LevelDbGet(dbFilepath, key string) ([]byte, error)

+ func LevelDbPut(dbFilepath, key string, value interface{}) error

+ type GetTaskByUuidResult struct

+ Data GetTaskResultData

+ Status string

+ type GetTaskByUuidResultData struct

+ Task model.Task

+ TotalItems int

+ TotalTaskCount int

type SwanClient

+ JwtToken string

+ func SwanGetClientByKey(apiUrl, apiKey, accessToken string) (*SwanClient, error)

+ func (swanClient *SwanClient) SwanGetAssignedTasksByLimit(limit *int) (*GetTaskResult, error)

+ func (swanClient *SwanClient) SwanGetTaskByUuid(uuid string) (*GetTaskByUuidResult, error)

Oct 26, 2021

Changes in this version

+ const GET_OFFLINEDEAL_LIMIT_DEFAULT

+ const HTTP_CONTENT_TYPE_FORM

+ const HTTP_CONTENT_TYPE_JSON

+ const LOTUS_CHAIN_HEAD

+ const LOTUS_CLIENT_CALC_COMM_P

+ const LOTUS_CLIENT_GEN_CAR

+ const LOTUS_CLIENT_GET_DEAL_INFO

+ const LOTUS_CLIENT_GET_DEAL_STATUS

+ const LOTUS_CLIENT_IMPORT

+ const LOTUS_CLIENT_START_DEAL

+ const LOTUS_JSON_RPC_ID

+ const LOTUS_JSON_RPC_VERSION

+ const LOTUS_MARKET_GET_ASK

+ const LOTUS_VERSION

+ const RESPONSE_STATUS_SUCCESS

+ const SHELL_TO_USE

+ func Delete(dbFilepath, key, value string) error

+ func ExecOsCmd(cmdStr string, checkStdErr bool) (string, error)

+ func ExecOsCmd2Screen(cmdStr string, checkStdErr bool) (string, error)

+ func ExecOsCmdBase(cmdStr string, out2Screen bool, checkStdErr bool) (string, error)

+ func Get(dbFilepath, key string) ([]byte, error)

+ func HttpDelete(uri, tokenString string, params interface{}) string

+ func HttpGet(uri, tokenString string, params interface{}) string

+ func HttpGetNoToken(uri string, params interface{}) string

+ func HttpPost(uri, tokenString string, params interface{}) string

+ func HttpPostFile(url string, tokenString string, paramTexts map[string]string, ...) (string, error)

+ func HttpPostNoToken(uri string, params interface{}) string

+ func HttpPut(uri, tokenString string, params interface{}) string

+ func HttpPutFile(url string, tokenString string, paramTexts map[string]string, ...) (string, error)

+ func HttpRequestFile(httpMethod, url string, tokenString string, paramTexts map[string]string, ...) (string, error)

+ func IpfsUploadCarFile(carFilePath string) (*string, error)

+ func LotusGetMinerConfig(minerFid string) (*decimal.Decimal, *decimal.Decimal, *string, *string)

+ func LotusProposeOfflineDeal(carFile model.FileDesc, cost decimal.Decimal, pieceSize int64, ...) (*string, *int, error)

+ func Put(dbFilepath, key, value string) error

+ type Cid struct

+ Cid string

+ type ClientCalcCommP struct

+ Result *ClientCalcCommPResult

+ type ClientCalcCommPResult struct

+ Root Cid

+ Size int

+ type ClientFileParam struct

+ IsCAR bool

+ Path string

+ type ClientImport struct

+ Result *ClientImportResult

+ type ClientImportResult struct

+ ImportID int64

+ Root Cid

+ type ClientStartDeal struct

+ Result *Cid

+ type ClientStartDealParam struct

+ Data ClientStartDealParamData

+ DealStartEpoch int

+ EpochPrice string

+ FastRetrieval bool

+ MinBlocksDuration int

+ Miner string

+ ProviderCollateral string

+ VerifiedDeal bool

+ Wallet string

+ type ClientStartDealParamData struct

+ PieceCid Cid

+ PieceSize int

+ RawBlockSize int

+ Root Cid

+ TransferType string

+ type GetOfflineDealData struct

+ Deal []model.OfflineDeal

+ type GetOfflineDealResponse struct

+ Data GetOfflineDealData

+ Status string

+ type GetOfflineDealsByTaskUuidResult struct

+ Data GetOfflineDealsByTaskUuidResultData

+ Status string

+ type GetOfflineDealsByTaskUuidResultData struct

+ AverageBid string

+ BidCount int

+ Deal []model.OfflineDeal

+ DealCompleteRate string

+ Miner model.Miner

+ Task model.Task

+ type GetTaskResult struct

+ Data GetTaskResultData

+ Status string

+ type GetTaskResultData struct

+ Task []model.Task

+ TotalItems int

+ TotalTaskCount int

+ type JsonRpcError struct

+ Code int

+ Message string

+ type LotusClient struct

+ AccessToken string

+ ApiUrl string

+ func LotusGetClient(apiUrl, accessToken string) (*LotusClient, error)

+ func (lotusClient *LotusClient) LotusClientCalcCommP(filepath string) *string

+ func (lotusClient *LotusClient) LotusClientGenCar(srcFilePath, destCarFilePath string, srcFilePathIsCar bool) error

+ func (lotusClient *LotusClient) LotusClientImport(filepath string, isCar bool) (*string, error)

+ func (lotusClient *LotusClient) LotusClientStartDeal(carFile model.FileDesc, cost decimal.Decimal, pieceSize int64, ...) (*string, error)

+ func (lotusClient *LotusClient) LotusMarketGetAsk() *MarketGetAskResultAsk

+ func (lotusClient *LotusClient) LotusVersion() (*string, error)

+ type LotusJsonRpcParams struct

+ Id int

+ JsonRpc string

+ Method string

+ Params []interface{}

+ type LotusJsonRpcResult struct

+ Error *JsonRpcError

+ Id int

+ JsonRpc string

+ type LotusVersionResponse struct

+ Result LotusVersionResult

+ type LotusVersionResult struct

+ APIVersion int

+ BlockDelay int

+ Version string

+ type MarketGetAsk struct

+ Result *MarketGetAskResult

+ type MarketGetAskResult struct

+ Ask MarketGetAskResultAsk

+ type MarketGetAskResultAsk struct

+ Expiry int

+ MaxPieceSize int

+ MinPieceSize int

+ Miner string

+ Price string

+ SeqNo int

+ Timestamp int

+ VerifiedPrice string

+ type SwanClient struct

+ ApiUrl string

+ Token string

+ func SwanGetClient(apiUrl, apiKey, accessToken string) (*SwanClient, error)

+ func (swanClient *SwanClient) SwanCreateTask(task model.Task, csvFilePath string) (*SwanCreateTaskResponse, error)

+ func (swanClient *SwanClient) SwanGetAssignedTasks() ([]model.Task, error)

+ func (swanClient *SwanClient) SwanGetJwtToken(apiKey, accessToken string) error

+ func (swanClient *SwanClient) SwanGetOfflineDeals(minerFid, status string, limit ...string) []model.OfflineDeal

+ func (swanClient *SwanClient) SwanGetOfflineDealsByTaskUuid(taskUuid string) (*GetOfflineDealsByTaskUuidResult, error)

+ func (swanClient *SwanClient) SwanGetTasks(limit *int) (*GetTaskResult, error)

+ func (swanClient *SwanClient) SwanUpdateAssignedTask(taskUuid, status, csvFilePath string) (*SwanCreateTaskResponse, error)

+ func (swanClient *SwanClient) SwanUpdateOfflineDealStatus(dealId int, status string, statusInfo ...string) bool

+ func (swanClient *SwanClient) SwanUpdateTaskByUuid(taskUuid string, minerFid string, csvFilePath string) error

+ type SwanCreateTaskResponse struct

+ Data SwanCreateTaskResponseData

+ Message string

+ Status string

+ type SwanCreateTaskResponseData struct

+ Filename string

+ Uuid string

+ type TokenAccessInfo struct

+ AccessToken string

+ ApiKey string

+ type UpdateOfflineDealData struct

+ Deal model.OfflineDeal

+ Message string

+ type UpdateOfflineDealResponse struct

+ Data UpdateOfflineDealData

+ Status string