service

Documentation

Index

• func ShopSearch(ctx context.Context, req *search_business.ShopSearchRequest) (result []*search_business.ShopSearchEntry, retCode int)
• func SkuInventorySearch(ctx context.Context, req *search_business.SkuInventorySearchRequest) (result []*search_business.SkuInventoryEntry, 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 ShopSearch

func ShopSearch(ctx context.Context, req *search_business.ShopSearchRequest) (result []*search_business.ShopSearchEntry, retCode int)

func SkuInventorySearch

func SkuInventorySearch(ctx context.Context, req *search_business.SkuInventorySearchRequest) (result []*search_business.SkuInventoryEntry, 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)