rabbit

type Amqp struct {
	Chan AmqpChannelCloser
	Conn AmqpConnectionCloser
}

type AmqpChannel interface {
	Qos(prefetchCount, prefetchSize int, global bool) error
	QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
	ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
	QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
	NotifyClose(c chan *amqp.Error) chan *amqp.Error
	Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
}

type AmqpChannelCloser interface {
	AmqpChannel
	AmqpCloser
}

type AmqpCloser interface {
	Close() error
}

type AmqpConnection interface {
	Channel() (*amqp.Channel, error)
}

type AmqpConnectionCloser interface {
	AmqpConnection
	AmqpCloser
}

type AmqpConsumer interface {
	Dial(url string) (*amqp.Connection, error)

	AmqpConnection
	AmqpChannel
	AmqpCloser
}

type Config struct {
	Connection struct {
		Host     string
		Username string
		Password string
		Vhost    string
		Port     int
	}
	Consumer struct {
		Exchange struct {
			Name       string
			Type       string
			Durable    bool
			AutoDelete bool `mapstructure:"auto_delete"`
		}
		Prefetch struct {
			Count  int
			Global bool
		}
		Queue struct {
			Name       string
			RoutingKey string `mapstructure:"routing_key"`
			Durable    bool
			AutoDelete bool `mapstructure:"auto_delete"`
		}
		Worker struct {
			Script        string
			Count         int
			RetryInterval int `mapstructure:"retry_interval"`
		}
	}
	Logger struct {
		Output    string
		Formatter string
		Level     string
		LogFile   string `mapstructure:"log_file"`
	}
}

type Logger struct {

	// Embedding logrus.Logger
	log.Logger
	// contains filtered or unexported fields
}

type MessageForwarder func(msgs <-chan amqp.Delivery, retryInterval int)

type NotifyCloseCallback func()

type Rex struct {
	Amqp    AmqpConsumer
	Config  *Config
	Logger  *Logger
	Script  ScriptCaller
	Forever chan bool
}

type Script struct {
	Config *Config
}

type ScriptCaller interface {
	ExecWith([]byte) ([]byte, error)
}