wechat

Documentation

Index

• type Cache
• type DistributedAccessTokenHandle
  • func NewDistributedAccessTokenHandle(appID, appSecret, cacheKeyPrefix string, cache Cache, ...) *DistributedAccessTokenHandle
  • func (ak *DistributedAccessTokenHandle) GetAccessToken() (accessToken string, err error)
  • func (ak *DistributedAccessTokenHandle) GetAccessTokenContext(ctx context.Context) (accessToken string, err error)
  • func (ak *DistributedAccessTokenHandle) RefreshAccessToken() (err error)
• type OfficialAccount
  • func NewOfficialAccount(config *OfficialAccountConfig, cache Cache, distributedLock lock.Locker) *OfficialAccount
  • func NewOfficialAccountByMemory(config *OfficialAccountConfig) *OfficialAccount
  • func NewOfficialAccountByRedis(config *OfficialAccountConfig, redisClient redis.UniversalClient) *OfficialAccount
  • func (oa *OfficialAccount) StartTokenChecking()
• type OfficialAccountConfig
• type Redis
  • func NewRedis(ctx context.Context, conn redis.UniversalClient) *Redis
  • func (r *Redis) Delete(key string) error
  • func (r *Redis) Get(key string) interface{}
  • func (r *Redis) IsExist(key string) bool
  • func (r *Redis) Set(key string, val interface{}, timeout time.Duration) error

Types

type Cache

type Cache interface {
	cache.Cache
}

type DistributedAccessTokenHandle

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

DistributedAccessTokenHandle AccessToken 获取 @Description 重写credential.DefaultAccessToken，实现分布式锁，支持多实例部署

func NewDistributedAccessTokenHandle

func NewDistributedAccessTokenHandle(
	appID, appSecret, cacheKeyPrefix string, cache Cache, distributedLock lock.Locker,
) *DistributedAccessTokenHandle

NewDistributedAccessTokenHandle new DistributedAccessTokenHandle

func (*DistributedAccessTokenHandle) GetAccessToken

func (ak *DistributedAccessTokenHandle) GetAccessToken() (accessToken string, err error)

GetAccessToken 获取access_token,先从cache中获取，没有则从服务端获取

func (*DistributedAccessTokenHandle) GetAccessTokenContext

func (ak *DistributedAccessTokenHandle) GetAccessTokenContext(ctx context.Context) (accessToken string, err error)

GetAccessTokenContext 获取access_token,先从cache中获取，没有则从服务端获取

func (*DistributedAccessTokenHandle) RefreshAccessToken

func (ak *DistributedAccessTokenHandle) RefreshAccessToken() (err error)

RefreshAccessToken 刷新access_token

type OfficialAccount

type OfficialAccount struct {
	officialaccount.OfficialAccount
	// contains filtered or unexported fields
}

func NewOfficialAccount

func NewOfficialAccount(config *OfficialAccountConfig, cache Cache, distributedLock lock.Locker) *OfficialAccount

func NewOfficialAccountByMemory

func NewOfficialAccountByMemory(config *OfficialAccountConfig) *OfficialAccount

func NewOfficialAccountByRedis

func NewOfficialAccountByRedis(config *OfficialAccountConfig, redisClient redis.UniversalClient) *OfficialAccount

func (*OfficialAccount) StartTokenChecking

func (oa *OfficialAccount) StartTokenChecking()

type OfficialAccountConfig

type OfficialAccountConfig struct {
	AppID          string `json:"app_id"`
	AppSecret      string `json:"app_secret"`
	Token          string `json:"token"`
	EncodingAESKey string `json:"encoding_aes_key"`
}

type Redis

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

Redis .redis cache @description: 实现cache.Cache的Redis类

func NewRedis

func NewRedis(ctx context.Context, conn redis.UniversalClient) *Redis

NewRedis 实例化

func (*Redis) Delete

func (r *Redis) Delete(key string) error

Delete 删除

func (*Redis) Get

func (r *Redis) Get(key string) interface{}

Get 获取一个值

func (*Redis) IsExist

func (r *Redis) IsExist(key string) bool

IsExist 判断key是否存在

func (*Redis) Set

func (r *Redis) Set(key string, val interface{}, timeout time.Duration) error

Set 设置一个值