rabbitmq

type PayloadRabbit struct {
	UpgradeRequest helmapi.UpgradeRequest `json:"upgradeRequest"`
	Name           string                 `json:"name"`
	Token          string                 `json:"token"`
	Filename       string                 `json:"filename"`
	CACertificate  string                 `json:"ca_certificate"`
	ClusterURI     string                 `json:"cluster_uri"`
	Namespace      string                 `json:"namespace"`
	DeploymentID   uint                   `json:"deployment_id"`
}

type RabbitImpl struct {
}

type RabbitInterface interface {
	GetConnection(uri string) *amqp.Connection
	GetChannel(conn *amqp.Connection) *amqp.Channel
	Publish(channel *amqp.Channel, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
	GetConsumer(channel *amqp.Channel, queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	QueueDeclare(channel *amqp.Channel, name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args amqp.Table) (amqp.Queue, error)
	CreateFanoutExchange(channel *amqp.Channel, name string) error
}

type RabbitPayloadConsumer struct {
	Success      bool   `json:"sucess"`
	Error        string `json:"error"`
	DeploymentID uint   `json:"deployment_id"`
}