Documentation
¶
Index ¶
- func SubscribeRoutine(subscriber *Subscriber, dao *dao.Follow)
- type Publisher
- type RedisManager
- func (r *RedisManager) Action(ctx context.Context, req *sociality.DouyinRelationActionRequest) error
- func (r *RedisManager) Check(ctx context.Context, uid, toUid int64) (bool, error)
- func (r *RedisManager) Count(ctx context.Context, uid int64, option int8) (int64, error)
- func (r *RedisManager) List(ctx context.Context, uid int64, option int8) (list []int64, err error)
- type Subscriber
- type UserManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SubscribeRoutine ¶
func SubscribeRoutine(subscriber *Subscriber, dao *dao.Follow)
Types ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher implements an amqp publisher.
func NewPublisher ¶
func NewPublisher(conn *amqp.Connection, exchange string) (*Publisher, error)
type RedisManager ¶
type RedisManager struct {
RedisClient *redis.Client
}
func NewRedisManager ¶
func NewRedisManager(client *redis.Client) *RedisManager
func (*RedisManager) Action ¶
func (r *RedisManager) Action(ctx context.Context, req *sociality.DouyinRelationActionRequest) error
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
Subscriber implements an amqp subscriber.
func NewSubscriber ¶
func NewSubscriber(conn *amqp.Connection, exchange string) (*Subscriber, error)
NewSubscriber creates an amqp subscriber.
func (*Subscriber) Subscribe ¶
func (s *Subscriber) Subscribe(c context.Context) (chan *sociality.DouyinRelationActionRequest, func(), error)
Subscribe subscribes and returns a channel with CarEntity data.
func (*Subscriber) SubscribeRaw ¶
SubscribeRaw subscribes and returns a channel with raw amqp delivery.
type UserManager ¶
type UserManager struct {
UserService userservice.Client
ChatService chatservice.Client
}
func (*UserManager) GetFriendUsers ¶
func (m *UserManager) GetFriendUsers(ctx context.Context, list []int64, viewerId int64) ([]*base.FriendUser, error)
Source Files
Click to show internal directories.
Click to hide internal directories.