go-micro: github.com/micro/go-micro/sync/task/broker Index | Files

package broker

import "github.com/micro/go-micro/sync/task/broker"

Package broker provides a distributed task manager built on the micro broker

Index

Package Files

broker.go

func NewTask Uses

func NewTask(opts ...task.Option) task.Task

NewTask returns a new broker task

func WithBroker Uses

func WithBroker(b broker.Broker) task.Option

Broker sets the micro broker

type Task Uses

type Task struct {
    // a micro broker
    Broker broker.Broker
    // Options
    Options task.Options
    // contains filtered or unexported fields
}

Task is a broker task

func (*Task) Run Uses

func (t *Task) Run(c task.Command) error

func (*Task) Status Uses

func (t *Task) Status() string

Package broker imports 10 packages (graph). Updated 2020-02-02. Refresh now. Tools for package owners.