utils

package module
v0.0.0-...-ff2eb03 Latest Latest
Warning

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

 Go to latest Published: Aug 21, 2024 License: MIT Imports: 41 Imported by: 78

README

utils

介绍

工具

软件架构

软件架构说明

安装教程
  1. xxxx
  2. xxxx
  3. xxxx
使用说明
  1. xxxx
  2. xxxx
  3. xxxx
参与贡献
  1. Fork 本仓库
  2. 新建 Feat_xxx 分支
  3. 提交代码
  4. 新建 Pull Request
特技
  1. 使用 Readme_XXX.md 来支持不同的语言，例如 Readme_en.md, Readme_zh.md
  2. Gitee 官方博客 blog.gitee.com
  3. 你可以 https://gitee.com/explore 这个地址来了解 Gitee 上的优秀开源项目
  4. GVP 全称是 Gitee 最有价值开源项目，是综合评定出的优秀开源项目
  5. Gitee 官方提供的使用手册 https://gitee.com/help
  6. Gitee 封面人物是一档用来展示 Gitee 会员风采的栏目 https://gitee.com/gitee-stars/

Documentation

Overview

指数退避算法 

动态扩展的channl

Package lru implements an LRU cache.

Package multihash is the Go implementation of https://github.com/multiformats/multihash, or self-describing hashes. 

投票系统

Index

Constants

View Source 
const (
	ERROR_CODE_success             = 60000 //成功
	ERROR_CODE_system_error_remote = 60001 //系统错误--远程节点
	ERROR_CODE_system_error_self   = 60002 //系统错误--自己节点
)
View Source 
const (
	ID         = 0x00
	SHA1       = 0x11
	SHA2_256   = 0x12
	SHA2_512   = 0x13
	SHA3_224   = 0x17
	SHA3_256   = 0x16
	SHA3_384   = 0x15
	SHA3_512   = 0x14
	SHA3       = SHA3_512
	KECCAK_224 = 0x1A
	KECCAK_256 = 0x1B
	KECCAK_384 = 0x1C
	KECCAK_512 = 0x1D

	SHAKE_128 = 0x18
	SHAKE_256 = 0x19

	BLAKE2B_MIN = 0xb201
	BLAKE2B_MAX = 0xb240
	BLAKE2S_MIN = 0xb241
	BLAKE2S_MAX = 0xb260

	DBL_SHA2_256 = 0x56

	MURMUR3 = 0x22
)

constants

View Source 
const AES_CTR_DEFAULT_KEY = "AES_CTR_DEFAULT_KEY" //默认密码
View Source 
const (
	RestartCommand = "restart" //重启参数
)

Variables

View Source 
var (
	ErrUnknownCode      = errors.New("unknown multihash code")
	ErrTooShort         = errors.New("multihash too short. must be > 3 bytes")
	ErrTooLong          = errors.New("multihash too long. must be < 129 bytes")
	ErrLenNotSupported  = errors.New("multihash does not yet support digests longer than 127 bytes")
	ErrInvalidMultihash = errors.New("input isn't valid multihash")

	ErrVarintBufferShort = errors.New("uvarint: buffer too small")
	ErrVarintTooLong     = errors.New("uvarint: varint too big (max 64bit)")
)

errors

View Source 
var Codes = map[uint64]string{
	ID:           "id",
	SHA1:         "sha1",
	SHA2_256:     "sha2-256",
	SHA2_512:     "sha2-512",
	SHA3_224:     "sha3-224",
	SHA3_256:     "sha3-256",
	SHA3_384:     "sha3-384",
	SHA3_512:     "sha3-512",
	DBL_SHA2_256: "dbl-sha2-256",
	MURMUR3:      "murmur3",
	KECCAK_224:   "keccak-224",
	KECCAK_256:   "keccak-256",
	KECCAK_384:   "keccak-384",
	KECCAK_512:   "keccak-512",
	SHAKE_128:    "shake-128",
	SHAKE_256:    "shake-256",
}

Codes maps a hash code to it's name

View Source 
var DefaultLengths = map[uint64]int{
	ID:           -1,
	SHA1:         20,
	SHA2_256:     32,
	SHA2_512:     64,
	SHA3_224:     28,
	SHA3_256:     32,
	SHA3_384:     48,
	SHA3_512:     64,
	DBL_SHA2_256: 32,
	KECCAK_224:   28,
	KECCAK_256:   32,
	MURMUR3:      4,
	KECCAK_384:   48,
	KECCAK_512:   64,
	SHAKE_128:    32,
	SHAKE_256:    64,
}

DefaultLengths maps a hash code to it's default length

View Source 
var Log zerolog.Logger
View Source 
var Name_pro []string //名称前缀 rune
View Source 
var Name_suffix_long []string //名称后缀（长）
View Source 
var Name_suffix_short []string //名称后缀（短）
View Source 
var Names = map[string]uint64{
	"id":           ID,
	"sha1":         SHA1,
	"sha2-256":     SHA2_256,
	"sha2-512":     SHA2_512,
	"sha3":         SHA3_512,
	"sha3-224":     SHA3_224,
	"sha3-256":     SHA3_256,
	"sha3-384":     SHA3_384,
	"sha3-512":     SHA3_512,
	"dbl-sha2-256": DBL_SHA2_256,
	"murmur3":      MURMUR3,
	"keccak-224":   KECCAK_224,
	"keccak-256":   KECCAK_256,
	"keccak-384":   KECCAK_384,
	"keccak-512":   KECCAK_512,
	"shake-128":    SHAKE_128,
	"shake-256":    SHAKE_256,
}

Names maps the name of a hash to the code

View Source 
var Quant *ledis.DB

Functions

func AddTimetask 

func AddTimetask(tick int64, fn f, class string, params []byte)

添加一个定时任务 @tick int64 未来的某个时刻,例如(未来10秒钟后执行)：time.Now().Unix()+int64(10)

func AesCTR_Decrypt 

func AesCTR_Decrypt(key, iv, cipherText []byte) ([]byte, error)

解密 @key []byte 加密密码 @iv []byte 加密向量 @cipherText []byte 待解密字节

func AesCTR_Decrypt_File 

func AesCTR_Decrypt_File(key, iv []byte, cipherFilePath, plainFilePath string) error

解密文件

func AesCTR_Encrypt 

func AesCTR_Encrypt(key, iv, plainText []byte) ([]byte, error)

加密 @key []byte 加密密码 @iv []byte 加密向量 @plainText []byte 待加密字节

func AesCTR_Encrypt_File 

func AesCTR_Encrypt_File(key, iv []byte, plainFilePath, cipherFilePath string) error

加密文件 @key []byte 加密密码 @iv []byte 加密向量 @plainFilePath string 待加密的文件路径 @cipherFilePath string 加密后的文件保存路径

func AppCode 

func AppCode(code uint64) bool

AppCode checks whether a multihash code is part of the App range.

func BuildGender 

func BuildGender() int

随机构建一个性别

func BuildKeyToByte 

func BuildKeyToByte(t, key string) (prkbs string)

func BuildMerkleRoot 

func BuildMerkleRoot(tx [][]byte) []byte

构建默克尔树根

func BuildName 

func BuildName() string

随机构建一个名称

func Bytes2string 

func Bytes2string(b []byte) string

把[]byte转换为string，只要性能，不在乎可读性

func BytesToInt64 

func BytesToInt64(b []byte) int64

byte转int64，大端字节序

func BytesToUint16 

func BytesToUint16(b []byte) uint16

byte转uint16，大端字节序

func BytesToUint32 

func BytesToUint32(b []byte) uint32

byte转uint64，大端字节序

func BytesToUint64 

func BytesToUint64(b []byte) uint64

byte转uint64，大端字节序

func ChangeMap 

func ChangeMap(v interface{}) (map[string]interface{}, error)

把一个对象转换成map

func Check 

func Check(message string, zeroes int, nonce int) bool

检查是否完成工作

func CheckCreateDir 

func CheckCreateDir(dir_path string) error

检查目录是否存在，不存在则创建

func CheckNonce 

func CheckNonce(code []byte, zeroes uint64) bool

检查hash值是否有足够多的前导零 @code string Hash值 @zeroes uint64 前导零个数

func DenBase64 

func DenBase64(str string) (bs []byte, err error)

func DistinctString 

func DistinctString(list []string) []string

去除重复，不保证顺序

func EnBase64 

func EnBase64(bs []byte) string

func Encode 

func Encode(buf []byte, code uint64) ([]byte, error)

Encode a hash digest along with the specified function code. Note: the length is derived from the length of the digest itself.

func EncodeName 

func EncodeName(buf []byte, name string) ([]byte, error)

EncodeName is like Encode() but providing a string name instead of a numeric code. See Names for allowed values.

func Encrypt 

func Encrypt(plantText, key []byte) ([]byte, error)

func EncryptPrk 

func EncryptPrk(prkbs, key []byte) []byte

对私钥加密

func FilePathSplit 

func FilePathSplit(path string) []string

把文件全路径切分成子路径

func FileSHA3_256 

func FileSHA3_256(path string) ([]byte, error)

计算文件的hash值

func FormatIdUtil 

func FormatIdUtil(idInt *big.Int) string

格式化id为十进制或十六进制字符串

func FormatTimeToSecond 

func FormatTimeToSecond(now time.Time) string

func FullHighPositionZero 

func FullHighPositionZero(bs *[]byte, n int) *[]byte

高位补零

func GetAccNumber 

func GetAccNumber() uint64

获得累加器的值

func GetAvailablePortForTCP 

func GetAvailablePortForTCP(addr string) net.Listener

获得一个可用的TCP端口

func GetAvailablePortForUDP 

func GetAvailablePortForUDP() int

获得一个可用的UDP端口

func GetDiskFreeSpace 

func GetDiskFreeSpace(dirPath string) (uint64, uint64, uint64, error)

获取磁盘空间大小以及可用空间大小 @return uint64 磁盘总大小 @return uint64 磁盘可用空间大小 @return uint64 磁盘可用空间大小

func GetHashByByte 

func GetHashByByte(bs []byte) string

func GetHashForDomain 

func GetHashForDomain(domain string) []byte

获得域名的hash值

func GetHashKey 

func GetHashKey(account string) *big.Int

通过一个域名和用户名得到节点的id @return 10进制字符串

func GetLocalHost 

func GetLocalHost() string

不联网的情况下，得到本机ip地址

func GetLocalIntenetIp 

func GetLocalIntenetIp() (string, bool)

获取本机能联网的ip地址 @return string 获得的ip地址 @return bool 是否能联网

func GetNow 

func GetNow() int64

获取时间

func GetRandNum 

func GetRandNum(n int64) int64

获得一个随机数(0 - n]，包含0，不包含n

func GetRandomDomain 

func GetRandomDomain() string

随机获取一个域名

func GetRandomOneInt64 

func GetRandomOneInt64() int64

随机获取一个int64类型的随机数

func GetStopService 

func GetStopService() chan bool

创建一个等待关机命令服务

func GetTCPListener 

func GetTCPListener(ip string, port int) (*net.TCPListener, error)

获得一个TCP监听

func GetTimeToken 

func GetTimeToken(class string, wait bool) (allow bool)

func Go 

func Go(f func())

func Hash_SHA3_256 

func Hash_SHA3_256(bs []byte) []byte

func Hash_SHA3_512 

func Hash_SHA3_512(bs []byte) []byte

func IPV4Long2String 

func IPV4Long2String(i uint32) (string, error)

Long2IPString 把数值转为ip字符串

func IPV4String2Long 

func IPV4String2Long(ip string) (uint32, error)

IPString2Long 把ip字符串转为数值

func InitBuildRandomName 

func InitBuildRandomName()

加载名称前缀和后缀

func InitLedis 

func InitLedis(dbpath string)

初始化ledis数据库

func Int64ToBytes 

func Int64ToBytes(n int64) []byte

int64转byte，大端字节序

func IsOnlyIp 

func IsOnlyIp(ip string) bool

是全球唯一ip

func Key16Padding 

func Key16Padding(key []byte) []byte

将加密秘钥填补成16字节长度

func LogBuildColorOutputConsole 

func LogBuildColorOutputConsole()

构建为ConsoleWriter格式输出 注意不要在生产环境中使用 ， ConsoleWriter 因为它会大大减慢日志记录的速度。它只是为了帮助在开发应用程序时使日志更易于阅读。您可以使用环境变量仅在开发中启用 ConsoleWriter 输出

func LogBuildColorOutputFile 

func LogBuildColorOutputFile(filename string) error

构建为ConsoleWriter格式输出 注意不要在生产环境中使用 ， ConsoleWriter 因为它会大大减慢日志记录的速度。它只是为了帮助在开发应用程序时使日志更易于阅读。您可以使用环境变量仅在开发中启用 ConsoleWriter 输出

func LogBuildDefaultConsole 

func LogBuildDefaultConsole()

默认日志配置，使用json格式，输出到控制台

func LogBuildDefaultFile 

func LogBuildDefaultFile(filename string) error

默认日志配置，使用json格式，输出到文件

func Mkdir 

func Mkdir(path string) error

递归创建目录

func NewPollManager 

func NewPollManager() *pollManager

func NotifyRestart 

func NotifyRestart() error

通知重启程序 arg 期望重启参数: load 或 空

func PKCS7Padding 

func PKCS7Padding(ciphertext []byte, blockSize int) []byte

func ParseKeyToByte 

func ParseKeyToByte(prkbs []byte) []byte

-----BEGIN EC PRIVATE KEY----- MIHcAgEBBEIAJuVZ2ujd64R6iA3mJ2Iuaorwc3kUXihcLvF51nuF8MHE82ZobU4k JBwOjjFX1jjZGDAyiIgXpD9HXtfIWCpIksigBwYFK4EEACOhgYkDgYYABAB7ZnsN kzgg7JrVxohq2FOxRpA+bUsVsxHKHRur0ezttNRu7ldR36fGgyztoplyUltUndID 7EEi2o9z2E4q99ozOgHwbHnx5WROGYtwvdwDQtvHnCynzO7eixMFZ8pKLddz7YLs hm8sApO1ZneSDMMBoKhtlX4+pywXZ91WxEfOY/GXlA== -----END EC PRIVATE KEY-----

将这种格式的[]byte，去掉头和尾后拼接中间的字符

func PathExists 

func PathExists(path string) (bool, error)

判断一个路径的文件是否存在

func PprofMem 

func PprofMem(timeout time.Duration)

go tool pprof -http 127.0.0.1:8081 .\mem.prof

func Print 

func Print(findInt *big.Int)

func PrintPanicStack 

func PrintPanicStack()

错误处理

func RandString 

func RandString(strs ...string) string

字符串中随机选择一个

func RenameTempFile 

func RenameTempFile(name string) error

安全保存文件方法未执行完，会生成临时文件。 此方法用来处理临时文件

func SaveFileSafe 

func SaveFileSafe(name string, bs *[]byte) error

保存文件 保存文件步骤： 1.创建临时文件 2.删除目标文件 3.修改临时文件名称为目标文件名称

func SaveJsonFile 

func SaveJsonFile(name string, o interface{}) error

保存对象为json格式

func SetTimeToken 

func SetTimeToken(class string, t time.Duration)

func StartOtherTime 

func StartOtherTime() error

func StartSystemTime 

func StartSystemTime() error

func StopMemProfile 

func StopMemProfile(memProfile, cpuProfile *os.File)

func StopService 

func StopService()

发送停止命令

func TimeFormatToNanosecond 

func TimeFormatToNanosecond() string

func TimeFormatToNanosecondStr 

func TimeFormatToNanosecondStr() string

func Uint16ToBytes 

func Uint16ToBytes(n uint16) []byte

uint16转byte，大端字节序

func Uint32ToBytes 

func Uint32ToBytes(n uint32) []byte

uint64转byte，大端字节序

func Uint64ToBytes 

func Uint64ToBytes(n uint64) []byte

uint64转byte，大端字节序

func ValidCode 

func ValidCode(code uint64) bool

ValidCode checks whether a multihash code is valid.

func Work 

func Work(message string, zeroes int) int

开始工作，猜解一段字符串hash后有足够个0 目前（2014年）一般计算机计算出20个0大约一百万次，用时3.0121722秒

Types

type BackoffTimer 

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

func NewBackoffTimer 

func NewBackoffTimer(n ...int64) *BackoffTimer

间隔n秒后发送一个信号

func (*BackoffTimer) Release 

func (this *BackoffTimer) Release()

立即释放暂停的程序

func (*BackoffTimer) Reset 

func (this *BackoffTimer) Reset()

重置 间隔时间从头开始

func (*BackoffTimer) Wait 

func (this *BackoffTimer) Wait() time.Duration

等待时间 @return time.Duration 等待的时间

type BackoffTimerChan 

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

func NewBackoffTimerChan 

func NewBackoffTimerChan(n ...time.Duration) *BackoffTimerChan

间隔n秒后发送一个信号

func (*BackoffTimerChan) Release 

func (this *BackoffTimerChan) Release()

立即释放暂停的程序

func (*BackoffTimerChan) Reset 

func (this *BackoffTimerChan) Reset()

重置 间隔时间从头开始

func (*BackoffTimerChan) Wait 

func (this *BackoffTimerChan) Wait(c context.Context) time.Duration

等待时间 @return time.Duration 等待的时间

type BufferByte 

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

func NewBufferByte 

func NewBufferByte(length int) *BufferByte

func (*BufferByte) Bytes 

func (this *BufferByte) Bytes() (bs *[]byte)

func (*BufferByte) Clean 

func (this *BufferByte) Clean()

清空缓冲区

func (*BufferByte) Length 

func (this *BufferByte) Length() (n int)

func (*BufferByte) SetLength 

func (this *BufferByte) SetLength(maxLength int)

设置缓冲大小，只能往大了设置，不能缩小

func (*BufferByte) Write 

func (this *BufferByte) Write(bs *[]byte)

type Cache 

type Cache struct {
	// MaxEntries is the maximum number of cache entries before
	// an item is evicted. Zero means no limit.
	MaxEntries int

	// OnEvicted optionally specificies a callback function to be
	// executed when an entry is purged from the cache.
	OnEvicted func(key Key, value interface{})
	// contains filtered or unexported fields
}

Cache is an LRU cache. It is not safe for concurrent access.

func NewCache 

func NewCache(maxEntries int) *Cache

New creates a new Cache. If maxEntries is zero, the cache has no limit and it's assumed that eviction is done by the caller.

func (*Cache) Add 

func (c *Cache) Add(key Key, value interface{})

Add adds a value to the cache.

func (*Cache) Clear 

func (c *Cache) Clear()

Clear purges all stored items from the cache.

func (*Cache) Get 

func (c *Cache) Get(key Key) (value interface{}, ok bool)

Get looks up a key's value from the cache.

func (*Cache) Len 

func (c *Cache) Len() int

Len returns the number of items in the cache.

func (*Cache) Remove 

func (c *Cache) Remove(key Key)

Remove removes the provided key from the cache.

func (*Cache) RemoveOldest 

func (c *Cache) RemoveOldest()

RemoveOldest removes the oldest item from the cache.

type ChanDynamic 

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

动态大小的管道

func NewChanDynamic 

func NewChanDynamic(chanLen uint64) *ChanDynamic

创建一个动态管道

func (*ChanDynamic) Add 

func (this *ChanDynamic) Add(one interface{})

func (*ChanDynamic) Get 

func (this *ChanDynamic) Get(contextRoot context.Context) interface{}

type DBLedis 

type DBLedis struct {
	DB *ledis.DB
	// contains filtered or unexported fields
}

DBConn leveldb 连接

func (*DBLedis) InitDB 

func (db *DBLedis) InitDB(name string) (curDB *ledis.DB, err error)

InitDB 初始化数据库

type DecodedMultihash 

type DecodedMultihash struct {
	Code   uint64
	Name   string
	Length int    // Length is just int as it is type of len() opearator
	Digest []byte // Digest holds the raw multihash bytes
}

DecodedMultihash represents a parsed multihash and allows easy access to the different parts of a multihash.

func Decode 

func Decode(buf []byte) (*DecodedMultihash, error)

Decode parses multihash bytes into a DecodedMultihash.

type ERROR 

type ERROR struct {
	Code uint64 `json:"c"` //业务错误编号
	Msg  string `json:"m"` //错误信息
}

func NewErrorBus 

func NewErrorBus(code uint64, msg string) ERROR

创建一个业务错误

func NewErrorSuccess 

func NewErrorSuccess() ERROR

创建一个返回成功

func NewErrorSysRemote 

func NewErrorSysRemote(msg string) ERROR

创建一个远端节点的系统错误

func NewErrorSysSelf 

func NewErrorSysSelf(err error) ERROR

创建一个系统错误

func ParseERROR 

func ParseERROR(bs []byte) (*ERROR, error)

func (*ERROR) CheckSuccess 

func (this *ERROR) CheckSuccess() bool

检查这个错误类型是否是成功

func (*ERROR) Proto 

func (this *ERROR) Proto() (*[]byte, error)

func (*ERROR) String 

func (this *ERROR) String() string

检查这个错误类型是否是成功

type ErrInconsistentLen 

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

ErrInconsistentLen is returned when a decoded multihash has an inconsistent length

func (ErrInconsistentLen) Error 

func (e ErrInconsistentLen) Error() string

type Key 

type Key interface{}

A Key may be any value that is comparable. See http://golang.org/ref/spec#Comparison_operators

type LedisDB 

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

func CreateLedisDB 

func CreateLedisDB(path string) (*LedisDB, error)

func (*LedisDB) AddZSet 

func (this *LedisDB) AddZSet(name, member *[]byte, orderId int64) error

添加一个数据到zset

func (*LedisDB) AddZSetAutoincrId 

func (this *LedisDB) AddZSetAutoincrId(name *[]byte, member []byte, duration int64) error

添加一个数据到zset，id为自增长

func (*LedisDB) CheckHashExist 

func (this *LedisDB) CheckHashExist(hash []byte) (bool, error)

检查key是否存在 @return bool true:存在;false:不存在;

func (*LedisDB) CheckNullDB 

func (this *LedisDB) CheckNullDB(key []byte) (bool, error)

检查是否是空数据库

func (*LedisDB) DelZSet 

func (this *LedisDB) DelZSet(name *[]byte, min, max int64) error

删除zset中一定范围score的数据

func (*LedisDB) DelZSetAll 

func (this *LedisDB) DelZSetAll(name *[]byte) error

添加一个数据到zset

func (*LedisDB) DelZSetByMembers 

func (this *LedisDB) DelZSetByMembers(name *[]byte, members ...[]byte) error

删除zset中多个members

func (*LedisDB) Find 

func (this *LedisDB) Find(txId []byte) (*[]byte, error)

查找

func (*LedisDB) GetDB 

func (this *LedisDB) GetDB() *ledis.DB

获取数据库连接

func (*LedisDB) GetRangeZSet 

func (ldb *LedisDB) GetRangeZSet(name *[]byte, start, stop int) (*[]ledis.ScorePair, error)

* 查询根据 start stop 查询返回zset

func (*LedisDB) GetZSetAll 

func (this *LedisDB) GetZSetAll(name *[]byte) (*[]ledis.ScorePair, error)

添加一个数据到zset

func (*LedisDB) GetZSetByMember 

func (this *LedisDB) GetZSetByMember(name *[]byte, member []byte) (int64, error)

获取一个member的下标，如果不存在，则返回-1

func (*LedisDB) GetZSetPage 

func (this *LedisDB) GetZSetPage(name *[]byte, min, max int64, count int) (*[]ledis.ScorePair, error)

添加一个数据到zset

func (*LedisDB) InitDB 

func (this *LedisDB) InitDB() (err error)

链接leveldb

func (*LedisDB) LRange 

func (ldb *LedisDB) LRange(key []byte, start, end int32) ([][]byte, error)

*

  • 获取List

func (*LedisDB) Remove 

func (this *LedisDB) Remove(id []byte) error

删除

func (*LedisDB) Rpush 

func (ldb *LedisDB) Rpush(key, val []byte) (int64, error)

*

  • 添加一个List

func (*LedisDB) Save 

func (this *LedisDB) Save(id []byte, bs *[]byte) error

保存

func (*LedisDB) SetExpire 

func (ldb *LedisDB) SetExpire(key *[]byte, duration int64) (int64, error)

* 设置key 过期时间 单位秒

func (*LedisDB) ZSetCard 

func (this *LedisDB) ZSetCard(name *[]byte) (n int64, err error)

得到一个数据到zset，数量

type Multihash 

type Multihash []byte

Multihash is byte slice with the following form: <hash function code><digest size><hash function output>. See the spec for more information.

func Cast 

func Cast(buf []byte) (Multihash, error)

Cast casts a buffer onto a multihash, and returns an error if it does not work.

func FromB58String 

func FromB58String(s string) (m Multihash, err error)

FromB58String parses a B58-encoded multihash.

func FromHexString 

func FromHexString(s string) (Multihash, error)

FromHexString parses a hex-encoded multihash.

func (*Multihash) B58String 

func (m *Multihash) B58String() string

B58String returns the B58-encoded representation of a multihash.

func (*Multihash) Data 

func (m *Multihash) Data() []byte

func (*Multihash) HexString 

func (m *Multihash) HexString() string

HexString returns the hex-encoded representation of a multihash.

func (*Multihash) String 

func (m *Multihash) String() string

String is an alias to HexString().

type Multihashs 

type Multihashs struct {
	Multihash `json:"mutihash"`
	B58string string `json:"b58string"`
}

func Casts 

func Casts(buf []byte) (Multihashs, error)

func FromB58Strings 

func FromB58Strings(s string) (m Multihashs, err error)

func FromHexStrings 

func FromHexStrings(s string) (Multihashs, error)

func NewMultihashs 

func NewMultihashs(data []byte) Multihashs

func (*Multihashs) B58String 

func (m *Multihashs) B58String() string

func (*Multihashs) Byte 

func (m *Multihashs) Byte() []byte

type NetParams 

type NetParams struct {
	Version uint64 //协议版本号
	Data    []byte //参数
}

网络发送参数

func NewNetParams 

func NewNetParams(version uint64, data []byte) *NetParams

创建一个网络发送参数对象

func ParseNetParams 

func ParseNetParams(bs []byte) (*NetParams, error)

解析网络接收参数

func (*NetParams) Proto 

func (this *NetParams) Proto() (*[]byte, error)

type NetResult 

type NetResult struct {
	Version uint64 //协议版本号
	Code    uint64 //错误编码
	Msg     string //错误信息
	Data    []byte //返回参数
}

网络返回参数

func NewNetResult 

func NewNetResult(version, code uint64, msg string, data []byte) *NetResult

func ParseNetResult 

func ParseNetResult(bs []byte) (*NetResult, error)

解析网络返回错误编号

func (*NetResult) CheckSuccess 

func (this *NetResult) CheckSuccess() bool

检查是否成功

func (*NetResult) ConvertERROR 

func (this *NetResult) ConvertERROR() ERROR

转化成错误

func (*NetResult) Proto 

func (this *NetResult) Proto() (*[]byte, error)

type SyncList 

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

func NewSyncList 

func NewSyncList() *SyncList

func (*SyncList) Add 

func (this *SyncList) Add(obj interface{})

func (*SyncList) Get 

func (this *SyncList) Get(index int) (n interface{})

func (*SyncList) GetAll 

func (this *SyncList) GetAll() []interface{}

func (*SyncList) Remove 

func (this *SyncList) Remove(index int) (ok bool)

type SyncTimeFun 

type SyncTimeFun func() (int64, error)

type Task 

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

func NewTask 

func NewTask(function f) *Task

func (*Task) Add 

func (this *Task) Add(tick int64, class string, params []byte)

@tick int64 执行的时间（时间戳） @class string 执行的命令 @params string 字符串参数

func (*Task) Destroy 

func (this *Task) Destroy()

销毁，回收协程

func (*Task) Len 

func (this *Task) Len() int

func (*Task) Less 

func (this *Task) Less(i, j int) bool

func (*Task) Remove 

func (this *Task) Remove(tick int64, class string, params []byte)

func (*Task) Swap 

func (this *Task) Swap(i, j int)

type Tick 

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

func NewTick 

func NewTick(tick int64, class string, params []byte) *Tick

type Ticks 

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

func NewTicks 

func NewTicks(tick Tick) *Ticks

Source Files

View all Source files

Directories

Path Synopsis
crc
Package crc implements generic CRC calculations up to 64 bits wide.
 Package crc implements generic CRC calculations up to 64 bits wide.
dh
x3dh
protos
go_protos

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.