sequence

Documentation

Index

• func NewSequence(generator *config.SequenceGenerator, tableName string) (proto.SequenceGenerator, error)
• type SegmentConfig
• type SegmentWorker
  • func NewSegmentWorker(dsn string, from, len int64, biz string) (*SegmentWorker, error)
  • func (w *SegmentWorker) NextID() (int64, error)
  • func (w *SegmentWorker) ProduceID()
• type SnowflakeConfig
• type SnowflakeWorker
  • func NewWorker(id int64) (*SnowflakeWorker, error)
  • func (w *SnowflakeWorker) NextID() (int64, error)

Functions

func NewSequence

func NewSequence(generator *config.SequenceGenerator, tableName string) (proto.SequenceGenerator, error)

Types

type SegmentConfig

type SegmentConfig struct {
	DSN  string `yaml:"dsn" json:"dsn"`
	From int64  `yaml:"from" json:"from"`
	Step int64  `default:"1000" yaml:"step" json:"step"`
}

type SegmentWorker

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

func NewSegmentWorker

func NewSegmentWorker(dsn string, from, len int64, biz string) (*SegmentWorker, error)

func (*SegmentWorker) NextID

func (w *SegmentWorker) NextID() (int64, error)

func (*SegmentWorker) ProduceID

func (w *SegmentWorker) ProduceID()

type SnowflakeConfig

type SnowflakeConfig struct {
	WorkerID int64 `json:"worker_id"`
}

type SnowflakeWorker

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

func NewWorker

func NewWorker(id int64) (*SnowflakeWorker, error)

func (*SnowflakeWorker) NextID

func (w *SnowflakeWorker) NextID() (int64, error)