pkg

Documentation

Index

• func SubscribeRoutine(subscriber *Subscriber, dao *dao.Follow)
• type Publisher
  • func NewPublisher(conn *amqp.Connection, exchange string) (*Publisher, error)
  • func (p *Publisher) Publish(_ context.Context, car *sociality.DouyinRelationActionRequest) error
• type RedisManager
  • func NewRedisManager(client *redis.Client) *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
  • func NewSubscriber(conn *amqp.Connection, exchange string) (*Subscriber, error)
  • func (s *Subscriber) Subscribe(c context.Context) (chan *sociality.DouyinRelationActionRequest, func(), error)
  • func (s *Subscriber) SubscribeRaw(_ context.Context) (<-chan amqp.Delivery, func(), error)
• type UserManager
  • func (m *UserManager) GetFriendUsers(ctx context.Context, list []int64, viewerId int64) ([]*base.FriendUser, error)
  • func (m *UserManager) GetUsers(ctx context.Context, list []int64, viewerId int64) ([]*base.User, error)

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)

func (*Publisher) Publish

func (p *Publisher) Publish(_ context.Context, car *sociality.DouyinRelationActionRequest) error

Publish publishes a message.

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

func (*RedisManager) Check

func (r *RedisManager) Check(ctx context.Context, uid, toUid int64) (bool, error)

func (*RedisManager) Count

func (r *RedisManager) Count(ctx context.Context, uid int64, option int8) (int64, error)

func (*RedisManager) List

func (r *RedisManager) List(ctx context.Context, uid int64, option int8) (list []int64, err 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

func (s *Subscriber) SubscribeRaw(_ context.Context) (<-chan amqp.Delivery, func(), error)

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)

func (*UserManager) GetUsers

func (m *UserManager) GetUsers(ctx context.Context, list []int64, viewerId int64) ([]*base.User, error)

GetUsers gets users info by list.