data

package

v0.0.0-...-28c23ed Latest Latest Go to latest Published: Apr 24, 2024 License: MIT Imports: 23 Imported by: 4

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/choral-io/gommerce-server-core

Documentation ¶

Index ¶

Constants
Variables
func NewBunDB(cfg config.ServerDBConfig, logger logging.Logger, tp trace.TracerProvider, ...) (bun.IDB, error)
func NewRedisClient(cfg config.ServerRedisConfig, tp trace.TracerProvider, mp metric.MeterProvider) (rueidis.Client, error)
func SetDefaultIdWorker(w IdWorker)
func WithPaging(p pagetoken) func(*bun.SelectQuery) *bun.SelectQuery
type IdWorker
- func DefaultIdWorker() IdWorker
- func NewIdWorker(cfg config.SnowflakeConfig, seq Seq) (IdWorker, error)
type Seq
- func NewRedisSeq(rdb rueidis.Client) Seq

Constants ¶

View Source

const (
	DEFAULT_ID_EPOCH = int64(1704067200000) // Defaults to: 2024-01-01T00:00:00Z
)

Variables ¶

View Source

var (
	ErrIdEpochOutOfRange       = errors.New("the value of 'idEpoch' must be greater than 0")
	ErrClusterIdBitsOutOfRange = errors.New("the value of 'clusterIdBits' must be greater than 0")
	ErrWorkerIdBitsOutOfRange  = errors.New("the value of 'workerIdBits' must be greater than 0")
	ErrSequenceBitsOutOfRange  = errors.New("the value of 'sequenceBits' must be greater than 0")
	ErrClusterIdOutOfRange     = errors.New("the value of 'clusterId' out of range")
	ErrWorkerIdOutOfRange      = errors.New("the value of 'workerId' out of range")
	ErrTimeMilliBitsOutOfRange = errors.New("the sum of 'clusterIdBits', 'workerIdBits' and 'sequenceBits' must be less than 23")
)

Functions ¶

func NewBunDB ¶

func NewBunDB(cfg config.ServerDBConfig, logger logging.Logger, tp trace.TracerProvider, mp metric.MeterProvider) (bun.IDB, error)

NewBunDB creates a new bun.IDB instance with metrics, tracing and logging.

func NewRedisClient ¶

func NewRedisClient(cfg config.ServerRedisConfig, tp trace.TracerProvider, mp metric.MeterProvider) (rueidis.Client, error)

NewRedisClient creates a new redis client with tracing and metrics.

func SetDefaultIdWorker ¶

func SetDefaultIdWorker(w IdWorker)

SetDefaultIdWorker sets the default IdWorker instance.

func WithPaging ¶

func WithPaging(p pagetoken) func(*bun.SelectQuery) *bun.SelectQuery

WithPaging is a bun.SelectQuery modifier that adds paging to the query.

Types ¶

type IdWorker ¶

type IdWorker interface {
	NextInt64() int64
	NextBytes() [8]byte
	NextHex() string
}

IdWorker is used to generate unique id.

func DefaultIdWorker ¶

func DefaultIdWorker() IdWorker

DefaultIdWorker returns the default IdWorker instance.

func NewIdWorker ¶

func NewIdWorker(cfg config.SnowflakeConfig, seq Seq) (IdWorker, error)

NewIdWorker creates a new IdWorker instance with the given config. If the workerSeqKey is not empty, the workerId will be generated from the Seq.

type Seq ¶

type Seq interface {
	// Next returns the next value in the sequence.
	Next(key string, min int64, max int64) (int64, error)
}

Seq is a sequence generator.

func NewRedisSeq ¶

func NewRedisSeq(rdb rueidis.Client) Seq

NewRedisSeq creates a new redis sequence generator.

Source Files ¶

View all Source files

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