handler

Documentation

Index

• Variables
• func CheckSession(ctx context.Context, req *pbrequest.CheckSession) (*pbresponse.CheckSession, error)
• func CreateSession(ctx context.Context, req *pbrequest.CreateSession) (*pbresponse.CreateSession, error)
• func CreateUser(ctx context.Context, req *pbrequest.CreateUser) (*pbmodel.User, error)
• func DeleteUser(ctx context.Context, req *pbrequest.DeleteUser) error
• func DescribeAccessKey(ctx context.Context, input *pbrequest.DescribeAccessKey) (output *executor.AccessKey, err error)
• func DescribeUsers(ctx context.Context, req *pbrequest.DescribeUsers) ([]*pbmodel.User, int64, error)
• func Init(opts ...Option)
• func UpdateUser(ctx context.Context, req *pbrequest.UpdateUser) (*pbmodel.User, error)
• func ValidateRequestSignature(ctx context.Context, req *pbrequest.ValidateRequestSignature) (*executor.AccessKey, error)
• type Cache
  • func (cache *Cache) CacheAccessKey(k *executor.AccessKey, accessKeyID string, source string) error
  • func (cache *Cache) CacheNotExistAccessKey(accessKeyID string, source string) error
  • func (cache *Cache) CacheNotExistUser(userID string, source string) error
  • func (cache *Cache) CacheSession(k *executor.AccessKey, sessionId string, userId string) error
  • func (cache *Cache) CacheUser(u *pbmodel.User, userID string, source string) error
  • func (cache *Cache) CacheUsers(users []*pbmodel.User, source string) error
  • func (cache *Cache) DelUser(userID string, withSession bool) error
  • func (cache *Cache) DeleteSession(sessionId string)
  • func (cache *Cache) GetAccessKey(accessKeyID string, source string) (*executor.AccessKey, error)
  • func (cache *Cache) GetPrefixKey(source string, resource string) string
  • func (cache *Cache) GetSession(sessionId string) (*executor.AccessKey, error)
  • func (cache *Cache) GetUser(userID string, source string) (*pbmodel.User, error)
  • func (cache *Cache) IsEnable(source string) bool
• type Option
  • func WithCfg(conf *config.Config) Option
  • func WithIdGenerator() Option
  • func WithLogger(log *glog.Logger) Option
  • func WithRedis(r rediswrap.Client, ctx context.Context) Option

Variables

var (
	IdGeneratorUser *idgenerator.IDGenerator
)

global options in this package.

Functions

func CheckSession

func CheckSession(ctx context.Context, req *pbrequest.CheckSession) (*pbresponse.CheckSession, error)

func CreateSession

func CreateSession(ctx context.Context, req *pbrequest.CreateSession) (*pbresponse.CreateSession, error)

func CreateUser

func CreateUser(ctx context.Context, req *pbrequest.CreateUser) (*pbmodel.User, error)

func DeleteUser

func DeleteUser(ctx context.Context, req *pbrequest.DeleteUser) error

func DescribeAccessKey

func DescribeAccessKey(ctx context.Context, input *pbrequest.DescribeAccessKey) (output *executor.AccessKey, err error)

func DescribeUsers

func DescribeUsers(ctx context.Context, req *pbrequest.DescribeUsers) ([]*pbmodel.User, int64, error)

func Init

func Init(opts ...Option)

func UpdateUser

func UpdateUser(ctx context.Context, req *pbrequest.UpdateUser) (*pbmodel.User, error)

func ValidateRequestSignature

func ValidateRequestSignature(ctx context.Context, req *pbrequest.ValidateRequestSignature) (*executor.AccessKey, error)

Types

type Cache

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

func (*Cache) CacheAccessKey

func (cache *Cache) CacheAccessKey(k *executor.AccessKey, accessKeyID string, source string) error

func (*Cache) CacheNotExistAccessKey

func (cache *Cache) CacheNotExistAccessKey(accessKeyID string, source string) error

func (*Cache) CacheNotExistUser

func (cache *Cache) CacheNotExistUser(userID string, source string) error

func (*Cache) CacheSession

func (cache *Cache) CacheSession(k *executor.AccessKey, sessionId string, userId string) error

func (*Cache) CacheUser

func (cache *Cache) CacheUser(u *pbmodel.User, userID string, source string) error

func (*Cache) CacheUsers

func (cache *Cache) CacheUsers(users []*pbmodel.User, source string) error

func (*Cache) DelUser

func (cache *Cache) DelUser(userID string, withSession bool) error

func (*Cache) DeleteSession

func (cache *Cache) DeleteSession(sessionId string)

func (*Cache) GetAccessKey

func (cache *Cache) GetAccessKey(accessKeyID string, source string) (*executor.AccessKey, error)

func (*Cache) GetPrefixKey

func (cache *Cache) GetPrefixKey(source string, resource string) string

func (*Cache) GetSession

func (cache *Cache) GetSession(sessionId string) (*executor.AccessKey, error)

func (*Cache) GetUser

func (cache *Cache) GetUser(userID string, source string) (*pbmodel.User, error)

func (*Cache) IsEnable

func (cache *Cache) IsEnable(source string) bool

type Option

type Option func()

func WithCfg

func WithCfg(conf *config.Config) Option

func WithIdGenerator

func WithIdGenerator() Option

func WithLogger

func WithLogger(log *glog.Logger) Option

func WithRedis

func WithRedis(r rediswrap.Client, ctx context.Context) Option