nodeidapi

package

v0.0.8 Latest Latest Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 13 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

README ¶

nodeid-service

服务地址

Documentation ¶

Index ¶

Constants
Variables
func GetIdGeneratorByGRPCAPI(serviceAPIManager clientutil.ServiceAPIManager, ...) (idpkg.Snowflake, func(), error)
func GetIdGeneratorByHTTPAPI(serviceAPIManager clientutil.ServiceAPIManager, ...) (idpkg.Snowflake, func(), error)
func GetSingletonSnowflakeNode(idManager IDManager, req *nodeidresourcev1.GetNodeIdReq) (idpkg.Snowflake, func(), error)
func NewGRPCClient(serviceAPIManager clientutil.ServiceAPIManager, ...) (nodeidservicev1.SrvNodeIDV1Client, error)
func NewHTTPClient(serviceAPIManager clientutil.ServiceAPIManager, ...) (nodeidservicev1.SrvNodeIDV1HTTPClient, error)
func SetSnowflake(node idpkg.Snowflake) error
type IDManager
- func NewIDManager(logger log.Logger, helper NodeIDHelper) IDManager
type IdOption
- func WithLoggerForIdOption(logger log.Logger) IdOption
- func WithMustGetNodeIdForAPI(mustGetNodeIdForAPI bool) IdOption
- func WithServerName(serverName clientutil.ServiceName) IdOption
type NodeIDAPI
- func NewGRPCApi(client nodeidservicev1.SrvNodeIDV1Client) NodeIDAPI
- func NewHTTPApi(client nodeidservicev1.SrvNodeIDV1HTTPClient) NodeIDAPI
type NodeIDHelper
- func NewNodeIDHelper(client NodeIDAPI, opts ...Option) NodeIDHelper
type Option
- func WithHeartbeatInterval(duration time.Duration) Option
- func WithLogger(logger log.Logger) Option
- func WithRetryDelay(delay time.Duration) Option
- func WithTries(tries int) Option
type RenewalManager
type RenewalResult
type SnowflakeNodeInfo

Constants ¶

View Source

const (
	NodeidServiceHTTP clientutil.ServiceName = "nodeid-service-http"
	NodeidServiceGRPC clientutil.ServiceName = "nodeid-service-grpc"
)

View Source

const (
	DefaultRetryDelay        = 10 * time.Millisecond
	DefaultHeartbeatInterval = 30 * time.Second
)

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 ¶ added in v0.0.8

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

func GetIdGeneratorByHTTPAPI ¶ added in v0.0.8

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

func GetSingletonSnowflakeNode ¶ added in v0.0.5

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

func NewGRPCClient ¶

func NewGRPCClient(serviceAPIManager clientutil.ServiceAPIManager, rewriteServiceName ...clientutil.ServiceName) (nodeidservicev1.SrvNodeIDV1Client, error)

NewGRPCClient ...

func NewHTTPClient ¶

func NewHTTPClient(serviceAPIManager clientutil.ServiceAPIManager, rewriteServiceName ...clientutil.ServiceName) (nodeidservicev1.SrvNodeIDV1HTTPClient, error)

NewHTTPClient ...

func SetSnowflake ¶ added in v0.0.4

func SetSnowflake(node idpkg.Snowflake) error

Types ¶

type IDManager ¶ added in v0.0.2

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.2

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

type IdOption ¶ added in v0.0.8

type IdOption func(*idOptions)

func WithLoggerForIdOption ¶ added in v0.0.8

func WithLoggerForIdOption(logger log.Logger) IdOption

func WithMustGetNodeIdForAPI ¶ added in v0.0.8

func WithMustGetNodeIdForAPI(mustGetNodeIdForAPI bool) IdOption

func WithServerName ¶ added in v0.0.8

func WithServerName(serverName clientutil.ServiceName) IdOption

type NodeIDAPI ¶

type NodeIDAPI interface {
	GetNodeId(context.Context, *nodeidresourcev1.GetNodeIdReq) (*nodeidresourcev1.GetNodeIdRespData, error)
	ReleaseNodeId(context.Context, *nodeidresourcev1.ReleaseNodeIdReq) (*nodeidresourcev1.ReleaseNodeIdRespData, error)
	RenewalNodeId(context.Context, *nodeidresourcev1.RenewalNodeIdReq) (*nodeidresourcev1.RenewalNodeIdRespData, error)
}

func NewGRPCApi ¶

func NewGRPCApi(client nodeidservicev1.SrvNodeIDV1Client) NodeIDAPI

func NewHTTPApi ¶

func NewHTTPApi(client nodeidservicev1.SrvNodeIDV1HTTPClient) NodeIDAPI

type NodeIDHelper ¶

type NodeIDHelper interface {
	GetAndAutoRenewalNodeID(ctx context.Context, req *nodeidresourcev1.GetNodeIdReq) (*nodeidresourcev1.GetNodeIdRespData, RenewalManager, error)
	GetNodeID(ctx context.Context, req *nodeidresourcev1.GetNodeIdReq) (*nodeidresourcev1.GetNodeIdRespData, error)
	RenewalNodeID(ctx context.Context, dataModel *nodeidresourcev1.GetNodeIdRespData) (RenewalManager, error)
	ReleaseNodeId(ctx context.Context, dataModel *nodeidresourcev1.GetNodeIdRespData) (*nodeidresourcev1.ReleaseNodeIdRespData, error)
}

func NewNodeIDHelper ¶

func NewNodeIDHelper(client NodeIDAPI, opts ...Option) NodeIDHelper

type Option ¶

type Option func(*options)

func WithHeartbeatInterval ¶

func WithHeartbeatInterval(duration time.Duration) Option

func WithLogger ¶

func WithLogger(logger log.Logger) Option

func WithRetryDelay ¶

func WithRetryDelay(delay time.Duration) Option

func WithTries ¶

func WithTries(tries int) Option

type RenewalManager ¶

type RenewalManager interface {
	Stop(ctx context.Context) error
	RenewalResult(ctx context.Context) *RenewalResult
}

type RenewalResult ¶

type RenewalResult struct {
	Data     *nodeidresourcev1.RenewalNodeIdRespData
	Err      error
	LastTime time.Time
}

type SnowflakeNodeInfo ¶ added in v0.0.4

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