task

Documentation

Index

• Constants
• func AfterHandleTask(task model.MessageTask, message model.MessageInfo, err error)
• func InitMonitor(ctx context.Context)
• func RunClearExpired(ctx context.Context)
• type MessageTask
  • func New(ctx context.Context, executor sender.TaskExecutor, opts ...Option) (t MessageTask, err error)
• type MonitorData
• type Option
  • func WithDb(scanInternal int) Option
  • func WithQueue(queueSize int) Option
• type SendMonitor
  • func GetMonitor() SendMonitor
• type Strategy

Constants

const (
	DefaultQueueSize      = 1024
	DefaultDbScanInterval = 10
)

Functions

func AfterHandleTask

func AfterHandleTask(task model.MessageTask, message model.MessageInfo, err error)

func InitMonitor

func InitMonitor(ctx context.Context)

func RunClearExpired

func RunClearExpired(ctx context.Context)

Types

type MessageTask

type MessageTask interface {
	Run()
	HandleMessage(message model.MessageInfo) (err error)
}

func New

func New(ctx context.Context, executor sender.TaskExecutor, opts ...Option) (t MessageTask, err error)

type MonitorData

type MonitorData struct {
	TaskId            int                 `json:"taskId,omitempty"`
	MessageId         int                 `json:"messageId,omitempty"`
	MessageCategory   msg.MessageCategory `json:"messageCategory,omitempty"`
	Subject           string              `json:"subject,omitempty"`
	MessageInstanceId int                 `json:"messageInstanceId,omitempty"`
	Status            int                 `json:"status,omitempty"`
}

type Option

type Option func(task *messageTask)

func WithDb

func WithDb(scanInternal int) Option

func WithQueue

func WithQueue(queueSize int) Option

type SendMonitor

type SendMonitor interface {
	Subscribe(c *websocket.Conn)
	UnSubscribe(c *websocket.Conn)
	Pub(msg MonitorData)
}

func GetMonitor

func GetMonitor() SendMonitor

type Strategy

type Strategy int

const (
	MemQueue Strategy = iota
	Db
)