worker

README

a simple worker for task server

Documentation

Index

• func ConfirmTask(id string, ok bool) bool
• func RegisterWorker(taskName string, f func(task *FetchedTask) bool)
• func Start()
• type FetchedTask
  • func FetchTask(taskName string) *FetchedTask
• type Task
  • func (task *Task) ArgsTo(to interface{})

Functions

func ConfirmTask

func ConfirmTask(id string, ok bool) bool

func RegisterWorker

func RegisterWorker(taskName string, f func(task *FetchedTask) bool)

func Start

func Start()

Types

type FetchedTask

type FetchedTask struct {
	Id   string
	Time int64
	Task Task
}

func FetchTask

func FetchTask(taskName string) *FetchedTask

type Task

type Task struct {
	Group string
	Name  string
	Args  map[string]interface{}
}

func (*Task) ArgsTo

func (task *Task) ArgsTo(to interface{})