controller

Documentation

Index

• func RestApiModuleProcessor()
• func ServiceBusConnectionMiddleware(next http.Handler) http.Handler
• type Controller
  • func NewAPIController(router *mux.Router) Controller
  • func (c *Controller) CreateSubscriptionRule(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) CreateTopic(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) DeleteQueue(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) DeleteSubscriptionRule(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) DeleteTopic(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) DeleteTopicSubscription(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetQueue(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetQueueDeadLetterMessages(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetQueueMessages(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetQueues(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetSubscriptionDeadLetterMessages(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetSubscriptionMessages(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetSubscriptionRule(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetSubscriptionRules(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetTopic(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetTopicSubscription(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetTopicSubscriptions(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetTopics(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SendBulkQueueMessage(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SendBulkTemplateQueueMessage(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SendBulkTemplateTopicMessage(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SendBulkTopicMessage(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SendQueueMessage(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SendTopicMessage(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SetConnectionString(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) UpsertQueue(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) UpsertTopicSubscription(w http.ResponseWriter, r *http.Request)

Functions

func RestApiModuleProcessor

func RestApiModuleProcessor()

func ServiceBusConnectionMiddleware

func ServiceBusConnectionMiddleware(next http.Handler) http.Handler

Types

type Controller

type Controller struct {
	Router *mux.Router
}

Controllers Controller structure

func NewAPIController

func NewAPIController(router *mux.Router) Controller

NewAPIController Creates a new controller

func (*Controller) CreateSubscriptionRule

func (c *Controller) CreateSubscriptionRule(w http.ResponseWriter, r *http.Request)

CreateSubscriptionRule Creates a rule in a subscription

func (*Controller) CreateTopic

func (c *Controller) CreateTopic(w http.ResponseWriter, r *http.Request)

func (*Controller) DeleteQueue

func (c *Controller) DeleteQueue(w http.ResponseWriter, r *http.Request)

DeleteQueue Deletes a Queue in the namespace

func (*Controller) DeleteSubscriptionRule

func (c *Controller) DeleteSubscriptionRule(w http.ResponseWriter, r *http.Request)

GetSubscriptionMessages Gets messages from a topic subscription

func (*Controller) DeleteTopic

func (c *Controller) DeleteTopic(w http.ResponseWriter, r *http.Request)

DeleteTopic Deletes a topic in the namespace

func (*Controller) DeleteTopicSubscription

func (c *Controller) DeleteTopicSubscription(w http.ResponseWriter, r *http.Request)

DeleteTopicSubscription Deletes subscription from a topic in the current namespace

func (*Controller) GetQueue

func (c *Controller) GetQueue(w http.ResponseWriter, r *http.Request)

GetQueue Gets the details of a specific Queue in the current namespace

func (*Controller) GetQueueDeadLetterMessages

func (c *Controller) GetQueueDeadLetterMessages(w http.ResponseWriter, r *http.Request)

GetQueueDeadLetterMessages Gets dead letters from a Queue in the current namespace

func (*Controller) GetQueueMessages

func (c *Controller) GetQueueMessages(w http.ResponseWriter, r *http.Request)

GetQueueMessages Gets messages from a Queue in the current namespace

func (*Controller) GetQueues

func (c *Controller) GetQueues(w http.ResponseWriter, r *http.Request)

GetQueues Gets all queues in the current namespace

func (*Controller) GetSubscriptionDeadLetterMessages

func (c *Controller) GetSubscriptionDeadLetterMessages(w http.ResponseWriter, r *http.Request)

GetSubscriptionMessages Gets dead letters from a subscription in a topic in the current namespace

func (*Controller) GetSubscriptionMessages

func (c *Controller) GetSubscriptionMessages(w http.ResponseWriter, r *http.Request)

GetSubscriptionMessages Gets messages from a subscription in a topic in the current namespace

func (*Controller) GetSubscriptionRule

func (c *Controller) GetSubscriptionRule(w http.ResponseWriter, r *http.Request)

GetSubscriptionMessages Gets messages from a topic subscription

func (*Controller) GetSubscriptionRules

func (c *Controller) GetSubscriptionRules(w http.ResponseWriter, r *http.Request)

GetSubscriptionMessages Gets messages from a topic subscription

func (*Controller) GetTopic

func (c *Controller) GetTopic(w http.ResponseWriter, r *http.Request)

GetTopic Get Topic by name from the namespace

func (*Controller) GetTopicSubscription

func (c *Controller) GetTopicSubscription(w http.ResponseWriter, r *http.Request)

GetTopicSubscription Gets the details of a subscription from a topic in the current namespace

func (*Controller) GetTopicSubscriptions

func (c *Controller) GetTopicSubscriptions(w http.ResponseWriter, r *http.Request)

GetTopicSubscriptions Gets all of the subscriptions from a topic in the current namespace

func (*Controller) GetTopics

func (c *Controller) GetTopics(w http.ResponseWriter, r *http.Request)

GetTopics Gets all topics in the namespace

func (*Controller) SendBulkQueueMessage

func (c *Controller) SendBulkQueueMessage(w http.ResponseWriter, r *http.Request)

SendBulkQueueMessage Sends a Message to a Queue in the current namespace

func (*Controller) SendBulkTemplateQueueMessage

func (c *Controller) SendBulkTemplateQueueMessage(w http.ResponseWriter, r *http.Request)

SendBulkQueueMessage Sends a Message to a Queue in the current namespace

func (*Controller) SendBulkTemplateTopicMessage

func (c *Controller) SendBulkTemplateTopicMessage(w http.ResponseWriter, r *http.Request)

func (*Controller) SendBulkTopicMessage

func (c *Controller) SendBulkTopicMessage(w http.ResponseWriter, r *http.Request)

func (*Controller) SendQueueMessage

func (c *Controller) SendQueueMessage(w http.ResponseWriter, r *http.Request)

SendQueueMessage Sends a Message to a Queue in the current namespace

func (*Controller) SendTopicMessage

func (c *Controller) SendTopicMessage(w http.ResponseWriter, r *http.Request)

func (*Controller) SetConnectionString

func (c *Controller) SetConnectionString(w http.ResponseWriter, r *http.Request)

GetTopics Gets all topics in the namespace

func (*Controller) UpsertQueue

func (c *Controller) UpsertQueue(w http.ResponseWriter, r *http.Request)

UpsertQueue Update or Insert a Queue in the current namespace

func (*Controller) UpsertTopicSubscription

func (c *Controller) UpsertTopicSubscription(w http.ResponseWriter, r *http.Request)

UpsertTopicSubscription Update or Insert a subscription in a topic in the current namespace