servicebus

package
v26.6.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2019 License: Apache-2.0 Imports: 10 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 (
	// 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 ...
	Listen AccessRights = "Listen"
	// Manage ...
	Manage AccessRights = "Manage"
	// Send ...
	Send AccessRights = "Send"
)

func PossibleAccessRightsValues 

func PossibleAccessRightsValues() []AccessRights

PossibleAccessRightsValues returns an array of possible values for the AccessRights const type.

type BaseClient 

type BaseClient struct {
	autorest.Client
	BaseURI        string
	SubscriptionID string
}

BaseClient is the base client for Servicebus.

func New 

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI 

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client.

type CheckNameAvailability 

type CheckNameAvailability struct {
	// Name - The Name to check the namespace name availability and The namespace name can contain only letters, numbers, and hyphens. The namespace must start with a letter, and it must end with a letter or number.
	Name *string `json:"name,omitempty"`
}

CheckNameAvailability description of a Check Name availability request properties.

type CheckNameAvailabilityResult 

type CheckNameAvailabilityResult struct {
	autorest.Response `json:"-"`
	// NameAvailable - Value indicating namespace is availability, true if the namespace is available; otherwise, false.
	NameAvailable *bool `json:"nameAvailable,omitempty"`
	// Reason - The reason for unavailability of a namespace. Possible values include: 'None', 'InvalidName', 'SubscriptionIsDisabled', 'NameInUse', 'NameInLockdown', 'TooManyNamespaceInCurrentSubscription'
	Reason UnavailableReason `json:"reason,omitempty"`
	// Message - The detailed info regarding the reason associated with the namespace.
	Message *string `json:"message,omitempty"`
}

CheckNameAvailabilityResult description of a Check Name availability request properties.

type EntityAvailabilityStatus 

type EntityAvailabilityStatus string

EntityAvailabilityStatus enumerates the values for entity availability status. 

const (
	// Available ...
	Available EntityAvailabilityStatus = "Available"
	// Limited ...
	Limited EntityAvailabilityStatus = "Limited"
	// Renaming ...
	Renaming EntityAvailabilityStatus = "Renaming"
	// Restoring ...
	Restoring EntityAvailabilityStatus = "Restoring"
	// Unknown ...
	Unknown EntityAvailabilityStatus = "Unknown"
)

func PossibleEntityAvailabilityStatusValues 

func PossibleEntityAvailabilityStatusValues() []EntityAvailabilityStatus

PossibleEntityAvailabilityStatusValues returns an array of possible values for the EntityAvailabilityStatus const type.

type EntityStatus 

type EntityStatus string

EntityStatus enumerates the values for entity status. 

const (
	// EntityStatusActive ...
	EntityStatusActive EntityStatus = "Active"
	// EntityStatusCreating ...
	EntityStatusCreating EntityStatus = "Creating"
	// EntityStatusDeleting ...
	EntityStatusDeleting EntityStatus = "Deleting"
	// EntityStatusDisabled ...
	EntityStatusDisabled EntityStatus = "Disabled"
	// EntityStatusReceiveDisabled ...
	EntityStatusReceiveDisabled EntityStatus = "ReceiveDisabled"
	// EntityStatusRenaming ...
	EntityStatusRenaming EntityStatus = "Renaming"
	// EntityStatusRestoring ...
	EntityStatusRestoring EntityStatus = "Restoring"
	// EntityStatusSendDisabled ...
	EntityStatusSendDisabled EntityStatus = "SendDisabled"
	// EntityStatusUnknown ...
	EntityStatusUnknown EntityStatus = "Unknown"
)

func PossibleEntityStatusValues 

func PossibleEntityStatusValues() []EntityStatus

PossibleEntityStatusValues returns an array of possible values for the EntityStatus const type.

type MessageCountDetails 

type MessageCountDetails struct {
	// ActiveMessageCount - Number of active messages in the queue, topic, or subscription.
	ActiveMessageCount *int64 `json:"activeMessageCount,omitempty"`
	// DeadLetterMessageCount - Number of messages that are dead lettered.
	DeadLetterMessageCount *int64 `json:"deadLetterMessageCount,omitempty"`
	// ScheduledMessageCount - Number of scheduled messages.
	ScheduledMessageCount *int64 `json:"scheduledMessageCount,omitempty"`
	// TransferDeadLetterMessageCount - Number of messages transferred into dead letters.
	TransferDeadLetterMessageCount *int64 `json:"transferDeadLetterMessageCount,omitempty"`
	// TransferMessageCount - Number of messages transferred to another queue, topic, or subscription.
	TransferMessageCount *int64 `json:"transferMessageCount,omitempty"`
}

MessageCountDetails message Count Details.

type NamespaceCreateOrUpdateParameters 

type NamespaceCreateOrUpdateParameters struct {
	// Location - Namespace location.
	Location *string `json:"location,omitempty"`
	Sku      *Sku    `json:"sku,omitempty"`
	// Tags - Namespace tags.
	Tags                 map[string]*string `json:"tags"`
	*NamespaceProperties `json:"properties,omitempty"`
}

NamespaceCreateOrUpdateParameters parameters supplied to the Create Or Update Namespace operation.

func (NamespaceCreateOrUpdateParameters) MarshalJSON 

func (ncoup NamespaceCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for NamespaceCreateOrUpdateParameters.

func (*NamespaceCreateOrUpdateParameters) UnmarshalJSON 

func (ncoup *NamespaceCreateOrUpdateParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for NamespaceCreateOrUpdateParameters struct.

type NamespaceListResult 

type NamespaceListResult struct {
	autorest.Response `json:"-"`
	// Value - Result of the List Namespace operation.
	Value *[]NamespaceResource `json:"value,omitempty"`
	// NextLink - Link to the next set of results. Not empty if Value contains incomplete list of Namespaces.
	NextLink *string `json:"nextLink,omitempty"`
}

NamespaceListResult the response of the List Namespace operation.

func (NamespaceListResult) IsEmpty 

func (nlr NamespaceListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type NamespaceListResultIterator 

type NamespaceListResultIterator struct {
	// contains filtered or unexported fields
}

NamespaceListResultIterator provides access to a complete listing of NamespaceResource values.

func NewNamespaceListResultIterator 

func NewNamespaceListResultIterator(page NamespaceListResultPage) NamespaceListResultIterator

Creates a new instance of the NamespaceListResultIterator type.

func (*NamespaceListResultIterator) Next 

func (iter *NamespaceListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*NamespaceListResultIterator) NextWithContext 

func (iter *NamespaceListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (NamespaceListResultIterator) NotDone 

func (iter NamespaceListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (NamespaceListResultIterator) Response 

func (iter NamespaceListResultIterator) Response() NamespaceListResult

Response returns the raw server response from the last page request.

func (NamespaceListResultIterator) Value 

func (iter NamespaceListResultIterator) Value() NamespaceResource

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type NamespaceListResultPage 

type NamespaceListResultPage struct {
	// contains filtered or unexported fields
}

NamespaceListResultPage contains a page of NamespaceResource values.

func NewNamespaceListResultPage 

func NewNamespaceListResultPage(getNextPage func(context.Context, NamespaceListResult) (NamespaceListResult, error)) NamespaceListResultPage

Creates a new instance of the NamespaceListResultPage type.

func (*NamespaceListResultPage) Next 

func (page *NamespaceListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*NamespaceListResultPage) NextWithContext 

func (page *NamespaceListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (NamespaceListResultPage) NotDone 

func (page NamespaceListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (NamespaceListResultPage) Response 

func (page NamespaceListResultPage) Response() NamespaceListResult

Response returns the raw server response from the last page request.

func (NamespaceListResultPage) Values 

func (page NamespaceListResultPage) Values() []NamespaceResource

Values returns the slice of values for the current page or nil if there are no values.

type NamespaceProperties 

type NamespaceProperties struct {
	// ProvisioningState - Provisioning state of the namespace.
	ProvisioningState *string `json:"provisioningState,omitempty"`
	// Status - State of the namespace. Possible values include: 'NamespaceStateUnknown', 'NamespaceStateCreating', 'NamespaceStateCreated', 'NamespaceStateActivating', 'NamespaceStateEnabling', 'NamespaceStateActive', 'NamespaceStateDisabling', 'NamespaceStateDisabled', 'NamespaceStateSoftDeleting', 'NamespaceStateSoftDeleted', 'NamespaceStateRemoving', 'NamespaceStateRemoved', 'NamespaceStateFailed'
	Status NamespaceState `json:"status,omitempty"`
	// CreatedAt - The time the namespace was created.
	CreatedAt *date.Time `json:"createdAt,omitempty"`
	// UpdatedAt - The time the namespace was updated.
	UpdatedAt *date.Time `json:"updatedAt,omitempty"`
	// ServiceBusEndpoint - Endpoint you can use to perform Service Bus operations.
	ServiceBusEndpoint *string `json:"serviceBusEndpoint,omitempty"`
	// CreateACSNamespace - Indicates whether to create an ACS namespace.
	CreateACSNamespace *bool `json:"createACSNamespace,omitempty"`
	// Enabled - Specifies whether this instance is enabled.
	Enabled *bool `json:"enabled,omitempty"`
}

NamespaceProperties properties of the namespace.

type NamespaceResource 

type NamespaceResource struct {
	autorest.Response    `json:"-"`
	Sku                  *Sku `json:"sku,omitempty"`
	*NamespaceProperties `json:"properties,omitempty"`
	// Tags - Resource tags
	Tags map[string]*string `json:"tags"`
	// ID - Resource Id
	ID *string `json:"id,omitempty"`
	// Name - Resource name
	Name *string `json:"name,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Type - Resource type
	Type *string `json:"type,omitempty"`
}

NamespaceResource description of a namespace resource.

func (NamespaceResource) MarshalJSON 

func (nr NamespaceResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for NamespaceResource.

func (*NamespaceResource) UnmarshalJSON 

func (nr *NamespaceResource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for NamespaceResource struct.

type NamespaceState 

type NamespaceState string

NamespaceState enumerates the values for namespace state. 

const (
	// NamespaceStateActivating ...
	NamespaceStateActivating NamespaceState = "Activating"
	// NamespaceStateActive ...
	NamespaceStateActive NamespaceState = "Active"
	// NamespaceStateCreated ...
	NamespaceStateCreated NamespaceState = "Created"
	// NamespaceStateCreating ...
	NamespaceStateCreating NamespaceState = "Creating"
	// NamespaceStateDisabled ...
	NamespaceStateDisabled NamespaceState = "Disabled"
	// NamespaceStateDisabling ...
	NamespaceStateDisabling NamespaceState = "Disabling"
	// NamespaceStateEnabling ...
	NamespaceStateEnabling NamespaceState = "Enabling"
	// NamespaceStateFailed ...
	NamespaceStateFailed NamespaceState = "Failed"
	// NamespaceStateRemoved ...
	NamespaceStateRemoved NamespaceState = "Removed"
	// NamespaceStateRemoving ...
	NamespaceStateRemoving NamespaceState = "Removing"
	// NamespaceStateSoftDeleted ...
	NamespaceStateSoftDeleted NamespaceState = "SoftDeleted"
	// NamespaceStateSoftDeleting ...
	NamespaceStateSoftDeleting NamespaceState = "SoftDeleting"
	// NamespaceStateUnknown ...
	NamespaceStateUnknown NamespaceState = "Unknown"
)

func PossibleNamespaceStateValues 

func PossibleNamespaceStateValues() []NamespaceState

PossibleNamespaceStateValues returns an array of possible values for the NamespaceState const type.

type NamespaceUpdateParameters 

type NamespaceUpdateParameters struct {
	// Tags - Resource tags
	Tags map[string]*string `json:"tags"`
	// Sku - The sku of the created namespace
	Sku *Sku `json:"sku,omitempty"`
}

NamespaceUpdateParameters parameters supplied to the Patch Namespace operation.

func (NamespaceUpdateParameters) MarshalJSON 

func (nup NamespaceUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for NamespaceUpdateParameters.

type NamespacesClient 

type NamespacesClient struct {
	BaseClient
}

NamespacesClient is the azure Service Bus client

func NewNamespacesClient 

func NewNamespacesClient(subscriptionID string) NamespacesClient

NewNamespacesClient creates an instance of the NamespacesClient client.

func NewNamespacesClientWithBaseURI 

func NewNamespacesClientWithBaseURI(baseURI string, subscriptionID string) NamespacesClient

NewNamespacesClientWithBaseURI creates an instance of the NamespacesClient client.

func (NamespacesClient) CheckNameAvailabilityMethod 

func (client NamespacesClient) CheckNameAvailabilityMethod(ctx context.Context, parameters CheckNameAvailability) (result CheckNameAvailabilityResult, err error)

CheckNameAvailabilityMethod check the give namespace name availability. Parameters: parameters - parameters to check availability of the given namespace name

func (NamespacesClient) CheckNameAvailabilityMethodPreparer 

func (client NamespacesClient) CheckNameAvailabilityMethodPreparer(ctx context.Context, parameters CheckNameAvailability) (*http.Request, error)

CheckNameAvailabilityMethodPreparer prepares the CheckNameAvailabilityMethod request.

func (NamespacesClient) CheckNameAvailabilityMethodResponder 

func (client NamespacesClient) CheckNameAvailabilityMethodResponder(resp *http.Response) (result CheckNameAvailabilityResult, err error)

CheckNameAvailabilityMethodResponder handles the response to the CheckNameAvailabilityMethod request. The method always closes the http.Response Body.

func (NamespacesClient) CheckNameAvailabilityMethodSender 

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

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

func (NamespacesClient) CreateOrUpdate 

func (client NamespacesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, parameters NamespaceCreateOrUpdateParameters) (result NamespacesCreateOrUpdateFuture, err error)

CreateOrUpdate creates or updates a service namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name. parameters - parameters supplied to create a namespace resource.

func (NamespacesClient) CreateOrUpdateAuthorizationRule 

func (client NamespacesClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters SharedAccessAuthorizationRuleCreateOrUpdateParameters) (result SharedAccessAuthorizationRuleResource, err error)

CreateOrUpdateAuthorizationRule creates or updates an authorization rule for a namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name authorizationRuleName - the authorization rule name. parameters - the shared access authorization rule.

func (NamespacesClient) CreateOrUpdateAuthorizationRulePreparer 

func (client NamespacesClient) CreateOrUpdateAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, parameters NamespaceCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (NamespacesClient) CreateOrUpdateResponder 

func (client NamespacesClient) CreateOrUpdateResponder(resp *http.Response) (result NamespaceResource, 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) (future NamespacesCreateOrUpdateFuture, err 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(ctx context.Context, resourceGroupName string, namespaceName string) (result NamespacesDeleteFuture, err error)

Delete deletes an existing namespace. This operation also removes all associated resources under the namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name

func (NamespacesClient) DeleteAuthorizationRule 

func (client NamespacesClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string) (result autorest.Response, err error)

DeleteAuthorizationRule deletes a namespace authorization rule. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name authorizationRuleName - the authorization rule name.

func (NamespacesClient) DeleteAuthorizationRulePreparer 

func (client NamespacesClient) DeleteAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string) (*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) (future NamespacesDeleteFuture, err 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(ctx context.Context, resourceGroupName string, namespaceName string) (result NamespaceResource, err error)

Get gets a description for the specified namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name

func (NamespacesClient) GetAuthorizationRule 

func (client NamespacesClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string) (result SharedAccessAuthorizationRuleResource, err error)

GetAuthorizationRule gets an authorization rule for a namespace by rule name. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name authorizationRuleName - the authorization rule name.

func (NamespacesClient) GetAuthorizationRulePreparer 

func (client NamespacesClient) GetAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string) (result SharedAccessAuthorizationRuleListResultPage, err error)

ListAuthorizationRules gets the authorization rules for a namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name

func (NamespacesClient) ListAuthorizationRulesComplete 

func (client NamespacesClient) ListAuthorizationRulesComplete(ctx context.Context, resourceGroupName string, namespaceName string) (result SharedAccessAuthorizationRuleListResultIterator, err error)

ListAuthorizationRulesComplete enumerates all values, automatically crossing page boundaries as required.

func (NamespacesClient) ListAuthorizationRulesPreparer 

func (client NamespacesClient) ListAuthorizationRulesPreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string) (result NamespaceListResultPage, err error)

ListByResourceGroup gets the available namespaces within a resource group. Parameters: resourceGroupName - name of the Resource group within the Azure subscription.

func (NamespacesClient) ListByResourceGroupComplete 

func (client NamespacesClient) ListByResourceGroupComplete(ctx context.Context, resourceGroupName string) (result NamespaceListResultIterator, err error)

ListByResourceGroupComplete enumerates all values, automatically crossing page boundaries as required.

func (NamespacesClient) ListByResourceGroupPreparer 

func (client NamespacesClient) ListByResourceGroupPreparer(ctx context.Context, 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(ctx context.Context) (result NamespaceListResultPage, err error)

ListBySubscription gets all the available namespaces within the subscription, irrespective of the resource groups.

func (NamespacesClient) ListBySubscriptionComplete 

func (client NamespacesClient) ListBySubscriptionComplete(ctx context.Context) (result NamespaceListResultIterator, err error)

ListBySubscriptionComplete enumerates all values, automatically crossing page boundaries as required.

func (NamespacesClient) ListBySubscriptionPreparer 

func (client NamespacesClient) ListBySubscriptionPreparer(ctx context.Context) (*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(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string) (result ResourceListKeys, err error)

ListKeys gets the primary and secondary connection strings for the namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name authorizationRuleName - the authorization rule name.

func (NamespacesClient) ListKeysPreparer 

func (client NamespacesClient) ListKeysPreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateKeysParameters) (result ResourceListKeys, err error)

RegenerateKeys regenerates the primary or secondary connection strings for the namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name authorizationRuleName - the authorization rule name. parameters - parameters supplied to regenerate the authorization rule.

func (NamespacesClient) RegenerateKeysPreparer 

func (client NamespacesClient) RegenerateKeysPreparer(ctx context.Context, 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.

func (NamespacesClient) Update 

func (client NamespacesClient) Update(ctx context.Context, resourceGroupName string, namespaceName string, parameters NamespaceUpdateParameters) (result NamespaceResource, err error)

Update updates a service namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name parameters - parameters supplied to update a namespace resource.

func (NamespacesClient) UpdatePreparer 

func (client NamespacesClient) UpdatePreparer(ctx context.Context, resourceGroupName string, namespaceName string, parameters NamespaceUpdateParameters) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (NamespacesClient) UpdateResponder 

func (client NamespacesClient) UpdateResponder(resp *http.Response) (result NamespaceResource, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (NamespacesClient) UpdateSender 

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

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

type NamespacesCreateOrUpdateFuture 

type NamespacesCreateOrUpdateFuture struct {
	azure.Future
}

NamespacesCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*NamespacesCreateOrUpdateFuture) Result 

func (future *NamespacesCreateOrUpdateFuture) Result(client NamespacesClient) (nr NamespaceResource, err error)

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type NamespacesDeleteFuture 

type NamespacesDeleteFuture struct {
	azure.Future
}

NamespacesDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*NamespacesDeleteFuture) Result 

func (future *NamespacesDeleteFuture) Result(client NamespacesClient) (ar autorest.Response, err error)

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type Operation 

type Operation struct {
	// Name - Operation name: {provider}/{resource}/{operation}
	Name *string `json:"name,omitempty"`
	// Display - The object that represents the operation.
	Display *OperationDisplay `json:"display,omitempty"`
}

Operation a ServiceBus REST API operation

type OperationDisplay 

type OperationDisplay struct {
	// Provider - Service provider: Microsoft.ServiceBus
	Provider *string `json:"provider,omitempty"`
	// Resource - Resource on which the operation is performed: Invoice, etc.
	Resource *string `json:"resource,omitempty"`
	// Operation - Operation type: Read, write, delete, etc.
	Operation *string `json:"operation,omitempty"`
}

OperationDisplay the object that represents the operation.

type OperationListResult 

type OperationListResult struct {
	autorest.Response `json:"-"`
	// Value - List of ServiceBus operations supported by the Microsoft.ServiceBus resource provider.
	Value *[]Operation `json:"value,omitempty"`
	// NextLink - URL to get the next set of operation list results if there are any.
	NextLink *string `json:"nextLink,omitempty"`
}

OperationListResult result of the request to list ServiceBus operations. It contains a list of operations and a URL link to get the next set of results.

func (OperationListResult) IsEmpty 

func (olr OperationListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type OperationListResultIterator 

type OperationListResultIterator struct {
	// contains filtered or unexported fields
}

OperationListResultIterator provides access to a complete listing of Operation values.

func NewOperationListResultIterator 

func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator

Creates a new instance of the OperationListResultIterator type.

func (*OperationListResultIterator) Next 

func (iter *OperationListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultIterator) NextWithContext 

func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (OperationListResultIterator) NotDone 

func (iter OperationListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (OperationListResultIterator) Response 

func (iter OperationListResultIterator) Response() OperationListResult

Response returns the raw server response from the last page request.

func (OperationListResultIterator) Value 

func (iter OperationListResultIterator) Value() Operation

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type OperationListResultPage 

type OperationListResultPage struct {
	// contains filtered or unexported fields
}

OperationListResultPage contains a page of Operation values.

func NewOperationListResultPage 

func NewOperationListResultPage(getNextPage func(context.Context, OperationListResult) (OperationListResult, error)) OperationListResultPage

Creates a new instance of the OperationListResultPage type.

func (*OperationListResultPage) Next 

func (page *OperationListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultPage) NextWithContext 

func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (OperationListResultPage) NotDone 

func (page OperationListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (OperationListResultPage) Response 

func (page OperationListResultPage) Response() OperationListResult

Response returns the raw server response from the last page request.

func (OperationListResultPage) Values 

func (page OperationListResultPage) Values() []Operation

Values returns the slice of values for the current page or nil if there are no values.

type OperationsClient 

type OperationsClient struct {
	BaseClient
}

OperationsClient is the azure Service Bus client

func NewOperationsClient 

func NewOperationsClient(subscriptionID string) OperationsClient

NewOperationsClient creates an instance of the OperationsClient client.

func NewOperationsClientWithBaseURI 

func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient

NewOperationsClientWithBaseURI creates an instance of the OperationsClient client.

func (OperationsClient) List 

func (client OperationsClient) List(ctx context.Context) (result OperationListResultPage, err error)

List lists all of the available ServiceBus REST API operations.

func (OperationsClient) ListComplete 

func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error)

ListComplete enumerates all values, automatically crossing page boundaries as required.

func (OperationsClient) ListPreparer 

func (client OperationsClient) ListPreparer(ctx context.Context) (*http.Request, error)

ListPreparer prepares the List request.

func (OperationsClient) ListResponder 

func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (OperationsClient) ListSender 

func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List 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 ...
	PrimaryKey Policykey = "PrimaryKey"
	// SecondaryKey ...
	SecondaryKey Policykey = "SecondaryKey"
)

func PossiblePolicykeyValues 

func PossiblePolicykeyValues() []Policykey

PossiblePolicykeyValues returns an array of possible values for the Policykey const type.

type QueueCreateOrUpdateParameters 

type QueueCreateOrUpdateParameters struct {
	// Name - Queue name.
	Name *string `json:"name,omitempty"`
	// Location - location of the resource.
	Location         *string `json:"location,omitempty"`
	*QueueProperties `json:"properties,omitempty"`
}

QueueCreateOrUpdateParameters parameters supplied to the Create Or Update Queue operation.

func (QueueCreateOrUpdateParameters) MarshalJSON 

func (qcoup QueueCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for QueueCreateOrUpdateParameters.

func (*QueueCreateOrUpdateParameters) UnmarshalJSON 

func (qcoup *QueueCreateOrUpdateParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for QueueCreateOrUpdateParameters struct.

type QueueListResult 

type QueueListResult struct {
	autorest.Response `json:"-"`
	// Value - Result of the List Queues operation.
	Value *[]QueueResource `json:"value,omitempty"`
	// NextLink - Link to the next set of results. Not empty if Value contains incomplete list of queues.
	NextLink *string `json:"nextLink,omitempty"`
}

QueueListResult the response to the List Queues operation.

func (QueueListResult) IsEmpty 

func (qlr QueueListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type QueueListResultIterator 

type QueueListResultIterator struct {
	// contains filtered or unexported fields
}

QueueListResultIterator provides access to a complete listing of QueueResource values.

func NewQueueListResultIterator 

func NewQueueListResultIterator(page QueueListResultPage) QueueListResultIterator

Creates a new instance of the QueueListResultIterator type.

func (*QueueListResultIterator) Next 

func (iter *QueueListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*QueueListResultIterator) NextWithContext 

func (iter *QueueListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (QueueListResultIterator) NotDone 

func (iter QueueListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (QueueListResultIterator) Response 

func (iter QueueListResultIterator) Response() QueueListResult

Response returns the raw server response from the last page request.

func (QueueListResultIterator) Value 

func (iter QueueListResultIterator) Value() QueueResource

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type QueueListResultPage 

type QueueListResultPage struct {
	// contains filtered or unexported fields
}

QueueListResultPage contains a page of QueueResource values.

func NewQueueListResultPage 

func NewQueueListResultPage(getNextPage func(context.Context, QueueListResult) (QueueListResult, error)) QueueListResultPage

Creates a new instance of the QueueListResultPage type.

func (*QueueListResultPage) Next 

func (page *QueueListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*QueueListResultPage) NextWithContext 

func (page *QueueListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (QueueListResultPage) NotDone 

func (page QueueListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (QueueListResultPage) Response 

func (page QueueListResultPage) Response() QueueListResult

Response returns the raw server response from the last page request.

func (QueueListResultPage) Values 

func (page QueueListResultPage) Values() []QueueResource

Values returns the slice of values for the current page or nil if there are no values.

type QueueProperties 

type QueueProperties struct {
	// LockDuration - The duration of a peek-lock; that is, the amount of time that the message is locked for other receivers. The maximum value for LockDuration is 5 minutes; the default value is 1 minute.
	LockDuration *string `json:"lockDuration,omitempty"`
	// AccessedAt - Last time a message was sent, or the last time there was a receive request to this queue.
	AccessedAt *date.Time `json:"accessedAt,omitempty"`
	// AutoDeleteOnIdle - the TimeSpan idle interval after which the queue is automatically deleted. The minimum duration is 5 minutes.
	AutoDeleteOnIdle *string `json:"autoDeleteOnIdle,omitempty"`
	// EntityAvailabilityStatus - Entity availability status for the queue. Possible values include: 'Available', 'Limited', 'Renaming', 'Restoring', 'Unknown'
	EntityAvailabilityStatus EntityAvailabilityStatus `json:"entityAvailabilityStatus,omitempty"`
	// CreatedAt - The exact time the message was created.
	CreatedAt *date.Time `json:"createdAt,omitempty"`
	// DefaultMessageTimeToLive - The default message time to live value. This is the duration after which the message expires, starting from when the message is sent to Service Bus. This is the default value used when TimeToLive is not set on a message itself.
	DefaultMessageTimeToLive *string `json:"defaultMessageTimeToLive,omitempty"`
	// DuplicateDetectionHistoryTimeWindow - TimeSpan structure that defines the duration of the duplicate detection history. The default value is 10 minutes.
	DuplicateDetectionHistoryTimeWindow *string `json:"duplicateDetectionHistoryTimeWindow,omitempty"`
	// EnableBatchedOperations - A value that indicates whether server-side batched operations are enabled.
	EnableBatchedOperations *bool `json:"enableBatchedOperations,omitempty"`
	// DeadLetteringOnMessageExpiration - A value that indicates whether this queue has dead letter support when a message expires.
	DeadLetteringOnMessageExpiration *bool `json:"deadLetteringOnMessageExpiration,omitempty"`
	// EnableExpress - A value that indicates whether Express Entities are enabled. An express queue holds a message in memory temporarily before writing it to persistent storage.
	EnableExpress *bool `json:"enableExpress,omitempty"`
	// EnablePartitioning - A value that indicates whether the queue is to be partitioned across multiple message brokers.
	EnablePartitioning *bool `json:"enablePartitioning,omitempty"`
	// IsAnonymousAccessible - A value that indicates whether the message is accessible anonymously.
	IsAnonymousAccessible *bool `json:"isAnonymousAccessible,omitempty"`
	// MaxDeliveryCount - The maximum delivery count. A message is automatically deadlettered after this number of deliveries.
	MaxDeliveryCount *int32 `json:"maxDeliveryCount,omitempty"`
	// MaxSizeInMegabytes - The maximum size of the queue in megabytes, which is the size of memory allocated for the queue.
	MaxSizeInMegabytes *int64 `json:"maxSizeInMegabytes,omitempty"`
	// MessageCount - The number of messages in the queue.
	MessageCount *int64               `json:"messageCount,omitempty"`
	CountDetails *MessageCountDetails `json:"countDetails,omitempty"`
	// RequiresDuplicateDetection - A value indicating if this queue requires duplicate detection.
	RequiresDuplicateDetection *bool `json:"requiresDuplicateDetection,omitempty"`
	// RequiresSession - A value that indicates whether the queue supports the concept of sessions.
	RequiresSession *bool `json:"requiresSession,omitempty"`
	// SizeInBytes - The size of the queue, in bytes.
	SizeInBytes *int64 `json:"sizeInBytes,omitempty"`
	// Status - Enumerates the possible values for the status of a messaging entity. Possible values include: 'EntityStatusActive', 'EntityStatusCreating', 'EntityStatusDeleting', 'EntityStatusDisabled', 'EntityStatusReceiveDisabled', 'EntityStatusRenaming', 'EntityStatusRestoring', 'EntityStatusSendDisabled', 'EntityStatusUnknown'
	Status EntityStatus `json:"status,omitempty"`
	// SupportOrdering - A value that indicates whether the queue supports ordering.
	SupportOrdering *bool `json:"supportOrdering,omitempty"`
	// UpdatedAt - The exact time the message was updated.
	UpdatedAt *date.Time `json:"updatedAt,omitempty"`
}

QueueProperties the Queue Properties definition.

type QueueResource 

type QueueResource struct {
	autorest.Response `json:"-"`
	*QueueProperties  `json:"properties,omitempty"`
	// ID - Resource Id
	ID *string `json:"id,omitempty"`
	// Name - Resource name
	Name *string `json:"name,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Type - Resource type
	Type *string `json:"type,omitempty"`
}

QueueResource description of queue Resource.

func (QueueResource) MarshalJSON 

func (qr QueueResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for QueueResource.

func (*QueueResource) UnmarshalJSON 

func (qr *QueueResource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for QueueResource struct.

type QueuesClient 

type QueuesClient struct {
	BaseClient
}

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(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, parameters QueueCreateOrUpdateParameters) (result QueueResource, err error)

CreateOrUpdate creates or updates a Service Bus queue. This operation is idempotent. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name. parameters - parameters supplied to create or update a queue resource.

func (QueuesClient) CreateOrUpdateAuthorizationRule 

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

CreateOrUpdateAuthorizationRule creates an authorization rule for a queue. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name. authorizationRuleName - the authorization rule name. parameters - the shared access authorization rule.

func (QueuesClient) CreateOrUpdateAuthorizationRulePreparer 

func (client QueuesClient) CreateOrUpdateAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, queueName string) (result autorest.Response, err error)

Delete deletes a queue from the specified namespace in a resource group. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name.

func (QueuesClient) DeleteAuthorizationRule 

func (client QueuesClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result autorest.Response, err error)

DeleteAuthorizationRule deletes a queue authorization rule. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name. authorizationRuleName - the authorization rule name.

func (QueuesClient) DeleteAuthorizationRulePreparer 

func (client QueuesClient) DeleteAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, queueName string) (result QueueResource, err error)

Get returns a description for the specified queue. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name.

func (QueuesClient) GetAuthorizationRule 

func (client QueuesClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result SharedAccessAuthorizationRuleResource, err error)

GetAuthorizationRule gets an authorization rule for a queue by rule name. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name. authorizationRuleName - the authorization rule name.

func (QueuesClient) GetAuthorizationRulePreparer 

func (client QueuesClient) GetAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string) (result QueueListResultPage, err error)

ListAll gets the queues within a namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name

func (QueuesClient) ListAllComplete 

func (client QueuesClient) ListAllComplete(ctx context.Context, resourceGroupName string, namespaceName string) (result QueueListResultIterator, err error)

ListAllComplete enumerates all values, automatically crossing page boundaries as required.

func (QueuesClient) ListAllPreparer 

func (client QueuesClient) ListAllPreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, queueName string) (result SharedAccessAuthorizationRuleListResultPage, err error)

ListAuthorizationRules gets all authorization rules for a queue. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name.

func (QueuesClient) ListAuthorizationRulesComplete 

func (client QueuesClient) ListAuthorizationRulesComplete(ctx context.Context, resourceGroupName string, namespaceName string, queueName string) (result SharedAccessAuthorizationRuleListResultIterator, err error)

ListAuthorizationRulesComplete enumerates all values, automatically crossing page boundaries as required.

func (QueuesClient) ListAuthorizationRulesPreparer 

func (client QueuesClient) ListAuthorizationRulesPreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result ResourceListKeys, err error)

ListKeys primary and secondary connection strings to the queue. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name. authorizationRuleName - the authorization rule name.

func (QueuesClient) ListKeysPreparer 

func (client QueuesClient) ListKeysPreparer(ctx context.Context, 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) PostAuthorizationRule 

func (client QueuesClient) PostAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (result SharedAccessAuthorizationRuleResource, err error)

PostAuthorizationRule gets an authorization rule for a queue by rule name. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name. authorizationRuleName - the authorization rule name.

func (QueuesClient) PostAuthorizationRulePreparer 

func (client QueuesClient) PostAuthorizationRulePreparer(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string) (*http.Request, error)

PostAuthorizationRulePreparer prepares the PostAuthorizationRule request.

func (QueuesClient) PostAuthorizationRuleResponder 

func (client QueuesClient) PostAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRuleResource, err error)

PostAuthorizationRuleResponder handles the response to the PostAuthorizationRule request. The method always closes the http.Response Body.

func (QueuesClient) PostAuthorizationRuleSender 

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

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

func (QueuesClient) RegenerateKeys 

func (client QueuesClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, queueName string, authorizationRuleName string, parameters RegenerateKeysParameters) (result ResourceListKeys, err error)

RegenerateKeys regenerates the primary or secondary connection strings to the queue. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name queueName - the queue name. authorizationRuleName - the authorization rule name. parameters - parameters supplied to regenerate the authorization rule.

func (QueuesClient) RegenerateKeysPreparer 

func (client QueuesClient) RegenerateKeysPreparer(ctx context.Context, 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 - Key that needs to be regenerated. Possible values include: 'PrimaryKey', 'SecondaryKey'
	Policykey Policykey `json:"Policykey,omitempty"`
}

RegenerateKeysParameters parameters supplied to the Regenerate Authorization Rule operation.

type Resource 

type Resource struct {
	// ID - Resource Id
	ID *string `json:"id,omitempty"`
	// Name - Resource name
	Name *string `json:"name,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Type - Resource type
	Type *string `json:"type,omitempty"`
}

Resource the Resource definition for other than namespace.

type ResourceListKeys 

type ResourceListKeys struct {
	autorest.Response `json:"-"`
	// PrimaryConnectionString - Primary connection string of the created namespace authorization rule.
	PrimaryConnectionString *string `json:"primaryConnectionString,omitempty"`
	// SecondaryConnectionString - Secondary connection string of the created namespace authorization rule.
	SecondaryConnectionString *string `json:"secondaryConnectionString,omitempty"`
	// PrimaryKey - A base64-encoded 256-bit primary key for signing and validating the SAS token.
	PrimaryKey *string `json:"primaryKey,omitempty"`
	// SecondaryKey - A base64-encoded 256-bit primary key for signing and validating the SAS token.
	SecondaryKey *string `json:"secondaryKey,omitempty"`
	// KeyName - A string that describes the authorization rule.
	KeyName *string `json:"keyName,omitempty"`
}

ResourceListKeys namespace/ServiceBus Connection String

type SharedAccessAuthorizationRuleCreateOrUpdateParameters 

type SharedAccessAuthorizationRuleCreateOrUpdateParameters struct {
	// Location - data center location.
	Location *string `json:"location,omitempty"`
	// Name - Name of the authorization rule.
	Name                                     *string `json:"name,omitempty"`
	*SharedAccessAuthorizationRuleProperties `json:"properties,omitempty"`
}

SharedAccessAuthorizationRuleCreateOrUpdateParameters parameters supplied to the Create Or Update Authorization Rules operation.

func (SharedAccessAuthorizationRuleCreateOrUpdateParameters) MarshalJSON 

func (saarcoup SharedAccessAuthorizationRuleCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SharedAccessAuthorizationRuleCreateOrUpdateParameters.

func (*SharedAccessAuthorizationRuleCreateOrUpdateParameters) UnmarshalJSON 

func (saarcoup *SharedAccessAuthorizationRuleCreateOrUpdateParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for SharedAccessAuthorizationRuleCreateOrUpdateParameters struct.

type SharedAccessAuthorizationRuleListResult 

type SharedAccessAuthorizationRuleListResult struct {
	autorest.Response `json:"-"`
	// Value - Result of the List Authorization Rules operation.
	Value *[]SharedAccessAuthorizationRuleResource `json:"value,omitempty"`
	// NextLink - Link to the next set of results. Not empty if Value contains incomplete list of Authorization Rules.
	NextLink *string `json:"nextLink,omitempty"`
}

SharedAccessAuthorizationRuleListResult the response to the List Namespace operation.

func (SharedAccessAuthorizationRuleListResult) IsEmpty 

func (saarlr SharedAccessAuthorizationRuleListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type SharedAccessAuthorizationRuleListResultIterator 

type SharedAccessAuthorizationRuleListResultIterator struct {
	// contains filtered or unexported fields
}

SharedAccessAuthorizationRuleListResultIterator provides access to a complete listing of SharedAccessAuthorizationRuleResource values.

func NewSharedAccessAuthorizationRuleListResultIterator 

func NewSharedAccessAuthorizationRuleListResultIterator(page SharedAccessAuthorizationRuleListResultPage) SharedAccessAuthorizationRuleListResultIterator

Creates a new instance of the SharedAccessAuthorizationRuleListResultIterator type.

func (*SharedAccessAuthorizationRuleListResultIterator) Next 

func (iter *SharedAccessAuthorizationRuleListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*SharedAccessAuthorizationRuleListResultIterator) NextWithContext 

func (iter *SharedAccessAuthorizationRuleListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (SharedAccessAuthorizationRuleListResultIterator) NotDone 

func (iter SharedAccessAuthorizationRuleListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (SharedAccessAuthorizationRuleListResultIterator) Response 

func (iter SharedAccessAuthorizationRuleListResultIterator) Response() SharedAccessAuthorizationRuleListResult

Response returns the raw server response from the last page request.

func (SharedAccessAuthorizationRuleListResultIterator) Value 

func (iter SharedAccessAuthorizationRuleListResultIterator) Value() SharedAccessAuthorizationRuleResource

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type SharedAccessAuthorizationRuleListResultPage 

type SharedAccessAuthorizationRuleListResultPage struct {
	// contains filtered or unexported fields
}

SharedAccessAuthorizationRuleListResultPage contains a page of SharedAccessAuthorizationRuleResource values.

func NewSharedAccessAuthorizationRuleListResultPage 

func NewSharedAccessAuthorizationRuleListResultPage(getNextPage func(context.Context, SharedAccessAuthorizationRuleListResult) (SharedAccessAuthorizationRuleListResult, error)) SharedAccessAuthorizationRuleListResultPage

Creates a new instance of the SharedAccessAuthorizationRuleListResultPage type.

func (*SharedAccessAuthorizationRuleListResultPage) Next 

func (page *SharedAccessAuthorizationRuleListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*SharedAccessAuthorizationRuleListResultPage) NextWithContext 

func (page *SharedAccessAuthorizationRuleListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (SharedAccessAuthorizationRuleListResultPage) NotDone 

func (page SharedAccessAuthorizationRuleListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (SharedAccessAuthorizationRuleListResultPage) Response 

func (page SharedAccessAuthorizationRuleListResultPage) Response() SharedAccessAuthorizationRuleListResult

Response returns the raw server response from the last page request.

func (SharedAccessAuthorizationRuleListResultPage) Values 

func (page SharedAccessAuthorizationRuleListResultPage) Values() []SharedAccessAuthorizationRuleResource

Values returns the slice of values for the current page or nil if there are no values.

type SharedAccessAuthorizationRuleProperties 

type SharedAccessAuthorizationRuleProperties struct {
	// Rights - The rights associated with the rule.
	Rights *[]AccessRights `json:"rights,omitempty"`
}

SharedAccessAuthorizationRuleProperties sharedAccessAuthorizationRule properties.

type SharedAccessAuthorizationRuleResource 

type SharedAccessAuthorizationRuleResource struct {
	autorest.Response                        `json:"-"`
	*SharedAccessAuthorizationRuleProperties `json:"properties,omitempty"`
	// ID - Resource Id
	ID *string `json:"id,omitempty"`
	// Name - Resource name
	Name *string `json:"name,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Type - Resource type
	Type *string `json:"type,omitempty"`
}

SharedAccessAuthorizationRuleResource description of a namespace authorization rule.

func (SharedAccessAuthorizationRuleResource) MarshalJSON 

func (saarr SharedAccessAuthorizationRuleResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SharedAccessAuthorizationRuleResource.

func (*SharedAccessAuthorizationRuleResource) UnmarshalJSON 

func (saarr *SharedAccessAuthorizationRuleResource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for SharedAccessAuthorizationRuleResource struct.

type Sku 

type Sku struct {
	// Name - Name of this SKU. Possible values include: 'Basic', 'Standard', 'Premium'
	Name SkuName `json:"name,omitempty"`
	// Tier - The billing tier of this particular SKU. Possible values include: 'SkuTierBasic', 'SkuTierStandard', 'SkuTierPremium'
	Tier SkuTier `json:"tier,omitempty"`
	// Capacity - The specified messaging units for the tier.
	Capacity *int32 `json:"capacity,omitempty"`
}

Sku SKU of the namespace.

type SkuName 

type SkuName string

SkuName enumerates the values for sku name. 

const (
	// Basic ...
	Basic SkuName = "Basic"
	// Premium ...
	Premium SkuName = "Premium"
	// Standard ...
	Standard SkuName = "Standard"
)

func PossibleSkuNameValues 

func PossibleSkuNameValues() []SkuName

PossibleSkuNameValues returns an array of possible values for the SkuName const type.

type SkuTier 

type SkuTier string

SkuTier enumerates the values for sku tier. 

const (
	// SkuTierBasic ...
	SkuTierBasic SkuTier = "Basic"
	// SkuTierPremium ...
	SkuTierPremium SkuTier = "Premium"
	// SkuTierStandard ...
	SkuTierStandard SkuTier = "Standard"
)

func PossibleSkuTierValues 

func PossibleSkuTierValues() []SkuTier

PossibleSkuTierValues returns an array of possible values for the SkuTier const type.

type SubscriptionCreateOrUpdateParameters 

type SubscriptionCreateOrUpdateParameters struct {
	// Location - Subscription data center location.
	Location *string `json:"location,omitempty"`
	// Type - Resource manager type of the resource.
	Type                    *string `json:"type,omitempty"`
	*SubscriptionProperties `json:"properties,omitempty"`
}

SubscriptionCreateOrUpdateParameters parameters supplied to the Create Or Update Subscription operation.

func (SubscriptionCreateOrUpdateParameters) MarshalJSON 

func (scoup SubscriptionCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SubscriptionCreateOrUpdateParameters.

func (*SubscriptionCreateOrUpdateParameters) UnmarshalJSON 

func (scoup *SubscriptionCreateOrUpdateParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for SubscriptionCreateOrUpdateParameters struct.

type SubscriptionListResult 

type SubscriptionListResult struct {
	autorest.Response `json:"-"`
	// Value - Result of the List Subscriptions operation.
	Value *[]SubscriptionResource `json:"value,omitempty"`
	// NextLink - Link to the next set of results. Not empty if Value contains incomplete list of subscriptions.
	NextLink *string `json:"nextLink,omitempty"`
}

SubscriptionListResult the response to the List Subscriptions operation.

func (SubscriptionListResult) IsEmpty 

func (slr SubscriptionListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type SubscriptionListResultIterator 

type SubscriptionListResultIterator struct {
	// contains filtered or unexported fields
}

SubscriptionListResultIterator provides access to a complete listing of SubscriptionResource values.

func NewSubscriptionListResultIterator 

func NewSubscriptionListResultIterator(page SubscriptionListResultPage) SubscriptionListResultIterator

Creates a new instance of the SubscriptionListResultIterator type.

func (*SubscriptionListResultIterator) Next 

func (iter *SubscriptionListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*SubscriptionListResultIterator) NextWithContext 

func (iter *SubscriptionListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (SubscriptionListResultIterator) NotDone 

func (iter SubscriptionListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (SubscriptionListResultIterator) Response 

func (iter SubscriptionListResultIterator) Response() SubscriptionListResult

Response returns the raw server response from the last page request.

func (SubscriptionListResultIterator) Value 

func (iter SubscriptionListResultIterator) Value() SubscriptionResource

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type SubscriptionListResultPage 

type SubscriptionListResultPage struct {
	// contains filtered or unexported fields
}

SubscriptionListResultPage contains a page of SubscriptionResource values.

func NewSubscriptionListResultPage 

func NewSubscriptionListResultPage(getNextPage func(context.Context, SubscriptionListResult) (SubscriptionListResult, error)) SubscriptionListResultPage

Creates a new instance of the SubscriptionListResultPage type.

func (*SubscriptionListResultPage) Next 

func (page *SubscriptionListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*SubscriptionListResultPage) NextWithContext 

func (page *SubscriptionListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (SubscriptionListResultPage) NotDone 

func (page SubscriptionListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (SubscriptionListResultPage) Response 

func (page SubscriptionListResultPage) Response() SubscriptionListResult

Response returns the raw server response from the last page request.

func (SubscriptionListResultPage) Values 

func (page SubscriptionListResultPage) Values() []SubscriptionResource

Values returns the slice of values for the current page or nil if there are no values.

type SubscriptionProperties 

type SubscriptionProperties struct {
	// AccessedAt - Last time there was a receive request to this subscription.
	AccessedAt *date.Time `json:"accessedAt,omitempty"`
	// AutoDeleteOnIdle - TimeSpan idle interval after which the topic is automatically deleted. The minimum duration is 5 minutes.
	AutoDeleteOnIdle *string              `json:"autoDeleteOnIdle,omitempty"`
	CountDetails     *MessageCountDetails `json:"countDetails,omitempty"`
	// CreatedAt - Exact time the message was created.
	CreatedAt *date.Time `json:"createdAt,omitempty"`
	// DefaultMessageTimeToLive - Default message time to live value. This is the duration after which the message expires, starting from when the message is sent to Service Bus. This is the default value used when TimeToLive is not set on a message itself.
	DefaultMessageTimeToLive *string `json:"defaultMessageTimeToLive,omitempty"`
	// DeadLetteringOnFilterEvaluationExceptions - Value that indicates whether a subscription has dead letter support on filter evaluation exceptions.
	DeadLetteringOnFilterEvaluationExceptions *bool `json:"deadLetteringOnFilterEvaluationExceptions,omitempty"`
	// DeadLetteringOnMessageExpiration - Value that indicates whether a subscription has dead letter support when a message expires.
	DeadLetteringOnMessageExpiration *bool `json:"deadLetteringOnMessageExpiration,omitempty"`
	// EnableBatchedOperations - Value that indicates whether server-side batched operations are enabled.
	EnableBatchedOperations *bool `json:"enableBatchedOperations,omitempty"`
	// EntityAvailabilityStatus - Entity availability status for the topic. Possible values include: 'Available', 'Limited', 'Renaming', 'Restoring', 'Unknown'
	EntityAvailabilityStatus EntityAvailabilityStatus `json:"entityAvailabilityStatus,omitempty"`
	// IsReadOnly - Value that indicates whether the entity description is read-only.
	IsReadOnly *bool `json:"isReadOnly,omitempty"`
	// LockDuration - The lock duration time span for the subscription.
	LockDuration *string `json:"lockDuration,omitempty"`
	// MaxDeliveryCount - Number of maximum deliveries.
	MaxDeliveryCount *int32 `json:"maxDeliveryCount,omitempty"`
	// MessageCount - Number of messages.
	MessageCount *int64 `json:"messageCount,omitempty"`
	// RequiresSession - Value indicating if a subscription supports the concept of sessions.
	RequiresSession *bool `json:"requiresSession,omitempty"`
	// Status - Enumerates the possible values for the status of a messaging entity. Possible values include: 'EntityStatusActive', 'EntityStatusCreating', 'EntityStatusDeleting', 'EntityStatusDisabled', 'EntityStatusReceiveDisabled', 'EntityStatusRenaming', 'EntityStatusRestoring', 'EntityStatusSendDisabled', 'EntityStatusUnknown'
	Status EntityStatus `json:"status,omitempty"`
	// UpdatedAt - The exact time the message was updated.
	UpdatedAt *date.Time `json:"updatedAt,omitempty"`
}

SubscriptionProperties description of Subscription Resource.

type SubscriptionResource 

type SubscriptionResource struct {
	autorest.Response       `json:"-"`
	*SubscriptionProperties `json:"properties,omitempty"`
	// ID - Resource Id
	ID *string `json:"id,omitempty"`
	// Name - Resource name
	Name *string `json:"name,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Type - Resource type
	Type *string `json:"type,omitempty"`
}

SubscriptionResource description of subscription resource.

func (SubscriptionResource) MarshalJSON 

func (sr SubscriptionResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SubscriptionResource.

func (*SubscriptionResource) UnmarshalJSON 

func (sr *SubscriptionResource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for SubscriptionResource struct.

type SubscriptionsClient 

type SubscriptionsClient struct {
	BaseClient
}

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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string, parameters SubscriptionCreateOrUpdateParameters) (result SubscriptionResource, err error)

CreateOrUpdate creates a topic subscription. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. subscriptionName - the subscription name. parameters - parameters supplied to create a subscription resource.

func (SubscriptionsClient) CreateOrUpdatePreparer 

func (client SubscriptionsClient) CreateOrUpdatePreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (result autorest.Response, err error)

Delete deletes a subscription from the specified topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. subscriptionName - the subscription name.

func (SubscriptionsClient) DeletePreparer 

func (client SubscriptionsClient) DeletePreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, subscriptionName string) (result SubscriptionResource, err error)

Get returns a subscription description for the specified topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. subscriptionName - the subscription name.

func (SubscriptionsClient) GetPreparer 

func (client SubscriptionsClient) GetPreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (result SubscriptionListResultPage, err error)

ListAll list all the subscriptions under a specified topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name.

func (SubscriptionsClient) ListAllComplete 

func (client SubscriptionsClient) ListAllComplete(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (result SubscriptionListResultIterator, err error)

ListAllComplete enumerates all values, automatically crossing page boundaries as required.

func (SubscriptionsClient) ListAllPreparer 

func (client SubscriptionsClient) ListAllPreparer(ctx context.Context, 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 - Topic name.
	Name *string `json:"name,omitempty"`
	// Location - Location of the resource.
	Location         *string `json:"location,omitempty"`
	*TopicProperties `json:"properties,omitempty"`
}

TopicCreateOrUpdateParameters parameters supplied to the Create Or Update Topic operation.

func (TopicCreateOrUpdateParameters) MarshalJSON 

func (tcoup TopicCreateOrUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TopicCreateOrUpdateParameters.

func (*TopicCreateOrUpdateParameters) UnmarshalJSON 

func (tcoup *TopicCreateOrUpdateParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for TopicCreateOrUpdateParameters struct.

type TopicListResult 

type TopicListResult struct {
	autorest.Response `json:"-"`
	// Value - Result of the List Topics operation.
	Value *[]TopicResource `json:"value,omitempty"`
	// NextLink - Link to the next set of results. Not empty if Value contains incomplete list of topics.
	NextLink *string `json:"nextLink,omitempty"`
}

TopicListResult the response to the List Topics operation.

func (TopicListResult) IsEmpty 

func (tlr TopicListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type TopicListResultIterator 

type TopicListResultIterator struct {
	// contains filtered or unexported fields
}

TopicListResultIterator provides access to a complete listing of TopicResource values.

func NewTopicListResultIterator 

func NewTopicListResultIterator(page TopicListResultPage) TopicListResultIterator

Creates a new instance of the TopicListResultIterator type.

func (*TopicListResultIterator) Next 

func (iter *TopicListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*TopicListResultIterator) NextWithContext 

func (iter *TopicListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (TopicListResultIterator) NotDone 

func (iter TopicListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (TopicListResultIterator) Response 

func (iter TopicListResultIterator) Response() TopicListResult

Response returns the raw server response from the last page request.

func (TopicListResultIterator) Value 

func (iter TopicListResultIterator) Value() TopicResource

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type TopicListResultPage 

type TopicListResultPage struct {
	// contains filtered or unexported fields
}

TopicListResultPage contains a page of TopicResource values.

func NewTopicListResultPage 

func NewTopicListResultPage(getNextPage func(context.Context, TopicListResult) (TopicListResult, error)) TopicListResultPage

Creates a new instance of the TopicListResultPage type.

func (*TopicListResultPage) Next 

func (page *TopicListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*TopicListResultPage) NextWithContext 

func (page *TopicListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (TopicListResultPage) NotDone 

func (page TopicListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (TopicListResultPage) Response 

func (page TopicListResultPage) Response() TopicListResult

Response returns the raw server response from the last page request.

func (TopicListResultPage) Values 

func (page TopicListResultPage) Values() []TopicResource

Values returns the slice of values for the current page or nil if there are no values.

type TopicProperties 

type TopicProperties struct {
	// AccessedAt - Last time the message was sent, or a request was received, for this topic.
	AccessedAt *date.Time `json:"accessedAt,omitempty"`
	// AutoDeleteOnIdle - TimeSpan idle interval after which the topic is automatically deleted. The minimum duration is 5 minutes.
	AutoDeleteOnIdle *string `json:"autoDeleteOnIdle,omitempty"`
	// EntityAvailabilityStatus - Entity availability status for the topic. Possible values include: 'Available', 'Limited', 'Renaming', 'Restoring', 'Unknown'
	EntityAvailabilityStatus EntityAvailabilityStatus `json:"entityAvailabilityStatus,omitempty"`
	// CreatedAt - Exact time the message was created.
	CreatedAt    *date.Time           `json:"createdAt,omitempty"`
	CountDetails *MessageCountDetails `json:"countDetails,omitempty"`
	// DefaultMessageTimeToLive - Default message time to live value. This is the duration after which the message expires, starting from when the message is sent to Service Bus. This is the default value used when TimeToLive is not set on a message itself.
	DefaultMessageTimeToLive *string `json:"defaultMessageTimeToLive,omitempty"`
	// DuplicateDetectionHistoryTimeWindow - TimeSpan structure that defines the duration of the duplicate detection history. The default value is 10 minutes.
	DuplicateDetectionHistoryTimeWindow *string `json:"duplicateDetectionHistoryTimeWindow,omitempty"`
	// EnableBatchedOperations - Value that indicates whether server-side batched operations are enabled.
	EnableBatchedOperations *bool `json:"enableBatchedOperations,omitempty"`
	// EnableExpress - Value that indicates whether Express Entities are enabled. An express topic holds a message in memory temporarily before writing it to persistent storage.
	EnableExpress *bool `json:"enableExpress,omitempty"`
	// EnablePartitioning - Value that indicates whether the topic to be partitioned across multiple message brokers is enabled.
	EnablePartitioning *bool `json:"enablePartitioning,omitempty"`
	// FilteringMessagesBeforePublishing - Whether messages should be filtered before publishing.
	FilteringMessagesBeforePublishing *bool `json:"filteringMessagesBeforePublishing,omitempty"`
	// IsAnonymousAccessible - Value that indicates whether the message is accessible anonymously.
	IsAnonymousAccessible *bool `json:"isAnonymousAccessible,omitempty"`
	IsExpress             *bool `json:"isExpress,omitempty"`
	// MaxSizeInMegabytes - Maximum size of the topic in megabytes, which is the size of the memory allocated for the topic.
	MaxSizeInMegabytes *int64 `json:"maxSizeInMegabytes,omitempty"`
	// RequiresDuplicateDetection - Value indicating if this topic requires duplicate detection.
	RequiresDuplicateDetection *bool `json:"requiresDuplicateDetection,omitempty"`
	// SizeInBytes - Size of the topic, in bytes.
	SizeInBytes *int64 `json:"sizeInBytes,omitempty"`
	// Status - Enumerates the possible values for the status of a messaging entity. Possible values include: 'EntityStatusActive', 'EntityStatusCreating', 'EntityStatusDeleting', 'EntityStatusDisabled', 'EntityStatusReceiveDisabled', 'EntityStatusRenaming', 'EntityStatusRestoring', 'EntityStatusSendDisabled', 'EntityStatusUnknown'
	Status EntityStatus `json:"status,omitempty"`
	// SubscriptionCount - Number of subscriptions.
	SubscriptionCount *int32 `json:"subscriptionCount,omitempty"`
	// SupportOrdering - Value that indicates whether the topic supports ordering.
	SupportOrdering *bool `json:"supportOrdering,omitempty"`
	// UpdatedAt - The exact time the message was updated.
	UpdatedAt *date.Time `json:"updatedAt,omitempty"`
}

TopicProperties the Topic Properties definition.

type TopicResource 

type TopicResource struct {
	autorest.Response `json:"-"`
	*TopicProperties  `json:"properties,omitempty"`
	// ID - Resource Id
	ID *string `json:"id,omitempty"`
	// Name - Resource name
	Name *string `json:"name,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Type - Resource type
	Type *string `json:"type,omitempty"`
}

TopicResource description of topic resource.

func (TopicResource) MarshalJSON 

func (tr TopicResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TopicResource.

func (*TopicResource) UnmarshalJSON 

func (tr *TopicResource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for TopicResource struct.

type TopicsClient 

type TopicsClient struct {
	BaseClient
}

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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, parameters TopicCreateOrUpdateParameters) (result TopicResource, err error)

CreateOrUpdate creates a topic in the specified namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. parameters - parameters supplied to create a topic resource.

func (TopicsClient) CreateOrUpdateAuthorizationRule 

func (client TopicsClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters SharedAccessAuthorizationRuleCreateOrUpdateParameters) (result SharedAccessAuthorizationRuleResource, err error)

CreateOrUpdateAuthorizationRule creates an authorization rule for the specified topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. authorizationRuleName - the authorization rule name. parameters - the shared access authorization rule.

func (TopicsClient) CreateOrUpdateAuthorizationRulePreparer 

func (client TopicsClient) CreateOrUpdateAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (result autorest.Response, err error)

Delete deletes a topic from the specified namespace and resource group. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name.

func (TopicsClient) DeleteAuthorizationRule 

func (client TopicsClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (result autorest.Response, err error)

DeleteAuthorizationRule deletes a topic authorization rule. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. authorizationRuleName - the authorization rule name.

func (TopicsClient) DeleteAuthorizationRulePreparer 

func (client TopicsClient) DeleteAuthorizationRulePreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (TopicsClient) DeleteResponder 

func (client TopicsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (TopicsClient) DeleteSender 

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

func (client TopicsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (result TopicResource, err error)

Get returns a description for the specified topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name.

func (TopicsClient) GetAuthorizationRule 

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

GetAuthorizationRule returns the specified authorization rule. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. authorizationRuleName - the authorization rule name.

func (TopicsClient) GetAuthorizationRulePreparer 

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

GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.

func (TopicsClient) GetAuthorizationRuleResponder 

func (client TopicsClient) GetAuthorizationRuleResponder(resp *http.Response) (result 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) GetPreparer 

func (client TopicsClient) GetPreparer(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (TopicsClient) GetResponder 

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

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

func (TopicsClient) GetSender 

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

func (client TopicsClient) ListAll(ctx context.Context, resourceGroupName string, namespaceName string) (result TopicListResultPage, err error)

ListAll gets all the topics in a namespace. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name

func (TopicsClient) ListAllComplete 

func (client TopicsClient) ListAllComplete(ctx context.Context, resourceGroupName string, namespaceName string) (result TopicListResultIterator, err error)

ListAllComplete enumerates all values, automatically crossing page boundaries as required.

func (TopicsClient) ListAllPreparer 

func (client TopicsClient) ListAllPreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (result SharedAccessAuthorizationRuleListResultPage, err error)

ListAuthorizationRules gets authorization rules for a topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name.

func (TopicsClient) ListAuthorizationRulesComplete 

func (client TopicsClient) ListAuthorizationRulesComplete(ctx context.Context, resourceGroupName string, namespaceName string, topicName string) (result SharedAccessAuthorizationRuleListResultIterator, err error)

ListAuthorizationRulesComplete enumerates all values, automatically crossing page boundaries as required.

func (TopicsClient) ListAuthorizationRulesPreparer 

func (client TopicsClient) ListAuthorizationRulesPreparer(ctx context.Context, 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(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (result ResourceListKeys, err error)

ListKeys gets the primary and secondary connection strings for the topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. authorizationRuleName - the authorization rule name.

func (TopicsClient) ListKeysPreparer 

func (client TopicsClient) ListKeysPreparer(ctx context.Context, 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) PostAuthorizationRule 

func (client TopicsClient) PostAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (result SharedAccessAuthorizationRuleResource, err error)

PostAuthorizationRule returns the specified authorization rule. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. authorizationRuleName - the authorization rule name.

func (TopicsClient) PostAuthorizationRulePreparer 

func (client TopicsClient) PostAuthorizationRulePreparer(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string) (*http.Request, error)

PostAuthorizationRulePreparer prepares the PostAuthorizationRule request.

func (TopicsClient) PostAuthorizationRuleResponder 

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

PostAuthorizationRuleResponder handles the response to the PostAuthorizationRule request. The method always closes the http.Response Body.

func (TopicsClient) PostAuthorizationRuleSender 

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

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

func (TopicsClient) RegenerateKeys 

func (client TopicsClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, topicName string, authorizationRuleName string, parameters RegenerateKeysParameters) (result ResourceListKeys, err error)

RegenerateKeys regenerates primary or secondary connection strings for the topic. Parameters: resourceGroupName - name of the Resource group within the Azure subscription. namespaceName - the namespace name topicName - the topic name. authorizationRuleName - the authorization rule name. parameters - parameters supplied to regenerate the authorization rule.

func (TopicsClient) RegenerateKeysPreparer 

func (client TopicsClient) RegenerateKeysPreparer(ctx context.Context, 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.

type TrackedResource 

type TrackedResource struct {
	// Tags - Resource tags
	Tags map[string]*string `json:"tags"`
	// ID - Resource Id
	ID *string `json:"id,omitempty"`
	// Name - Resource name
	Name *string `json:"name,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Type - Resource type
	Type *string `json:"type,omitempty"`
}

TrackedResource the Resource definition.

func (TrackedResource) MarshalJSON 

func (tr TrackedResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TrackedResource.

type UnavailableReason 

type UnavailableReason string

UnavailableReason enumerates the values for unavailable reason. 

const (
	// InvalidName ...
	InvalidName UnavailableReason = "InvalidName"
	// NameInLockdown ...
	NameInLockdown UnavailableReason = "NameInLockdown"
	// NameInUse ...
	NameInUse UnavailableReason = "NameInUse"
	// None ...
	None UnavailableReason = "None"
	// SubscriptionIsDisabled ...
	SubscriptionIsDisabled UnavailableReason = "SubscriptionIsDisabled"
	// TooManyNamespaceInCurrentSubscription ...
	TooManyNamespaceInCurrentSubscription UnavailableReason = "TooManyNamespaceInCurrentSubscription"
)

func PossibleUnavailableReasonValues 

func PossibleUnavailableReasonValues() []UnavailableReason

PossibleUnavailableReasonValues returns an array of possible values for the UnavailableReason const type.

Source Files

View all Source files

Directories

Path Synopsis

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.