queue

Documentation

Index

• func Handlers() map[string]string
• func Register(n string, h HandlerFunc)
• type HandlerFunc
  • func Get(n string) (HandlerFunc, bool)
• type Queue
• type Task
  • func NewTask(t string, p uint8, b []byte) *Task

Functions

func Handlers

func Handlers() map[string]string

Handlers handlers info

func Register

func Register(n string, h HandlerFunc)

Register register handler

Types

type HandlerFunc

type HandlerFunc func(id string, body []byte) error

HandlerFunc task handler func

func Get

func Get(n string) (HandlerFunc, bool)

Get get handler by name

type Queue

type Queue interface {
	Put(*Task) error
	Launch(name string) error
}

Queue message queue

type Task

type Task struct {
	ID       string    `json:"id"`
	Type     string    `json:"type"`
	Body     []byte    `json:"body"`
	Priority uint8     `json:"priority"`
	Created  time.Time `json:"created"`
}

Task task model

func NewTask

func NewTask(t string, p uint8, b []byte) *Task

NewTask create task