base

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: May 10, 2023 License: MIT Imports: 21 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	Bit8              = 8
	Bit16             = 16
	Bit32             = 32
	Bit64             = 64
	Bit128            = 128
	MAX_PACKET        = 1 * 1024 * 1024
	MAX_CLIENT_PACKET = 10 * 1024
)
View Source 
const (
	NONE_ERROR      = iota
	VERSION_ERROR   //版本不正确
	ACCOUNT_NOEXIST //账号不存在
	PASSWORD_ERROR  //密码不正确
)
View Source 
const (
	CRYPT_BUFFER_SIZE = 0x500
)
View Source 
const (
	PATH = "log"
)
View Source 
const (
	REPLICASNUM = 5
)
View Source 
const (
	WorkeridMax = workeridMax //集群自增量
)

Variables

View Source 
var (
	CryptBuffer []uint32
)
View Source 
var ErrEmptyRing = errors.New("empty ring")

ErrEmptyRing is the error returned when trying to get an element when nothing has been added to hash.

View Source 
var RAND = Rand{rand.New(rand.NewSource(time.Now().UnixNano()))}
View Source 
var (
	SEVERNAME string
)
View Source 
var (
	UUID = ISnowflake(&Snowflake{})
)

Functions

func Abs 

func Abs(x float32) float32

func Assert 

func Assert(x bool, y string)

func BIT 

func BIT(x interface{}) interface{}

func BIT64 

func BIT64(x interface{}) interface{}

func Bool 

func Bool(str string) bool

func BytesToFloat32 

func BytesToFloat32(data []byte) float32

func BytesToFloat64 

func BytesToFloat64(data []byte) float64

func BytesToInt 

func BytesToInt(data []byte) int

字节转换成整形

func BytesToInt16 

func BytesToInt16(data []byte) int16

字节转换成为int16

func BytesToInt64 

func BytesToInt64(data []byte) int64

func ChechErr 

func ChechErr(err error)

func Clamp 

func Clamp(val, low, high int) int

func DecryptName1 added in v0.0.7 

func DecryptName1(strName string) uint32

func DecryptName2 added in v0.0.7 

func DecryptName2(strName string) uint32

func Float32 

func Float32(str string) float32

func Float32ToByte 

func Float32ToByte(val float32) []byte

转化float

func Float64 

func Float64(str string) float64

func Float64ToByte 

func Float64ToByte(val float64) []byte

转化float64

func GetClassName 

func GetClassName(rType reflect.Type) string

func GetDBTime 

func GetDBTime(strTime string) *time.Time

func GetLanAddr added in v0.0.5 

func GetLanAddr(ip string) string

func GetMessageCode added in v0.0.7 

func GetMessageCode(strName string, m1 *uint32, m2 *uint32)

func GetMessageCode1 added in v0.0.7 

func GetMessageCode1(strName string) uint32

func GetMessageCode2 added in v0.0.7 

func GetMessageCode2(strName string) uint32

func Htonl 

func Htonl(n uint64) []byte

func Htons 

func Htons(n uint16) []byte

func Int 

func Int(str string) int

-----------string strconv type-------------//

func Int16ToBytes 

func Int16ToBytes(val int16) []byte

整形16转换成字节

func Int64 

func Int64(str string) int64

func Int64ToBytes 

func Int64ToBytes(val int64) []byte

转化64位

func IntToBytes 

func IntToBytes(val int) []byte

整形转换成字节

func IntToInt32 

func IntToInt32(val []int) []int32

[]int转[]int32

func Max 

func Max(a, b int) int

func Min 

func Min(a, b int) int

func ParseTag 

func ParseTag(sf reflect.StructField, tag string) map[string]string

func ParseUUID 

func ParseUUID(id int64) (ts int64, workerId int64, seq int64)

func PathExists 

func PathExists(path string) bool

func PrepareCryptBuffer added in v0.0.7 

func PrepareCryptBuffer()

func ReadConf added in v0.0.5 

func ReadConf(path string, data interface{}) bool

func SetTcpEnd 

func SetTcpEnd(buff []byte) []byte

func Time 

func Time(str string) int64

func ToHash 

func ToHash(str string) uint32

func TraceCode 

func TraceCode(code ...interface{})

输出错误，跟踪代码

Types

type BitMap added in v0.0.9 

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

func NewBitMap added in v0.0.9 

func NewBitMap(size int) *BitMap

func (*BitMap) Clear added in v0.0.9 

func (b *BitMap) Clear(index int)

func (*BitMap) ClearAll added in v0.0.9 

func (b *BitMap) ClearAll()

func (*BitMap) Init added in v0.0.9 

func (b *BitMap) Init(size int)

func (*BitMap) Set added in v0.0.9 

func (b *BitMap) Set(index int)

func (*BitMap) Test added in v0.0.9 

func (b *BitMap) Test(index int) bool

type BitStream 

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

func NewBitStream 

func NewBitStream(buf []byte, nLen int) *BitStream

func (*BitStream) BuildPacketStream 

func (b *BitStream) BuildPacketStream(buffer []byte, writeSize int) bool

func (*BitStream) GetBuffer 

func (b *BitStream) GetBuffer() []byte

func (*BitStream) GetBytePtr 

func (b *BitStream) GetBytePtr() []byte

func (*BitStream) GetCurPos 

func (b *BitStream) GetCurPos() int

func (*BitStream) GetPosition 

func (b *BitStream) GetPosition() int

func (*BitStream) GetReadByteSize 

func (b *BitStream) GetReadByteSize() int

func (*BitStream) GetStreamSize 

func (b *BitStream) GetStreamSize() int

func (*BitStream) ReadBits 

func (b *BitStream) ReadBits(bitCount int) []byte

func (*BitStream) ReadFlag 

func (b *BitStream) ReadFlag() bool

func (*BitStream) ReadFloat 

func (b *BitStream) ReadFloat() float32

func (*BitStream) ReadFloat64 

func (b *BitStream) ReadFloat64() float64

func (*BitStream) ReadInt 

func (b *BitStream) ReadInt(bitCount int) int

func (*BitStream) ReadInt64 

func (b *BitStream) ReadInt64(bitCount int) int64

func (*BitStream) ReadString 

func (b *BitStream) ReadString() string

func (*BitStream) SetPosition 

func (b *BitStream) SetPosition(pos int) bool

func (*BitStream) WriteBits 

func (b *BitStream) WriteBits(bitPtr []byte, bitCount int)

func (*BitStream) WriteFlag 

func (b *BitStream) WriteFlag(value bool) bool

func (*BitStream) WriteFloat 

func (b *BitStream) WriteFloat(value float32)

func (*BitStream) WriteFloat64 

func (b *BitStream) WriteFloat64(value float64)

func (*BitStream) WriteInt 

func (b *BitStream) WriteInt(value int, bitCount int)

func (*BitStream) WriteInt64 

func (b *BitStream) WriteInt64(value int64, bitCount int)

func (*BitStream) WriteString 

func (b *BitStream) WriteString(value string)

type Dh added in v0.0.5 

type Dh struct {
	Y1 big.Int //自己公钥
	Y2 big.Int //对方公钥
	// contains filtered or unexported fields
}

func (*Dh) ExchangePubk added in v0.0.5 

func (d *Dh) ExchangePubk(key int64)

func (*Dh) Init added in v0.0.5 

func (d *Dh) Init()

func (*Dh) PubKey added in v0.0.5 

func (d *Dh) PubKey() int64

func (*Dh) ShareKey added in v0.0.5 

func (d *Dh) ShareKey() int64

type HashRing 

type HashRing struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

HashRing holds the information about the members of the consistent hash ring.

func NewHashRing 

func NewHashRing() *HashRing

New creates a new HashRing( object with a default setting of 20 replicas for each entry. To change the number of replicas, set NumberOfReplicas before adding entries.

func (*HashRing) Add 

func (h *HashRing) Add(elt string)

Add inserts a string element in the consistent hash.

func (*HashRing) Get 

func (h *HashRing) Get(name string) (error, string)

Get returns an element close to where name hashes to in the ring.

func (*HashRing) Get64 

func (h *HashRing) Get64(val int64) (error, uint32)

func (*HashRing) HasMember 

func (h *HashRing) HasMember(elt string) bool

func (*HashRing) Members 

func (h *HashRing) Members() []string

func (*HashRing) Remove 

func (h *HashRing) Remove(elt string)

Remove removes an element from the hash.

type IBitMap added in v0.0.9 

type IBitMap interface {
	Init(size int)
	Set(index int)       //设置位
	Test(index int) bool //位是否被设置
	Clear(index int)     //清楚位
	ClearAll()
}

type IBitStream 

type IBitStream interface {
	BuildPacketStream([]byte, int) bool

	GetBuffer() []byte
	GetBytePtr() []byte
	GetReadByteSize() int
	GetCurPos() int
	GetPosition() int
	GetStreamSize() int
	SetPosition(int) bool

	WriteBits([]byte, int)
	ReadBits(int) []byte
	WriteInt(int, int)
	ReadInt(int) int
	ReadFlag() bool
	WriteFlag(bool) bool
	WriteString(string)
	ReadString() string

	WriteInt64(int64, int)
	ReadInt64(int) int64
	WriteFloat(float32)
	ReadFloat() float32
	WriteFloat64(float64)
	ReadFloat64() float64
	// contains filtered or unexported methods
}

type IDh added in v0.0.5 

type IDh interface {
	Init()

	ExchangePubk(key int64) //交换公钥
	PubKey() int64          //公钥
	ShareKey() int64        //生成共享密钥
	// contains filtered or unexported methods
}

type IHashRing 

type IHashRing interface {
	Add(elt string)
	Remove(elt string)
	HasMember(elt string) bool
	Members() []string
	Get(name string) (error, string)
	Get64(val int64) (error, uint32)
}

type ILog 

type ILog interface {
	Init(string) bool
	Write(LG_TYPE)
	WriteFile(LG_TYPE)
	Println(...interface{})
	Print(...interface{})
	Printf(string, ...interface{})
	Fatalln(...interface{})
	Fatal(...interface{})
	Fatalf(string, ...interface{})
}

type ISnowflake 

type ISnowflake interface {
	Init(workerid int64)
	UUID() int64
}

type IStuHashRing 

type IStuHashRing interface {
	Init(endpoints []string)
	Get(val int64) (error, uint32)
}

use for stubring

type IWorkIdQue 

type IWorkIdQue interface {
	Init(int)
	Add(string) int
	Del(string) int
}

type LG_TYPE 

type LG_TYPE int
const (
	LG_WARN  LG_TYPE = iota
	LG_ERROR LG_TYPE = iota
	LG_MAX   LG_TYPE = iota
)

type Log 

type Log struct {
	// contains filtered or unexported fields
}
var (
	LOG Log
)

func (*Log) Fatal 

func (this *Log) Fatal(v1 ...interface{})

func (*Log) Fatalf 

func (this *Log) Fatalf(format string, params ...interface{})

func (*Log) Fatalln 

func (this *Log) Fatalln(v1 ...interface{})

func (*Log) GetSuffix 

func (this *Log) GetSuffix(nType LG_TYPE) string

func (*Log) Init 

func (this *Log) Init(fileName string) bool

func (*Log) Print 

func (this *Log) Print(v1 ...interface{})

func (*Log) Printf 

func (this *Log) Printf(format string, params ...interface{})

func (*Log) Println 

func (this *Log) Println(v1 ...interface{})

func (*Log) Write 

func (this *Log) Write(nType LG_TYPE)

func (*Log) WriteFile 

func (this *Log) WriteFile(nType LG_TYPE)

type Rand 

type Rand struct {
	*rand.Rand
}

func (*Rand) RandF 

func (r *Rand) RandF(i float32, n float32) float32

func (*Rand) RandI 

func (r *Rand) RandI(i int, n int) int

type Snowflake 

type Snowflake struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Snowflake) Init 

func (s *Snowflake) Init(workerid int64)

func (*Snowflake) UUID 

func (s *Snowflake) UUID() int64

Generate creates and returns a unique snowflake ID

type StubHashRing 

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

HashRing holds the information about the members of the consistent hash ring.

func (*StubHashRing) Get 

func (h *StubHashRing) Get(val int64) (error, uint32)

func (*StubHashRing) Init 

func (h *StubHashRing) Init(endpoints []string)

Add inserts a string element in the consistent hash.

type WorkIdQue 

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

func (*WorkIdQue) Add 

func (w *WorkIdQue) Add(val string) int

func (*WorkIdQue) Del 

func (w *WorkIdQue) Del(val string) int

func (*WorkIdQue) Init 

func (w *WorkIdQue) Init(id int)

Source Files

View all Source files

Directories

Path Synopsis
Package mpsc provides an efficient implementation of a multi-producer, single-consumer lock-free queue.
 Package mpsc provides an efficient implementation of a multi-producer, single-consumer lock-free queue.

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.