computing

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2025 License: MIT Imports: 93 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ResourceCpu     string = "cpu"
	ResourceMem     string = "mem"
	ResourceStorage string = "storage"
)
View Source 
const (
	PingMsg    = "ping"
	PingPeriod = 3 * time.Second
)
View Source 
const (
	TransferInterval = 10000
)

Variables

View Source 
var NetworkPolicyFlag bool
View Source 
var TaskMap sync.Map

Functions

func BlackList added in v0.6.0 

func BlackList(c *gin.Context)

func BuildImagesByDockerfile 

func BuildImagesByDockerfile(jobUuid, spaceName, imagePath string) (string, string)

func BytesToHumanReadable added in v0.7.0 

func BytesToHumanReadable(bytes int64) string

func CancelJob 

func CancelJob(c *gin.Context)

func CheckClusterNetworkPolicy added in v0.7.0 

func CheckClusterNetworkPolicy()

func CheckNodeportServiceEnv added in v0.7.0 

func CheckNodeportServiceEnv(c *gin.Context)

func CheckWalletBlackList added in v0.6.0 

func CheckWalletBlackList(jobSourceURI string) bool

func CheckWalletBlackListForEcp added in v1.0.0 

func CheckWalletBlackListForEcp(walletAddress string) bool

func CheckWalletWhiteList added in v0.4.6 

func CheckWalletWhiteList(jobSourceURI string) bool

func CheckWalletWhiteListForEcp added in v1.0.0 

func CheckWalletWhiteListForEcp(walletAddress string) bool

func ContractABI added in v1.0.0 

func ContractABI(contractABI string) (abi.ABI, error)

func ContractSigMethods added in v1.0.0 

func ContractSigMethods(contractABI string) (methods map[string]abi.Method, err error)

func CronTaskForEcp added in v0.5.0 

func CronTaskForEcp()

func DeleteJob added in v0.6.5 

func DeleteJob(namespace, jobUuid string, msg string) error

func DeployImage added in v1.0.0 

func DeployImage(c *gin.Context)

func DeployImageSpaceTask added in v1.0.0 

func DeployImageSpaceTask(jobData models.JobData, job models.FcpDeployImageReq, hostName string, nodeName string, gpuIndex []string, prepareGpu []models.PodGpu)

func DeploySpaceTask 

func DeploySpaceTask(jobData models.JobData, deployParam DeployParam, hostName string, gpuProductName string, nodePort int32, jobType int, ipWhiteList []string, gpuIndex []string, gpuNum int)

func DoProof 

func DoProof(c *gin.Context)

func DoUbiTaskForDocker added in v0.4.6 

func DoUbiTaskForDocker(c *gin.Context)

func DoUbiTaskForK8s added in v0.4.6 

func DoUbiTaskForK8s(c *gin.Context)

func DoZkTask added in v1.1.0 

func DoZkTask(c *gin.Context)

func ExtractExposedPort 

func ExtractExposedPort(dockerfilePath string) (string, error)

func GenerateNodeID 

func GenerateNodeID(cpRepoPath string) (string, string, string)

func GeneratePriceConfig added in v0.6.5 

func GeneratePriceConfig() error

func GetAggregatedTaskInfo added in v0.6.2 

func GetAggregatedTaskInfo(taskContract string) (string, error)

func GetCpBalance added in v1.0.1 

func GetCpBalance()

func GetCpResource added in v0.4.6 

func GetCpResource(c *gin.Context)

func GetJobStatus added in v0.5.0 

func GetJobStatus(c *gin.Context)

func GetNodeGpuResource added in v1.1.0 

func GetNodeGpuResource(allPods []corev1.Pod, node *corev1.Node) map[string]GpuData

func GetNodeId 

func GetNodeId(cpRepoPath string) string

func GetNodeResource 

func GetNodeResource(allPods []corev1.Pod, node *corev1.Node) (map[string]GpuData, map[string]int64, *models.NodeResource)

func GetOwnerAddressAndWorkerAddress added in v0.5.0 

func GetOwnerAddressAndWorkerAddress() (string, string, error)

func GetPrice added in v0.6.5 

func GetPrice(c *gin.Context)

func GetPublicKey added in v0.6.4 

func GetPublicKey(c *gin.Context)

func GetServiceProviderInfo 

func GetServiceProviderInfo(c *gin.Context)

func GetSpaceLog 

func GetSpaceLog(c *gin.Context)

func GetTaskInfoOnChain added in v0.5.0 

func GetTaskInfoOnChain(taskContract string) (models.EcpTaskInfo, error)

func GetToken added in v0.6.2 

func GetToken() (string, error)

func ImportImageToContainerd added in v0.6.5 

func ImportImageToContainerd(tarFile string) error

func InitComputingProvider 

func InitComputingProvider(cpRepoPath string) string

func ReNewJob 

func ReNewJob(c *gin.Context)

func ReceiveJob 

func ReceiveJob(c *gin.Context)

func ReceiveUbiProof 

func ReceiveUbiProof(c *gin.Context)

func RestartResourceExporter added in v0.5.0 

func RestartResourceExporter() error

func RestartTraefikService added in v1.0.0 

func RestartTraefikService() error

func RetryFn added in v1.0.0 

func RetryFn(fn func() error, maxRetries int, delay time.Duration) error

func StatisticalSources 

func StatisticalSources(c *gin.Context)

func SyncCpAccountInfo added in v0.5.0 

func SyncCpAccountInfo() (*models.Account, error)

func TransactionInputParas added in v1.0.0 

func TransactionInputParas(ethClient *ethclient.Client, sigMethods map[string]abi.Method, txHash common.Hash) ([]interface{}, error)

func ValidateName added in v1.0.0 

func ValidateName(name string) error

func WhiteList added in v0.5.0 

func WhiteList(c *gin.Context)

Types

type Config added in v0.6.5 

type Config struct {
	Resources map[string]string `toml:"-"`
}

type CpBalanceService added in v1.0.1 

type CpBalanceService struct {
	*gorm.DB
}

func NewCpBalanceService added in v1.0.1 

func NewCpBalanceService() CpBalanceService

func (CpBalanceService) GetCpBalance added in v1.0.1 

func (cpServ CpBalanceService) GetCpBalance(cpAccount string) (*models.CpBalanceEntity, error)

func (CpBalanceService) SaveCpBalance added in v1.0.1 

func (cpServ CpBalanceService) SaveCpBalance(cpBalance models.CpBalanceEntity) (err error)

func (CpBalanceService) UpdateCpBalance added in v1.0.1 

func (cpServ CpBalanceService) UpdateCpBalance(cpBalance models.CpBalanceEntity) error

type CpInfoService added in v0.5.0 

type CpInfoService struct {
	*gorm.DB
}

func NewCpInfoService added in v0.5.0 

func NewCpInfoService() CpInfoService

func (CpInfoService) GetCpInfoEntityByAccountAddress added in v0.5.0 

func (cpServ CpInfoService) GetCpInfoEntityByAccountAddress(accountAddress string) (*models.CpInfoEntity, error)

func (CpInfoService) SaveCpInfoEntity added in v0.5.0 

func (cpServ CpInfoService) SaveCpInfoEntity(cp *models.CpInfoEntity) (err error)

func (CpInfoService) UpdateCpInfoByNodeId added in v0.5.0 

func (cpServ CpInfoService) UpdateCpInfoByNodeId(cp *models.CpInfoEntity) (err error)

type CpResourceSummary added in v0.5.0 

type CpResourceSummary struct {
	ClusterInfo []*models.NodeResource
}

type CronTask 

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

func NewCronTask 

func NewCronTask(nodeId string) *CronTask

func (*CronTask) CheckCpBalance added in v1.0.1 

func (task *CronTask) CheckCpBalance()

func (*CronTask) DeleteSpaceLog added in v1.0.2 

func (task *CronTask) DeleteSpaceLog()

func (*CronTask) RunTask 

func (task *CronTask) RunTask()

func (*CronTask) UpdateContainerLog added in v1.0.2 

func (task *CronTask) UpdateContainerLog()

type Deploy 

type Deploy struct {
	SpacePath string
	TaskType  string
	// contains filtered or unexported fields
}

func NewDeploy 

func NewDeploy(originalJobUuid, lowerJobUuid, hostName, walletAddress, hardwareDesc string, duration int64, spaceType string, spaceHardware models.SpaceHardware, jobType int) *Deploy

func (*Deploy) DeployImageToK8s added in v1.0.0 

func (d *Deploy) DeployImageToK8s(containerResource models.DeployJobParam) error

func (*Deploy) DeploySshTaskToK8s added in v0.7.0 

func (d *Deploy) DeploySshTaskToK8s(containerResource yaml.ContainerResource, nodePort int32) error

func (*Deploy) DockerfileToK8s 

func (d *Deploy) DockerfileToK8s()

func (*Deploy) ModelInferenceToK8s 

func (d *Deploy) ModelInferenceToK8s() error

func (*Deploy) WithDockerfile 

func (d *Deploy) WithDockerfile(image, dockerfilePath string) *Deploy

func (*Deploy) WithGpuIndex added in v1.0.0 

func (d *Deploy) WithGpuIndex(index []string) *Deploy

func (*Deploy) WithGpuProductName 

func (d *Deploy) WithGpuProductName(gpuProductName string) *Deploy

func (*Deploy) WithHardware added in v0.4.6 

func (d *Deploy) WithHardware(cpu, memory, storage int, gpuModel string, gpuNum int) *Deploy

func (*Deploy) WithImage added in v0.4.6 

func (d *Deploy) WithImage(images string) *Deploy

func (*Deploy) WithIpWhiteList added in v0.7.0 

func (d *Deploy) WithIpWhiteList(ipWhiteList []string) *Deploy

func (*Deploy) WithModelSettingFile 

func (d *Deploy) WithModelSettingFile(modelsSettingFile string) *Deploy

func (*Deploy) WithSpaceName added in v0.6.5 

func (d *Deploy) WithSpaceName(spaceName string) *Deploy

func (*Deploy) WithSpacePath 

func (d *Deploy) WithSpacePath(spacePath string) *Deploy

func (*Deploy) WithSshKey added in v0.7.0 

func (d *Deploy) WithSshKey(sshKey string) *Deploy

func (*Deploy) WithYamlInfo 

func (d *Deploy) WithYamlInfo(yamlPath string) *Deploy

func (*Deploy) YamlToK8s 

func (d *Deploy) YamlToK8s(nodePort int32) error

type DeployParam added in v0.6.4 

type DeployParam struct {
	ContainsYaml          bool
	YamlFilePath          string
	BuildImagePath        string
	ModelsSettingFilePath string
}

func DownloadSpaceResources added in v0.6.5 

func DownloadSpaceResources(jobUuid string, files []models.SpaceFile) (DeployParam, error)

type DockerService 

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

func NewDockerService 

func NewDockerService() *DockerService

func (*DockerService) BuildImage 

func (ds *DockerService) BuildImage(jobUuid, buildPath, imageName string) error

func (*DockerService) CheckRunningContainer added in v0.5.0 

func (ds *DockerService) CheckRunningContainer(containerName string) (bool, string, error)

func (*DockerService) CleanResourceForDocker added in v0.6.4 

func (ds *DockerService) CleanResourceForDocker(onlyClearContainer bool)

func (*DockerService) CleanResourceForK8s added in v0.6.4 

func (ds *DockerService) CleanResourceForK8s()

func (*DockerService) ContainerCreateAndStart added in v0.4.6 

func (ds *DockerService) ContainerCreateAndStart(config *container.Config, hostConfig *container.HostConfig, networkingConfig *network.NetworkingConfig, containerName string) error

func (*DockerService) ContainerLogs added in v0.4.6 

func (ds *DockerService) ContainerLogs(containerName string) (string, error)

func (*DockerService) CreateNetwork added in v1.0.0 

func (ds *DockerService) CreateNetwork(networkName string) error

func (*DockerService) GetContainerLogStream added in v0.4.8 

func (ds *DockerService) GetContainerLogStream(ctx context.Context, containerName string) (io.ReadCloser, error)

func (*DockerService) GetContainerStatus added in v0.7.0 

func (ds *DockerService) GetContainerStatus() (map[string]string, error)

func (*DockerService) IsExistContainer added in v0.6.0 

func (ds *DockerService) IsExistContainer(containerName string) bool

func (*DockerService) PullImage added in v0.4.6 

func (ds *DockerService) PullImage(imageName string) error

func (*DockerService) PushImage 

func (ds *DockerService) PushImage(imagesName string) error

func (*DockerService) RemoveContainerByName added in v0.5.0 

func (ds *DockerService) RemoveContainerByName(containerName string) error

func (*DockerService) RemoveImage 

func (ds *DockerService) RemoveImage(imageId string) error

func (*DockerService) SaveDockerImage added in v0.6.5 

func (ds *DockerService) SaveDockerImage(imageName string) (string, error)

type EcpJobService added in v0.7.0 

type EcpJobService struct {
	*gorm.DB
}

func NewEcpJobService added in v0.7.0 

func NewEcpJobService() EcpJobService

func (EcpJobService) DeleteContainerByUuid added in v0.7.0 

func (cpServ EcpJobService) DeleteContainerByUuid(uuid string) (err error)

func (EcpJobService) GetEcpJobByUuid added in v0.7.0 

func (cpServ EcpJobService) GetEcpJobByUuid(uuid string) (*models.EcpJobEntity, error)

func (EcpJobService) GetEcpJobList added in v1.0.0 

func (cpServ EcpJobService) GetEcpJobList(status []string) ([]models.EcpJobEntity, error)

func (EcpJobService) GetEcpJobs added in v0.7.0 

func (cpServ EcpJobService) GetEcpJobs(jobUuid string) ([]models.EcpJobEntity, error)

func (EcpJobService) GetEcpJobsByLimit added in v1.0.0 

func (cpServ EcpJobService) GetEcpJobsByLimit(tailNum int) ([]models.EcpJobEntity, error)

func (EcpJobService) SaveEcpJobEntity added in v0.7.0 

func (cpServ EcpJobService) SaveEcpJobEntity(job *models.EcpJobEntity) (err error)

func (EcpJobService) UpdateEcpJobEntity added in v0.7.0 

func (cpServ EcpJobService) UpdateEcpJobEntity(jobUuid, status string) (err error)

func (EcpJobService) UpdateEcpJobEntityContainerName added in v0.7.1 

func (cpServ EcpJobService) UpdateEcpJobEntityContainerName(jobUuid string, containerName string) (err error)

func (EcpJobService) UpdateEcpJobEntityMessage added in v1.0.0 

func (cpServ EcpJobService) UpdateEcpJobEntityMessage(jobUuid string, message string) (err error)

func (EcpJobService) UpdateEcpJobEntityPortsAndServiceUrl added in v1.0.0 

func (cpServ EcpJobService) UpdateEcpJobEntityPortsAndServiceUrl(jobUuid, portMap, serviceUrl string) (err error)

func (EcpJobService) UpdateEcpJobEntityRewardAndBlock added in v0.7.1 

func (cpServ EcpJobService) UpdateEcpJobEntityRewardAndBlock(jobUuid string, blockNumber int64, reward float64) (err error)

type ErrorLine 

type ErrorLine struct {
	Error       string `json:"error"`
	ErrorDetail struct {
		Message string `json:"message"`
	} `json:"errorDetail"`
}

type GPUInfo added in v1.0.0 

type GPUInfo struct {
	Name      string
	Total     int
	Used      int
	Available int
	FreeIndex []string
}

type GPUManager added in v1.0.0 

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

func NewGpuManager added in v1.0.0 

func NewGpuManager() *GPUManager

func (*GPUManager) AllocateGPU added in v1.0.0 

func (gm *GPUManager) AllocateGPU(key string, count int) ([]string, error)

func (*GPUManager) CheckAvailableGPU added in v1.0.0 

func (gm *GPUManager) CheckAvailableGPU() (string, bool)

func (*GPUManager) GetGPU added in v1.0.0 

func (gm *GPUManager) GetGPU(key string) (GPUInfo, bool)

func (*GPUManager) ReleaseGPU added in v1.0.0 

func (gm *GPUManager) ReleaseGPU(key string, count int, indexs []string) error

func (*GPUManager) UpdateGPU added in v1.0.0 

func (gm *GPUManager) UpdateGPU(key string, gpuInfo GPUInfo)

type GpuData added in v1.0.0 

type GpuData struct {
	Total     int
	Used      int
	Free      int
	FreeIndex []string
	UsedIndex []string
}

type HardwareField added in v0.6.5 

type HardwareField struct {
	TagValue int
	Name     string
	Value    string
}

func GetStructByTag added in v0.6.5 

func GetStructByTag(v interface{}) ([]HardwareField, error)

type HardwarePrice added in v0.6.5 

type HardwarePrice struct {
	TARGET_CPU          string `toml:"TARGET_CPU" tag:"1"`
	TARGET_MEMORY       string `toml:"TARGET_MEMORY" tag:"2"`
	TARGET_HD_EPHEMERAL string `toml:"TARGET_HD_EPHEMERAL" tag:"3"`
	TARGET_GPU_DEFAULT  string `toml:"TARGET_GPU_DEFAULT" tag:"4"`
	GpusPrice           map[string]string
}

func ReadPriceConfig added in v0.6.5 

func ReadPriceConfig() (HardwarePrice, error)

type HttpClient added in v0.6.2 

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

func NewHttpClient added in v0.6.2 

func NewHttpClient(host string, header http.Header) *HttpClient

func (*HttpClient) Get added in v0.6.2 

func (c *HttpClient) Get(api string, queries url.Values, dest any) error

func (*HttpClient) PostForm added in v0.6.2 

func (c *HttpClient) PostForm(api string, data url.Values, dest any) error

func (*HttpClient) PostJSON added in v0.6.2 

func (c *HttpClient) PostJSON(api string, data any, dest any) error

func (*HttpClient) Request added in v0.6.2 

func (c *HttpClient) Request(method string, api string, body io.Reader, dest any, contentType ...string) (err error)

type ImageJobService added in v0.7.0 

type ImageJobService struct {
}

func NewImageJobService added in v0.7.0 

func NewImageJobService() *ImageJobService

func (*ImageJobService) CheckJobCondition added in v0.7.0 

func (*ImageJobService) CheckJobCondition(c *gin.Context)

func (*ImageJobService) DeleteJob added in v0.7.0 

func (*ImageJobService) DeleteJob(c *gin.Context)

func (*ImageJobService) DeployInference added in v1.0.0 

func (*ImageJobService) DeployInference(c *gin.Context, deployJob models.DeployJobParam, totalCost float64, logUrl string)

func (*ImageJobService) DeployJob added in v0.7.0 

func (imageJob *ImageJobService) DeployJob(c *gin.Context)

func (*ImageJobService) DeployMining added in v1.0.0 

func (*ImageJobService) DeployMining(c *gin.Context, deployJob models.DeployJobParam, totalCost float64, logUrl string, price string)

func (*ImageJobService) DockerLogsHandler added in v1.0.0 

func (*ImageJobService) DockerLogsHandler(c *gin.Context)

func (*ImageJobService) GetJobStatus added in v0.7.0 

func (*ImageJobService) GetJobStatus(c *gin.Context)

type JobService added in v0.5.0 

type JobService struct {
	*gorm.DB
}

func NewJobService added in v0.5.0 

func NewJobService() JobService

func (JobService) DeleteJobEntityByJobUuId added in v0.6.5 

func (jobServ JobService) DeleteJobEntityByJobUuId(jobUuid string, jobStatus int) error

func (JobService) DeleteJobEntityBySpaceUuId added in v0.5.0 

func (jobServ JobService) DeleteJobEntityBySpaceUuId(spaceUuid, jobUuid string, jobStatus int) error

func (JobService) GetJobEntityByJobUuid added in v0.5.0 

func (jobServ JobService) GetJobEntityByJobUuid(jobUuid string) (models.JobEntity, error)

func (JobService) GetJobEntityBySpaceUuid added in v0.5.0 

func (jobServ JobService) GetJobEntityBySpaceUuid(spaceUuid string) int64

func (JobService) GetJobEntityByTaskUuid added in v0.5.0 

func (jobServ JobService) GetJobEntityByTaskUuid(taskUuid string) (models.JobEntity, error)

func (JobService) GetJobList added in v0.5.0 

func (jobServ JobService) GetJobList(status int, tailNum int) (list []*models.JobEntity, err error)

func (JobService) GetJobListByNoReward added in v0.6.2 

func (jobServ JobService) GetJobListByNoReward() (list []*models.JobEntity, err error)

func (JobService) SaveJobEntity added in v0.5.0 

func (jobServ JobService) SaveJobEntity(job *models.JobEntity) (err error)

func (JobService) UpdateJobEntityByJobUuid added in v0.5.0 

func (jobServ JobService) UpdateJobEntityByJobUuid(job *models.JobEntity) (err error)

func (JobService) UpdateJobEntityStatusByJobUuid added in v1.1.0 

func (jobServ JobService) UpdateJobEntityStatusByJobUuid(jobUuid string, status int) (err error)

func (JobService) UpdateJobResultUrlByJobUuid added in v0.5.0 

func (jobServ JobService) UpdateJobResultUrlByJobUuid(jobUuid string, resultUrl string) (err error)

func (JobService) UpdateJobReward added in v0.6.2 

func (jobServ JobService) UpdateJobReward(taskUuid string, amount string) (err error)

func (JobService) UpdateJobScannedBlock added in v0.6.2 

func (jobServ JobService) UpdateJobScannedBlock(taskUuid string, end uint64) (err error)

type K8sService 

type K8sService struct {
	Version string
	// contains filtered or unexported fields
}

func NewK8sService 

func NewK8sService() *K8sService

func (*K8sService) AddNodeLabel 

func (s *K8sService) AddNodeLabel(nodeName, key string) error

func (*K8sService) AddNodeLabelForArchitecture added in v0.7.1 

func (s *K8sService) AddNodeLabelForArchitecture(nodeName, key string) error

func (*K8sService) CheckServiceNodePort added in v0.7.0 

func (s *K8sService) CheckServiceNodePort(targetNodePort int32) (bool, int32, error)

func (*K8sService) CreateConfigMap 

func (s *K8sService) CreateConfigMap(ctx context.Context, k8sNameSpace, jobUuid, basePath, configName string) (*coreV1.ConfigMap, error)

func (*K8sService) CreateDeployment 

func (s *K8sService) CreateDeployment(ctx context.Context, nameSpace string, deploy *appV1.Deployment) (result *appV1.Deployment, err error)

func (*K8sService) CreateIngress 

func (s *K8sService) CreateIngress(ctx context.Context, k8sNameSpace, spaceUuid, hostName string, port int32, ipWhiteList []string) (*networkingv1.Ingress, error)

func (*K8sService) CreateNameSpace 

func (s *K8sService) CreateNameSpace(ctx context.Context, nameSpace *coreV1.Namespace, opts metaV1.CreateOptions) (result *coreV1.Namespace, err error)

func (*K8sService) CreateNetworkPolicy 

func (s *K8sService) CreateNetworkPolicy(ctx context.Context, namespace string) (*networkingv1.NetworkPolicy, error)

func (*K8sService) CreateService 

func (s *K8sService) CreateService(ctx context.Context, nameSpace, spaceUuid string, containerPort int32) (result *coreV1.Service, err error)

func (*K8sService) CreateServiceByNodePort added in v0.4.6 

func (s *K8sService) CreateServiceByNodePort(ctx context.Context, nameSpace, taskUuid string, containerPort int32, nodePort int32, exclude22Port []int32, labelName string) (result *coreV1.Service, err error)

func (*K8sService) DeleteDeployRs 

func (s *K8sService) DeleteDeployRs(ctx context.Context, namespace, jobUuid string) error

func (*K8sService) DeleteDeployment 

func (s *K8sService) DeleteDeployment(ctx context.Context, namespace, deploymentName string) error

func (*K8sService) DeleteIngress 

func (s *K8sService) DeleteIngress(ctx context.Context, nameSpace, ingressName string) error

func (*K8sService) DeleteNameSpace 

func (s *K8sService) DeleteNameSpace(ctx context.Context, nameSpace string) error

func (*K8sService) DeletePod 

func (s *K8sService) DeletePod(ctx context.Context, namespace, spaceUuid string) error

func (*K8sService) DeleteService 

func (s *K8sService) DeleteService(ctx context.Context, namespace, serviceName string) error

func (*K8sService) GetAPIServerEndpoint 

func (s *K8sService) GetAPIServerEndpoint() string

func (*K8sService) GetAllActivePod 

func (s *K8sService) GetAllActivePod(ctx context.Context) ([]coreV1.Pod, error)

func (*K8sService) GetClusterRuntime added in v0.6.5 

func (s *K8sService) GetClusterRuntime() (string, error)

func (*K8sService) GetDeploymentActiveCount 

func (s *K8sService) GetDeploymentActiveCount() (int, error)

func (*K8sService) GetDeploymentImages 

func (s *K8sService) GetDeploymentImages(ctx context.Context, namespace, deploymentName string) ([]string, error)

func (*K8sService) GetDeploymentStatus 

func (s *K8sService) GetDeploymentStatus(namespace, spaceUuid string) (string, error)

func (*K8sService) GetGlobalNetworkPolicy added in v0.7.0 

func (s *K8sService) GetGlobalNetworkPolicy(gnpName string) (*calicov3.GlobalNetworkPolicy, error)

func (*K8sService) GetGlobalNetworkSet added in v0.7.0 

func (s *K8sService) GetGlobalNetworkSet(gnsName string) (*calicov3.GlobalNetworkSet, error)

func (*K8sService) GetNameSpace 

func (s *K8sService) GetNameSpace(ctx context.Context, nameSpace string, opts metaV1.GetOptions) (result *coreV1.Namespace, err error)

func (*K8sService) GetNodeGpuSummary 

func (s *K8sService) GetNodeGpuSummary(ctx context.Context) (map[string]map[string]GpuData, error)

func (*K8sService) GetPodLogByPodName added in v0.4.5 

func (s *K8sService) GetPodLogByPodName(namespace, podName string, podLogOptions *coreV1.PodLogOptions) (string, error)

func (*K8sService) GetPods 

func (s *K8sService) GetPods(namespace, jobUuid string) (bool, error)

func (*K8sService) GetResourceExporterPodLog 

func (s *K8sService) GetResourceExporterPodLog(ctx context.Context) (map[string]models.CollectNodeInfo, error)

func (*K8sService) GetResourceExporterPodLogForNode added in v1.1.0 

func (s *K8sService) GetResourceExporterPodLogForNode(ctx context.Context) (map[string]models.NodeResource, error)

func (*K8sService) GetResourceExporterVersion added in v1.1.0 

func (s *K8sService) GetResourceExporterVersion() (string, error)

func (*K8sService) GetServiceByName 

func (s *K8sService) GetServiceByName(ctx context.Context, namespace, serviceName string, opts metaV1.GetOptions) (result *coreV1.Service, err error)

func (*K8sService) GetUsedNodePorts added in v0.7.0 

func (s *K8sService) GetUsedNodePorts() (map[int32]struct{}, error)

func (*K8sService) ListNamespace 

func (s *K8sService) ListNamespace(ctx context.Context) ([]string, error)

func (*K8sService) ListUsedImage 

func (s *K8sService) ListUsedImage(ctx context.Context, nameSpace string) ([]string, error)

func (*K8sService) PodDoCommand 

func (s *K8sService) PodDoCommand(namespace, podName, containerName string, podCmd []string) error

func (*K8sService) StatisticalSources 

func (s *K8sService) StatisticalSources(ctx context.Context) ([]*models.NodeResource, error)

func (*K8sService) UpdateContainerLogToFile added in v1.0.2 

func (s *K8sService) UpdateContainerLogToFile(jobUuid string)

func (*K8sService) WaitForPodRunningByHttp added in v0.4.6 

func (s *K8sService) WaitForPodRunningByHttp(namespace, jobUuid, serviceIp string) (string, error)

func (*K8sService) WaitForPodRunningByTcp added in v0.4.6 

func (s *K8sService) WaitForPodRunningByTcp(namespace, jobUuid string) (string, error)

type ResultChecker added in v0.6.2 

type ResultChecker interface {
	Check() error
}

type SendProofResp added in v0.6.2 

type SendProofResp struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
	Data struct {
		BlockHash string `json:"block_hash"`
		Sign      string `json:"sign"`
	} `json:"data"`
}

type SequenceTask added in v0.6.2 

type SequenceTask struct {
	Id                 int    `json:"id"`
	Uuid               string `json:"uuid"`
	Type               int    `json:"type"`
	InputParam         string `json:"input_param"`
	VerifyParam        string `json:"verify_param"`
	ResourceType       int    `json:"resource_type"`
	Deadline           int    `json:"deadline"`
	Proof              string `json:"proof"`
	CheckCode          string `json:"check_code"`
	Reward             string `json:"reward"`
	Status             string `json:"status"`
	SequenceCid        string `json:"sequence_cid"`
	SettlementCid      string `json:"settlement_cid"`
	SequenceTaskAddr   string `json:"sequence_task_addr"`
	SettlementTaskAddr string `json:"settlement_task_addr"`
}

type Sequencer added in v0.6.2 

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

func NewSequencer added in v0.6.2 

func NewSequencer() *Sequencer

func (*Sequencer) GetToken added in v0.6.2 

func (s *Sequencer) GetToken() error

func (*Sequencer) QueryTask added in v0.6.2 

func (s *Sequencer) QueryTask(taskType int, taskIds []int64, uuids []string) (TaskListResp, error)

func (*Sequencer) SendTaskProof added in v0.6.2 

func (s *Sequencer) SendTaskProof(data []byte) (SendProofResp, error)

type StorageService 

type StorageService struct {
	McsApiKey      string `json:"mcs_api_key"`
	McsAccessToken string `json:"mcs_access_token"`
	NetWork        string `json:"net_work"`
	BucketName     string `json:"bucket_name"`
	// contains filtered or unexported fields
}

func NewStorageService 

func NewStorageService() (*StorageService, error)

func (*StorageService) CreateBucket 

func (storage *StorageService) CreateBucket(bucketName string)

func (*StorageService) CreateFolder 

func (storage *StorageService) CreateFolder(folderName string)

func (*StorageService) DeleteBucket 

func (storage *StorageService) DeleteBucket(bucketName string) error

func (*StorageService) GetGatewayUrl 

func (storage *StorageService) GetGatewayUrl() (*string, error)

func (*StorageService) UploadFileToBucket 

func (storage *StorageService) UploadFileToBucket(objectName, filePath string, replace bool) (*bucket.OssFile, error)

type TaskGroup added in v0.6.2 

type TaskGroup struct {
	Items []*models.TaskEntity
	Ids   []int64
	Uuids []string
	Type  int // 1: contract  2: sequncer 3: mining
}

type TaskListResp added in v0.6.2 

type TaskListResp struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
	Data struct {
		Total int            `json:"total"`
		List  []SequenceTask `json:"list"`
	} `json:"data"`
}

type TaskManagerContract added in v0.6.2 

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

func NewTaskManagerContract added in v0.6.2 

func NewTaskManagerContract() (*TaskManagerContract, error)

func (*TaskManagerContract) Scan added in v0.6.2 

func (taskManager *TaskManagerContract) Scan() error

type TaskPaymentService added in v0.7.1 

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

func NewTaskPaymentService added in v0.7.1 

func NewTaskPaymentService() *TaskPaymentService

func (*TaskPaymentService) ScannerChainGetTaskPayment added in v0.7.1 

func (tps *TaskPaymentService) ScannerChainGetTaskPayment()

type TaskService added in v0.5.0 

type TaskService struct {
	*gorm.DB
}

func NewTaskService added in v0.5.0 

func NewTaskService() TaskService

func (TaskService) GetTaskByUuid added in v1.0.0 

func (taskServ TaskService) GetTaskByUuid(uuid string) (*models.TaskEntity, error)

func (TaskService) GetTaskEntity added in v0.5.0 

func (taskServ TaskService) GetTaskEntity(taskId int64) (*models.TaskEntity, error)

func (TaskService) GetTaskList added in v0.5.0 

func (taskServ TaskService) GetTaskList(tailNum int, taskStatus ...int) (list []*models.TaskEntity, err error)

func (TaskService) GetTaskListNoRewardForFilC2 added in v1.0.2 

func (taskServ TaskService) GetTaskListNoRewardForFilC2() (list []*models.TaskEntity, err error)

func (TaskService) GetTaskListNoRewardForMining added in v1.0.2 

func (taskServ TaskService) GetTaskListNoRewardForMining() (list []*models.TaskEntity, err error)

func (TaskService) SaveTaskEntity added in v0.5.0 

func (taskServ TaskService) SaveTaskEntity(task *models.TaskEntity) (err error)

func (TaskService) UpdateTaskEntityByTaskId added in v0.6.2 

func (taskServ TaskService) UpdateTaskEntityByTaskId(task *models.TaskEntity) (err error)

func (TaskService) UpdateTaskEntityByTaskUuId added in v1.0.2 

func (taskServ TaskService) UpdateTaskEntityByTaskUuId(task *models.TaskEntity) (err error)

func (TaskService) UpdateTaskStatusById added in v1.0.0 

func (taskServ TaskService) UpdateTaskStatusById(taskId int, status int) (err error)

func (TaskService) UpdateTaskStatusByUuid added in v1.0.0 

func (taskServ TaskService) UpdateTaskStatusByUuid(uuid string, status int) (err error)

type TaskStatus added in v0.7.1 

type TaskStatus struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
	Data struct {
		Ended  bool   `json:"ended"`
		Status string `json:"status"`
	} `json:"data"`
}

type TokenResp added in v0.6.2 

type TokenResp struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
	Data struct {
		Token string `json:"token"`
	} `json:"data"`
}

type WsClient 

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

func NewWsClient 

func NewWsClient(client *websocket.Conn) *WsClient

func (*WsClient) Close 

func (ws *WsClient) Close()

func (*WsClient) HandleLogs 

func (ws *WsClient) HandleLogs(reader io.Reader)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.