broker

Documentation

Index

• type Broker
• type Taskdispatcher

Types

type Broker

type Broker interface {
	SetTaskDispatcher(dispatcher Taskdispatcher)
	Publish(ctx context.Context, task *task.Task) error
}

Broker - a common interface for all brokers local node remote(ip:port) node the mq

type Taskdispatcher

type Taskdispatcher interface {
	AddTask(task *task.Task) error
}

TaskProcessor - can process a delivered task This will probably always be a worker instance