tokenStore

Documentation

Index

• func NewTokenStoreFactory[C any](keyPrefix string, getClient func() *redis.Client) func() TokenStore[C]
• type Node
  • func (node *Node) WithClient(client *redis.Client) NodeWithClient
• type NodeWithClient
  • func (node NodeWithClient) GenID(ctx context.Context) (uint64, error)
• type Point
  • func (point Point[C]) Destroy(ctx context.Context) error
  • func (point Point[C]) Get(ctx context.Context, claims *C) error
  • func (point Point[C]) GetAndDestroy(ctx context.Context, claims *C) error
• type TokenStore
  • func (store TokenStore[C]) CreateStorePoint(ctx context.Context, valid time.Duration, claims *C) (uint64, error)
  • func (store TokenStore[C]) CreateStorePointWithID(ctx context.Context, id uint64, valid time.Duration, claims *C) error
  • func (store TokenStore[C]) MPointGet(ctx context.Context, ids ...uint64) ([]interface{}, error)
  • func (store TokenStore[C]) NewStorePoint(id uint64) Point[C]

Functions

func NewTokenStoreFactory

func NewTokenStoreFactory[C any](keyPrefix string, getClient func() *redis.Client) func() TokenStore[C]

NewTokenStoreFactory only support maximum 128 partial program instance, and maximum 1 year validate of token.

Types

type Node

type Node struct {
	// this is a unique id for each node process, it
	// will be reallocated every day.
	// ID must be smaller than 128.
	ID uint64

	// use for refresh fields.
	Lock       *sync.Mutex
	IDTimeMark uint64
	TokenID    *atomic.Uint64
	// contains filtered or unexported fields
}

func (*Node) WithClient

func (node *Node) WithClient(client *redis.Client) NodeWithClient

type NodeWithClient

type NodeWithClient struct {
	*Node
	// contains filtered or unexported fields
}

func (NodeWithClient) GenID

func (node NodeWithClient) GenID(ctx context.Context) (uint64, error)

type Point

type Point[C any] struct {
	// contains filtered or unexported fields
}

func (Point[C]) Destroy

func (point Point[C]) Destroy(ctx context.Context) error

func (Point[C]) Get

func (point Point[C]) Get(ctx context.Context, claims *C) error

func (Point[C]) GetAndDestroy

func (point Point[C]) GetAndDestroy(ctx context.Context, claims *C) error

type TokenStore

type TokenStore[C any] struct {
	// contains filtered or unexported fields
}

func (TokenStore[C]) CreateStorePoint

func (store TokenStore[C]) CreateStorePoint(ctx context.Context, valid time.Duration, claims *C) (uint64, error)

func (TokenStore[C]) CreateStorePointWithID

func (store TokenStore[C]) CreateStorePointWithID(ctx context.Context, id uint64, valid time.Duration, claims *C) error

func (TokenStore[C]) MPointGet

func (store TokenStore[C]) MPointGet(ctx context.Context, ids ...uint64) ([]interface{}, error)

func (TokenStore[C]) NewStorePoint

func (store TokenStore[C]) NewStorePoint(id uint64) Point[C]