engines

type AMQP struct {
	ExchangeName    string
	ExchangeType    string
	ExchangeDurable bool
	PrefetchCount   uint8
	AutoAck         bool
	// contains filtered or unexported fields
}

type AMQPConsumer struct {
	*rabbitgo.Consumer
}

type AckOptions struct {
	Multiple bool
	Requeue  bool
}

type Consumer interface {
	Consume(handlers []context.Handler) error
	Close() error
}

type Context struct {
	*rabbitgo.Delivery
}

type Engine interface {
	MergeRoutingKeys(string, string) string
	Connect() error
	IsConnected() bool
	Close() error
	Consumer(routingKey string) (Consumer, error)
}

type HTTPSimple struct {
	Address        string
	ReadTimeout    time.Duration
	WriteTimeout   time.Duration
	MaxHeaderBytes uint
}

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

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

type Mock struct {
	RoutingKey string
	Handlers   []context.Handler
	// contains filtered or unexported fields
}

type MockConsumer struct {
	*Mock
	IsConnected bool
}

type Server struct {
	*http.Server
	// contains filtered or unexported fields
}