user-core-client

用户中心 SDK

数据同步

内部使用Kafka订阅进行同步

type UserCentSync interface {
    Start(ctx context.Context) error
    Stop(ctx context.Context) error
    
    // SetCallUserListener 设置用户事件回调函数
    SetCallUserListener(func (context.Context, *UserEvent) error)
    // SetErrorListener 设置错误回调函数
    SetErrorListener(func (context.Context, error) error)
}

API调用

内部使用GRPC调用

type UserCenterApi interface {
    // Verify 验证 token 并且返回 token 中的信息
    Verify(ctx context.Context, token string) (*TokenClaims, error)
    
    // GetPhoneTextByUID 获取明文手机号 来自于 uid
    GetPhoneTextByUID(ctx context.Context, uid int64) (string, error)
    
    // UpdateUserByUID 更新用户信息
    UpdateUserByUID(ctx context.Context, uid int64, user *UpdateUserReq) (*User, error)
}