Versions in this module Expand all Collapse all v1 v1.0.0 Sep 2, 2024 Changes in this version + type RedisStreamMQ struct + Client *redis.Client + NewPostStream string + Oauth2CodeHash string + PostCancelStream string + PublishPostStream string + PublishStatusHash string + func NewRedisStreamMQ() *RedisStreamMQ + func (r *RedisStreamMQ) CheckPostPublishStatus(postID int) (bool, error) + func (r *RedisStreamMQ) DeletePostPublishStatus(postID int) error + func (r *RedisStreamMQ) GetOauth2Uin(code string) (int64, error) + func (r *RedisStreamMQ) NewPost(postID int) error + func (r *RedisStreamMQ) PostCancel(postID int) error + func (r *RedisStreamMQ) PublishPost(postID int) error + func (r *RedisStreamMQ) SetOauth2Code(code string, uin int64) error
Go to main page