worker

type IF interface {
	ID() int
	Label() string
	Run(wg *sync.WaitGroup)
	Command(int)
	Subscribe(int, string) *Subscription
	UnSubscribe(int)
	Subscriptions() []*Subscription
}

type Subscription struct {
	ID      int              `json:"id,omitempty"`
	Type    string           `json:"type,omitempty"`
	Label   string           `json:"label,omitempty"`
	Channel chan interface{} `json:"-"`
	Next    *Subscription    `json:"-"`
}

type Workers []interface{}