snowflake

package

v0.0.0-...-cb7ffae Latest Latest Go to latest Published: Apr 3, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

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

Repository

github.com/derry6/gleafd

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Factory
- func NewFactory(machineID int) (Factory, error)
type Metadata
type Service
- func NewService(name, addr string, storage Storage, logger log.Logger) *Service
- func (s *Service) Close() error
- func (s *Service) Get(ctx context.Context, biztag string, count int) (ids []int64, err error)
type Storage
- func NewRedisStorage(p *redis.Pool, logger log.Logger) Storage

Constants ¶

View Source

const (
	MachineIDBits  uint8 = 10
	SeqBits        uint8 = 12
	MachineIDShift       = SeqBits
	TimeShift            = SeqBits + MachineIDBits
	MachineIDMax   int   = -1 ^ (-1 << MachineIDBits)
	SeqMask        int32 = -1 ^ (-1 << SeqBits)
)

1+41+10+12

Variables ¶

View Source

var (
	ErrClockMoveBackwards = errors.New("system clock move backwards")
	ErrInvalidMachineID   = errors.New("invalid machine id")
)

Functions ¶

This section is empty.

Types ¶

type Factory ¶

type Factory interface {
	Next() (int64, error)
}

func NewFactory ¶

func NewFactory(machineID int) (Factory, error)

不支持多routine并发

type Metadata ¶

type Metadata struct {
	Name      string // 服务名称
	Addr      string // 监听IP:PORT
	MachineID int    // 机器ID 0 - 1023
	Timestamp int64  // 最后更新的时间
}

type Service ¶

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

func NewService ¶

func NewService(name, addr string, storage Storage, logger log.Logger) *Service

func (*Service) Close ¶

func (s *Service) Close() error

func (*Service) Get ¶

func (s *Service) Get(ctx context.Context, biztag string, count int) (ids []int64, err error)

type Storage ¶

type Storage interface {
	// 查找指定的metadata,不存在则创建并返回合适的machineID
	GetOrNew(ctx context.Context, name, addr string) (md Metadata, err error)
	// 获取所有的metadata
	List(ctx context.Context) (mds []Metadata, err error)
	// 更新时间戳
	Update(ctx context.Context, md Metadata) (err error)
}

func NewRedisStorage ¶

func NewRedisStorage(p *redis.Pool, logger log.Logger) Storage

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL