snowflake

Documentation

Index

• type Config
• type Snowflake
  • func New(ctx context.Context, config Config) (*Snowflake, error)
  • func (s *Snowflake) Close()
  • func (s *Snowflake) Generate() int64
  • func (s *Snowflake) GetWorkerID() int64

Types

type Config

type Config struct {
	DSN       string
	TableName string
	Epoch     int64
	Schema    string
}

Config configuration for distributed snowflake

type Snowflake

type Snowflake struct {
	*snowflakex.Node
	// contains filtered or unexported fields
}

Snowflake represents a distributed snowflake ID generator backed by PostgreSQL

func New

func New(ctx context.Context, config Config) (*Snowflake, error)

New creates a new distributed snowflake instance

func (*Snowflake) Close

func (s *Snowflake) Close()

Close releases resources

func (*Snowflake) Generate

func (s *Snowflake) Generate() int64

Generate creates and returns a unique snowflake ID It panics if the worker lease has expired to prevent ID collision.

func (*Snowflake) GetWorkerID

func (s *Snowflake) GetWorkerID() int64

GetWorkerID returns the current worker ID