Documentation
¶
Index ¶
- Variables
- func MqRecovery(...) ...
- func NewGRPCServer(c *conf.Server, messageService *service.MessageService, logger log.Logger) *grpc.Server
- func NewHTTPServer(c *conf.Server, messageService *service.MessageService, logger log.Logger) *http.Server
- type AchievementMqConsumerServer
- type ArticleMqConsumerServer
- type ArticleReviewMqConsumerServer
- type CodeMqConsumerServer
- type CollectionsMqConsumerServer
- type CollectionsReviewMqConsumerServer
- type ColumnMqConsumerServer
- type ColumnReviewMqConsumerServer
- type CommentMqConsumerServer
- type CommentReviewMqConsumerServer
- type FollowMqConsumerServer
- type PictureMqConsumerServer
- type ProfileMqConsumerServer
- type TalkMqConsumerServer
- type TalkReviewMqConsumerServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewHTTPServer, NewGRPCServer, NewCodeMqConsumerServer, NewProfileMqConsumerServer, NewArticleReviewMqConsumerServer, NewArticleMqConsumerServer, NewTalkReviewMqConsumerServer, NewTalkMqConsumerServer, NewColumnReviewMqConsumerServer, NewColumnMqConsumerServer, NewAchievementMqConsumerServer, NewCommentReviewMqConsumerServer, NewCommentMqConsumerServer, NewFollowMqConsumerServer, NewPictureMqConsumerServer, NewCollectionsReviewMqConsumerServer, NewCollectionsMqConsumerServer)
ProviderSet is user providers.
Functions ¶
func MqRecovery ¶
func MqRecovery(fn func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)) func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)
func NewGRPCServer ¶
func NewHTTPServer ¶
func NewHTTPServer(c *conf.Server, messageService *service.MessageService, logger log.Logger) *http.Server
NewHTTPServer new a HTTP user.
Types ¶
type AchievementMqConsumerServer ¶
type AchievementMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewAchievementMqConsumerServer ¶
func NewAchievementMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *AchievementMqConsumerServer
type ArticleMqConsumerServer ¶
type ArticleMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewArticleMqConsumerServer ¶
func NewArticleMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *ArticleMqConsumerServer
type ArticleReviewMqConsumerServer ¶
type ArticleReviewMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewArticleReviewMqConsumerServer ¶
func NewArticleReviewMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *ArticleReviewMqConsumerServer
type CodeMqConsumerServer ¶
type CodeMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewCodeMqConsumerServer ¶
func NewCodeMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *CodeMqConsumerServer
type CollectionsMqConsumerServer ¶
type CollectionsMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewCollectionsMqConsumerServer ¶
func NewCollectionsMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *CollectionsMqConsumerServer
type CollectionsReviewMqConsumerServer ¶
type CollectionsReviewMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewCollectionsReviewMqConsumerServer ¶
func NewCollectionsReviewMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *CollectionsReviewMqConsumerServer
type ColumnMqConsumerServer ¶
type ColumnMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewColumnMqConsumerServer ¶
func NewColumnMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *ColumnMqConsumerServer
type ColumnReviewMqConsumerServer ¶
type ColumnReviewMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewColumnReviewMqConsumerServer ¶
func NewColumnReviewMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *ColumnReviewMqConsumerServer
type CommentMqConsumerServer ¶
type CommentMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewCommentMqConsumerServer ¶
func NewCommentMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *CommentMqConsumerServer
type CommentReviewMqConsumerServer ¶
type CommentReviewMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewCommentReviewMqConsumerServer ¶
func NewCommentReviewMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *CommentReviewMqConsumerServer
type FollowMqConsumerServer ¶
type FollowMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewFollowMqConsumerServer ¶
func NewFollowMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *FollowMqConsumerServer
type PictureMqConsumerServer ¶
type PictureMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewPictureMqConsumerServer ¶
func NewPictureMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *PictureMqConsumerServer
type ProfileMqConsumerServer ¶
type ProfileMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewProfileMqConsumerServer ¶
func NewProfileMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *ProfileMqConsumerServer
type TalkMqConsumerServer ¶
type TalkMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewTalkMqConsumerServer ¶
func NewTalkMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *TalkMqConsumerServer
type TalkReviewMqConsumerServer ¶
type TalkReviewMqConsumerServer struct {
// contains filtered or unexported fields
}
func NewTalkReviewMqConsumerServer ¶
func NewTalkReviewMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *TalkReviewMqConsumerServer
Source Files
Click to show internal directories.
Click to hide internal directories.