util

package

v0.0.0-...-214a605 Latest Latest Go to latest Published: Jun 2, 2019 License: MIT Imports: 7 Imported by: 3

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func BytesToString(b []byte) string

BytesToString convert []byte type to string type

func GetUUID() uint64

GetUUID 使用默认的uuidWorker生成一个uuid

func NewUUIDWorker(workerID int64) (*uuidWorker, error)

NewUUIDWorker 指定一个节点id,返回该节点对应的uuid生成器使用多个uuidWorker时,id由调用者保证不重复

func StringToBytes(s string) []byte

StringToBytes convert string type to []byte type

func WriteFull(writer io.Writer, data []byte) error

WriteFull往指定writer中写数据,知道数据完全写入或者发生错误

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

MsgQueue 是一个双缓冲队列的BlockingQueue 在"多生产者,单消费者"的场景下下保证线程安全

func NewMsgQueue() *MsgQueue

NewMsgQueue 创建并返回一个初始容量为0的消息队列

func NewMsgQueueWithCap(cap int) *MsgQueue

NewMsgQueueWithCap 创建并返回一个指定初始容量的消息队列

func (q *MsgQueue) Pick(retList *[]interface{})

Pick 获取当前队列中的所有元素,若当前队列为空,则阻塞直至有新元素被添加

func (q *MsgQueue) PickWithCtx(ctx context.Context, retList *[]interface{})

PickWithCtx 与Pick相同,但当ctx active时,强制退出阻塞状态并返回

func (q *MsgQueue) PickWithSignal(signal <-chan struct{}, retList *[]interface{})

PickWithSignal 与Pick相同,但当signal active时,强制退出阻塞状态并返回

func (q *MsgQueue) Put(msg interface{})

Put 往队列中添加元素