servicebus

package
v3.2.0-beta+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2016 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package servicebus implements the Azure ARM Servicebus service API version 2015-08-01.

Azure Service Bus client

Index

Constants

View Source
const (
	// APIVersion is the version of the Servicebus
	APIVersion = "2015-08-01"

	// 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 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 AvailabilityStatus

type AvailabilityStatus string

AvailabilityStatus enumerates the values for availability status.

const (
	// Available specifies the available state for availability status.
	Available AvailabilityStatus = "Available"
	// Limited specifies the limited state for availability status.
	Limited AvailabilityStatus = "Limited"
	// Renaming specifies the renaming state for availability status.
	Renaming AvailabilityStatus = "Renaming"
	// Restoring specifies the restoring state for availability status.
	Restoring AvailabilityStatus = "Restoring"
	// Unknown specifies the unknown state for availability status.
	Unknown AvailabilityStatus = "Unknown"
)

type EntityStatus

type EntityStatus string

EntityStatus enumerates the values for entity status.

const (
	// EntityStatusActive specifies the entity status active state for entity
	// status.
	EntityStatusActive EntityStatus = "Active"
	// EntityStatusCreating specifies the entity status creating state for
	// entity status.
	EntityStatusCreating EntityStatus = "Creating"
	// EntityStatusDeleting specifies the entity status deleting state for
	// entity status.
	EntityStatusDeleting EntityStatus = "Deleting"
	// EntityStatusDisabled specifies the entity status disabled state for
	// entity status.
	EntityStatusDisabled EntityStatus = "Disabled"
	// EntityStatusReceiveDisabled specifies the entity status receive
	// disabled state for entity status.
	EntityStatusReceiveDisabled EntityStatus = "ReceiveDisabled"
	// EntityStatusRenaming specifies the entity status renaming state for
	// entity status.
	EntityStatusRenaming EntityStatus = "Renaming"
	// EntityStatusRestoring specifies the entity status restoring state for
	// entity status.
	EntityStatusRestoring EntityStatus = "Restoring"
	// EntityStatusSendDisabled specifies the entity status send disabled
	// state for entity status.
	EntityStatusSendDisabled EntityStatus = "SendDisabled"
	// EntityStatusUnknown specifies the entity status unknown state for
	// entity status.
	EntityStatusUnknown EntityStatus = "Unknown"
)

type Kind

type Kind string

Kind enumerates the values for kind.

const (
	// Messaging specifies the messaging state for kind.
	Messaging Kind = "Messaging"
)

type ManagementClient

type ManagementClient struct {
	autorest.Client
	BaseURI        string
	APIVersion     string
	SubscriptionID string
}

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"`
	TransferDeadLetterMessageCount *int64 `json:"TransferDeadLetterMessageCount,omitempty"`
	TransferMessageCount           *int64 `json:"TransferMessageCount,omitempty"`
}

MessageCountDetails is message Count Details.

type NamespaceCreateOrUpdateParameters

type NamespaceCreateOrUpdateParameters struct {
	Location   *string              `json:"location,omitempty"`
	Sku        *Sku                 `json:"sku,omitempty"`
	Tags       *map[string]*string  `json:"tags,omitempty"`
	Kind       Kind                 `json:"kind,omitempty"`
	Properties *NamespaceProperties `json:"properties,omitempty"`
}

NamespaceCreateOrUpdateParameters is parameters supplied to the CreateOrUpdate Namespace operation.

type NamespaceListResult

type NamespaceListResult struct {
	autorest.Response `json:"-"`
	Value             *[]NamespaceResource `json:"value,omitempty"`
	NextLink          *string              `json:"nextLink,omitempty"`
}

NamespaceListResult is the response of the List Namespace operation.

func (NamespaceListResult) NamespaceListResultPreparer

func (client NamespaceListResult) NamespaceListResultPreparer() (*http.Request, error)

NamespaceListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type NamespaceProperties

type NamespaceProperties struct {
	ProvisioningState  *string        `json:"provisioningState,omitempty"`
	Status             NamespaceState `json:"status,omitempty"`
	CreatedAt          *date.Time     `json:"createdAt,omitempty"`
	UpdatedAt          *date.Time     `json:"updatedAt,omitempty"`
	ServiceBusEndpoint *string        `json:"serviceBusEndpoint,omitempty"`
	CreateACSNamespace *bool          `json:"createACSNamespace,omitempty"`
	Enabled            *bool          `json:"enabled,omitempty"`
}

NamespaceProperties is properties of the Namespace.

type NamespaceResource

type NamespaceResource 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"`
	Kind              Kind                 `json:"kind,omitempty"`
	Sku               *Sku                 `json:"sku,omitempty"`
	Properties        *NamespaceProperties `json:"properties,omitempty"`
}

NamespaceResource is description of a Namespace resource.

type NamespaceState

type NamespaceState string

NamespaceState enumerates the values for namespace state.

const (
	// NamespaceStateActivating specifies the namespace state activating state
	// for namespace state.
	NamespaceStateActivating NamespaceState = "Activating"
	// NamespaceStateActive specifies the namespace state active state for
	// namespace state.
	NamespaceStateActive NamespaceState = "Active"
	// NamespaceStateCreated specifies the namespace state created state for
	// namespace state.
	NamespaceStateCreated NamespaceState = "Created"
	// NamespaceStateCreating specifies the namespace state creating state for
	// namespace state.
	NamespaceStateCreating NamespaceState = "Creating"
	// NamespaceStateDisabled specifies the namespace state disabled state for
	// namespace state.
	NamespaceStateDisabled NamespaceState = "Disabled"
	// NamespaceStateDisabling specifies the namespace state disabling state
	// for namespace state.
	NamespaceStateDisabling NamespaceState = "Disabling"
	// NamespaceStateEnabling specifies the namespace state enabling state for
	// namespace state.
	NamespaceStateEnabling NamespaceState = "Enabling"
	// NamespaceStateFailed specifies the namespace state failed state for
	// namespace state.
	NamespaceStateFailed NamespaceState = "Failed"
	// NamespaceStateRemoved specifies the namespace state removed state for
	// namespace state.
	NamespaceStateRemoved NamespaceState = "Removed"
	// NamespaceStateRemoving specifies the namespace state removing state for
	// namespace state.
	NamespaceStateRemoving NamespaceState = "Removing"
	// NamespaceStateSoftDeleted specifies the namespace state soft deleted
	// state for namespace state.
	NamespaceStateSoftDeleted NamespaceState = "SoftDeleted"
	// NamespaceStateSoftDeleting specifies the namespace state soft deleting
	// state for namespace state.
	NamespaceStateSoftDeleting NamespaceState = "SoftDeleting"
	// NamespaceStateUnknown specifies the namespace state unknown state for
	// namespace state.
	NamespaceStateUnknown NamespaceState = "Unknown"
)

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) CreateOrUpdate

func (client NamespacesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, parameters NamespaceCreateOrUpdateParameters, cancel <-chan struct{}) (result autorest.Response, err error)

CreateOrUpdate creates/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 the name of the resource group. 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 SharedAccessAuthorizationRuleCreateOrUpdateParameters) (result SharedAccessAuthorizationRuleResource, err error)

CreateOrUpdateAuthorizationRule creates an authorization rule for a namespace

resourceGroupName is the name of the resource group. namespaceName is the namespace name. authorizationRuleName is namespace Aauthorization Rule Name. parameters is the shared access authorization rule.

func (NamespacesClient) CreateOrUpdateAuthorizationRulePreparer

func (client NamespacesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters SharedAccessAuthorizationRuleCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.

func (NamespacesClient) CreateOrUpdateAuthorizationRuleResponder

func (client NamespacesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRuleResource, 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 NamespaceCreateOrUpdateParameters, cancel <-chan struct{}) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (NamespacesClient) CreateOrUpdateResponder

func (client NamespacesClient) CreateOrUpdateResponder(resp *http.Response) (result autorest.Response, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (NamespacesClient) CreateOrUpdateSender

func (client NamespacesClient) 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 (NamespacesClient) Delete

func (client NamespacesClient) Delete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (result autorest.Response, err 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 the name of the resource group. 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 the name of the resource group. namespaceName is the namespace name. authorizationRuleName is authorization Rule 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

func (client NamespacesClient) DeleteSender(req *http.Request) (*http.Response, error)

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 NamespaceResource, err error)

Get returns the description for the specified namespace.

resourceGroupName is the name of the resource group. namespaceName is the namespace name.

func (NamespacesClient) GetAuthorizationRule

func (client NamespacesClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result SharedAccessAuthorizationRuleResource, err error)

GetAuthorizationRule authorization rule for a namespace by name.

resourceGroupName is the name of the resource group. namespaceName is the namespace name authorizationRuleName is authorization rule 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 SharedAccessAuthorizationRuleResource, 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 NamespaceResource, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (NamespacesClient) GetSender

func (client NamespacesClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (NamespacesClient) ListAuthorizationRules

func (client NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string) (result SharedAccessAuthorizationRuleListResult, err error)

ListAuthorizationRules authorization rules for a namespace.

resourceGroupName is the name of the resource group. namespaceName is the namespace name

func (NamespacesClient) ListAuthorizationRulesNextResults

func (client NamespacesClient) ListAuthorizationRulesNextResults(lastResults SharedAccessAuthorizationRuleListResult) (result SharedAccessAuthorizationRuleListResult, 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 SharedAccessAuthorizationRuleListResult, 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 NamespaceListResult, err error)

ListByResourceGroup lists the available namespaces within a resourceGroup.

resourceGroupName is the name of the resource group.

func (NamespacesClient) ListByResourceGroupNextResults

func (client NamespacesClient) ListByResourceGroupNextResults(lastResults NamespaceListResult) (result NamespaceListResult, 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 NamespaceListResult, err error)

ListByResourceGroupResponder handles the response to the ListByResourceGroup request. The method always closes the http.Response Body.

func (NamespacesClient) ListByResourceGroupSender

func (client NamespacesClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)

ListByResourceGroupSender sends the ListByResourceGroup request. The method will close the http.Response Body if it receives an error.

func (NamespacesClient) ListBySubscription

func (client NamespacesClient) ListBySubscription() (result NamespaceListResult, err error)

ListBySubscription lists all the available namespaces within the subscription irrespective of the resourceGroups.

func (NamespacesClient) ListBySubscriptionNextResults

func (client NamespacesClient) ListBySubscriptionNextResults(lastResults NamespaceListResult) (result NamespaceListResult, err error)

ListBySubscriptionNextResults retrieves the next set of results, if any.

func (NamespacesClient) ListBySubscriptionPreparer

func (client NamespacesClient) ListBySubscriptionPreparer() (*http.Request, error)

ListBySubscriptionPreparer prepares the ListBySubscription request.

func (NamespacesClient) ListBySubscriptionResponder

func (client NamespacesClient) ListBySubscriptionResponder(resp *http.Response) (result NamespaceListResult, err error)

ListBySubscriptionResponder handles the response to the ListBySubscription request. The method always closes the http.Response Body.

func (NamespacesClient) ListBySubscriptionSender

func (client NamespacesClient) ListBySubscriptionSender(req *http.Request) (*http.Response, error)

ListBySubscriptionSender sends the ListBySubscription request. The method will close the http.Response Body if it receives an error.

func (NamespacesClient) ListKeys

func (client NamespacesClient) ListKeys(resourceGroupName string, namespaceName string, authorizationRuleName string) (result ResourceListKeys, err error)

ListKeys primary and Secondary ConnectionStrings to the namespace

resourceGroupName is the name of the resource group. 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 ResourceListKeys, err error)

ListKeysResponder handles the response to the ListKeys request. The method always closes the http.Response Body.

func (NamespacesClient) ListKeysSender

func (client NamespacesClient) ListKeysSender(req *http.Request) (*http.Response, error)

ListKeysSender sends the ListKeys 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 RegenerateKeysParameters) (result ResourceListKeys, err error)

RegenerateKeys regenerats the Primary or Secondary ConnectionStrings to the namespace

resourceGroupName is the name of the resource group. namespaceName is the namespace name. authorizationRuleName is the authorizationRule name. parameters is parameters supplied to regenerate Auth Rule.

func (NamespacesClient) RegenerateKeysPreparer

func (client NamespacesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateKeysParameters) (*http.Request, error)

RegenerateKeysPreparer prepares the RegenerateKeys request.

func (NamespacesClient) RegenerateKeysResponder

func (client NamespacesClient) RegenerateKeysResponder(resp *http.Response) (result ResourceListKeys, err error)

RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.

func (NamespacesClient) RegenerateKeysSender

func (client NamespacesClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)

RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.

type Policykey

type Policykey string

Policykey enumerates the values for policykey.

const (
	// PrimaryKey specifies the primary key state for policykey.
	PrimaryKey Policykey = "PrimaryKey"
	// SecondayKey specifies the seconday key state for policykey.
	SecondayKey Policykey = "SecondayKey"
)

type QueueCreateOrUpdateParameters

type QueueCreateOrUpdateParameters struct {
	Name       *string          `json:"name,omitempty"`
	Location   *string          `json:"location,omitempty"`
	Properties *QueueProperties `json:"properties,omitempty"`
}

QueueCreateOrUpdateParameters is parameters supplied to the CreateOrUpdate Queue operation.

type QueueListResult

type QueueListResult struct {
	autorest.Response `json:"-"`
	Value             *[]QueueResource `json:"value,omitempty"`
	NextLink          *string          `json:"nextLink,omitempty"`
}

QueueListResult is the response of the List Queues operation.

func (QueueListResult) QueueListResultPreparer

func (client QueueListResult) QueueListResultPreparer() (*http.Request, error)

QueueListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type QueueProperties

type QueueProperties struct {
	AccessedAt                             *date.Time           `json:"AccessedAt,omitempty"`
	AutoDeleteOnIdle                       *string              `json:"AutoDeleteOnIdle,omitempty"`
	AvailabilityStatus                     AvailabilityStatus   `json:"AvailabilityStatus ,omitempty"`
	CreatedAt                              *date.Time           `json:"CreatedAt,omitempty"`
	DefaultMessageTimeToLive               *string              `json:"DefaultMessageTimeToLive,omitempty"`
	DuplicateDetectionHistoryTimeWindow    *string              `json:"DuplicateDetectionHistoryTimeWindow ,omitempty"`
	EnableBatchedOperations                *bool                `json:"EnableBatchedOperations,omitempty"`
	EnableDeadLetteringOnMessageExpiration *bool                `json:"EnableDeadLetteringOnMessageExpiration,omitempty"`
	EnableExpress                          *bool                `json:"EnableExpress,omitempty"`
	EnablePartitioning                     *bool                `json:"EnablePartitioning,omitempty"`
	ForwardDeadLetteredMessagesTo          *string              `json:"ForwardDeadLetteredMessagesTo,omitempty"`
	ForwardTo                              *string              `json:"ForwardTo,omitempty"`
	IsAnonymousAccessible                  *bool                `json:"IsAnonymousAccessible,omitempty"`
	LockDuration                           *string              `json:"LockDuration ,omitempty"`
	MaxDeliveryCount                       *int32               `json:"MaxDeliveryCount ,omitempty"`
	MaxSizeInMegabytes                     *int64               `json:"MaxSizeInMegabytes ,omitempty"`
	MessageCount                           *int64               `json:"MessageCount ,omitempty"`
	MessageCountDetails                    *MessageCountDetails `json:"MessageCountDetails,omitempty"`
	Path                                   *string              `json:"Path,omitempty"`
	RequiresDuplicateDetection             *bool                `json:"RequiresDuplicateDetection,omitempty"`
	RequiresSession                        *bool                `json:"RequiresSession,omitempty"`
	SizeInBytes                            *int64               `json:"SizeInBytes ,omitempty"`
	Status                                 EntityStatus         `json:"Status,omitempty"`
	SupportOrdering                        *bool                `json:"SupportOrdering,omitempty"`
	UpdatedAt                              *date.Time           `json:"UpdatedAt,omitempty"`
	UserMetadata                           *string              `json:"UserMetadata,omitempty"`
}

QueueProperties is

type QueueResource

type QueueResource 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"`
	Properties        *QueueProperties    `json:"properties,omitempty"`
}

QueueResource is description of queue Resource.

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 QueueCreateOrUpdateParameters) (result QueueResource, err error)

CreateOrUpdate creates/Updates a service Queue. This operation is idempotent.

resourceGroupName is the name of the resource group. namespaceName is the namespace name. queueName is the queue name. parameters is parameters supplied to create a Queue Resource.

func (QueuesClient) CreateOrUpdateAuthorizationRule

func (client QueuesClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters SharedAccessAuthorizationRuleCreateOrUpdateParameters) (result SharedAccessAuthorizationRuleResource, err error)

CreateOrUpdateAuthorizationRule creates an authorization rule for a queue

resourceGroupName is the name of the resource group. namespaceName is the namespace name. queueName is the queue name. authorizationRuleName is aauthorization Rule Name. parameters is the shared access authorization rule.

func (QueuesClient) CreateOrUpdateAuthorizationRulePreparer

func (client QueuesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters SharedAccessAuthorizationRuleCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.

func (QueuesClient) CreateOrUpdateAuthorizationRuleResponder

func (client QueuesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRuleResource, 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 QueueCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (QueuesClient) CreateOrUpdateResponder

func (client QueuesClient) CreateOrUpdateResponder(resp *http.Response) (result QueueResource, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (QueuesClient) CreateOrUpdateSender

func (client QueuesClient) 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 (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 resource group.

resourceGroupName is the name of the resource group. 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 the name of the resource group. namespaceName is the namespace name. queueName is the queue name. authorizationRuleName is authorization Rule 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

func (client QueuesClient) 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 (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

func (client QueuesClient) DeleteSender(req *http.Request) (*http.Response, error)

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 QueueResource, err error)

Get returns the description for the specified queue.

resourceGroupName is the name of the resource group. 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 SharedAccessAuthorizationRuleResource, err error)

GetAuthorizationRule queue authorizationRule for a queue by name.

resourceGroupName is the name of the resource group. namespaceName is the namespace name queueName is the queue name. authorizationRuleName is authorization rule 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 SharedAccessAuthorizationRuleResource, err error)

GetAuthorizationRuleResponder handles the response to the GetAuthorizationRule request. The method always closes the http.Response Body.

func (QueuesClient) GetAuthorizationRuleSender

func (client QueuesClient) 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 (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 QueueResource, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (QueuesClient) GetSender

func (client QueuesClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (QueuesClient) ListAll

func (client QueuesClient) ListAll(resourceGroupName string, namespaceName string) (result QueueListResult, err error)

ListAll lists the queues within the namespace.

resourceGroupName is the name of the resource group. namespaceName is the namespace name.

func (QueuesClient) ListAllNextResults

func (client QueuesClient) ListAllNextResults(lastResults QueueListResult) (result QueueListResult, err error)

ListAllNextResults retrieves the next set of results, if any.

func (QueuesClient) ListAllPreparer

func (client QueuesClient) ListAllPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)

ListAllPreparer prepares the ListAll request.

func (QueuesClient) ListAllResponder

func (client QueuesClient) ListAllResponder(resp *http.Response) (result QueueListResult, err error)

ListAllResponder handles the response to the ListAll request. The method always closes the http.Response Body.

func (QueuesClient) ListAllSender

func (client QueuesClient) ListAllSender(req *http.Request) (*http.Response, error)

ListAllSender sends the ListAll 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 SharedAccessAuthorizationRuleListResult, err error)

ListAuthorizationRules returns all Queue authorizationRules.

resourceGroupName is the name of the resource group. namespaceName is the namespace name queueName is the queue name.

func (QueuesClient) ListAuthorizationRulesNextResults

func (client QueuesClient) ListAuthorizationRulesNextResults(lastResults SharedAccessAuthorizationRuleListResult) (result SharedAccessAuthorizationRuleListResult, 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 SharedAccessAuthorizationRuleListResult, err error)

ListAuthorizationRulesResponder handles the response to the ListAuthorizationRules request. The method always closes the http.Response Body.

func (QueuesClient) ListAuthorizationRulesSender

func (client QueuesClient) 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 (QueuesClient) ListKeys

func (client QueuesClient) ListKeys(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result ResourceListKeys, err error)

ListKeys primary and Secondary ConnectionStrings to the queue.

resourceGroupName is the name of the resource group. 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 ResourceListKeys, err error)

ListKeysResponder handles the response to the ListKeys request. The method always closes the http.Response Body.

func (QueuesClient) ListKeysSender

func (client QueuesClient) ListKeysSender(req *http.Request) (*http.Response, error)

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 RegenerateKeysParameters) (result ResourceListKeys, err error)

RegenerateKeys regenerates the Primary or Secondary ConnectionStrings to the Queue

resourceGroupName is the name of the resource group. namespaceName is the namespace name. queueName is the queue name. authorizationRuleName is the authorizationRule name parameters is parameters supplied to regenerate Auth Rule.

func (QueuesClient) RegenerateKeysPreparer

func (client QueuesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters RegenerateKeysParameters) (*http.Request, error)

RegenerateKeysPreparer prepares the RegenerateKeys request.

func (QueuesClient) RegenerateKeysResponder

func (client QueuesClient) RegenerateKeysResponder(resp *http.Response) (result ResourceListKeys, err error)

RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.

func (QueuesClient) RegenerateKeysSender

func (client QueuesClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)

RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.

type RegenerateKeysParameters

type RegenerateKeysParameters struct {
	Policykey Policykey `json:"Policykey,omitempty"`
}

RegenerateKeysParameters is parameters supplied to the Regenerate Auth Rule.

type Resource

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

Resource is

type ResourceListKeys

type ResourceListKeys struct {
	autorest.Response         `json:"-"`
	PrimaryConnectionString   *string `json:"primaryConnectionString,omitempty"`
	SecondaryConnectionString *string `json:"secondaryConnectionString,omitempty"`
	PrimaryKey                *string `json:"primaryKey,omitempty"`
	SecondaryKey              *string `json:"secondaryKey,omitempty"`
	KeyName                   *string `json:"keyName,omitempty"`
}

ResourceListKeys is namespace/ServiceBus Connection String

type SharedAccessAuthorizationRuleCreateOrUpdateParameters

type SharedAccessAuthorizationRuleCreateOrUpdateParameters struct {
	Location   *string                                  `json:"location,omitempty"`
	Name       *string                                  `json:"name,omitempty"`
	Properties *SharedAccessAuthorizationRuleProperties `json:"properties,omitempty"`
}

SharedAccessAuthorizationRuleCreateOrUpdateParameters is parameters supplied to the CreateOrUpdate AuthorizationRules.

type SharedAccessAuthorizationRuleListResult

type SharedAccessAuthorizationRuleListResult struct {
	autorest.Response `json:"-"`
	Value             *[]SharedAccessAuthorizationRuleResource `json:"value,omitempty"`
	NextLink          *string                                  `json:"nextLink,omitempty"`
}

SharedAccessAuthorizationRuleListResult is the response of the List Namespace operation.

func (SharedAccessAuthorizationRuleListResult) SharedAccessAuthorizationRuleListResultPreparer

func (client SharedAccessAuthorizationRuleListResult) SharedAccessAuthorizationRuleListResultPreparer() (*http.Request, error)

SharedAccessAuthorizationRuleListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type SharedAccessAuthorizationRuleProperties

type SharedAccessAuthorizationRuleProperties struct {
	Rights *[]AccessRights `json:"rights,omitempty"`
}

SharedAccessAuthorizationRuleProperties is sharedAccessAuthorizationRule properties.

type SharedAccessAuthorizationRuleResource

type SharedAccessAuthorizationRuleResource 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"`
	Properties        *SharedAccessAuthorizationRuleProperties `json:"properties,omitempty"`
}

SharedAccessAuthorizationRuleResource is description of a Namespace AuthorizationRules.

type Sku

type Sku struct {
	Name     SkuName `json:"name,omitempty"`
	Tier     SkuTier `json:"tier,omitempty"`
	Capacity *int32  `json:"capacity,omitempty"`
}

Sku is sku of the Namespace.

type SkuName

type SkuName string

SkuName enumerates the values for sku name.

const (
	// Basic specifies the basic state for sku name.
	Basic SkuName = "Basic"
	// Premium specifies the premium state for sku name.
	Premium SkuName = "Premium"
	// Standard specifies the standard state for sku name.
	Standard SkuName = "Standard"
)

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 SubscriptionCreateOrUpdateParameters

type SubscriptionCreateOrUpdateParameters struct {
	Location   *string                 `json:"location,omitempty"`
	Type       *string                 `json:"type,omitempty"`
	Properties *SubscriptionProperties `json:"properties,omitempty"`
}

SubscriptionCreateOrUpdateParameters is parameters supplied to the CreateOrUpdate Subscription operation.

type SubscriptionListResult

type SubscriptionListResult struct {
	autorest.Response `json:"-"`
	Value             *[]SubscriptionResource `json:"value,omitempty"`
	NextLink          *string                 `json:"nextLink,omitempty"`
}

SubscriptionListResult is the response of the List Subscriptions operation.

func (SubscriptionListResult) SubscriptionListResultPreparer

func (client SubscriptionListResult) SubscriptionListResultPreparer() (*http.Request, error)

SubscriptionListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type SubscriptionProperties

type SubscriptionProperties struct {
	AccessedAt                                      *date.Time           `json:"AccessedAt,omitempty"`
	AutoDeleteOnIdle                                *string              `json:"AutoDeleteOnIdle,omitempty"`
	AvailabilityStatus                              AvailabilityStatus   `json:"AvailabilityStatus ,omitempty"`
	CreatedAt                                       *date.Time           `json:"CreatedAt,omitempty"`
	DefaultMessageTimeToLive                        *string              `json:"DefaultMessageTimeToLive,omitempty"`
	EnableBatchedOperations                         *bool                `json:"EnableBatchedOperations,omitempty"`
	EnableDeadLetteringOnFilterEvaluationExceptions *bool                `json:"EnableDeadLetteringOnFilterEvaluationExceptions,omitempty"`
	EnableDeadLetteringOnMessageExpiration          *bool                `json:"EnableDeadLetteringOnMessageExpiration,omitempty"`
	ForwardDeadLetteredMessagesTo                   *string              `json:"ForwardDeadLetteredMessagesTo,omitempty"`
	ForwardTo                                       *string              `json:"ForwardTo,omitempty"`
	IsReadOnly                                      *bool                `json:"IsReadOnly,omitempty"`
	LockDuration                                    *string              `json:"LockDuration,omitempty"`
	MaxDeliveryCount                                *int32               `json:"MaxDeliveryCount,omitempty"`
	MessageCount                                    *int64               `json:"MessageCount,omitempty"`
	MessageCountDetails                             *MessageCountDetails `json:"MessageCountDetails,omitempty"`
	RequiresSession                                 *bool                `json:"RequiresSession,omitempty"`
	Status                                          EntityStatus         `json:"Status,omitempty"`
	TopicPath                                       *string              `json:"TopicPath,omitempty"`
	UpdatedAt                                       *date.Time           `json:"UpdatedAt,omitempty"`
	UserMetadata                                    *string              `json:"UserMetadata,omitempty"`
}

SubscriptionProperties is description of Subscription Resource.

type SubscriptionResource

type SubscriptionResource 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"`
	Properties        *SubscriptionProperties `json:"properties,omitempty"`
}

SubscriptionResource is description of Subscription Resource.

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 SubscriptionCreateOrUpdateParameters) (result SubscriptionResource, err error)

CreateOrUpdate creates a topic subscription

resourceGroupName is the name of the resource group. namespaceName is the namespace name. topicName is the topicName name. subscriptionName is the subscriptionName 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 SubscriptionCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (SubscriptionsClient) CreateOrUpdateResponder

func (client SubscriptionsClient) CreateOrUpdateResponder(resp *http.Response) (result SubscriptionResource, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (SubscriptionsClient) CreateOrUpdateSender

func (client SubscriptionsClient) 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 (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 the name of the resource group. 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

func (client SubscriptionsClient) DeleteSender(req *http.Request) (*http.Response, error)

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 SubscriptionResource, err error)

Get returns a subscription description for the specified topic.

resourceGroupName is the name of the resource group. 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 SubscriptionResource, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (SubscriptionsClient) GetSender

func (client SubscriptionsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (SubscriptionsClient) ListAll

func (client SubscriptionsClient) ListAll(resourceGroupName string, namespaceName string, topicName string) (result SubscriptionListResult, err error)

ListAll lsit all the subscriptions under a specified topic

resourceGroupName is the name of the resource group. namespaceName is the namespace name. topicName is the topic name.

func (SubscriptionsClient) ListAllNextResults

func (client SubscriptionsClient) ListAllNextResults(lastResults SubscriptionListResult) (result SubscriptionListResult, err error)

ListAllNextResults retrieves the next set of results, if any.

func (SubscriptionsClient) ListAllPreparer

func (client SubscriptionsClient) ListAllPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)

ListAllPreparer prepares the ListAll request.

func (SubscriptionsClient) ListAllResponder

func (client SubscriptionsClient) ListAllResponder(resp *http.Response) (result SubscriptionListResult, err error)

ListAllResponder handles the response to the ListAll request. The method always closes the http.Response Body.

func (SubscriptionsClient) ListAllSender

func (client SubscriptionsClient) ListAllSender(req *http.Request) (*http.Response, error)

ListAllSender sends the ListAll request. The method will close the http.Response Body if it receives an error.

type TopicCreateOrUpdateParameters

type TopicCreateOrUpdateParameters struct {
	Name       *string          `json:"name,omitempty"`
	Location   *string          `json:"location,omitempty"`
	Properties *TopicProperties `json:"properties,omitempty"`
}

TopicCreateOrUpdateParameters is parameters supplied to the CreateOrUpdate Topic operation.

type TopicListResult

type TopicListResult struct {
	autorest.Response `json:"-"`
	Value             *[]TopicResource `json:"value,omitempty"`
	NextLink          *string          `json:"nextLink,omitempty"`
}

TopicListResult is the response of the List Topics operation.

func (TopicListResult) TopicListResultPreparer

func (client TopicListResult) TopicListResultPreparer() (*http.Request, error)

TopicListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type TopicProperties

type TopicProperties struct {
	AccessedAt                              *date.Time           `json:"AccessedAt,omitempty"`
	AutoDeleteOnIdle                        *string              `json:"AutoDeleteOnIdle,omitempty"`
	AvailabilityStatus                      AvailabilityStatus   `json:"AvailabilityStatus ,omitempty"`
	CreatedAt                               *date.Time           `json:"CreatedAt,omitempty"`
	DefaultMessageTimeToLive                *string              `json:"DefaultMessageTimeToLive,omitempty"`
	DuplicateDetectionHistoryTimeWindow     *string              `json:"DuplicateDetectionHistoryTimeWindow ,omitempty"`
	EnableBatchedOperations                 *bool                `json:"EnableBatchedOperations,omitempty"`
	EnableExpress                           *bool                `json:"EnableExpress,omitempty"`
	EnableFilteringMessagesBeforePublishing *bool                `json:"EnableFilteringMessagesBeforePublishing,omitempty"`
	EnablePartitioning                      *bool                `json:"EnablePartitioning,omitempty"`
	IsAnonymousAccessible                   *bool                `json:"IsAnonymousAccessible,omitempty"`
	MaxSizeInMegabytes                      *int64               `json:"MaxSizeInMegabytes ,omitempty"`
	MessageCountDetails                     *MessageCountDetails `json:"MessageCountDetails,omitempty"`
	Path                                    *string              `json:"Path,omitempty"`
	RequiresDuplicateDetection              *bool                `json:"RequiresDuplicateDetection,omitempty"`
	SizeInBytes                             *int64               `json:"SizeInBytes ,omitempty"`
	Status                                  EntityStatus         `json:"Status,omitempty"`
	SubscriptionCount                       *int32               `json:"SubscriptionCount,omitempty"`
	SupportOrdering                         *bool                `json:"SupportOrdering,omitempty"`
	UpdatedAt                               *date.Time           `json:"UpdatedAt,omitempty"`
	UserMetadata                            *string              `json:"UserMetadata,omitempty"`
}

TopicProperties is

type TopicResource

type TopicResource 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"`
	Properties        *TopicProperties    `json:"properties,omitempty"`
}

TopicResource is description of topic Resource.

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 TopicCreateOrUpdateParameters) (result TopicResource, err error)

CreateOrUpdate creates a topic in the specified namespace

resourceGroupName is the name of the resource group. 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 SharedAccessAuthorizationRuleCreateOrUpdateParameters) (result SharedAccessAuthorizationRuleResource, err error)

CreateOrUpdateAuthorizationRule creates an authorizatioRule for the specified topic.

resourceGroupName is the name of the resource group. namespaceName is the namespace name. topicName is the topic name. authorizationRuleName is aauthorization Rule Name. parameters is the shared access authorization rule.

func (TopicsClient) CreateOrUpdateAuthorizationRulePreparer

func (client TopicsClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters SharedAccessAuthorizationRuleCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.

func (TopicsClient) CreateOrUpdateAuthorizationRuleResponder

func (client TopicsClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRuleResource, 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 TopicCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (TopicsClient) CreateOrUpdateResponder

func (client TopicsClient) CreateOrUpdateResponder(resp *http.Response) (result TopicResource, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (TopicsClient) CreateOrUpdateSender

func (client TopicsClient) 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 (TopicsClient) Delete

func (client TopicsClient) Delete(resourceGroupName string, namespaceName string, topicName string, cancel <-chan struct{}) (result autorest.Response, err error)

Delete deletes a topic from the specified namespace and resource group. 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 the name of the resource group. namespaceName is the topics name. topicName is the topics 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 authorizationRule

resourceGroupName is the name of the resource group. namespaceName is the namespace name. topicName is the topic name. authorizationRuleName is 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

func (client TopicsClient) 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 (TopicsClient) DeletePreparer

func (client TopicsClient) DeletePreparer(resourceGroupName string, namespaceName string, topicName string, cancel <-chan struct{}) (*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

func (client TopicsClient) DeleteSender(req *http.Request) (*http.Response, error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) GetAuthorizationRule

func (client TopicsClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string, topicName string) (result SharedAccessAuthorizationRuleResource, err error)

GetAuthorizationRule returns the specified authorizationRule.

resourceGroupName is the name of the resource group. namespaceName is the namespace name authorizationRuleName is authorization rule name. topicName is the topic name.

func (TopicsClient) GetAuthorizationRulePreparer

func (client TopicsClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, topicName string) (*http.Request, error)

GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.

func (TopicsClient) GetAuthorizationRuleResponder

func (client TopicsClient) GetAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRuleResource, err error)

GetAuthorizationRuleResponder handles the response to the GetAuthorizationRule request. The method always closes the http.Response Body.

func (TopicsClient) GetAuthorizationRuleSender

func (client TopicsClient) 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 (TopicsClient) GetTopic

func (client TopicsClient) GetTopic(resourceGroupName string, namespaceName string, topicName string) (result TopicResource, err error)

GetTopic returns the description for the specified topic

resourceGroupName is the name of the resource group. namespaceName is the namespace name. topicName is the topic name.

func (TopicsClient) GetTopicPreparer

func (client TopicsClient) GetTopicPreparer(resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)

GetTopicPreparer prepares the GetTopic request.

func (TopicsClient) GetTopicResponder

func (client TopicsClient) GetTopicResponder(resp *http.Response) (result TopicResource, err error)

GetTopicResponder handles the response to the GetTopic request. The method always closes the http.Response Body.

func (TopicsClient) GetTopicSender

func (client TopicsClient) GetTopicSender(req *http.Request) (*http.Response, error)

GetTopicSender sends the GetTopic request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) ListAll

func (client TopicsClient) ListAll(resourceGroupName string, namespaceName string) (result TopicListResult, err error)

ListAll lists all the topics in a namespace.

resourceGroupName is the name of the resource group. namespaceName is the namespace name.

func (TopicsClient) ListAllNextResults

func (client TopicsClient) ListAllNextResults(lastResults TopicListResult) (result TopicListResult, err error)

ListAllNextResults retrieves the next set of results, if any.

func (TopicsClient) ListAllPreparer

func (client TopicsClient) ListAllPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)

ListAllPreparer prepares the ListAll request.

func (TopicsClient) ListAllResponder

func (client TopicsClient) ListAllResponder(resp *http.Response) (result TopicListResult, err error)

ListAllResponder handles the response to the ListAll request. The method always closes the http.Response Body.

func (TopicsClient) ListAllSender

func (client TopicsClient) ListAllSender(req *http.Request) (*http.Response, error)

ListAllSender sends the ListAll 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 SharedAccessAuthorizationRuleListResult, err error)

ListAuthorizationRules authorization rules for a topic.

resourceGroupName is the name of the resource group. namespaceName is the topic name topicName is the topic name.

func (TopicsClient) ListAuthorizationRulesNextResults

func (client TopicsClient) ListAuthorizationRulesNextResults(lastResults SharedAccessAuthorizationRuleListResult) (result SharedAccessAuthorizationRuleListResult, 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 SharedAccessAuthorizationRuleListResult, err error)

ListAuthorizationRulesResponder handles the response to the ListAuthorizationRules request. The method always closes the http.Response Body.

func (TopicsClient) ListAuthorizationRulesSender

func (client TopicsClient) 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 (TopicsClient) ListKeys

func (client TopicsClient) ListKeys(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (result ResourceListKeys, err error)

ListKeys primary and Secondary ConnectionStrings to the topic

resourceGroupName is the name of the resource group. 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 ResourceListKeys, err error)

ListKeysResponder handles the response to the ListKeys request. The method always closes the http.Response Body.

func (TopicsClient) ListKeysSender

func (client TopicsClient) ListKeysSender(req *http.Request) (*http.Response, error)

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 RegenerateKeysParameters) (result ResourceListKeys, err error)

RegenerateKeys regenerates Primary or Secondary ConnectionStrings to the topic

resourceGroupName is the name of the resource group. namespaceName is the namespace name. topicName is the topic name. authorizationRuleName is the authorizationRule name. parameters is parameters supplied to regenerate Auth Rule.

func (TopicsClient) RegenerateKeysPreparer

func (client TopicsClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters RegenerateKeysParameters) (*http.Request, error)

RegenerateKeysPreparer prepares the RegenerateKeys request.

func (TopicsClient) RegenerateKeysResponder

func (client TopicsClient) RegenerateKeysResponder(resp *http.Response) (result ResourceListKeys, err error)

RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.

func (TopicsClient) RegenerateKeysSender

func (client TopicsClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)

RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL