task

type Agent struct {
	ConnectionInfo constants.ConnectionInfo
	Channel        string
	BrokerType     constants.BrokerType `conf:"env"`

	CentralChannel string `conf:"env"`
	CentralSubject string `conf:"env"`
	// contains filtered or unexported fields
}

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

type Consumer interface {
	RegisterChannel(channel string, processor constants.TaskProcessor) error
	Work()
	Stop()
}

type CronDescriber interface {
	CronSpec() string
}

type Producer interface {
	SendTask(task *constants.Task) error
	Stop()
}

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