rabbitmq

type HandlerDeleteRepoQueue func(string) error

type HandlerInstall func(Install) error

type HandlerRepo func(model.Repository) error

type HandlerUpdateRepoQueue func() error

type Install 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 Queues struct {
	InstallQueue       string
	ResultInstallQueue string
	AddRepoQueue       string
	DeleteRepoQueue    string
	UpdateRepoQueue    string
}

type RabbitImpl struct {
	Conn    *amqp.Connection
	Channel *amqp.Channel
	Queues  Queues
}

type RabbitInterface interface {
	GetConnection(uri string) *amqp.Connection
	GetChannel() *amqp.Channel
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
	GetConsumer(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	CreateQueue(queueName string, exclusive bool) error
	CreateFanoutExchange(name string) error
	Bind(queueName, routingKey, exchange string) error
	ConsumeRepoQueue(fn HandlerRepo, repo model.Repository) error
	ConsumeInstallQueue(fn HandlerInstall, install Install) error
	ConsumeDeleteRepoQueue(fn HandlerDeleteRepoQueue) error
	ConsumeUpdateRepoQueue(fn HandlerUpdateRepoQueue) error
}

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