computing

Oct 28, 2025

Changes in this version

+ func GetResourceExporterMetrics(c *gin.Context)

+ func GetUbiResourceExporterMetrics(c *gin.Context)

type DockerService

+ func (ds *DockerService) ContainerExec(containerID string, cmd []string) (string, error)

Feb 21, 2025

Changes in this version

+ func DoZkTaskForK8s(c *gin.Context)

type JobService

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

Feb 10, 2025

Changes in this version

+ func DoZkTask(c *gin.Context)

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

type JobService

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

type K8sService

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

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

Jan 17, 2025

Changes in this version

type CronTask

+ func (task *CronTask) DeleteSpaceLog()

+ func (task *CronTask) UpdateContainerLog()

type K8sService

+ func (s *K8sService) UpdateContainerLogToFile(jobUuid string)

type SequenceTask

+ Uuid string

type TaskGroup

+ Uuids []string

type TaskService

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

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

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

Dec 31, 2024

Changes in this version

+ func GetCpBalance()

+ type CpBalanceService struct

+ func NewCpBalanceService() CpBalanceService

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

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

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

type CronTask

+ func (task *CronTask) CheckCpBalance()

Dec 14, 2024

Changes in this version

+ func CheckWalletBlackListForEcp(walletAddress string) bool

+ func CheckWalletWhiteListForEcp(walletAddress string) bool

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

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

+ func DeployImage(c *gin.Context)

+ func DeployImageSpaceTask(jobData models.JobData, job models.FcpDeployImageReq, hostName string, ...)

+ func RestartTraefikService() error

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

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

+ func ValidateName(name string) error

type Deploy

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

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

type DockerService

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

type EcpJobService

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

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

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

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

+ type GPUInfo struct

+ Available int

+ FreeIndex []string

+ Name string

+ Total int

+ Used int

+ type GPUManager struct

+ func NewGpuManager() *GPUManager

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

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

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

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

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

+ type GpuData struct

+ Free int

+ FreeIndex []string

+ Total int

+ Used int

+ UsedIndex []string

type ImageJobService

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

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

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

type TaskService

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

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

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

Nov 13, 2024

Changes in this version

+ const TransferInterval

type EcpJobService

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

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

type K8sService

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

+ type TaskPaymentService struct

+ func NewTaskPaymentService() *TaskPaymentService

+ func (tps *TaskPaymentService) ScannerChainGetTaskPayment()

+ type TaskStatus struct

+ Code int

+ Data struct{ ... }

+ Msg string

Oct 25, 2024

Changes in this version

+ var NetworkPolicyFlag bool

+ func BytesToHumanReadable(bytes int64) string

+ func CheckClusterNetworkPolicy()

+ func CheckNodeportServiceEnv(c *gin.Context)

type Deploy

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

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

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

type DockerService

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

+ type EcpJobService struct

+ func NewEcpJobService() EcpJobService

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

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

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

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

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

+ type ImageJobService struct

+ func NewImageJobService() *ImageJobService

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

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

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

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

type K8sService

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

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

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

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

Sep 14, 2024

Changes in this version

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

+ func GeneratePriceConfig() error

+ func GetPrice(c *gin.Context)

+ func ImportImageToContainerd(tarFile string) error

+ type Config struct

+ Resources map[string]string

type Deploy

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

type DeployParam

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

type DockerService

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

+ type HardwareField struct

+ Name string

+ TagValue int

+ Value string

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

+ type HardwarePrice struct

+ GpusPrice map[string]string

+ TARGET_CPU string

+ TARGET_GPU_DEFAULT string

+ TARGET_HD_EPHEMERAL string

+ TARGET_MEMORY string

+ func ReadPriceConfig() (HardwarePrice, error)

type JobService

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

type K8sService

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

Aug 22, 2024

Changes in this version

+ func GetPublicKey(c *gin.Context)

+ type DeployParam struct

+ BuildImagePath string

+ ContainsYaml bool

+ ModelsSettingFilePath string

+ YamlFilePath string

type DockerService

+ func (ds *DockerService) CleanResourceForDocker()

+ func (ds *DockerService) CleanResourceForK8s()

Jul 30, 2024

Changes in this version

+ func GetAggregatedTaskInfo(taskContract string) (string, error)

+ func GetToken() (string, error)

+ type HttpClient struct

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

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

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

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

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

type JobService

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

+ func (jobServ JobService) UpdateAllJobStatusToDeleted() error

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

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

+ type ResultChecker interface

+ Check func() error

+ type SendProofResp struct

+ Code int

+ Data struct{ ... }

+ Msg string

+ type SequenceTask struct

+ CheckCode string

+ Deadline int

+ Id int

+ InputParam string

+ Proof string

+ ResourceType int

+ Reward string

+ SequenceCid string

+ SequenceTaskAddr string

+ SettlementCid string

+ SettlementTaskAddr string

+ Status string

+ Type int

+ VerifyParam string

+ type Sequencer struct

+ func NewSequencer() *Sequencer

+ func (s *Sequencer) GetToken() error

+ func (s *Sequencer) QueryTask(taskType int, taskIds ...int64) (TaskListResp, error)

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

+ type TaskGroup struct

+ Ids []int64

+ Items []*models.TaskEntity

+ Type int

+ type TaskListResp struct

+ Code int

+ Data struct{ ... }

+ Msg string

+ type TaskManagerContract struct

+ func NewTaskManagerContract() *TaskManagerContract

+ func (taskManager *TaskManagerContract) Scan(job *models.JobEntity)

+ func (taskManager *TaskManagerContract) ScannedBlock(job *models.JobEntity) uint64

type TaskService

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

+ type TokenResp struct

+ Code int

+ Data struct{ ... }

+ Msg string

Jul 11, 2024

Changes in this version

+ func BlackList(c *gin.Context)

+ func CheckWalletBlackList(jobSourceURI string) bool

type DockerService

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

Jun 12, 2024

Changes in this version

+ var TaskMap sync.Map

+ func CronTaskForEcp()

+ func GetJobStatus(c *gin.Context)

+ func GetOwnerAddressAndWorkerAddress() (string, string, error)

+ func GetTaskInfoOnChain(rpcName string, taskContract string) (ecp.ECPTaskTaskInfo, error)

+ func RestartResourceExporter() error

+ func SyncCpAccountInfo()

+ func WhiteList(c *gin.Context)

+ type CpInfoService struct

+ func NewCpInfoService() CpInfoService

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

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

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

+ type CpResourceSummary struct

+ ClusterInfo []*models.NodeResource

type DockerService

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

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

+ type JobService struct

+ func NewJobService() JobService

+ func (jobServ JobService) DeleteJobEntityBySpaceUuId(spaceUuid string) error

+ func (jobServ JobService) DeleteJobs(spaceIds []string) (err error)

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

+ func (jobServ JobService) GetJobEntityBySpaceUuid(spaceUuid string) (models.JobEntity, error)

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

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

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

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

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

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

+ type TaskService struct

+ func NewTaskService() TaskService

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

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

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

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

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

May 24, 2024

Changes in this version

type DockerService

+ func (ds *DockerService) GetContainerLogStream(containerName string) (io.ReadCloser, error)

Apr 26, 2024

Changes in this version

+ func CheckWalletWhiteList(jobSourceURI string) bool

+ func CleanDockerResource()

+ func DoUbiTaskForDocker(c *gin.Context)

+ func DoUbiTaskForK8s(c *gin.Context)

+ func GetCpResource(c *gin.Context)

+ func ReceiveUbiProofForDocker(c *gin.Context)

+ func ReceiveUbiProofForK8s(c *gin.Context)

+ func RunDockerCompose(dockerComposeContent, cpPath string) error

+ func StopPreviousServices(dockerComposeContent, cpPath string) error

+ type ComposeApiService struct

+ func NewComposeService() (*ComposeApiService, error)

+ func (cas *ComposeApiService) ServiceDown(dockerComposeBody string) error

+ func (cas *ComposeApiService) ServiceUp(dockerComposeBody string) error

type Deploy

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

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

type DockerService

+ func (ds *DockerService) ContainerCreateAndStart(config *container.Config, hostConfig *container.HostConfig, ...) error

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

+ func (ds *DockerService) PullImage(imagesName string) error

+ func (ds *DockerService) RemoveImageByName(containerName string) error

type K8sService

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

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

+ func (s *K8sService) WaitForPodRunningByTcp(namespace, taskUuid string) (string, error)

Mar 8, 2024

Changes in this version

type K8sService

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

Mar 4, 2024

Changes in this version

+ const BuildFileName

+ const PingMsg

+ const PingPeriod

+ const ResourceCpu

+ const ResourceMem

+ const ResourceStorage

+ var NotFoundError = errors.New("not found resource")

+ var NotFoundRedisKey = stErr.New("not found redis key")

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

+ func BuildSpaceTaskImage(spaceUuid string, files []models.SpaceFile) (bool, string, string, string, error)

+ func CancelJob(c *gin.Context)

+ func DeploySpaceTask(jobSourceURI, hostName string, duration int, jobUuid string, taskUuid string, ...) string

+ func DoProof(c *gin.Context)

+ func DoUbiTask(c *gin.Context)

+ func ExtractExposedPort(dockerfilePath string) (string, error)

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

+ func GetCpInfo(c *gin.Context)

+ func GetNodeId(cpRepoPath string) string

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

+ func GetRedisClient() redis.Conn

+ func GetServiceProviderInfo(c *gin.Context)

+ func GetSpaceLog(c *gin.Context)

+ func InitComputingProvider(cpRepoPath string) string

+ func ReNewJob(c *gin.Context)

+ func ReceiveJob(c *gin.Context)

+ func ReceiveUbiProof(c *gin.Context)

+ func Reconnect(nodeID string) string

+ func RedeployJob(c *gin.Context)

+ func RemoveContainerIfExists(imageName string) error

+ func RetrieveJobMetadata(key string) (models.CacheSpaceDetail, error)

+ func RetrieveUbiTaskMetadata(key string) (*models.CacheUbiTaskDetail, error)

+ func RunContainer(imageName, dockerfilePath string) string

+ func RunSyncTask(nodeId string)

+ func SaveUbiTaskMetadata(ubiTask *models.CacheUbiTaskDetail)

+ func StatisticalSources(c *gin.Context)

+ type CeleryService struct

+ func NewCeleryService() *CeleryService

+ func (s *CeleryService) DelayTask(taskName string, params ...interface{}) (*gocelery.AsyncResult, error)

+ func (s *CeleryService) RegisterTask(taskName string, task interface{})

+ func (s *CeleryService) Start()

+ func (s *CeleryService) Stop()

+ type CronTask struct

+ func NewCronTask() *CronTask

+ func (task *CronTask) RunTask()

+ type Deploy struct

+ DeployName string

+ SpacePath string

+ TaskType string

+ func NewDeploy(jobUuid, hostName, walletAddress, hardwareDesc string, duration int64, ...) *Deploy

+ func (d *Deploy) DockerfileToK8s()

+ func (d *Deploy) ModelInferenceToK8s() error

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

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

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

+ func (d *Deploy) WithSpaceInfo(spaceUuid, spaceName string) *Deploy

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

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

+ func (d *Deploy) YamlToK8s()

+ type DockerService struct

+ func NewDockerService() *DockerService

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

+ func (ds *DockerService) CleanResource()

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

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

+ type ErrorLine struct

+ Error string

+ ErrorDetail struct{ ... }

+ type K8sService struct

+ Version string

+ func NewK8sService() *K8sService

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (s *K8sService) GetAPIServerEndpoint() string

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (s *K8sService) WaitForPodRunning(namespace, spaceUuid, serviceIp string) (string, error)

+ type ScheduleTask struct

+ TaskMap sync.Map

+ func NewScheduleTask() *ScheduleTask

+ func (s *ScheduleTask) Run()

+ type StorageService struct

+ BucketName string

+ McsAccessToken string

+ McsApiKey string

+ NetWork string

+ func NewStorageService() *StorageService

+ func (storage *StorageService) CreateBucket(bucketName string)

+ func (storage *StorageService) CreateFolder(folderName string)

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

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

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

+ type WsClient struct

+ func NewWsClient(client *websocket.Conn) *WsClient

+ func (ws *WsClient) Close()

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