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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.