snowflakeapi

package

v0.0.9 Latest Latest Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/go-micro-saas/service-api

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func GetIdGeneratorByGRPCAPI(serviceAPIManager clientutil.ServiceAPIManager, ...) (idpkg.Snowflake, func(), error)
func GetIdGeneratorByHTTPAPI(serviceAPIManager clientutil.ServiceAPIManager, ...) (idpkg.Snowflake, func(), error)
func GetIdGeneratorFromAPI(nodeidAPI nodeidapi.NodeIDAPI, req *nodeidresourcev1.GetNodeIdReq, ...) (idpkg.Snowflake, func(), error)
func GetIdGeneratorFromIPV4() (idpkg.Snowflake, func(), error)
func GetSingletonSnowflakeNode(idManager IDManager, req *nodeidresourcev1.GetNodeIdReq) (idpkg.Snowflake, func(), error)
func SetSnowflake(node idpkg.Snowflake) error
type IDManager
- func NewIDManager(logger log.Logger, helper nodeidapi.NodeIDHelper) IDManager
type Option
type SnowflakeNodeInfo

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	DefaultTries = 3
)

View Source

var (
	// NewSnowflakeNode func(int64) (idpkg.Snowflake, error)
	// idpkg.NewSonySonyflake
	// idpkg.NewBwmarrinSnowflake
	NewSnowflakeNode = idpkg.NewSonySonyflake
)

Functions ¶

func GetIdGeneratorByGRPCAPI ¶

func GetIdGeneratorByGRPCAPI(serviceAPIManager clientutil.ServiceAPIManager, req *nodeidresourcev1.GetNodeIdReq, opts ...Option) (idpkg.Snowflake, func(), error)

func GetIdGeneratorByHTTPAPI ¶

func GetIdGeneratorByHTTPAPI(serviceAPIManager clientutil.ServiceAPIManager, req *nodeidresourcev1.GetNodeIdReq, opts ...Option) (idpkg.Snowflake, func(), error)

func GetIdGeneratorFromAPI ¶ added in v0.0.9

func GetIdGeneratorFromAPI(nodeidAPI nodeidapi.NodeIDAPI, req *nodeidresourcev1.GetNodeIdReq, opt *options) (idpkg.Snowflake, func(), error)

func GetIdGeneratorFromIPV4 ¶ added in v0.0.9

func GetIdGeneratorFromIPV4() (idpkg.Snowflake, func(), error)

func GetSingletonSnowflakeNode ¶ added in v0.0.9

func GetSingletonSnowflakeNode(idManager IDManager, req *nodeidresourcev1.GetNodeIdReq) (idpkg.Snowflake, func(), error)

func SetSnowflake ¶ added in v0.0.9

func SetSnowflake(node idpkg.Snowflake) error

Types ¶

type IDManager ¶ added in v0.0.9

type IDManager interface {
	GetSingletonSnowflakeNode(ctx context.Context, req *nodeidresourcev1.GetNodeIdReq) (idpkg.Snowflake, func(), error)
	GetSnowflakeNode(ctx context.Context, req *nodeidresourcev1.GetNodeIdReq) (idpkg.Snowflake, func(), error)
	SetSnowflakeNode(ctx context.Context, req *nodeidresourcev1.GetNodeIdReq) (idpkg.Snowflake, func(), error)
}

func NewIDManager ¶ added in v0.0.9

func NewIDManager(logger log.Logger, helper nodeidapi.NodeIDHelper) IDManager

type Option ¶

type Option func(*options)

func Options ¶

func Options(logger log.Logger) []Option

func WithGetNodeIdFromIPV4 ¶ added in v0.0.9

func WithGetNodeIdFromIPV4(isGetNodeIDFromIPV4 bool) Option

func WithLogger ¶

func WithLogger(logger log.Logger) Option

func WithMustGetNodeIdFromAPI ¶ added in v0.0.9

func WithMustGetNodeIdFromAPI(mustGetNodeIdForAPI bool) Option

func WithServerName ¶

func WithServerName(serverName clientutil.ServiceName) Option

type SnowflakeNodeInfo ¶ added in v0.0.9

type SnowflakeNodeInfo struct {
	Node    idpkg.Snowflake
	Cleanup func()
}

Source Files ¶

View all Source files

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