The highest tagged major version is v3.

ytask

package

v1.0.0 Latest Latest Go to latest Published: Jul 10, 2019 License: GPL-3.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type YTask struct {
	// contains filtered or unexported fields
}

func NewYTask(c config.Config) YTask

func (t *YTask) Add(group string, w yworker.WorkerInterface)

func (t *YTask) Get(groupName string) (ymsg.Message, error)

func (t *YTask) Run(groupName string, numWorkers int)

func (t *YTask) Send(groupName string, values ...interface{}) error

send task

t.Send("xx", ymsg.Message{} )

t.Send("xx", "workerName1" , User{1,"name"} )

t.Send("xx", "workerName1" , "userJsonString" )

func (t *YTask) Shutdown(ctx context.Context) error