Documentation
¶
Index ¶
- func HandleExchangeBindingAdd(exchangeRepository storage.ExchangeRepository, ...) http.HandlerFunc
- func HandleExchangeBindingDelete(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
- func HandleExchangeCreate(exchangeRepository storage.ExchangeRepository, validate *validator.Validate) http.HandlerFunc
- func HandleExchangeDelete(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
- func HandleExchangeFind(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
- func HandleExchangeGet(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
- func HandleExchangeMessagePublish(exchangeRepository storage.ExchangeRepository, ...) http.HandlerFunc
- func HandleQueueCreate(queueRepository storage.QueueRepository, validate *validator.Validate) http.HandlerFunc
- func HandleQueueDelete(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueFind(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueGet(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueMessageAck(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueMessageConsume(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueMessageGet(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueMessageNack(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueMessagePeek(queueRepository storage.QueueRepository) http.HandlerFunc
- func HandleQueueMessagePublish(queueRepository storage.QueueRepository, validate *validator.Validate) http.HandlerFunc
- func HandleQueueMessagePurge(queueRepository storage.QueueRepository) http.HandlerFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HandleExchangeBindingAdd ¶
func HandleExchangeBindingAdd(exchangeRepository storage.ExchangeRepository, queueRepository storage.QueueRepository, validate *validator.Validate) http.HandlerFunc
func HandleExchangeBindingDelete ¶
func HandleExchangeBindingDelete(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
func HandleExchangeCreate ¶
func HandleExchangeCreate(exchangeRepository storage.ExchangeRepository, validate *validator.Validate) http.HandlerFunc
func HandleExchangeDelete ¶
func HandleExchangeDelete(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
func HandleExchangeFind ¶
func HandleExchangeFind(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
func HandleExchangeGet ¶
func HandleExchangeGet(exchangeRepository storage.ExchangeRepository) http.HandlerFunc
func HandleExchangeMessagePublish ¶
func HandleExchangeMessagePublish( exchangeRepository storage.ExchangeRepository, queueRepository storage.QueueRepository, validate *validator.Validate, ) http.HandlerFunc
func HandleQueueCreate ¶
func HandleQueueCreate(queueRepository storage.QueueRepository, validate *validator.Validate) http.HandlerFunc
func HandleQueueDelete ¶
func HandleQueueDelete(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueFind ¶
func HandleQueueFind(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueGet ¶
func HandleQueueGet(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueMessageAck ¶
func HandleQueueMessageAck(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueMessageConsume ¶
func HandleQueueMessageConsume(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueMessageGet ¶
func HandleQueueMessageGet(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueMessageNack ¶
func HandleQueueMessageNack(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueMessagePeek ¶
func HandleQueueMessagePeek(queueRepository storage.QueueRepository) http.HandlerFunc
func HandleQueueMessagePublish ¶
func HandleQueueMessagePublish(queueRepository storage.QueueRepository, validate *validator.Validate) http.HandlerFunc
func HandleQueueMessagePurge ¶
func HandleQueueMessagePurge(queueRepository storage.QueueRepository) http.HandlerFunc
Types ¶
This section is empty.
Source Files
¶
- handle_exchange_binding_add.go
- handle_exchange_binding_delete.go
- handle_exchange_create.go
- handle_exchange_delete.go
- handle_exchange_find.go
- handle_exchange_get.go
- handle_exchange_message_publish.go
- handle_queue_create.go
- handle_queue_delete.go
- handle_queue_find.go
- handle_queue_get.go
- handle_queue_message_ack.go
- handle_queue_message_consume.go
- handle_queue_message_get.go
- handle_queue_message_nack.go
- handle_queue_message_peek.go
- handle_queue_message_publish.go
- handle_queue_message_purge.go
Click to show internal directories.
Click to hide internal directories.