service

Documentation

Index

• func CommentsOrder(ctx context.Context, req *comments_business.CommentsOrderRequest) (retCode int)
• func FindCommentsTags(ctx context.Context, req *comments_business.FindCommentsTagRequest) (result []*comments_business.CommentsTags, retCode int)
• func FindShopComments(ctx context.Context, req *comments_business.FindShopCommentsRequest) (result []*comments_business.OrderCommentsInfo, retCode int)
• func ModifyCommentsTags(ctx context.Context, req *comments_business.ModifyCommentsTagsRequest) (retCode int)
• type PushMsgTag
• type PushNoticeService
  • func NewPushNoticeService(server *queue.MachineryQueue, tag PushMsgTag) *PushNoticeService
  • func (p *PushNoticeService) GetTaskState(taskId string) (*tasks.TaskState, error)
  • func (p *PushNoticeService) PushMessage(ctx context.Context, args interface{}) (string, int)

Functions

func CommentsOrder

func CommentsOrder(ctx context.Context, req *comments_business.CommentsOrderRequest) (retCode int)

func FindCommentsTags

func FindCommentsTags(ctx context.Context, req *comments_business.FindCommentsTagRequest) (result []*comments_business.CommentsTags, retCode int)

func FindShopComments

func FindShopComments(ctx context.Context, req *comments_business.FindShopCommentsRequest) (result []*comments_business.OrderCommentsInfo, retCode int)

func ModifyCommentsTags

func ModifyCommentsTags(ctx context.Context, req *comments_business.ModifyCommentsTagsRequest) (retCode int)

Types

type PushMsgTag

type PushMsgTag struct {
	DeliveryTag    string
	DeliveryErrTag string
	RetryCount     int
	RetryTimeout   int
}

type PushNoticeService

type PushNoticeService struct {
	// contains filtered or unexported fields
}

func NewPushNoticeService

func NewPushNoticeService(server *queue.MachineryQueue, tag PushMsgTag) *PushNoticeService

func (*PushNoticeService) GetTaskState

func (p *PushNoticeService) GetTaskState(taskId string) (*tasks.TaskState, error)

func (*PushNoticeService) PushMessage

func (p *PushNoticeService) PushMessage(ctx context.Context, args interface{}) (string, int)