snowflakeapi

Documentation

Index

• Variables
• func GetIDGeneratorFromIPV4(opts ...Option) (idpkg.Snowflake, func(), error)
• func GetSingletonIDGeneratorByGRPCAPI(serviceAPIManager clientutil.ServiceAPIManager, ...) (idpkg.Snowflake, func(), error)
• func GetSingletonIDGeneratorByHTTPAPI(serviceAPIManager clientutil.ServiceAPIManager, ...) (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
  • func DefaultOptions(logger log.Logger) []Option
  • func WithGetNodeIdFromIPV4(isGetNodeIDFromIPV4 bool) Option
  • func WithLogger(logger log.Logger) Option
  • func WithMustGetNodeIdFromAPI(mustGetNodeIdForAPI bool) Option
  • func WithNodeEpoch(nodeEpoch time.Time) Option
  • func WithServerName(serverName clientutil.ServiceName) Option
• type SnowflakeNodeInfo

Variables

var (
	DefaultTries = 3
)

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

Functions

func GetIDGeneratorFromIPV4

func GetIDGeneratorFromIPV4(opts ...Option) (idpkg.Snowflake, func(), error)

func GetSingletonIDGeneratorByGRPCAPI

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

func GetSingletonIDGeneratorByHTTPAPI

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

func GetSingletonSnowflakeNode

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

GetSingletonSnowflakeNode 获取节点 http GetSingletonIDGeneratorByHTTPAPI grpc GetSingletonIDGeneratorByGRPCAPI

func SetSnowflake

func SetSnowflake(node idpkg.Snowflake) error

Types

type IDManager

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

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

type Option

type Option func(*options)

func DefaultOptions

func DefaultOptions(logger log.Logger) []Option

func WithGetNodeIdFromIPV4

func WithGetNodeIdFromIPV4(isGetNodeIDFromIPV4 bool) Option

func WithLogger

func WithLogger(logger log.Logger) Option

func WithMustGetNodeIdFromAPI

func WithMustGetNodeIdFromAPI(mustGetNodeIdForAPI bool) Option

func WithNodeEpoch

func WithNodeEpoch(nodeEpoch time.Time) Option

func WithServerName

func WithServerName(serverName clientutil.ServiceName) Option

type SnowflakeNodeInfo

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