swan

Documentation

Index

• Constants
• type GetOfflineDealData
• type GetOfflineDealResponse
• type GetOfflineDealsByTaskUuidResult
• type GetOfflineDealsByTaskUuidResultData
• type GetTaskByUuidResult
• type GetTaskByUuidResultData
• type GetTaskResult
• type GetTaskResultData
• type MinerResponse
• type SwanClient
  • func SwanGetClient(apiUrl, apiKey, accessToken, swanToken string) (*SwanClient, error)
  • func (swanClient *SwanClient) CheckDatacap(wallet string) (bool, error)
  • func (swanClient *SwanClient) GetMiner(minerFid string) (*MinerResponse, error)
  • func (swanClient *SwanClient) SendHeartbeatRequest(minerFid string) error
  • func (swanClient *SwanClient) SwanCreateTask(task model.Task, csvFilePath string) (*SwanCreateTaskResponse, error)
  • func (swanClient *SwanClient) SwanGetAssignedTasks() ([]model.Task, error)
  • func (swanClient *SwanClient) SwanGetAssignedTasksByLimit(limit *int) (*GetTaskResult, error)
  • func (swanClient *SwanClient) SwanGetJwtToken() error
  • func (swanClient *SwanClient) SwanGetJwtTokenUp3Times() error
  • func (swanClient *SwanClient) SwanGetOfflineDeals(minerFid, status string, limit ...string) []model.OfflineDeal
  • func (swanClient *SwanClient) SwanGetOfflineDealsByTaskUuid(taskUuid string) (*GetOfflineDealsByTaskUuidResult, error)
  • func (swanClient *SwanClient) SwanGetTaskByUuid(uuid string) (*GetTaskByUuidResult, 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
  • func (swanClient *SwanClient) UpdateMinerBidConf(minerFid string, confMiner model.Miner)
• type SwanCreateTaskResponse
• type SwanCreateTaskResponseData
• type TokenAccessInfo
• type UpdateOfflineDealData
• type UpdateOfflineDealResponse

Constants

const GET_OFFLINEDEAL_LIMIT_DEFAULT = 50

Types

type GetOfflineDealData

type GetOfflineDealData struct {
	Deal []model.OfflineDeal `json:"deal"`
}

type GetOfflineDealResponse

type GetOfflineDealResponse struct {
	Data   GetOfflineDealData `json:"data"`
	Status string             `json:"status"`
}

type GetOfflineDealsByTaskUuidResult

type GetOfflineDealsByTaskUuidResult struct {
	Data   GetOfflineDealsByTaskUuidResultData `json:"data"`
	Status string                              `json:"status"`
}

type GetOfflineDealsByTaskUuidResultData

type GetOfflineDealsByTaskUuidResultData struct {
	//AverageBid       string              `json:"average_bid"`
	BidCount         int                 `json:"bid_count"`
	DealCompleteRate string              `json:"deal_complete_rate"`
	Deal             []model.OfflineDeal `json:"deal"`
	Miner            model.Miner         `json:"miner"`
	Task             model.Task          `json:"task"`
}

type GetTaskByUuidResult

type GetTaskByUuidResult struct {
	Data   GetTaskResultData `json:"data"`
	Status string            `json:"status"`
}

type GetTaskByUuidResultData

type GetTaskByUuidResultData struct {
	Task           model.Task `json:"task"`
	TotalItems     int        `json:"total_items"`
	TotalTaskCount int        `json:"total_task_count"`
}

type GetTaskResult

type GetTaskResult struct {
	Data   GetTaskResultData `json:"data"`
	Status string            `json:"status"`
}

type GetTaskResultData

type GetTaskResultData struct {
	Task           []model.Task `json:"task"`
	TotalItems     int          `json:"total_items"`
	TotalTaskCount int          `json:"total_task_count"`
}

type MinerResponse

type MinerResponse struct {
	Status  string      `json:"status"`
	Message string      `json:"message"`
	Data    model.Miner `json:"data"`
}

type SwanClient

type SwanClient struct {
	ApiUrl      string
	SwanToken   string
	ApiKey      string
	AccessToken string
}

func SwanGetClient

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

func (*SwanClient) CheckDatacap

func (swanClient *SwanClient) CheckDatacap(wallet string) (bool, error)

func (*SwanClient) GetMiner

func (swanClient *SwanClient) GetMiner(minerFid string) (*MinerResponse, error)

func (*SwanClient) SendHeartbeatRequest

func (swanClient *SwanClient) SendHeartbeatRequest(minerFid string) error

func (*SwanClient) SwanCreateTask

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

func (*SwanClient) SwanGetAssignedTasks

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

func (*SwanClient) SwanGetAssignedTasksByLimit

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

func (*SwanClient) SwanGetJwtToken

func (swanClient *SwanClient) SwanGetJwtToken() error

func (*SwanClient) SwanGetJwtTokenUp3Times

func (swanClient *SwanClient) SwanGetJwtTokenUp3Times() error

func (*SwanClient) SwanGetOfflineDeals

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

func (*SwanClient) SwanGetOfflineDealsByTaskUuid

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

func (*SwanClient) SwanGetTaskByUuid

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

func (*SwanClient) SwanGetTasks

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

func (*SwanClient) SwanUpdateAssignedTask

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

func (*SwanClient) SwanUpdateOfflineDealStatus

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

func (*SwanClient) SwanUpdateTaskByUuid

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

func (*SwanClient) UpdateMinerBidConf

func (swanClient *SwanClient) UpdateMinerBidConf(minerFid string, confMiner model.Miner)

type SwanCreateTaskResponse

type SwanCreateTaskResponse struct {
	Data    SwanCreateTaskResponseData `json:"data"`
	Status  string                     `json:"status"`
	Message string                     `json:"message"`
}

type SwanCreateTaskResponseData

type SwanCreateTaskResponseData struct {
	Filename string `json:"filename"`
	Uuid     string `json:"uuid"`
}

type TokenAccessInfo

type TokenAccessInfo struct {
	ApiKey      string `json:"apikey"`
	AccessToken string `json:"access_token"`
}

type UpdateOfflineDealData

type UpdateOfflineDealData struct {
	Deal    model.OfflineDeal `json:"deal"`
	Message string            `json:"message"`
}

type UpdateOfflineDealResponse

type UpdateOfflineDealResponse struct {
	Data   UpdateOfflineDealData `json:"data"`
	Status string                `json:"status"`
}