queue_helper

Documentation

Index

• type PublishService
  • func NewPublishService(server *queue.MachineryQueue, tag *PushMsgTag, logger log.LoggerContextIface) (*PublishService, error)
  • func (p *PublishService) GetTaskState(taskId string) (*tasks.TaskState, error)
  • func (p *PublishService) PushMessage(ctx context.Context, args interface{}) (string, int)
• type PushMsgTag

Types

type PublishService

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

func NewPublishService

func NewPublishService(server *queue.MachineryQueue, tag *PushMsgTag, logger log.LoggerContextIface) (*PublishService, error)

func (*PublishService) GetTaskState

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

func (*PublishService) PushMessage

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

type PushMsgTag

type PushMsgTag struct {
	DeliveryTag    string // consume func name
	DeliveryErrTag string // consume err func name
	RetryCount     int    // default 3 cycle
	RetryTimeout   int    // default 10s
}