Documentation ¶
Overview ¶
Package servicebus implements the Azure ARM Servicebus service API version 2017-04-01.
Azure Service Bus client
Index ¶
- Constants
- func UserAgent() string
- func Version() string
- type AccessKeys
- type AccessRights
- type Action
- type ArmDisasterRecovery
- type ArmDisasterRecoveryListResult
- type ArmDisasterRecoveryProperties
- type AuthorizationRuleProperties
- type CaptureDescription
- type CheckNameAvailability
- type CheckNameAvailabilityResult
- type CorrelationFilter
- type Destination
- type DestinationProperties
- type DisasterRecoveryConfigsClient
- func (client DisasterRecoveryConfigsClient) BreakPairing(resourceGroupName string, namespaceName string, alias string) (result autorest.Response, err error)
- func (client DisasterRecoveryConfigsClient) BreakPairingPreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
- func (client DisasterRecoveryConfigsClient) BreakPairingResponder(resp *http.Response) (result autorest.Response, err error)
- func (client DisasterRecoveryConfigsClient) BreakPairingSender(req *http.Request) (*http.Response, error)
- func (client DisasterRecoveryConfigsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, alias string, ...) (result ArmDisasterRecovery, err error)
- func (client DisasterRecoveryConfigsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, alias string, ...) (*http.Request, error)
- func (client DisasterRecoveryConfigsClient) CreateOrUpdateResponder(resp *http.Response) (result ArmDisasterRecovery, err error)
- func (client DisasterRecoveryConfigsClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client DisasterRecoveryConfigsClient) Delete(resourceGroupName string, namespaceName string, alias string) (result autorest.Response, err error)
- func (client DisasterRecoveryConfigsClient) DeletePreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
- func (client DisasterRecoveryConfigsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client DisasterRecoveryConfigsClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client DisasterRecoveryConfigsClient) FailOver(resourceGroupName string, namespaceName string, alias string) (result autorest.Response, err error)
- func (client DisasterRecoveryConfigsClient) FailOverPreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
- func (client DisasterRecoveryConfigsClient) FailOverResponder(resp *http.Response) (result autorest.Response, err error)
- func (client DisasterRecoveryConfigsClient) FailOverSender(req *http.Request) (*http.Response, error)
- func (client DisasterRecoveryConfigsClient) Get(resourceGroupName string, namespaceName string, alias string) (result ArmDisasterRecovery, err error)
- func (client DisasterRecoveryConfigsClient) GetPreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
- func (client DisasterRecoveryConfigsClient) GetResponder(resp *http.Response) (result ArmDisasterRecovery, err error)
- func (client DisasterRecoveryConfigsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client DisasterRecoveryConfigsClient) List(resourceGroupName string, namespaceName string) (result ArmDisasterRecoveryListResult, err error)
- func (client DisasterRecoveryConfigsClient) ListComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan ArmDisasterRecovery, <-chan error)
- func (client DisasterRecoveryConfigsClient) ListNextResults(lastResults ArmDisasterRecoveryListResult) (result ArmDisasterRecoveryListResult, err error)
- func (client DisasterRecoveryConfigsClient) ListPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client DisasterRecoveryConfigsClient) ListResponder(resp *http.Response) (result ArmDisasterRecoveryListResult, err error)
- func (client DisasterRecoveryConfigsClient) ListSender(req *http.Request) (*http.Response, error)
- type EncodingCaptureDescription
- type EntityStatus
- type ErrorResponse
- type EventHubListResult
- type EventHubsClient
- func (client EventHubsClient) ListByNamespace(resourceGroupName string, namespaceName string) (result EventHubListResult, err error)
- func (client EventHubsClient) ListByNamespaceComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan Eventhub, <-chan error)
- func (client EventHubsClient) ListByNamespaceNextResults(lastResults EventHubListResult) (result EventHubListResult, err error)
- func (client EventHubsClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client EventHubsClient) ListByNamespaceResponder(resp *http.Response) (result EventHubListResult, err error)
- func (client EventHubsClient) ListByNamespaceSender(req *http.Request) (*http.Response, error)
- type Eventhub
- type EventhubProperties
- type FilterType
- type KeyType
- type ManagementClient
- type MessageCountDetails
- type NamespacesClient
- func (client NamespacesClient) CheckNameAvailabilityMethod(parameters CheckNameAvailability) (result CheckNameAvailabilityResult, err error)
- func (client NamespacesClient) CheckNameAvailabilityMethodPreparer(parameters CheckNameAvailability) (*http.Request, error)
- func (client NamespacesClient) CheckNameAvailabilityMethodResponder(resp *http.Response) (result CheckNameAvailabilityResult, err error)
- func (client NamespacesClient) CheckNameAvailabilityMethodSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, parameters SBNamespace, ...) (<-chan SBNamespace, <-chan error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (result SBAuthorizationRule, err error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (*http.Request, error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, parameters SBNamespace, ...) (*http.Request, error)
- func (client NamespacesClient) CreateOrUpdateResponder(resp *http.Response) (result SBNamespace, err error)
- func (client NamespacesClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) Delete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)
- func (client NamespacesClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result autorest.Response, err error)
- func (client NamespacesClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
- func (client NamespacesClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
- func (client NamespacesClient) DeleteAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) DeletePreparer(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (*http.Request, error)
- func (client NamespacesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client NamespacesClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) Get(resourceGroupName string, namespaceName string) (result SBNamespace, err error)
- func (client NamespacesClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result SBAuthorizationRule, err error)
- func (client NamespacesClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
- func (client NamespacesClient) GetAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
- func (client NamespacesClient) GetAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) GetPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client NamespacesClient) GetResponder(resp *http.Response) (result SBNamespace, err error)
- func (client NamespacesClient) GetSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) List() (result SBNamespaceListResult, err error)
- func (client NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string) (result SBAuthorizationRuleListResult, err error)
- func (client NamespacesClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan SBAuthorizationRule, <-chan error)
- func (client NamespacesClient) ListAuthorizationRulesNextResults(lastResults SBAuthorizationRuleListResult) (result SBAuthorizationRuleListResult, err error)
- func (client NamespacesClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client NamespacesClient) ListAuthorizationRulesResponder(resp *http.Response) (result SBAuthorizationRuleListResult, err error)
- func (client NamespacesClient) ListAuthorizationRulesSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) ListByResourceGroup(resourceGroupName string) (result SBNamespaceListResult, err error)
- func (client NamespacesClient) ListByResourceGroupComplete(resourceGroupName string, cancel <-chan struct{}) (<-chan SBNamespace, <-chan error)
- func (client NamespacesClient) ListByResourceGroupNextResults(lastResults SBNamespaceListResult) (result SBNamespaceListResult, err error)
- func (client NamespacesClient) ListByResourceGroupPreparer(resourceGroupName string) (*http.Request, error)
- func (client NamespacesClient) ListByResourceGroupResponder(resp *http.Response) (result SBNamespaceListResult, err error)
- func (client NamespacesClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) ListComplete(cancel <-chan struct{}) (<-chan SBNamespace, <-chan error)
- func (client NamespacesClient) ListKeys(resourceGroupName string, namespaceName string, authorizationRuleName string) (result AccessKeys, err error)
- func (client NamespacesClient) ListKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
- func (client NamespacesClient) ListKeysResponder(resp *http.Response) (result AccessKeys, err error)
- func (client NamespacesClient) ListKeysSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) ListNextResults(lastResults SBNamespaceListResult) (result SBNamespaceListResult, err error)
- func (client NamespacesClient) ListPreparer() (*http.Request, error)
- func (client NamespacesClient) ListResponder(resp *http.Response) (result SBNamespaceListResult, err error)
- func (client NamespacesClient) ListSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) RegenerateKeys(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (result AccessKeys, err error)
- func (client NamespacesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (*http.Request, error)
- func (client NamespacesClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, err error)
- func (client NamespacesClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) Update(resourceGroupName string, namespaceName string, ...) (result SBNamespace, err error)
- func (client NamespacesClient) UpdatePreparer(resourceGroupName string, namespaceName string, ...) (*http.Request, error)
- func (client NamespacesClient) UpdateResponder(resp *http.Response) (result SBNamespace, err error)
- func (client NamespacesClient) UpdateSender(req *http.Request) (*http.Response, error)
- type Operation
- type OperationDisplay
- type OperationListResult
- type OperationsClient
- func (client OperationsClient) List() (result OperationListResult, err error)
- func (client OperationsClient) ListComplete(cancel <-chan struct{}) (<-chan Operation, <-chan error)
- func (client OperationsClient) ListNextResults(lastResults OperationListResult) (result OperationListResult, err error)
- func (client OperationsClient) ListPreparer() (*http.Request, error)
- func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)
- func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)
- type PremiumMessagingRegions
- type PremiumMessagingRegionsClient
- func (client PremiumMessagingRegionsClient) List() (result PremiumMessagingRegionsListResult, err error)
- func (client PremiumMessagingRegionsClient) ListComplete(cancel <-chan struct{}) (<-chan PremiumMessagingRegions, <-chan error)
- func (client PremiumMessagingRegionsClient) ListNextResults(lastResults PremiumMessagingRegionsListResult) (result PremiumMessagingRegionsListResult, err error)
- func (client PremiumMessagingRegionsClient) ListPreparer() (*http.Request, error)
- func (client PremiumMessagingRegionsClient) ListResponder(resp *http.Response) (result PremiumMessagingRegionsListResult, err error)
- func (client PremiumMessagingRegionsClient) ListSender(req *http.Request) (*http.Response, error)
- type PremiumMessagingRegionsListResult
- type PremiumMessagingRegionsProperties
- type ProvisioningStateDR
- type QueuesClient
- func (client QueuesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, queueName string, ...) (result SBQueue, err error)
- func (client QueuesClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, queueName string, ...) (result SBAuthorizationRule, err error)
- func (client QueuesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, queueName string, ...) (*http.Request, error)
- func (client QueuesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
- func (client QueuesClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, queueName string, ...) (*http.Request, error)
- func (client QueuesClient) CreateOrUpdateResponder(resp *http.Response) (result SBQueue, err error)
- func (client QueuesClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) Delete(resourceGroupName string, namespaceName string, queueName string) (result autorest.Response, err error)
- func (client QueuesClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, queueName string, ...) (result autorest.Response, err error)
- func (client QueuesClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, queueName string, ...) (*http.Request, error)
- func (client QueuesClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
- func (client QueuesClient) DeleteAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) DeletePreparer(resourceGroupName string, namespaceName string, queueName string) (*http.Request, error)
- func (client QueuesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client QueuesClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) Get(resourceGroupName string, namespaceName string, queueName string) (result SBQueue, err error)
- func (client QueuesClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, queueName string, ...) (result SBAuthorizationRule, err error)
- func (client QueuesClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, queueName string, ...) (*http.Request, error)
- func (client QueuesClient) GetAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
- func (client QueuesClient) GetAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) GetPreparer(resourceGroupName string, namespaceName string, queueName string) (*http.Request, error)
- func (client QueuesClient) GetResponder(resp *http.Response) (result SBQueue, err error)
- func (client QueuesClient) GetSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, queueName string) (result SBAuthorizationRuleListResult, err error)
- func (client QueuesClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, queueName string, ...) (<-chan SBAuthorizationRule, <-chan error)
- func (client QueuesClient) ListAuthorizationRulesNextResults(lastResults SBAuthorizationRuleListResult) (result SBAuthorizationRuleListResult, err error)
- func (client QueuesClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string, queueName string) (*http.Request, error)
- func (client QueuesClient) ListAuthorizationRulesResponder(resp *http.Response) (result SBAuthorizationRuleListResult, err error)
- func (client QueuesClient) ListAuthorizationRulesSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) ListByNamespace(resourceGroupName string, namespaceName string) (result SBQueueListResult, err error)
- func (client QueuesClient) ListByNamespaceComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan SBQueue, <-chan error)
- func (client QueuesClient) ListByNamespaceNextResults(lastResults SBQueueListResult) (result SBQueueListResult, err error)
- func (client QueuesClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client QueuesClient) ListByNamespaceResponder(resp *http.Response) (result SBQueueListResult, err error)
- func (client QueuesClient) ListByNamespaceSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) ListKeys(resourceGroupName string, namespaceName string, queueName string, ...) (result AccessKeys, err error)
- func (client QueuesClient) ListKeysPreparer(resourceGroupName string, namespaceName string, queueName string, ...) (*http.Request, error)
- func (client QueuesClient) ListKeysResponder(resp *http.Response) (result AccessKeys, err error)
- func (client QueuesClient) ListKeysSender(req *http.Request) (*http.Response, error)
- func (client QueuesClient) RegenerateKeys(resourceGroupName string, namespaceName string, queueName string, ...) (result AccessKeys, err error)
- func (client QueuesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, queueName string, ...) (*http.Request, error)
- func (client QueuesClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, err error)
- func (client QueuesClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)
- type RegenerateAccessKeyParameters
- type RegionsClient
- func (client RegionsClient) ListBySku(sku string) (result PremiumMessagingRegionsListResult, err error)
- func (client RegionsClient) ListBySkuComplete(sku string, cancel <-chan struct{}) (<-chan PremiumMessagingRegions, <-chan error)
- func (client RegionsClient) ListBySkuNextResults(lastResults PremiumMessagingRegionsListResult) (result PremiumMessagingRegionsListResult, err error)
- func (client RegionsClient) ListBySkuPreparer(sku string) (*http.Request, error)
- func (client RegionsClient) ListBySkuResponder(resp *http.Response) (result PremiumMessagingRegionsListResult, err error)
- func (client RegionsClient) ListBySkuSender(req *http.Request) (*http.Response, error)
- type Resource
- type ResourceNamespacePatch
- type RoleDisasterRecovery
- type Rule
- type RuleListResult
- type Ruleproperties
- type RulesClient
- func (client RulesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, topicName string, ...) (result Rule, err error)
- func (client RulesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client RulesClient) CreateOrUpdateResponder(resp *http.Response) (result Rule, err error)
- func (client RulesClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client RulesClient) Delete(resourceGroupName string, namespaceName string, topicName string, ...) (result autorest.Response, err error)
- func (client RulesClient) DeletePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client RulesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client RulesClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client RulesClient) Get(resourceGroupName string, namespaceName string, topicName string, ...) (result Rule, err error)
- func (client RulesClient) GetPreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client RulesClient) GetResponder(resp *http.Response) (result Rule, err error)
- func (client RulesClient) GetSender(req *http.Request) (*http.Response, error)
- func (client RulesClient) ListBySubscriptions(resourceGroupName string, namespaceName string, topicName string, ...) (result RuleListResult, err error)
- func (client RulesClient) ListBySubscriptionsComplete(resourceGroupName string, namespaceName string, topicName string, ...) (<-chan Rule, <-chan error)
- func (client RulesClient) ListBySubscriptionsNextResults(lastResults RuleListResult) (result RuleListResult, err error)
- func (client RulesClient) ListBySubscriptionsPreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client RulesClient) ListBySubscriptionsResponder(resp *http.Response) (result RuleListResult, err error)
- func (client RulesClient) ListBySubscriptionsSender(req *http.Request) (*http.Response, error)
- type SBAuthorizationRule
- type SBAuthorizationRuleListResult
- type SBAuthorizationRuleProperties
- type SBNamespace
- type SBNamespaceListResult
- type SBNamespaceProperties
- type SBNamespaceUpdateParameters
- type SBQueue
- type SBQueueListResult
- type SBQueueProperties
- type SBSku
- type SBSubscription
- type SBSubscriptionListResult
- type SBSubscriptionProperties
- type SBTopic
- type SBTopicListResult
- type SBTopicProperties
- type SQLFilter
- type SQLRuleAction
- type SkuName
- type SkuTier
- type SubscriptionsClient
- func (client SubscriptionsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, topicName string, ...) (result SBSubscription, err error)
- func (client SubscriptionsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client SubscriptionsClient) CreateOrUpdateResponder(resp *http.Response) (result SBSubscription, err error)
- func (client SubscriptionsClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client SubscriptionsClient) Delete(resourceGroupName string, namespaceName string, topicName string, ...) (result autorest.Response, err error)
- func (client SubscriptionsClient) DeletePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client SubscriptionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client SubscriptionsClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client SubscriptionsClient) Get(resourceGroupName string, namespaceName string, topicName string, ...) (result SBSubscription, err error)
- func (client SubscriptionsClient) GetPreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client SubscriptionsClient) GetResponder(resp *http.Response) (result SBSubscription, err error)
- func (client SubscriptionsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client SubscriptionsClient) ListByTopic(resourceGroupName string, namespaceName string, topicName string) (result SBSubscriptionListResult, err error)
- func (client SubscriptionsClient) ListByTopicComplete(resourceGroupName string, namespaceName string, topicName string, ...) (<-chan SBSubscription, <-chan error)
- func (client SubscriptionsClient) ListByTopicNextResults(lastResults SBSubscriptionListResult) (result SBSubscriptionListResult, err error)
- func (client SubscriptionsClient) ListByTopicPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
- func (client SubscriptionsClient) ListByTopicResponder(resp *http.Response) (result SBSubscriptionListResult, err error)
- func (client SubscriptionsClient) ListByTopicSender(req *http.Request) (*http.Response, error)
- type TopicsClient
- func (client TopicsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, topicName string, ...) (result SBTopic, err error)
- func (client TopicsClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, topicName string, ...) (result SBAuthorizationRule, err error)
- func (client TopicsClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client TopicsClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
- func (client TopicsClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client TopicsClient) CreateOrUpdateResponder(resp *http.Response) (result SBTopic, err error)
- func (client TopicsClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) Delete(resourceGroupName string, namespaceName string, topicName string) (result autorest.Response, err error)
- func (client TopicsClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, topicName string, ...) (result autorest.Response, err error)
- func (client TopicsClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client TopicsClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
- func (client TopicsClient) DeleteAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) DeletePreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
- func (client TopicsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client TopicsClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) Get(resourceGroupName string, namespaceName string, topicName string) (result SBTopic, err error)
- func (client TopicsClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, topicName string, ...) (result SBAuthorizationRule, err error)
- func (client TopicsClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client TopicsClient) GetAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
- func (client TopicsClient) GetAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) GetPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
- func (client TopicsClient) GetResponder(resp *http.Response) (result SBTopic, err error)
- func (client TopicsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, topicName string) (result SBAuthorizationRuleListResult, err error)
- func (client TopicsClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, topicName string, ...) (<-chan SBAuthorizationRule, <-chan error)
- func (client TopicsClient) ListAuthorizationRulesNextResults(lastResults SBAuthorizationRuleListResult) (result SBAuthorizationRuleListResult, err error)
- func (client TopicsClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
- func (client TopicsClient) ListAuthorizationRulesResponder(resp *http.Response) (result SBAuthorizationRuleListResult, err error)
- func (client TopicsClient) ListAuthorizationRulesSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) ListByNamespace(resourceGroupName string, namespaceName string) (result SBTopicListResult, err error)
- func (client TopicsClient) ListByNamespaceComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan SBTopic, <-chan error)
- func (client TopicsClient) ListByNamespaceNextResults(lastResults SBTopicListResult) (result SBTopicListResult, err error)
- func (client TopicsClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client TopicsClient) ListByNamespaceResponder(resp *http.Response) (result SBTopicListResult, err error)
- func (client TopicsClient) ListByNamespaceSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) ListKeys(resourceGroupName string, namespaceName string, topicName string, ...) (result AccessKeys, err error)
- func (client TopicsClient) ListKeysPreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client TopicsClient) ListKeysResponder(resp *http.Response) (result AccessKeys, err error)
- func (client TopicsClient) ListKeysSender(req *http.Request) (*http.Response, error)
- func (client TopicsClient) RegenerateKeys(resourceGroupName string, namespaceName string, topicName string, ...) (result AccessKeys, err error)
- func (client TopicsClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, topicName string, ...) (*http.Request, error)
- func (client TopicsClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, err error)
- func (client TopicsClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)
- type TrackedResource
- type UnavailableReason
Constants ¶
const (
// DefaultBaseURI is the default URI used for the service Servicebus
DefaultBaseURI = "https://management.azure.com"
)
Variables ¶
This section is empty.
Functions ¶
func UserAgent ¶
func UserAgent() string
UserAgent returns the UserAgent string to use when sending http.Requests.
func Version ¶
func Version() string
Version returns the semantic version (see http://semver.org) of the client.
Types ¶
type AccessKeys ¶
type AccessKeys struct { autorest.Response `json:"-"` PrimaryConnectionString *string `json:"primaryConnectionString,omitempty"` SecondaryConnectionString *string `json:"secondaryConnectionString,omitempty"` AliasPrimaryConnectionString *string `json:"aliasPrimaryConnectionString,omitempty"` AliasSecondaryConnectionString *string `json:"aliasSecondaryConnectionString,omitempty"` PrimaryKey *string `json:"primaryKey,omitempty"` SecondaryKey *string `json:"secondaryKey,omitempty"` KeyName *string `json:"keyName,omitempty"` }
AccessKeys is namespace/ServiceBus Connection String
type AccessRights ¶
type AccessRights string
AccessRights enumerates the values for access rights.
const ( // Listen specifies the listen state for access rights. Listen AccessRights = "Listen" // Manage specifies the manage state for access rights. Manage AccessRights = "Manage" // Send specifies the send state for access rights. Send AccessRights = "Send" )
type Action ¶
type Action struct { SQLExpression *string `json:"sqlExpression,omitempty"` CompatibilityLevel *int32 `json:"compatibilityLevel,omitempty"` RequiresPreprocessing *bool `json:"requiresPreprocessing,omitempty"` }
Action is represents the filter actions which are allowed for the transformation of a message that have been matched by a filter expression.
type ArmDisasterRecovery ¶
type ArmDisasterRecovery struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *ArmDisasterRecoveryProperties `json:"properties,omitempty"` }
ArmDisasterRecovery is single item in List or Get Alias(Disaster Recovery configuration) operation
type ArmDisasterRecoveryListResult ¶
type ArmDisasterRecoveryListResult struct { autorest.Response `json:"-"` Value *[]ArmDisasterRecovery `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
ArmDisasterRecoveryListResult is the result of the List Alias(Disaster Recovery configuration) operation.
func (ArmDisasterRecoveryListResult) ArmDisasterRecoveryListResultPreparer ¶
func (client ArmDisasterRecoveryListResult) ArmDisasterRecoveryListResultPreparer() (*http.Request, error)
ArmDisasterRecoveryListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type ArmDisasterRecoveryProperties ¶
type ArmDisasterRecoveryProperties struct { ProvisioningState ProvisioningStateDR `json:"provisioningState,omitempty"` PartnerNamespace *string `json:"partnerNamespace,omitempty"` Role RoleDisasterRecovery `json:"role,omitempty"` }
ArmDisasterRecoveryProperties is properties required to the Create Or Update Alias(Disaster Recovery configurations)
type AuthorizationRuleProperties ¶
type AuthorizationRuleProperties struct {
Rights *[]AccessRights `json:"rights,omitempty"`
}
AuthorizationRuleProperties is authorizationRule properties.
type CaptureDescription ¶
type CaptureDescription struct { Enabled *bool `json:"enabled,omitempty"` Encoding EncodingCaptureDescription `json:"encoding,omitempty"` IntervalInSeconds *int32 `json:"intervalInSeconds,omitempty"` SizeLimitInBytes *int32 `json:"sizeLimitInBytes,omitempty"` Destination *Destination `json:"destination,omitempty"` }
CaptureDescription is properties to configure capture description for eventhub
type CheckNameAvailability ¶
type CheckNameAvailability struct {
Name *string `json:"name,omitempty"`
}
CheckNameAvailability is description of a Check Name availability request properties.
type CheckNameAvailabilityResult ¶
type CheckNameAvailabilityResult struct { autorest.Response `json:"-"` Message *string `json:"message,omitempty"` NameAvailable *bool `json:"nameAvailable,omitempty"` Reason UnavailableReason `json:"reason,omitempty"` }
CheckNameAvailabilityResult is description of a Check Name availability request properties.
type CorrelationFilter ¶
type CorrelationFilter struct { CorrelationID *string `json:"correlationId,omitempty"` MessageID *string `json:"messageId,omitempty"` To *string `json:"to,omitempty"` ReplyTo *string `json:"replyTo,omitempty"` Label *string `json:"label,omitempty"` SessionID *string `json:"sessionId,omitempty"` ReplyToSessionID *string `json:"replyToSessionId,omitempty"` ContentType *string `json:"contentType,omitempty"` RequiresPreprocessing *bool `json:"requiresPreprocessing,omitempty"` }
CorrelationFilter is represents the correlation filter expression.
type Destination ¶
type Destination struct { Name *string `json:"name,omitempty"` *DestinationProperties `json:"properties,omitempty"` }
Destination is capture storage details for capture description
type DestinationProperties ¶
type DestinationProperties struct { StorageAccountResourceID *string `json:"storageAccountResourceId,omitempty"` BlobContainer *string `json:"blobContainer,omitempty"` ArchiveNameFormat *string `json:"archiveNameFormat,omitempty"` }
DestinationProperties is properties describing the storage account, blob container and acrchive name format for capture destination
type DisasterRecoveryConfigsClient ¶
type DisasterRecoveryConfigsClient struct {
ManagementClient
}
DisasterRecoveryConfigsClient is the azure Service Bus client
func NewDisasterRecoveryConfigsClient ¶
func NewDisasterRecoveryConfigsClient(subscriptionID string) DisasterRecoveryConfigsClient
NewDisasterRecoveryConfigsClient creates an instance of the DisasterRecoveryConfigsClient client.
func NewDisasterRecoveryConfigsClientWithBaseURI ¶
func NewDisasterRecoveryConfigsClientWithBaseURI(baseURI string, subscriptionID string) DisasterRecoveryConfigsClient
NewDisasterRecoveryConfigsClientWithBaseURI creates an instance of the DisasterRecoveryConfigsClient client.
func (DisasterRecoveryConfigsClient) BreakPairing ¶
func (client DisasterRecoveryConfigsClient) BreakPairing(resourceGroupName string, namespaceName string, alias string) (result autorest.Response, err error)
BreakPairing this operation disables the Disaster Recovery and stops replicating changes from primary to secondary namespaces
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name alias is the Disaster Recovery configuration name
func (DisasterRecoveryConfigsClient) BreakPairingPreparer ¶
func (client DisasterRecoveryConfigsClient) BreakPairingPreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
BreakPairingPreparer prepares the BreakPairing request.
func (DisasterRecoveryConfigsClient) BreakPairingResponder ¶
func (client DisasterRecoveryConfigsClient) BreakPairingResponder(resp *http.Response) (result autorest.Response, err error)
BreakPairingResponder handles the response to the BreakPairing request. The method always closes the http.Response Body.
func (DisasterRecoveryConfigsClient) BreakPairingSender ¶
func (client DisasterRecoveryConfigsClient) BreakPairingSender(req *http.Request) (*http.Response, error)
BreakPairingSender sends the BreakPairing request. The method will close the http.Response Body if it receives an error.
func (DisasterRecoveryConfigsClient) CreateOrUpdate ¶
func (client DisasterRecoveryConfigsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, alias string, parameters ArmDisasterRecovery) (result ArmDisasterRecovery, err error)
CreateOrUpdate creates or updates a new Alias(Disaster Recovery configuration)
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name alias is the Disaster Recovery configuration name parameters is parameters required to create an Alias(Disaster Recovery configuration)
func (DisasterRecoveryConfigsClient) CreateOrUpdatePreparer ¶
func (client DisasterRecoveryConfigsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, alias string, parameters ArmDisasterRecovery) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (DisasterRecoveryConfigsClient) CreateOrUpdateResponder ¶
func (client DisasterRecoveryConfigsClient) CreateOrUpdateResponder(resp *http.Response) (result ArmDisasterRecovery, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (DisasterRecoveryConfigsClient) CreateOrUpdateSender ¶
func (client DisasterRecoveryConfigsClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (DisasterRecoveryConfigsClient) Delete ¶
func (client DisasterRecoveryConfigsClient) Delete(resourceGroupName string, namespaceName string, alias string) (result autorest.Response, err error)
Delete deletes an Alias(Disaster Recovery configuration)
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name alias is the Disaster Recovery configuration name
func (DisasterRecoveryConfigsClient) DeletePreparer ¶
func (client DisasterRecoveryConfigsClient) DeletePreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (DisasterRecoveryConfigsClient) DeleteResponder ¶
func (client DisasterRecoveryConfigsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (DisasterRecoveryConfigsClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (DisasterRecoveryConfigsClient) FailOver ¶
func (client DisasterRecoveryConfigsClient) FailOver(resourceGroupName string, namespaceName string, alias string) (result autorest.Response, err error)
FailOver envokes GEO DR failover and reconfigure the alias to point to the secondary namespace
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name alias is the Disaster Recovery configuration name
func (DisasterRecoveryConfigsClient) FailOverPreparer ¶
func (client DisasterRecoveryConfigsClient) FailOverPreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
FailOverPreparer prepares the FailOver request.
func (DisasterRecoveryConfigsClient) FailOverResponder ¶
func (client DisasterRecoveryConfigsClient) FailOverResponder(resp *http.Response) (result autorest.Response, err error)
FailOverResponder handles the response to the FailOver request. The method always closes the http.Response Body.
func (DisasterRecoveryConfigsClient) FailOverSender ¶
func (client DisasterRecoveryConfigsClient) FailOverSender(req *http.Request) (*http.Response, error)
FailOverSender sends the FailOver request. The method will close the http.Response Body if it receives an error.
func (DisasterRecoveryConfigsClient) Get ¶
func (client DisasterRecoveryConfigsClient) Get(resourceGroupName string, namespaceName string, alias string) (result ArmDisasterRecovery, err error)
Get retrieves Alias(Disaster Recovery configuration) for primary or secondary namespace
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name alias is the Disaster Recovery configuration name
func (DisasterRecoveryConfigsClient) GetPreparer ¶
func (client DisasterRecoveryConfigsClient) GetPreparer(resourceGroupName string, namespaceName string, alias string) (*http.Request, error)
GetPreparer prepares the Get request.
func (DisasterRecoveryConfigsClient) GetResponder ¶
func (client DisasterRecoveryConfigsClient) GetResponder(resp *http.Response) (result ArmDisasterRecovery, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (DisasterRecoveryConfigsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (DisasterRecoveryConfigsClient) List ¶
func (client DisasterRecoveryConfigsClient) List(resourceGroupName string, namespaceName string) (result ArmDisasterRecoveryListResult, err error)
List gets all Alias(Disaster Recovery configurations)
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (DisasterRecoveryConfigsClient) ListComplete ¶
func (client DisasterRecoveryConfigsClient) ListComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan ArmDisasterRecovery, <-chan error)
ListComplete gets all elements from the list without paging.
func (DisasterRecoveryConfigsClient) ListNextResults ¶
func (client DisasterRecoveryConfigsClient) ListNextResults(lastResults ArmDisasterRecoveryListResult) (result ArmDisasterRecoveryListResult, err error)
ListNextResults retrieves the next set of results, if any.
func (DisasterRecoveryConfigsClient) ListPreparer ¶
func (client DisasterRecoveryConfigsClient) ListPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
ListPreparer prepares the List request.
func (DisasterRecoveryConfigsClient) ListResponder ¶
func (client DisasterRecoveryConfigsClient) ListResponder(resp *http.Response) (result ArmDisasterRecoveryListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (DisasterRecoveryConfigsClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type EncodingCaptureDescription ¶
type EncodingCaptureDescription string
EncodingCaptureDescription enumerates the values for encoding capture description.
const ( // Avro specifies the avro state for encoding capture description. Avro EncodingCaptureDescription = "Avro" // AvroDeflate specifies the avro deflate state for encoding capture description. AvroDeflate EncodingCaptureDescription = "AvroDeflate" )
type EntityStatus ¶
type EntityStatus string
EntityStatus enumerates the values for entity status.
const ( // Active specifies the active state for entity status. Active EntityStatus = "Active" // Creating specifies the creating state for entity status. Creating EntityStatus = "Creating" // Deleting specifies the deleting state for entity status. Deleting EntityStatus = "Deleting" // Disabled specifies the disabled state for entity status. Disabled EntityStatus = "Disabled" // ReceiveDisabled specifies the receive disabled state for entity status. ReceiveDisabled EntityStatus = "ReceiveDisabled" // Renaming specifies the renaming state for entity status. Renaming EntityStatus = "Renaming" // Restoring specifies the restoring state for entity status. Restoring EntityStatus = "Restoring" // SendDisabled specifies the send disabled state for entity status. SendDisabled EntityStatus = "SendDisabled" // Unknown specifies the unknown state for entity status. Unknown EntityStatus = "Unknown" )
type ErrorResponse ¶
type ErrorResponse struct { Code *string `json:"code,omitempty"` Message *string `json:"message,omitempty"` }
ErrorResponse is error reponse indicates ServiceBus service is not able to process the incoming request. The reason is provided in the error message.
type EventHubListResult ¶
type EventHubListResult struct { autorest.Response `json:"-"` Value *[]Eventhub `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
EventHubListResult is the result of the List EventHubs operation.
func (EventHubListResult) EventHubListResultPreparer ¶
func (client EventHubListResult) EventHubListResultPreparer() (*http.Request, error)
EventHubListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type EventHubsClient ¶
type EventHubsClient struct {
ManagementClient
}
EventHubsClient is the azure Service Bus client
func NewEventHubsClient ¶
func NewEventHubsClient(subscriptionID string) EventHubsClient
NewEventHubsClient creates an instance of the EventHubsClient client.
func NewEventHubsClientWithBaseURI ¶
func NewEventHubsClientWithBaseURI(baseURI string, subscriptionID string) EventHubsClient
NewEventHubsClientWithBaseURI creates an instance of the EventHubsClient client.
func (EventHubsClient) ListByNamespace ¶
func (client EventHubsClient) ListByNamespace(resourceGroupName string, namespaceName string) (result EventHubListResult, err error)
ListByNamespace gets all the Event Hubs in a service bus Namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (EventHubsClient) ListByNamespaceComplete ¶
func (client EventHubsClient) ListByNamespaceComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan Eventhub, <-chan error)
ListByNamespaceComplete gets all elements from the list without paging.
func (EventHubsClient) ListByNamespaceNextResults ¶
func (client EventHubsClient) ListByNamespaceNextResults(lastResults EventHubListResult) (result EventHubListResult, err error)
ListByNamespaceNextResults retrieves the next set of results, if any.
func (EventHubsClient) ListByNamespacePreparer ¶
func (client EventHubsClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
ListByNamespacePreparer prepares the ListByNamespace request.
func (EventHubsClient) ListByNamespaceResponder ¶
func (client EventHubsClient) ListByNamespaceResponder(resp *http.Response) (result EventHubListResult, err error)
ListByNamespaceResponder handles the response to the ListByNamespace request. The method always closes the http.Response Body.
func (EventHubsClient) ListByNamespaceSender ¶
ListByNamespaceSender sends the ListByNamespace request. The method will close the http.Response Body if it receives an error.
type Eventhub ¶
type Eventhub struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *EventhubProperties `json:"properties,omitempty"` }
Eventhub is single item in List or Get Event Hub operation
type EventhubProperties ¶
type EventhubProperties struct { PartitionIds *[]string `json:"partitionIds,omitempty"` CreatedAt *date.Time `json:"createdAt,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` MessageRetentionInDays *int64 `json:"messageRetentionInDays,omitempty"` PartitionCount *int64 `json:"partitionCount,omitempty"` Status EntityStatus `json:"status,omitempty"` CaptureDescription *CaptureDescription `json:"captureDescription,omitempty"` }
EventhubProperties is properties supplied to the Create Or Update Event Hub operation.
type FilterType ¶
type FilterType string
FilterType enumerates the values for filter type.
const ( // FilterTypeCorrelationFilter specifies the filter type correlation filter state for filter type. FilterTypeCorrelationFilter FilterType = "CorrelationFilter" // FilterTypeSQLFilter specifies the filter type sql filter state for filter type. FilterTypeSQLFilter FilterType = "SqlFilter" )
type ManagementClient ¶
ManagementClient is the base client for Servicebus.
func New ¶
func New(subscriptionID string) ManagementClient
New creates an instance of the ManagementClient client.
func NewWithBaseURI ¶
func NewWithBaseURI(baseURI string, subscriptionID string) ManagementClient
NewWithBaseURI creates an instance of the ManagementClient client.
type MessageCountDetails ¶
type MessageCountDetails struct { ActiveMessageCount *int64 `json:"activeMessageCount,omitempty"` DeadLetterMessageCount *int64 `json:"deadLetterMessageCount,omitempty"` ScheduledMessageCount *int64 `json:"scheduledMessageCount,omitempty"` TransferMessageCount *int64 `json:"transferMessageCount,omitempty"` TransferDeadLetterMessageCount *int64 `json:"transferDeadLetterMessageCount,omitempty"` }
MessageCountDetails is message Count Details.
type NamespacesClient ¶
type NamespacesClient struct {
ManagementClient
}
NamespacesClient is the azure Service Bus client
func NewNamespacesClient ¶
func NewNamespacesClient(subscriptionID string) NamespacesClient
NewNamespacesClient creates an instance of the NamespacesClient client.
func NewNamespacesClientWithBaseURI ¶
func NewNamespacesClientWithBaseURI(baseURI string, subscriptionID string) NamespacesClient
NewNamespacesClientWithBaseURI creates an instance of the NamespacesClient client.
func (NamespacesClient) CheckNameAvailabilityMethod ¶
func (client NamespacesClient) CheckNameAvailabilityMethod(parameters CheckNameAvailability) (result CheckNameAvailabilityResult, err error)
CheckNameAvailabilityMethod check the give namespace name availability.
parameters is parameters to check availability of the given namespace name
func (NamespacesClient) CheckNameAvailabilityMethodPreparer ¶
func (client NamespacesClient) CheckNameAvailabilityMethodPreparer(parameters CheckNameAvailability) (*http.Request, error)
CheckNameAvailabilityMethodPreparer prepares the CheckNameAvailabilityMethod request.
func (NamespacesClient) CheckNameAvailabilityMethodResponder ¶
func (client NamespacesClient) CheckNameAvailabilityMethodResponder(resp *http.Response) (result CheckNameAvailabilityResult, err error)
CheckNameAvailabilityMethodResponder handles the response to the CheckNameAvailabilityMethod request. The method always closes the http.Response Body.
func (NamespacesClient) CheckNameAvailabilityMethodSender ¶
func (client NamespacesClient) CheckNameAvailabilityMethodSender(req *http.Request) (*http.Response, error)
CheckNameAvailabilityMethodSender sends the CheckNameAvailabilityMethod request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) CreateOrUpdate ¶
func (client NamespacesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, parameters SBNamespace, cancel <-chan struct{}) (<-chan SBNamespace, <-chan error)
CreateOrUpdate creates or updates a service namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name. parameters is parameters supplied to create a namespace resource.
func (NamespacesClient) CreateOrUpdateAuthorizationRule ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters SBAuthorizationRule) (result SBAuthorizationRule, err error)
CreateOrUpdateAuthorizationRule creates or updates an authorization rule for a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name. parameters is the shared access authorization rule.
func (NamespacesClient) CreateOrUpdateAuthorizationRulePreparer ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters SBAuthorizationRule) (*http.Request, error)
CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.
func (NamespacesClient) CreateOrUpdateAuthorizationRuleResponder ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
CreateOrUpdateAuthorizationRuleResponder handles the response to the CreateOrUpdateAuthorizationRule request. The method always closes the http.Response Body.
func (NamespacesClient) CreateOrUpdateAuthorizationRuleSender ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
CreateOrUpdateAuthorizationRuleSender sends the CreateOrUpdateAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) CreateOrUpdatePreparer ¶
func (client NamespacesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, parameters SBNamespace, cancel <-chan struct{}) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (NamespacesClient) CreateOrUpdateResponder ¶
func (client NamespacesClient) CreateOrUpdateResponder(resp *http.Response) (result SBNamespace, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (NamespacesClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) Delete ¶
func (client NamespacesClient) Delete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)
Delete deletes an existing namespace. This operation also removes all associated resources under the namespace. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (NamespacesClient) DeleteAuthorizationRule ¶
func (client NamespacesClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result autorest.Response, err error)
DeleteAuthorizationRule deletes a namespace authorization rule.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name.
func (NamespacesClient) DeleteAuthorizationRulePreparer ¶
func (client NamespacesClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
DeleteAuthorizationRulePreparer prepares the DeleteAuthorizationRule request.
func (NamespacesClient) DeleteAuthorizationRuleResponder ¶
func (client NamespacesClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
DeleteAuthorizationRuleResponder handles the response to the DeleteAuthorizationRule request. The method always closes the http.Response Body.
func (NamespacesClient) DeleteAuthorizationRuleSender ¶
func (client NamespacesClient) DeleteAuthorizationRuleSender(req *http.Request) (*http.Response, error)
DeleteAuthorizationRuleSender sends the DeleteAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) DeletePreparer ¶
func (client NamespacesClient) DeletePreparer(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (NamespacesClient) DeleteResponder ¶
func (client NamespacesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (NamespacesClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) Get ¶
func (client NamespacesClient) Get(resourceGroupName string, namespaceName string) (result SBNamespace, err error)
Get gets a description for the specified namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (NamespacesClient) GetAuthorizationRule ¶
func (client NamespacesClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result SBAuthorizationRule, err error)
GetAuthorizationRule gets an authorization rule for a namespace by rule name.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name.
func (NamespacesClient) GetAuthorizationRulePreparer ¶
func (client NamespacesClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.
func (NamespacesClient) GetAuthorizationRuleResponder ¶
func (client NamespacesClient) GetAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
GetAuthorizationRuleResponder handles the response to the GetAuthorizationRule request. The method always closes the http.Response Body.
func (NamespacesClient) GetAuthorizationRuleSender ¶
func (client NamespacesClient) GetAuthorizationRuleSender(req *http.Request) (*http.Response, error)
GetAuthorizationRuleSender sends the GetAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) GetPreparer ¶
func (client NamespacesClient) GetPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (NamespacesClient) GetResponder ¶
func (client NamespacesClient) GetResponder(resp *http.Response) (result SBNamespace, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (NamespacesClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) List ¶
func (client NamespacesClient) List() (result SBNamespaceListResult, err error)
List gets all the available namespaces within the subscription, irrespective of the resource groups.
func (NamespacesClient) ListAuthorizationRules ¶
func (client NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRules gets the authorization rules for a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (NamespacesClient) ListAuthorizationRulesComplete ¶
func (client NamespacesClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan SBAuthorizationRule, <-chan error)
ListAuthorizationRulesComplete gets all elements from the list without paging.
func (NamespacesClient) ListAuthorizationRulesNextResults ¶
func (client NamespacesClient) ListAuthorizationRulesNextResults(lastResults SBAuthorizationRuleListResult) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRulesNextResults retrieves the next set of results, if any.
func (NamespacesClient) ListAuthorizationRulesPreparer ¶
func (client NamespacesClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.
func (NamespacesClient) ListAuthorizationRulesResponder ¶
func (client NamespacesClient) ListAuthorizationRulesResponder(resp *http.Response) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRulesResponder handles the response to the ListAuthorizationRules request. The method always closes the http.Response Body.
func (NamespacesClient) ListAuthorizationRulesSender ¶
func (client NamespacesClient) ListAuthorizationRulesSender(req *http.Request) (*http.Response, error)
ListAuthorizationRulesSender sends the ListAuthorizationRules request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) ListByResourceGroup ¶
func (client NamespacesClient) ListByResourceGroup(resourceGroupName string) (result SBNamespaceListResult, err error)
ListByResourceGroup gets the available namespaces within a resource group.
resourceGroupName is name of the Resource group within the Azure subscription.
func (NamespacesClient) ListByResourceGroupComplete ¶
func (client NamespacesClient) ListByResourceGroupComplete(resourceGroupName string, cancel <-chan struct{}) (<-chan SBNamespace, <-chan error)
ListByResourceGroupComplete gets all elements from the list without paging.
func (NamespacesClient) ListByResourceGroupNextResults ¶
func (client NamespacesClient) ListByResourceGroupNextResults(lastResults SBNamespaceListResult) (result SBNamespaceListResult, err error)
ListByResourceGroupNextResults retrieves the next set of results, if any.
func (NamespacesClient) ListByResourceGroupPreparer ¶
func (client NamespacesClient) ListByResourceGroupPreparer(resourceGroupName string) (*http.Request, error)
ListByResourceGroupPreparer prepares the ListByResourceGroup request.
func (NamespacesClient) ListByResourceGroupResponder ¶
func (client NamespacesClient) ListByResourceGroupResponder(resp *http.Response) (result SBNamespaceListResult, err error)
ListByResourceGroupResponder handles the response to the ListByResourceGroup request. The method always closes the http.Response Body.
func (NamespacesClient) ListByResourceGroupSender ¶
ListByResourceGroupSender sends the ListByResourceGroup request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) ListComplete ¶
func (client NamespacesClient) ListComplete(cancel <-chan struct{}) (<-chan SBNamespace, <-chan error)
ListComplete gets all elements from the list without paging.
func (NamespacesClient) ListKeys ¶
func (client NamespacesClient) ListKeys(resourceGroupName string, namespaceName string, authorizationRuleName string) (result AccessKeys, err error)
ListKeys gets the primary and secondary connection strings for the namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name.
func (NamespacesClient) ListKeysPreparer ¶
func (client NamespacesClient) ListKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
ListKeysPreparer prepares the ListKeys request.
func (NamespacesClient) ListKeysResponder ¶
func (client NamespacesClient) ListKeysResponder(resp *http.Response) (result AccessKeys, err error)
ListKeysResponder handles the response to the ListKeys request. The method always closes the http.Response Body.
func (NamespacesClient) ListKeysSender ¶
ListKeysSender sends the ListKeys request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) ListNextResults ¶
func (client NamespacesClient) ListNextResults(lastResults SBNamespaceListResult) (result SBNamespaceListResult, err error)
ListNextResults retrieves the next set of results, if any.
func (NamespacesClient) ListPreparer ¶
func (client NamespacesClient) ListPreparer() (*http.Request, error)
ListPreparer prepares the List request.
func (NamespacesClient) ListResponder ¶
func (client NamespacesClient) ListResponder(resp *http.Response) (result SBNamespaceListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (NamespacesClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) RegenerateKeys ¶
func (client NamespacesClient) RegenerateKeys(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters) (result AccessKeys, err error)
RegenerateKeys regenerates the primary or secondary connection strings for the namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name. parameters is parameters supplied to regenerate the authorization rule.
func (NamespacesClient) RegenerateKeysPreparer ¶
func (client NamespacesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters) (*http.Request, error)
RegenerateKeysPreparer prepares the RegenerateKeys request.
func (NamespacesClient) RegenerateKeysResponder ¶
func (client NamespacesClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, err error)
RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.
func (NamespacesClient) RegenerateKeysSender ¶
RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) Update ¶
func (client NamespacesClient) Update(resourceGroupName string, namespaceName string, parameters SBNamespaceUpdateParameters) (result SBNamespace, err error)
Update updates a service namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name parameters is parameters supplied to update a namespace resource.
func (NamespacesClient) UpdatePreparer ¶
func (client NamespacesClient) UpdatePreparer(resourceGroupName string, namespaceName string, parameters SBNamespaceUpdateParameters) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (NamespacesClient) UpdateResponder ¶
func (client NamespacesClient) UpdateResponder(resp *http.Response) (result SBNamespace, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (NamespacesClient) UpdateSender ¶
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type Operation ¶
type Operation struct { Name *string `json:"name,omitempty"` Display *OperationDisplay `json:"display,omitempty"` }
Operation is a ServiceBus REST API operation
type OperationDisplay ¶
type OperationDisplay struct { Provider *string `json:"provider,omitempty"` Resource *string `json:"resource,omitempty"` Operation *string `json:"operation,omitempty"` }
OperationDisplay is the object that represents the operation.
type OperationListResult ¶
type OperationListResult struct { autorest.Response `json:"-"` Value *[]Operation `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
OperationListResult is result of the request to list ServiceBus operations. It contains a list of operations and a URL link to get the next set of results.
func (OperationListResult) OperationListResultPreparer ¶
func (client OperationListResult) OperationListResultPreparer() (*http.Request, error)
OperationListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type OperationsClient ¶
type OperationsClient struct {
ManagementClient
}
OperationsClient is the azure Service Bus client
func NewOperationsClient ¶
func NewOperationsClient(subscriptionID string) OperationsClient
NewOperationsClient creates an instance of the OperationsClient client.
func NewOperationsClientWithBaseURI ¶
func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient
NewOperationsClientWithBaseURI creates an instance of the OperationsClient client.
func (OperationsClient) List ¶
func (client OperationsClient) List() (result OperationListResult, err error)
List lists all of the available ServiceBus REST API operations.
func (OperationsClient) ListComplete ¶
func (client OperationsClient) ListComplete(cancel <-chan struct{}) (<-chan Operation, <-chan error)
ListComplete gets all elements from the list without paging.
func (OperationsClient) ListNextResults ¶
func (client OperationsClient) ListNextResults(lastResults OperationListResult) (result OperationListResult, err error)
ListNextResults retrieves the next set of results, if any.
func (OperationsClient) ListPreparer ¶
func (client OperationsClient) ListPreparer() (*http.Request, error)
ListPreparer prepares the List request.
func (OperationsClient) ListResponder ¶
func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (OperationsClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type PremiumMessagingRegions ¶
type PremiumMessagingRegions struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` Location *string `json:"location,omitempty"` Tags *map[string]*string `json:"tags,omitempty"` Properties *PremiumMessagingRegionsProperties `json:"properties,omitempty"` }
PremiumMessagingRegions is premium Messaging Region
type PremiumMessagingRegionsClient ¶
type PremiumMessagingRegionsClient struct {
ManagementClient
}
PremiumMessagingRegionsClient is the azure Service Bus client
func NewPremiumMessagingRegionsClient ¶
func NewPremiumMessagingRegionsClient(subscriptionID string) PremiumMessagingRegionsClient
NewPremiumMessagingRegionsClient creates an instance of the PremiumMessagingRegionsClient client.
func NewPremiumMessagingRegionsClientWithBaseURI ¶
func NewPremiumMessagingRegionsClientWithBaseURI(baseURI string, subscriptionID string) PremiumMessagingRegionsClient
NewPremiumMessagingRegionsClientWithBaseURI creates an instance of the PremiumMessagingRegionsClient client.
func (PremiumMessagingRegionsClient) List ¶
func (client PremiumMessagingRegionsClient) List() (result PremiumMessagingRegionsListResult, err error)
List gets the available premium messaging regions for servicebus
func (PremiumMessagingRegionsClient) ListComplete ¶
func (client PremiumMessagingRegionsClient) ListComplete(cancel <-chan struct{}) (<-chan PremiumMessagingRegions, <-chan error)
ListComplete gets all elements from the list without paging.
func (PremiumMessagingRegionsClient) ListNextResults ¶
func (client PremiumMessagingRegionsClient) ListNextResults(lastResults PremiumMessagingRegionsListResult) (result PremiumMessagingRegionsListResult, err error)
ListNextResults retrieves the next set of results, if any.
func (PremiumMessagingRegionsClient) ListPreparer ¶
func (client PremiumMessagingRegionsClient) ListPreparer() (*http.Request, error)
ListPreparer prepares the List request.
func (PremiumMessagingRegionsClient) ListResponder ¶
func (client PremiumMessagingRegionsClient) ListResponder(resp *http.Response) (result PremiumMessagingRegionsListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (PremiumMessagingRegionsClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type PremiumMessagingRegionsListResult ¶
type PremiumMessagingRegionsListResult struct { autorest.Response `json:"-"` Value *[]PremiumMessagingRegions `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
PremiumMessagingRegionsListResult is the response of the List PremiumMessagingRegions operation.
func (PremiumMessagingRegionsListResult) PremiumMessagingRegionsListResultPreparer ¶
func (client PremiumMessagingRegionsListResult) PremiumMessagingRegionsListResultPreparer() (*http.Request, error)
PremiumMessagingRegionsListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type PremiumMessagingRegionsProperties ¶
type PremiumMessagingRegionsProperties struct { Code *string `json:"code,omitempty"` FullName *string `json:"fullName,omitempty"` }
PremiumMessagingRegionsProperties is
type ProvisioningStateDR ¶
type ProvisioningStateDR string
ProvisioningStateDR enumerates the values for provisioning state dr.
const ( // Accepted specifies the accepted state for provisioning state dr. Accepted ProvisioningStateDR = "Accepted" // Failed specifies the failed state for provisioning state dr. Failed ProvisioningStateDR = "Failed" // Succeeded specifies the succeeded state for provisioning state dr. Succeeded ProvisioningStateDR = "Succeeded" )
type QueuesClient ¶
type QueuesClient struct {
ManagementClient
}
QueuesClient is the azure Service Bus client
func NewQueuesClient ¶
func NewQueuesClient(subscriptionID string) QueuesClient
NewQueuesClient creates an instance of the QueuesClient client.
func NewQueuesClientWithBaseURI ¶
func NewQueuesClientWithBaseURI(baseURI string, subscriptionID string) QueuesClient
NewQueuesClientWithBaseURI creates an instance of the QueuesClient client.
func (QueuesClient) CreateOrUpdate ¶
func (client QueuesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, queueName string, parameters SBQueue) (result SBQueue, err error)
CreateOrUpdate creates or updates a Service Bus queue. This operation is idempotent.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name. parameters is parameters supplied to create or update a queue resource.
func (QueuesClient) CreateOrUpdateAuthorizationRule ¶
func (client QueuesClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters SBAuthorizationRule) (result SBAuthorizationRule, err error)
CreateOrUpdateAuthorizationRule creates an authorization rule for a queue.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name. authorizationRuleName is the authorizationrule name. parameters is the shared access authorization rule.
func (QueuesClient) CreateOrUpdateAuthorizationRulePreparer ¶
func (client QueuesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters SBAuthorizationRule) (*http.Request, error)
CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.
func (QueuesClient) CreateOrUpdateAuthorizationRuleResponder ¶
func (client QueuesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
CreateOrUpdateAuthorizationRuleResponder handles the response to the CreateOrUpdateAuthorizationRule request. The method always closes the http.Response Body.
func (QueuesClient) CreateOrUpdateAuthorizationRuleSender ¶
func (client QueuesClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
CreateOrUpdateAuthorizationRuleSender sends the CreateOrUpdateAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) CreateOrUpdatePreparer ¶
func (client QueuesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, queueName string, parameters SBQueue) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (QueuesClient) CreateOrUpdateResponder ¶
func (client QueuesClient) CreateOrUpdateResponder(resp *http.Response) (result SBQueue, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (QueuesClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) Delete ¶
func (client QueuesClient) Delete(resourceGroupName string, namespaceName string, queueName string) (result autorest.Response, err error)
Delete deletes a queue from the specified namespace in a resource group.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name.
func (QueuesClient) DeleteAuthorizationRule ¶
func (client QueuesClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result autorest.Response, err error)
DeleteAuthorizationRule deletes a queue authorization rule.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name. authorizationRuleName is the authorizationrule name.
func (QueuesClient) DeleteAuthorizationRulePreparer ¶
func (client QueuesClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (*http.Request, error)
DeleteAuthorizationRulePreparer prepares the DeleteAuthorizationRule request.
func (QueuesClient) DeleteAuthorizationRuleResponder ¶
func (client QueuesClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
DeleteAuthorizationRuleResponder handles the response to the DeleteAuthorizationRule request. The method always closes the http.Response Body.
func (QueuesClient) DeleteAuthorizationRuleSender ¶
DeleteAuthorizationRuleSender sends the DeleteAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) DeletePreparer ¶
func (client QueuesClient) DeletePreparer(resourceGroupName string, namespaceName string, queueName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (QueuesClient) DeleteResponder ¶
func (client QueuesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (QueuesClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) Get ¶
func (client QueuesClient) Get(resourceGroupName string, namespaceName string, queueName string) (result SBQueue, err error)
Get returns a description for the specified queue.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name.
func (QueuesClient) GetAuthorizationRule ¶
func (client QueuesClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result SBAuthorizationRule, err error)
GetAuthorizationRule gets an authorization rule for a queue by rule name.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name. authorizationRuleName is the authorizationrule name.
func (QueuesClient) GetAuthorizationRulePreparer ¶
func (client QueuesClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (*http.Request, error)
GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.
func (QueuesClient) GetAuthorizationRuleResponder ¶
func (client QueuesClient) GetAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
GetAuthorizationRuleResponder handles the response to the GetAuthorizationRule request. The method always closes the http.Response Body.
func (QueuesClient) GetAuthorizationRuleSender ¶
GetAuthorizationRuleSender sends the GetAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) GetPreparer ¶
func (client QueuesClient) GetPreparer(resourceGroupName string, namespaceName string, queueName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (QueuesClient) GetResponder ¶
func (client QueuesClient) GetResponder(resp *http.Response) (result SBQueue, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (QueuesClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) ListAuthorizationRules ¶
func (client QueuesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, queueName string) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRules gets all authorization rules for a queue.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name.
func (QueuesClient) ListAuthorizationRulesComplete ¶
func (client QueuesClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, queueName string, cancel <-chan struct{}) (<-chan SBAuthorizationRule, <-chan error)
ListAuthorizationRulesComplete gets all elements from the list without paging.
func (QueuesClient) ListAuthorizationRulesNextResults ¶
func (client QueuesClient) ListAuthorizationRulesNextResults(lastResults SBAuthorizationRuleListResult) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRulesNextResults retrieves the next set of results, if any.
func (QueuesClient) ListAuthorizationRulesPreparer ¶
func (client QueuesClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string, queueName string) (*http.Request, error)
ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.
func (QueuesClient) ListAuthorizationRulesResponder ¶
func (client QueuesClient) ListAuthorizationRulesResponder(resp *http.Response) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRulesResponder handles the response to the ListAuthorizationRules request. The method always closes the http.Response Body.
func (QueuesClient) ListAuthorizationRulesSender ¶
ListAuthorizationRulesSender sends the ListAuthorizationRules request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) ListByNamespace ¶
func (client QueuesClient) ListByNamespace(resourceGroupName string, namespaceName string) (result SBQueueListResult, err error)
ListByNamespace gets the queues within a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (QueuesClient) ListByNamespaceComplete ¶
func (client QueuesClient) ListByNamespaceComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan SBQueue, <-chan error)
ListByNamespaceComplete gets all elements from the list without paging.
func (QueuesClient) ListByNamespaceNextResults ¶
func (client QueuesClient) ListByNamespaceNextResults(lastResults SBQueueListResult) (result SBQueueListResult, err error)
ListByNamespaceNextResults retrieves the next set of results, if any.
func (QueuesClient) ListByNamespacePreparer ¶
func (client QueuesClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
ListByNamespacePreparer prepares the ListByNamespace request.
func (QueuesClient) ListByNamespaceResponder ¶
func (client QueuesClient) ListByNamespaceResponder(resp *http.Response) (result SBQueueListResult, err error)
ListByNamespaceResponder handles the response to the ListByNamespace request. The method always closes the http.Response Body.
func (QueuesClient) ListByNamespaceSender ¶
ListByNamespaceSender sends the ListByNamespace request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) ListKeys ¶
func (client QueuesClient) ListKeys(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result AccessKeys, err error)
ListKeys primary and secondary connection strings to the queue.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name. authorizationRuleName is the authorizationrule name.
func (QueuesClient) ListKeysPreparer ¶
func (client QueuesClient) ListKeysPreparer(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (*http.Request, error)
ListKeysPreparer prepares the ListKeys request.
func (QueuesClient) ListKeysResponder ¶
func (client QueuesClient) ListKeysResponder(resp *http.Response) (result AccessKeys, err error)
ListKeysResponder handles the response to the ListKeys request. The method always closes the http.Response Body.
func (QueuesClient) ListKeysSender ¶
ListKeysSender sends the ListKeys request. The method will close the http.Response Body if it receives an error.
func (QueuesClient) RegenerateKeys ¶
func (client QueuesClient) RegenerateKeys(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters) (result AccessKeys, err error)
RegenerateKeys regenerates the primary or secondary connection strings to the queue.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name queueName is the queue name. authorizationRuleName is the authorizationrule name. parameters is parameters supplied to regenerate the authorization rule.
func (QueuesClient) RegenerateKeysPreparer ¶
func (client QueuesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters) (*http.Request, error)
RegenerateKeysPreparer prepares the RegenerateKeys request.
func (QueuesClient) RegenerateKeysResponder ¶
func (client QueuesClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, err error)
RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.
func (QueuesClient) RegenerateKeysSender ¶
RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.
type RegenerateAccessKeyParameters ¶
type RegenerateAccessKeyParameters struct { KeyType KeyType `json:"keyType,omitempty"` Key *string `json:"key,omitempty"` }
RegenerateAccessKeyParameters is parameters supplied to the Regenerate Authorization Rule operation, specifies which key neeeds to be reset.
type RegionsClient ¶
type RegionsClient struct {
ManagementClient
}
RegionsClient is the azure Service Bus client
func NewRegionsClient ¶
func NewRegionsClient(subscriptionID string) RegionsClient
NewRegionsClient creates an instance of the RegionsClient client.
func NewRegionsClientWithBaseURI ¶
func NewRegionsClientWithBaseURI(baseURI string, subscriptionID string) RegionsClient
NewRegionsClientWithBaseURI creates an instance of the RegionsClient client.
func (RegionsClient) ListBySku ¶
func (client RegionsClient) ListBySku(sku string) (result PremiumMessagingRegionsListResult, err error)
ListBySku gets the available Regions for a given sku
sku is the sku type.
func (RegionsClient) ListBySkuComplete ¶
func (client RegionsClient) ListBySkuComplete(sku string, cancel <-chan struct{}) (<-chan PremiumMessagingRegions, <-chan error)
ListBySkuComplete gets all elements from the list without paging.
func (RegionsClient) ListBySkuNextResults ¶
func (client RegionsClient) ListBySkuNextResults(lastResults PremiumMessagingRegionsListResult) (result PremiumMessagingRegionsListResult, err error)
ListBySkuNextResults retrieves the next set of results, if any.
func (RegionsClient) ListBySkuPreparer ¶
func (client RegionsClient) ListBySkuPreparer(sku string) (*http.Request, error)
ListBySkuPreparer prepares the ListBySku request.
func (RegionsClient) ListBySkuResponder ¶
func (client RegionsClient) ListBySkuResponder(resp *http.Response) (result PremiumMessagingRegionsListResult, err error)
ListBySkuResponder handles the response to the ListBySku request. The method always closes the http.Response Body.
func (RegionsClient) ListBySkuSender ¶
ListBySkuSender sends the ListBySku request. The method will close the http.Response Body if it receives an error.
type Resource ¶
type Resource struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` }
Resource is the Resource definition for other than namespace.
type ResourceNamespacePatch ¶
type ResourceNamespacePatch struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` Location *string `json:"location,omitempty"` Tags *map[string]*string `json:"tags,omitempty"` }
ResourceNamespacePatch is the Resource definition.
type RoleDisasterRecovery ¶
type RoleDisasterRecovery string
RoleDisasterRecovery enumerates the values for role disaster recovery.
const ( // Primary specifies the primary state for role disaster recovery. Primary RoleDisasterRecovery = "Primary" // PrimaryNotReplicating specifies the primary not replicating state for role disaster recovery. PrimaryNotReplicating RoleDisasterRecovery = "PrimaryNotReplicating" // Secondary specifies the secondary state for role disaster recovery. Secondary RoleDisasterRecovery = "Secondary" )
type Rule ¶
type Rule struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *Ruleproperties `json:"properties,omitempty"` }
Rule is description of Rule Resource.
type RuleListResult ¶
type RuleListResult struct { autorest.Response `json:"-"` Value *[]Rule `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
RuleListResult is the response of the List rule operation.
func (RuleListResult) RuleListResultPreparer ¶
func (client RuleListResult) RuleListResultPreparer() (*http.Request, error)
RuleListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type Ruleproperties ¶
type Ruleproperties struct { Action *Action `json:"action,omitempty"` FilterType FilterType `json:"filterType,omitempty"` SQLFilter *SQLFilter `json:"sqlFilter,omitempty"` CorrelationFilter *CorrelationFilter `json:"correlationFilter,omitempty"` }
Ruleproperties is description of Rule Resource.
type RulesClient ¶
type RulesClient struct {
ManagementClient
}
RulesClient is the azure Service Bus client
func NewRulesClient ¶
func NewRulesClient(subscriptionID string) RulesClient
NewRulesClient creates an instance of the RulesClient client.
func NewRulesClientWithBaseURI ¶
func NewRulesClientWithBaseURI(baseURI string, subscriptionID string) RulesClient
NewRulesClientWithBaseURI creates an instance of the RulesClient client.
func (RulesClient) CreateOrUpdate ¶
func (client RulesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string, parameters Rule) (result Rule, err error)
CreateOrUpdate creates a new rule and updates an existing rule
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. subscriptionName is the subscription name. ruleName is the rule name. parameters is parameters supplied to create a rule.
func (RulesClient) CreateOrUpdatePreparer ¶
func (client RulesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string, parameters Rule) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (RulesClient) CreateOrUpdateResponder ¶
func (client RulesClient) CreateOrUpdateResponder(resp *http.Response) (result Rule, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (RulesClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (RulesClient) Delete ¶
func (client RulesClient) Delete(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string) (result autorest.Response, err error)
Delete deletes an existing rule.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. subscriptionName is the subscription name. ruleName is the rule name.
func (RulesClient) DeletePreparer ¶
func (client RulesClient) DeletePreparer(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (RulesClient) DeleteResponder ¶
func (client RulesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (RulesClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (RulesClient) Get ¶
func (client RulesClient) Get(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string) (result Rule, err error)
Get retrieves the description for the specified rule.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. subscriptionName is the subscription name. ruleName is the rule name.
func (RulesClient) GetPreparer ¶
func (client RulesClient) GetPreparer(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, ruleName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (RulesClient) GetResponder ¶
func (client RulesClient) GetResponder(resp *http.Response) (result Rule, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (RulesClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (RulesClient) ListBySubscriptions ¶
func (client RulesClient) ListBySubscriptions(resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (result RuleListResult, err error)
ListBySubscriptions list all the rules within given topic-subscription
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. subscriptionName is the subscription name.
func (RulesClient) ListBySubscriptionsComplete ¶
func (client RulesClient) ListBySubscriptionsComplete(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, cancel <-chan struct{}) (<-chan Rule, <-chan error)
ListBySubscriptionsComplete gets all elements from the list without paging.
func (RulesClient) ListBySubscriptionsNextResults ¶
func (client RulesClient) ListBySubscriptionsNextResults(lastResults RuleListResult) (result RuleListResult, err error)
ListBySubscriptionsNextResults retrieves the next set of results, if any.
func (RulesClient) ListBySubscriptionsPreparer ¶
func (client RulesClient) ListBySubscriptionsPreparer(resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (*http.Request, error)
ListBySubscriptionsPreparer prepares the ListBySubscriptions request.
func (RulesClient) ListBySubscriptionsResponder ¶
func (client RulesClient) ListBySubscriptionsResponder(resp *http.Response) (result RuleListResult, err error)
ListBySubscriptionsResponder handles the response to the ListBySubscriptions request. The method always closes the http.Response Body.
func (RulesClient) ListBySubscriptionsSender ¶
ListBySubscriptionsSender sends the ListBySubscriptions request. The method will close the http.Response Body if it receives an error.
type SBAuthorizationRule ¶
type SBAuthorizationRule struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *SBAuthorizationRuleProperties `json:"properties,omitempty"` }
SBAuthorizationRule is description of a namespace authorization rule.
type SBAuthorizationRuleListResult ¶
type SBAuthorizationRuleListResult struct { autorest.Response `json:"-"` Value *[]SBAuthorizationRule `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
SBAuthorizationRuleListResult is the response to the List Namespace operation.
func (SBAuthorizationRuleListResult) SBAuthorizationRuleListResultPreparer ¶
func (client SBAuthorizationRuleListResult) SBAuthorizationRuleListResultPreparer() (*http.Request, error)
SBAuthorizationRuleListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type SBAuthorizationRuleProperties ¶
type SBAuthorizationRuleProperties struct {
Rights *[]AccessRights `json:"rights,omitempty"`
}
SBAuthorizationRuleProperties is authorizationRule properties.
type SBNamespace ¶
type SBNamespace struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` Location *string `json:"location,omitempty"` Tags *map[string]*string `json:"tags,omitempty"` Sku *SBSku `json:"sku,omitempty"` *SBNamespaceProperties `json:"properties,omitempty"` }
SBNamespace is description of a namespace resource.
type SBNamespaceListResult ¶
type SBNamespaceListResult struct { autorest.Response `json:"-"` Value *[]SBNamespace `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
SBNamespaceListResult is the response of the List Namespace operation.
func (SBNamespaceListResult) SBNamespaceListResultPreparer ¶
func (client SBNamespaceListResult) SBNamespaceListResultPreparer() (*http.Request, error)
SBNamespaceListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type SBNamespaceProperties ¶
type SBNamespaceProperties struct { ProvisioningState *string `json:"provisioningState,omitempty"` CreatedAt *date.Time `json:"createdAt,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` ServiceBusEndpoint *string `json:"serviceBusEndpoint,omitempty"` MetricID *string `json:"metricId,omitempty"` }
SBNamespaceProperties is properties of the namespace.
type SBNamespaceUpdateParameters ¶
type SBNamespaceUpdateParameters struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` Location *string `json:"location,omitempty"` Tags *map[string]*string `json:"tags,omitempty"` Sku *SBSku `json:"sku,omitempty"` *SBNamespaceProperties `json:"properties,omitempty"` }
SBNamespaceUpdateParameters is description of a namespace resource.
type SBQueue ¶
type SBQueue struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *SBQueueProperties `json:"properties,omitempty"` }
SBQueue is description of queue Resource.
type SBQueueListResult ¶
type SBQueueListResult struct { autorest.Response `json:"-"` Value *[]SBQueue `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
SBQueueListResult is the response to the List Queues operation.
func (SBQueueListResult) SBQueueListResultPreparer ¶
func (client SBQueueListResult) SBQueueListResultPreparer() (*http.Request, error)
SBQueueListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type SBQueueProperties ¶
type SBQueueProperties struct { CountDetails *MessageCountDetails `json:"countDetails,omitempty"` CreatedAt *date.Time `json:"createdAt,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` AccessedAt *date.Time `json:"accessedAt,omitempty"` SizeInBytes *int64 `json:"sizeInBytes,omitempty"` MessageCount *int64 `json:"messageCount,omitempty"` LockDuration *string `json:"lockDuration,omitempty"` MaxSizeInMegabytes *int32 `json:"maxSizeInMegabytes,omitempty"` RequiresDuplicateDetection *bool `json:"requiresDuplicateDetection,omitempty"` RequiresSession *bool `json:"requiresSession,omitempty"` DefaultMessageTimeToLive *string `json:"defaultMessageTimeToLive,omitempty"` DeadLetteringOnMessageExpiration *bool `json:"deadLetteringOnMessageExpiration,omitempty"` DuplicateDetectionHistoryTimeWindow *string `json:"duplicateDetectionHistoryTimeWindow,omitempty"` MaxDeliveryCount *int32 `json:"maxDeliveryCount,omitempty"` Status EntityStatus `json:"status,omitempty"` AutoDeleteOnIdle *string `json:"autoDeleteOnIdle,omitempty"` EnablePartitioning *bool `json:"enablePartitioning,omitempty"` EnableExpress *bool `json:"enableExpress,omitempty"` }
SBQueueProperties is the Queue Properties definition.
type SBSku ¶
type SBSku struct { Name SkuName `json:"name,omitempty"` Tier SkuTier `json:"tier,omitempty"` Capacity *int32 `json:"capacity,omitempty"` }
SBSku is SKU of the namespace.
type SBSubscription ¶
type SBSubscription struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *SBSubscriptionProperties `json:"properties,omitempty"` }
SBSubscription is description of subscription resource.
type SBSubscriptionListResult ¶
type SBSubscriptionListResult struct { autorest.Response `json:"-"` Value *[]SBSubscription `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
SBSubscriptionListResult is the response to the List Subscriptions operation.
func (SBSubscriptionListResult) SBSubscriptionListResultPreparer ¶
func (client SBSubscriptionListResult) SBSubscriptionListResultPreparer() (*http.Request, error)
SBSubscriptionListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type SBSubscriptionProperties ¶
type SBSubscriptionProperties struct { MessageCount *int64 `json:"messageCount,omitempty"` CreatedAt *date.Time `json:"createdAt,omitempty"` AccessedAt *date.Time `json:"accessedAt,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` CountDetails *MessageCountDetails `json:"countDetails,omitempty"` LockDuration *string `json:"lockDuration,omitempty"` RequiresSession *bool `json:"requiresSession,omitempty"` DefaultMessageTimeToLive *string `json:"defaultMessageTimeToLive,omitempty"` DeadLetteringOnMessageExpiration *bool `json:"deadLetteringOnMessageExpiration,omitempty"` DuplicateDetectionHistoryTimeWindow *string `json:"duplicateDetectionHistoryTimeWindow,omitempty"` MaxDeliveryCount *int32 `json:"maxDeliveryCount,omitempty"` Status EntityStatus `json:"status,omitempty"` EnableBatchedOperations *bool `json:"enableBatchedOperations,omitempty"` AutoDeleteOnIdle *string `json:"autoDeleteOnIdle,omitempty"` }
SBSubscriptionProperties is description of Subscription Resource.
type SBTopic ¶
type SBTopic struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *SBTopicProperties `json:"properties,omitempty"` }
SBTopic is description of topic resource.
type SBTopicListResult ¶
type SBTopicListResult struct { autorest.Response `json:"-"` Value *[]SBTopic `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
SBTopicListResult is the response to the List Topics operation.
func (SBTopicListResult) SBTopicListResultPreparer ¶
func (client SBTopicListResult) SBTopicListResultPreparer() (*http.Request, error)
SBTopicListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type SBTopicProperties ¶
type SBTopicProperties struct { SizeInBytes *int64 `json:"sizeInBytes,omitempty"` CreatedAt *date.Time `json:"createdAt,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` AccessedAt *date.Time `json:"accessedAt,omitempty"` SubscriptionCount *int32 `json:"subscriptionCount,omitempty"` CountDetails *MessageCountDetails `json:"countDetails,omitempty"` DefaultMessageTimeToLive *string `json:"defaultMessageTimeToLive,omitempty"` MaxSizeInMegabytes *int32 `json:"maxSizeInMegabytes,omitempty"` RequiresDuplicateDetection *bool `json:"requiresDuplicateDetection,omitempty"` DuplicateDetectionHistoryTimeWindow *string `json:"duplicateDetectionHistoryTimeWindow,omitempty"` EnableBatchedOperations *bool `json:"enableBatchedOperations,omitempty"` Status EntityStatus `json:"status,omitempty"` SupportOrdering *bool `json:"supportOrdering,omitempty"` AutoDeleteOnIdle *string `json:"autoDeleteOnIdle,omitempty"` EnablePartitioning *bool `json:"enablePartitioning,omitempty"` EnableExpress *bool `json:"enableExpress,omitempty"` }
SBTopicProperties is the Tpoic Properties definition.
type SQLFilter ¶
type SQLFilter struct { SQLExpression *string `json:"sqlExpression,omitempty"` CompatibilityLevel *int32 `json:"compatibilityLevel,omitempty"` RequiresPreprocessing *bool `json:"requiresPreprocessing,omitempty"` }
SQLFilter is represents a filter which is a composition of an expression and an action that is executed in the pub/sub pipeline.
type SQLRuleAction ¶
type SQLRuleAction struct { SQLExpression *string `json:"sqlExpression,omitempty"` CompatibilityLevel *int32 `json:"compatibilityLevel,omitempty"` RequiresPreprocessing *bool `json:"requiresPreprocessing,omitempty"` }
SQLRuleAction is represents set of actions written in SQL language-based syntax that is performed against a ServiceBus.Messaging.BrokeredMessage
type SkuTier ¶
type SkuTier string
SkuTier enumerates the values for sku tier.
const ( // SkuTierBasic specifies the sku tier basic state for sku tier. SkuTierBasic SkuTier = "Basic" // SkuTierPremium specifies the sku tier premium state for sku tier. SkuTierPremium SkuTier = "Premium" // SkuTierStandard specifies the sku tier standard state for sku tier. SkuTierStandard SkuTier = "Standard" )
type SubscriptionsClient ¶
type SubscriptionsClient struct {
ManagementClient
}
SubscriptionsClient is the azure Service Bus client
func NewSubscriptionsClient ¶
func NewSubscriptionsClient(subscriptionID string) SubscriptionsClient
NewSubscriptionsClient creates an instance of the SubscriptionsClient client.
func NewSubscriptionsClientWithBaseURI ¶
func NewSubscriptionsClientWithBaseURI(baseURI string, subscriptionID string) SubscriptionsClient
NewSubscriptionsClientWithBaseURI creates an instance of the SubscriptionsClient client.
func (SubscriptionsClient) CreateOrUpdate ¶
func (client SubscriptionsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, parameters SBSubscription) (result SBSubscription, err error)
CreateOrUpdate creates a topic subscription.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. subscriptionName is the subscription name. parameters is parameters supplied to create a subscription resource.
func (SubscriptionsClient) CreateOrUpdatePreparer ¶
func (client SubscriptionsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, topicName string, subscriptionName string, parameters SBSubscription) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (SubscriptionsClient) CreateOrUpdateResponder ¶
func (client SubscriptionsClient) CreateOrUpdateResponder(resp *http.Response) (result SBSubscription, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (SubscriptionsClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (SubscriptionsClient) Delete ¶
func (client SubscriptionsClient) Delete(resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (result autorest.Response, err error)
Delete deletes a subscription from the specified topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. subscriptionName is the subscription name.
func (SubscriptionsClient) DeletePreparer ¶
func (client SubscriptionsClient) DeletePreparer(resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (SubscriptionsClient) DeleteResponder ¶
func (client SubscriptionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (SubscriptionsClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (SubscriptionsClient) Get ¶
func (client SubscriptionsClient) Get(resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (result SBSubscription, err error)
Get returns a subscription description for the specified topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. subscriptionName is the subscription name.
func (SubscriptionsClient) GetPreparer ¶
func (client SubscriptionsClient) GetPreparer(resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (SubscriptionsClient) GetResponder ¶
func (client SubscriptionsClient) GetResponder(resp *http.Response) (result SBSubscription, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (SubscriptionsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (SubscriptionsClient) ListByTopic ¶
func (client SubscriptionsClient) ListByTopic(resourceGroupName string, namespaceName string, topicName string) (result SBSubscriptionListResult, err error)
ListByTopic list all the subscriptions under a specified topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name.
func (SubscriptionsClient) ListByTopicComplete ¶
func (client SubscriptionsClient) ListByTopicComplete(resourceGroupName string, namespaceName string, topicName string, cancel <-chan struct{}) (<-chan SBSubscription, <-chan error)
ListByTopicComplete gets all elements from the list without paging.
func (SubscriptionsClient) ListByTopicNextResults ¶
func (client SubscriptionsClient) ListByTopicNextResults(lastResults SBSubscriptionListResult) (result SBSubscriptionListResult, err error)
ListByTopicNextResults retrieves the next set of results, if any.
func (SubscriptionsClient) ListByTopicPreparer ¶
func (client SubscriptionsClient) ListByTopicPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
ListByTopicPreparer prepares the ListByTopic request.
func (SubscriptionsClient) ListByTopicResponder ¶
func (client SubscriptionsClient) ListByTopicResponder(resp *http.Response) (result SBSubscriptionListResult, err error)
ListByTopicResponder handles the response to the ListByTopic request. The method always closes the http.Response Body.
func (SubscriptionsClient) ListByTopicSender ¶
ListByTopicSender sends the ListByTopic request. The method will close the http.Response Body if it receives an error.
type TopicsClient ¶
type TopicsClient struct {
ManagementClient
}
TopicsClient is the azure Service Bus client
func NewTopicsClient ¶
func NewTopicsClient(subscriptionID string) TopicsClient
NewTopicsClient creates an instance of the TopicsClient client.
func NewTopicsClientWithBaseURI ¶
func NewTopicsClientWithBaseURI(baseURI string, subscriptionID string) TopicsClient
NewTopicsClientWithBaseURI creates an instance of the TopicsClient client.
func (TopicsClient) CreateOrUpdate ¶
func (client TopicsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, topicName string, parameters SBTopic) (result SBTopic, err error)
CreateOrUpdate creates a topic in the specified namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. parameters is parameters supplied to create a topic resource.
func (TopicsClient) CreateOrUpdateAuthorizationRule ¶
func (client TopicsClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters SBAuthorizationRule) (result SBAuthorizationRule, err error)
CreateOrUpdateAuthorizationRule creates an authorizatio rule for the specified topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. authorizationRuleName is the authorizationrule name. parameters is the shared access authorization rule.
func (TopicsClient) CreateOrUpdateAuthorizationRulePreparer ¶
func (client TopicsClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters SBAuthorizationRule) (*http.Request, error)
CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.
func (TopicsClient) CreateOrUpdateAuthorizationRuleResponder ¶
func (client TopicsClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
CreateOrUpdateAuthorizationRuleResponder handles the response to the CreateOrUpdateAuthorizationRule request. The method always closes the http.Response Body.
func (TopicsClient) CreateOrUpdateAuthorizationRuleSender ¶
func (client TopicsClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
CreateOrUpdateAuthorizationRuleSender sends the CreateOrUpdateAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) CreateOrUpdatePreparer ¶
func (client TopicsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, topicName string, parameters SBTopic) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (TopicsClient) CreateOrUpdateResponder ¶
func (client TopicsClient) CreateOrUpdateResponder(resp *http.Response) (result SBTopic, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (TopicsClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) Delete ¶
func (client TopicsClient) Delete(resourceGroupName string, namespaceName string, topicName string) (result autorest.Response, err error)
Delete deletes a topic from the specified namespace and resource group.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name.
func (TopicsClient) DeleteAuthorizationRule ¶
func (client TopicsClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (result autorest.Response, err error)
DeleteAuthorizationRule deletes a topic authorization rule.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. authorizationRuleName is the authorizationrule name.
func (TopicsClient) DeleteAuthorizationRulePreparer ¶
func (client TopicsClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (*http.Request, error)
DeleteAuthorizationRulePreparer prepares the DeleteAuthorizationRule request.
func (TopicsClient) DeleteAuthorizationRuleResponder ¶
func (client TopicsClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
DeleteAuthorizationRuleResponder handles the response to the DeleteAuthorizationRule request. The method always closes the http.Response Body.
func (TopicsClient) DeleteAuthorizationRuleSender ¶
DeleteAuthorizationRuleSender sends the DeleteAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) DeletePreparer ¶
func (client TopicsClient) DeletePreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (TopicsClient) DeleteResponder ¶
func (client TopicsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (TopicsClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) Get ¶
func (client TopicsClient) Get(resourceGroupName string, namespaceName string, topicName string) (result SBTopic, err error)
Get returns a description for the specified topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name.
func (TopicsClient) GetAuthorizationRule ¶
func (client TopicsClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (result SBAuthorizationRule, err error)
GetAuthorizationRule returns the specified authorization rule.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. authorizationRuleName is the authorizationrule name.
func (TopicsClient) GetAuthorizationRulePreparer ¶
func (client TopicsClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (*http.Request, error)
GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.
func (TopicsClient) GetAuthorizationRuleResponder ¶
func (client TopicsClient) GetAuthorizationRuleResponder(resp *http.Response) (result SBAuthorizationRule, err error)
GetAuthorizationRuleResponder handles the response to the GetAuthorizationRule request. The method always closes the http.Response Body.
func (TopicsClient) GetAuthorizationRuleSender ¶
GetAuthorizationRuleSender sends the GetAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) GetPreparer ¶
func (client TopicsClient) GetPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (TopicsClient) GetResponder ¶
func (client TopicsClient) GetResponder(resp *http.Response) (result SBTopic, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (TopicsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) ListAuthorizationRules ¶
func (client TopicsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, topicName string) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRules gets authorization rules for a topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name.
func (TopicsClient) ListAuthorizationRulesComplete ¶
func (client TopicsClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, topicName string, cancel <-chan struct{}) (<-chan SBAuthorizationRule, <-chan error)
ListAuthorizationRulesComplete gets all elements from the list without paging.
func (TopicsClient) ListAuthorizationRulesNextResults ¶
func (client TopicsClient) ListAuthorizationRulesNextResults(lastResults SBAuthorizationRuleListResult) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRulesNextResults retrieves the next set of results, if any.
func (TopicsClient) ListAuthorizationRulesPreparer ¶
func (client TopicsClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)
ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.
func (TopicsClient) ListAuthorizationRulesResponder ¶
func (client TopicsClient) ListAuthorizationRulesResponder(resp *http.Response) (result SBAuthorizationRuleListResult, err error)
ListAuthorizationRulesResponder handles the response to the ListAuthorizationRules request. The method always closes the http.Response Body.
func (TopicsClient) ListAuthorizationRulesSender ¶
ListAuthorizationRulesSender sends the ListAuthorizationRules request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) ListByNamespace ¶
func (client TopicsClient) ListByNamespace(resourceGroupName string, namespaceName string) (result SBTopicListResult, err error)
ListByNamespace gets all the topics in a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (TopicsClient) ListByNamespaceComplete ¶
func (client TopicsClient) ListByNamespaceComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan SBTopic, <-chan error)
ListByNamespaceComplete gets all elements from the list without paging.
func (TopicsClient) ListByNamespaceNextResults ¶
func (client TopicsClient) ListByNamespaceNextResults(lastResults SBTopicListResult) (result SBTopicListResult, err error)
ListByNamespaceNextResults retrieves the next set of results, if any.
func (TopicsClient) ListByNamespacePreparer ¶
func (client TopicsClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
ListByNamespacePreparer prepares the ListByNamespace request.
func (TopicsClient) ListByNamespaceResponder ¶
func (client TopicsClient) ListByNamespaceResponder(resp *http.Response) (result SBTopicListResult, err error)
ListByNamespaceResponder handles the response to the ListByNamespace request. The method always closes the http.Response Body.
func (TopicsClient) ListByNamespaceSender ¶
ListByNamespaceSender sends the ListByNamespace request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) ListKeys ¶
func (client TopicsClient) ListKeys(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (result AccessKeys, err error)
ListKeys gets the primary and secondary connection strings for the topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. authorizationRuleName is the authorizationrule name.
func (TopicsClient) ListKeysPreparer ¶
func (client TopicsClient) ListKeysPreparer(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (*http.Request, error)
ListKeysPreparer prepares the ListKeys request.
func (TopicsClient) ListKeysResponder ¶
func (client TopicsClient) ListKeysResponder(resp *http.Response) (result AccessKeys, err error)
ListKeysResponder handles the response to the ListKeys request. The method always closes the http.Response Body.
func (TopicsClient) ListKeysSender ¶
ListKeysSender sends the ListKeys request. The method will close the http.Response Body if it receives an error.
func (TopicsClient) RegenerateKeys ¶
func (client TopicsClient) RegenerateKeys(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters) (result AccessKeys, err error)
RegenerateKeys regenerates primary or secondary connection strings for the topic.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name topicName is the topic name. authorizationRuleName is the authorizationrule name. parameters is parameters supplied to regenerate the authorization rule.
func (TopicsClient) RegenerateKeysPreparer ¶
func (client TopicsClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters) (*http.Request, error)
RegenerateKeysPreparer prepares the RegenerateKeys request.
func (TopicsClient) RegenerateKeysResponder ¶
func (client TopicsClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, err error)
RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.
func (TopicsClient) RegenerateKeysSender ¶
RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.
type TrackedResource ¶
type TrackedResource struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` Location *string `json:"location,omitempty"` Tags *map[string]*string `json:"tags,omitempty"` }
TrackedResource is the Resource definition.
type UnavailableReason ¶
type UnavailableReason string
UnavailableReason enumerates the values for unavailable reason.
const ( // InvalidName specifies the invalid name state for unavailable reason. InvalidName UnavailableReason = "InvalidName" // NameInLockdown specifies the name in lockdown state for unavailable reason. NameInLockdown UnavailableReason = "NameInLockdown" // NameInUse specifies the name in use state for unavailable reason. NameInUse UnavailableReason = "NameInUse" // None specifies the none state for unavailable reason. None UnavailableReason = "None" // SubscriptionIsDisabled specifies the subscription is disabled state for unavailable reason. SubscriptionIsDisabled UnavailableReason = "SubscriptionIsDisabled" // TooManyNamespaceInCurrentSubscription specifies the too many namespace in current subscription state for unavailable // reason. TooManyNamespaceInCurrentSubscription UnavailableReason = "TooManyNamespaceInCurrentSubscription" )