redis

Documentation

Index

• Constants
• Variables
• func NewMfaLogin(uid uint) tokenStore.TokenStore[jwtClaims.MfaRedis]
• func NewThirdPartyLogin() tokenStore.TokenStore[jwtClaims.LoginRedis]
• func NewU2F(uid uint) tokenStore.TokenStore[types.Nil]
• func PublishSshDev(messages []rpcModel.SshAccountMsg) error
• func SubScribeSshDev() *redis.PubSub
• type AppCodeHelper
  • func (a AppCodeHelper) Add(data ...string) error
  • func (a AppCodeHelper) Del(data ...string) error
  • func (a AppCodeHelper) Exist(data string) (bool, error)
  • func (a AppCodeHelper) IsEmpty() (bool, error)
  • func (a AppCodeHelper) Load() ([]string, error)
• type MfaEnable
  • func NewMfaEnable(uid uint) MfaEnable
  • func (a MfaEnable) Del() error
  • func (a MfaEnable) Get() (string, error)
  • func (a MfaEnable) Set(secret string, valid time.Duration) error
• type Passkey
  • func NewPasskey(ip string) Passkey
  • func (p Passkey) NewUser(id uint) UserPasskey
  • func (p Passkey) ReadSession(ctx context.Context, session any) error
  • func (p Passkey) StoreSession(ctx context.Context, session any, expire time.Duration) error
• type Sms
  • func NewSms(phone string) Sms
  • func (a Sms) IsLocked() (bool, error)
  • func (a Sms) TryLock() (bool, error)
  • func (a Sms) UnLock() error
• type SyncStat
  • func NewSyncStat(name string) SyncStat
  • func (a *SyncStat) Inject(schedule cron.Schedule, f func() error) func() error
  • func (a *SyncStat) SetSuccess(ctx context.Context, expire time.Duration) error
  • func (a *SyncStat) ShouldLock(ctx context.Context, expire time.Duration) (bool, error)
  • func (a *SyncStat) Succeed(ctx context.Context) (bool, error)
  • func (a *SyncStat) TryLock(ctx context.Context, expire time.Duration) (bool, error)
  • func (a *SyncStat) Unlock(ctx context.Context) error
• type UserIdentityCode
  • func NewUserIdentityCode(uid uint) UserIdentityCode
  • func (a UserIdentityCode) Destroy() error
  • func (a UserIdentityCode) New() (string, error)
  • func (a UserIdentityCode) VerifyAndDestroy(code string) (bool, error)
• type UserJwt
  • func NewUserJwt() UserJwt
  • func (u UserJwt) Empty(ctx context.Context) (bool, error)
  • func (u UserJwt) NewOperator(uid uint) UserJwtOperator
• type UserJwtOperator
  • func (u UserJwtOperator) ChangeOperateID(ctx context.Context) (uint64, error)
  • func (u UserJwtOperator) CheckOperateID(ctx context.Context, oid uint64) (bool, error)
  • func (u UserJwtOperator) Create(ctx context.Context) error
  • func (u UserJwtOperator) Del(ctx context.Context) error
  • func (u UserJwtOperator) Exist(ctx context.Context) (bool, error)
  • func (u UserJwtOperator) GetOperateID(ctx context.Context) (uint64, error)
• type UserPasskey
  • func (u UserPasskey) ReadSession(ctx context.Context, session any) error
  • func (u UserPasskey) StoreSession(ctx context.Context, session any, expire time.Duration) error

Constants

const Nil = redis.Nil

Variables

var AppCode = AppCodeHelper{
	// contains filtered or unexported fields
}

var Client *redis.Client

Functions

func NewMfaLogin

func NewMfaLogin(uid uint) tokenStore.TokenStore[jwtClaims.MfaRedis]

func NewThirdPartyLogin

func NewThirdPartyLogin() tokenStore.TokenStore[jwtClaims.LoginRedis]

func NewU2F

func NewU2F(uid uint) tokenStore.TokenStore[types.Nil]

func PublishSshDev

func PublishSshDev(messages []rpcModel.SshAccountMsg) error

func SubScribeSshDev

func SubScribeSshDev() *redis.PubSub

Types

type AppCodeHelper

type AppCodeHelper struct {
	// contains filtered or unexported fields
}

func (AppCodeHelper) Add

func (a AppCodeHelper) Add(data ...string) error

func (AppCodeHelper) Del

func (a AppCodeHelper) Del(data ...string) error

func (AppCodeHelper) Exist

func (a AppCodeHelper) Exist(data string) (bool, error)

func (AppCodeHelper) IsEmpty

func (a AppCodeHelper) IsEmpty() (bool, error)

func (AppCodeHelper) Load

func (a AppCodeHelper) Load() ([]string, error)

type MfaEnable

type MfaEnable struct {
	// contains filtered or unexported fields
}

func NewMfaEnable

func NewMfaEnable(uid uint) MfaEnable

func (MfaEnable) Del

func (a MfaEnable) Del() error

func (MfaEnable) Get

func (a MfaEnable) Get() (string, error)

func (MfaEnable) Set

func (a MfaEnable) Set(secret string, valid time.Duration) error

type Passkey

type Passkey struct {
	// contains filtered or unexported fields
}

func NewPasskey

func NewPasskey(ip string) Passkey

func (Passkey) NewUser

func (p Passkey) NewUser(id uint) UserPasskey

func (Passkey) ReadSession

func (p Passkey) ReadSession(ctx context.Context, session any) error

ReadSession 读取后自动销毁

func (Passkey) StoreSession

func (p Passkey) StoreSession(ctx context.Context, session any, expire time.Duration) error

type Sms

type Sms struct {
	// contains filtered or unexported fields
}

func NewSms

func NewSms(phone string) Sms

func (Sms) IsLocked

func (a Sms) IsLocked() (bool, error)

func (Sms) TryLock

func (a Sms) TryLock() (bool, error)

func (Sms) UnLock

func (a Sms) UnLock() error

type SyncStat

type SyncStat struct {
	// contains filtered or unexported fields
}

func NewSyncStat

func NewSyncStat(name string) SyncStat

func (*SyncStat) Inject

func (a *SyncStat) Inject(schedule cron.Schedule, f func() error) func() error

Inject 注入 backoff 内容函数，使其支持分布式锁与成功跳过

func (*SyncStat) SetSuccess

func (a *SyncStat) SetSuccess(ctx context.Context, expire time.Duration) error

func (*SyncStat) ShouldLock

func (a *SyncStat) ShouldLock(ctx context.Context, expire time.Duration) (bool, error)

func (*SyncStat) Succeed

func (a *SyncStat) Succeed(ctx context.Context) (bool, error)

func (*SyncStat) TryLock

func (a *SyncStat) TryLock(ctx context.Context, expire time.Duration) (bool, error)

func (*SyncStat) Unlock

func (a *SyncStat) Unlock(ctx context.Context) error

type UserIdentityCode

type UserIdentityCode struct {
	// contains filtered or unexported fields
}

func NewUserIdentityCode

func NewUserIdentityCode(uid uint) UserIdentityCode

func (UserIdentityCode) Destroy

func (a UserIdentityCode) Destroy() error

func (UserIdentityCode) New

func (a UserIdentityCode) New() (string, error)

New 新建身份校验码，五分钟有效，每用户仅存在一个

func (UserIdentityCode) VerifyAndDestroy

func (a UserIdentityCode) VerifyAndDestroy(code string) (bool, error)

VerifyAndDestroy 校验并销毁 code

type UserJwt

type UserJwt struct {
	// contains filtered or unexported fields
}

func NewUserJwt

func NewUserJwt() UserJwt

NewUserJwt user jwt Operate ID hash 表

func (UserJwt) Empty

func (u UserJwt) Empty(ctx context.Context) (bool, error)

func (UserJwt) NewOperator

func (u UserJwt) NewOperator(uid uint) UserJwtOperator

type UserJwtOperator

type UserJwtOperator struct {
	// contains filtered or unexported fields
}

func (UserJwtOperator) ChangeOperateID

func (u UserJwtOperator) ChangeOperateID(ctx context.Context) (uint64, error)

func (UserJwtOperator) CheckOperateID

func (u UserJwtOperator) CheckOperateID(ctx context.Context, oid uint64) (bool, error)

func (UserJwtOperator) Create

func (u UserJwtOperator) Create(ctx context.Context) error

func (UserJwtOperator) Del

func (u UserJwtOperator) Del(ctx context.Context) error

func (UserJwtOperator) Exist

func (u UserJwtOperator) Exist(ctx context.Context) (bool, error)

func (UserJwtOperator) GetOperateID

func (u UserJwtOperator) GetOperateID(ctx context.Context) (uint64, error)

type UserPasskey

type UserPasskey struct {
	// contains filtered or unexported fields
}

func (UserPasskey) ReadSession

func (u UserPasskey) ReadSession(ctx context.Context, session any) error

func (UserPasskey) StoreSession

func (u UserPasskey) StoreSession(ctx context.Context, session any, expire time.Duration) error