service

Documentation

Index

• Variables
• func GoCron()
• func Init(signingKey string)
• type RelationServiceImpl
  • func (r *RelationServiceImpl) RelationAction(ctx context.Context, req *relation.RelationActionRequest) (resp *relation.RelationActionResponse, err error)
  • func (r *RelationServiceImpl) RelationFollowList(ctx context.Context, req *relation.RelationFollowListRequest) (resp *relation.RelationFollowListResponse, err error)
  • func (r *RelationServiceImpl) RelationFollowerList(ctx context.Context, req *relation.RelationFollowerListRequest) (resp *relation.RelationFollowerListResponse, err error)
  • func (r *RelationServiceImpl) RelationFriendList(ctx context.Context, req *relation.RelationFriendListRequest) (resp *relation.RelationFriendListResponse, err error)

Variables

var (
	Jwt *jwt.JWT

	RelationMq = rabbitmq.NewRabbitMQSimple("relation", autoAck)
)

Functions

func GoCron

func GoCron()

gocron定时任务,每隔一段时间就让Consumer消费消息队列的所有消息

func Init

func Init(signingKey string)

Types

type RelationServiceImpl

type RelationServiceImpl struct{}

func (*RelationServiceImpl) RelationAction

func (r *RelationServiceImpl) RelationAction(ctx context.Context, req *relation.RelationActionRequest) (resp *relation.RelationActionResponse, err error)

func (*RelationServiceImpl) RelationFollowList

func (r *RelationServiceImpl) RelationFollowList(ctx context.Context, req *relation.RelationFollowListRequest) (resp *relation.RelationFollowListResponse, err error)

func (*RelationServiceImpl) RelationFollowerList

func (r *RelationServiceImpl) RelationFollowerList(ctx context.Context, req *relation.RelationFollowerListRequest) (resp *relation.RelationFollowerListResponse, err error)

func (*RelationServiceImpl) RelationFriendList

func (r *RelationServiceImpl) RelationFriendList(ctx context.Context, req *relation.RelationFriendListRequest) (resp *relation.RelationFriendListResponse, err error)