channel

Documentation

Overview

Package channel @Link https://gitee.com/linngc/central-mirror @Copyright Copyright (c) 2024 central-mirror CLI @Author linngc @License

Package channel @Link https://gitee.com/linngc/central-mirror @Copyright Copyright (c) 2024 central-mirror CLI @Author linngc @License

Package channel @Link https://gitee.com/linngc/central-mirror @Copyright Copyright (c) 2024 central-mirror CLI @Author linngc @License

Package channel @Link https://gitee.com/linngc/central-mirror @Copyright Copyright (c) 2024 central-mirror CLI @Author linngc @License

Index

• Variables
• type QueueJobFunc
• type WResponse

Variables

var (
	NumCPU    = runtime.NumCPU() + 1
	Process   = newProcess()   //异步发送数据
	ChanNum   = newChanNum()   //多通道执行方法
	QueueDown = newQueueDown() //队列下载
)

Types

type QueueJobFunc

type QueueJobFunc = func(ctx context.Context, url string, readAll []byte)

QueueJobFunc 下载完成返回方法 @param url 下载url路径 param bt 下载完成后二进制

type WResponse

type WResponse struct {
	Event string      `json:"event"` //属性名称
	Tag   string      `json:"tag"`   //所属标记
	Data  interface{} `json:"data"`  //数据
}

WResponse 输出对象