snowflakehelper

README

snowflake_helper

借助etcd自动生成snowflake算法需要的workerId

1. 可以直接使用当前工程的 snowflake算法，比如：

node, _ := InitSnowFlake(&clientv3.Config{
                        Endpoints:   []string{"127.0.0.1:2379"},
                        DialTimeout: dialTimeout,  
                        }, "testservice")

1. 或者只用生成的workerID：

 workerID,err:=GenerateSnowFlakeWorkerID(&clientv3.Config{
                                  Endpoints:   []string{"127.0.0.1:2379"},
                                  DialTimeout: dialTimeout,  
                               }, "testservice")`

Documentation

Overview

Package snowflake provides a very simple Twitter snowflake generator and parser.

Index

• Variables
• func GenerateSnowFlakeWorkerID(config *clientv3.Config, serviceName string) (int64, error)
• type ID
  • func ParseBase32(b []byte) (ID, error)
  • func ParseBase58(b []byte) (ID, error)
  • func (f ID) Base2() string
  • func (f ID) Base32() string
  • func (f ID) Base36() string
  • func (f ID) Base58() string
  • func (f ID) Base64() string
  • func (f ID) Bytes() []byte
  • func (f ID) Int64() int64
  • func (f ID) IntBytes() [8]byte
  • func (f ID) MarshalJSON() ([]byte, error)
  • func (f ID) Node() int64
  • func (f ID) Step() int64
  • func (f ID) String() string
  • func (f ID) Time() int64
  • func (f *ID) UnmarshalJSON(b []byte) error
• type JSONSyntaxError
  • func (j JSONSyntaxError) Error() string
• type Node
  • func InitSnowFlake(config *clientv3.Config, serviceName string) (*Node, error)
  • func NewNode(node int64) (*Node, error)
  • func (n *Node) Generate() ID
  • func (n *Node) WorkerID() int64

Variables

var (
	// Epoch is set to the twitter snowflake epoch of Nov 04 2010 01:42:54 UTC
	// You may customize this to set a different epoch for your application.
	Epoch int64 = 1551671515123

	// NodeBits Number of bits to use for Node
	// Remember, you have a total 22 bits to share between Node/Step
	NodeBits uint8 = 10

	// StepBits Number of bits to use for Step
	// Remember, you have a total 22 bits to share between Node/Step
	StepBits uint8 = 12
)

var ErrInvalidBase32 = errors.New("invalid base32")

ErrInvalidBase32 is returned by ParseBase32 when given an invalid []byte

var ErrInvalidBase58 = errors.New("invalid base58")

ErrInvalidBase58 is returned by ParseBase58 when given an invalid []byte

Functions

func GenerateSnowFlakeWorkerID

func GenerateSnowFlakeWorkerID(config *clientv3.Config, serviceName string) (int64, error)

GenerateSnowFlakeWorkerID 产生一个workerID

Types

type ID

type ID int64

An ID is a custom type used for a snowflake ID. This is used so we can attach methods onto the ID.

func ParseBase32

func ParseBase32(b []byte) (ID, error)

ParseBase32 parses a base32 []byte into a snowflake ID NOTE: There are many different base32 implementations so becareful when doing any interoperation interop with other packages.

func ParseBase58

func ParseBase58(b []byte) (ID, error)

ParseBase58 parses a base58 []byte into a snowflake ID

func (ID) Base2

func (f ID) Base2() string

Base2 returns a string base2 of the snowflake ID

func (ID) Base32

func (f ID) Base32() string

Base32 uses the z-base-32 character set but encodes and decodes similar to base58, allowing it to create an even smaller result string. NOTE: There are many different base32 implementations so becareful when doing any interoperation interop with other packages.

func (ID) Base36

func (f ID) Base36() string

Base36 returns a base36 string of the snowflake ID

func (ID) Base58

func (f ID) Base58() string

Base58 returns a base58 string of the snowflake ID

func (ID) Base64

func (f ID) Base64() string

Base64 returns a base64 string of the snowflake ID

func (ID) Bytes

func (f ID) Bytes() []byte

Bytes returns a byte slice of the snowflake ID

func (ID) Int64

func (f ID) Int64() int64

Int64 returns an int64 of the snowflake ID

func (ID) IntBytes

func (f ID) IntBytes() [8]byte

IntBytes returns an array of bytes of the snowflake ID, encoded as a big endian integer.

func (ID) MarshalJSON

func (f ID) MarshalJSON() ([]byte, error)

MarshalJSON returns a json byte array string of the snowflake ID.

func (ID) Node

func (f ID) Node() int64

Node returns an int64 of the snowflake ID node number

func (ID) Step

func (f ID) Step() int64

Step returns an int64 of the snowflake step (or sequence) number

func (ID) String

func (f ID) String() string

String returns a string of the snowflake ID

func (ID) Time

func (f ID) Time() int64

Time returns an int64 unix timestamp of the snowflake ID time

func (*ID) UnmarshalJSON

func (f *ID) UnmarshalJSON(b []byte) error

UnmarshalJSON converts a json byte array of a snowflake ID into an ID type.

type JSONSyntaxError

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

A JSONSyntaxError is returned from UnmarshalJSON if an invalid ID is provided.

func (JSONSyntaxError) Error

func (j JSONSyntaxError) Error() string

type Node

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

A Node struct holds the basic information needed for a snowflake generator node

func InitSnowFlake

func InitSnowFlake(config *clientv3.Config, serviceName string) (*Node, error)

InitSnowFlake ...

func NewNode

func NewNode(node int64) (*Node, error)

NewNode returns a new snowflake node that can be used to generate snowflake IDs

func (*Node) Generate

func (n *Node) Generate() ID

Generate creates and returns a unique snowflake ID

func (*Node) WorkerID

func (n *Node) WorkerID() int64

WorkerID ...