queue.go

queue.go

package queue

type Command interface {
    Process(ctx context, task string, arg interface{}) Command
/*

// like tree
proc := cmd.Pocess(ctx, `users.GerAll`,&users.Req{Filter: true})
proc.Pipe(`users.Reindex`)
proc.Pipe(`users.FlushData`)
proc.Pipe(`users.SendNews`)

proc.Do()

// like pipe
err := cmd.Pocess(ctx, `users.GerAll`,&users.Req{Filter: true}).Pipe(`users.Reindex`).Pipe(`reporter.Report`).Do()

*/
    Pipe(task string) Command
    Do() error
}