rabbitmq

Documentation

Index

• Constants
• type PayloadRabbit
• type RabbitImpl
  • func (rabbit RabbitImpl) CreateFanoutExchange(channel *amqp.Channel, name string) error
  • func (rabbit RabbitImpl) GetChannel(conn *amqp.Connection) *amqp.Channel
  • func (rabbit RabbitImpl) GetConnection(uri string) *amqp.Connection
  • func (rabbit RabbitImpl) GetConsumer(channel *amqp.Channel, queue, consumer string, ...) (<-chan amqp.Delivery, error)
  • func (rabbit RabbitImpl) Publish(channel *amqp.Channel, exchange, key string, mandatory, immediate bool, ...) error
  • func (rabbit RabbitImpl) QueueDeclare(channel *amqp.Channel, name string, durable bool, autoDelete bool, ...) (amqp.Queue, error)
• type RabbitInterface
• type RabbitPayloadConsumer

Constants

const (
	InstallQueue       = "InstallQueue"
	ResultInstallQueue = "ResultInstallQueue"
	RepositoriesQueue  = "RepositoriesQueue"
	DeleteRepoQueue    = "DeleteRepoQueue"
)

Queues

const (
	ExchangeAddRepo    = "add.repository.fx"
	ExchangeDelRepo    = "del.repository.fx"
	ExchangeUpdateRepo = "update.repository.fx"
)

Exchanges

Types

type PayloadRabbit

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"`
}

PayloadRabbit consumer

type RabbitImpl

type RabbitImpl struct {
}

RabbitImpl struct

func (RabbitImpl) CreateFanoutExchange

func (rabbit RabbitImpl) CreateFanoutExchange(channel *amqp.Channel, name string) error

CreateFanoutExchange func

func (RabbitImpl) GetChannel

func (rabbit RabbitImpl) GetChannel(conn *amqp.Connection) *amqp.Channel

GetChannel with rabbitMQ Server

func (RabbitImpl) GetConnection

func (rabbit RabbitImpl) GetConnection(uri string) *amqp.Connection

GetConnection to the RabbitMQ Server

func (RabbitImpl) GetConsumer

func (rabbit RabbitImpl) GetConsumer(channel *amqp.Channel, queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

GetConsumer queue

func (RabbitImpl) Publish

func (rabbit RabbitImpl) Publish(channel *amqp.Channel, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

Publish a message on queue

func (RabbitImpl) QueueDeclare

func (rabbit RabbitImpl) QueueDeclare(channel *amqp.Channel, name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args amqp.Table) (amqp.Queue, error)

QueueDeclare declare a queue

type RabbitInterface

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
}

RabbitInterface interface

type RabbitPayloadConsumer

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

RabbitPayloadConsumer consumer