queue_helper

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 23, 2023 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.