async

type Channel interface {
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
	Consume(queue, consumer string, autoAck, exclusive, noLocal, noWail bool, args amqp.Table) (<-chan amqp.Delivery, error)
	Close() error
}

type ConsumerOption struct {
	Pool        *routine.Pool   // goroutine safe run pool
	Manager     ManagerExecutor // manager executor how to run
	Marshal     mq.MarshalAPI   // mq  assemble request or response
	JSONHandler jsoniter.API
	ParamPool   ParamPool // get Param
	Validator   validator.Validator
}

type Executor interface {
	SafeCopy() Executor
	ID() string
	Run(ctx context.Context, data []byte) error
}

type ManagerExecutor interface {
	Register(executors ...Executor) error
	Run(ctx context.Context, param *Param) error
}

type Param struct {
	Name     string                 `json:"name" binding:"required"`
	Metadata map[string]interface{} `json:"metadata"`
	Data     []byte                 `json:"data"`
}

type ParamPool interface {
	Get() *Param
	Put(*Param)
}

type ProducerOption struct {
	Marshal     mq.MarshalAPI
	Exchange    string
	JSONHandler jsoniter.API
	ParamPool   ParamPool
	Validator   validator.Validator
}

type TaskProducer struct {
	ProducerOption
	// contains filtered or unexported fields
}