azure-sdk-for-go: github.com/Azure/azure-sdk-for-go/services/servicebus/mgmt/2015-08-01/servicebus Index | Files | Directories

package servicebus

import "github.com/Azure/azure-sdk-for-go/services/servicebus/mgmt/2015-08-01/servicebus"

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

Azure Service Bus client

Index

Package Files

client.go models.go namespaces.go operations.go queues.go subscriptions.go topics.go version.go

Constants

const (
    // DefaultBaseURI is the default URI used for the service Servicebus
    DefaultBaseURI = "https://management.azure.com"
)

func UserAgent Uses

func UserAgent() string

UserAgent returns the UserAgent string to use when sending http.Requests.

func Version Uses

func Version() string

Version returns the semantic version (see http://semver.org) of the client.

type AccessRights Uses

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 Uses

func PossibleAccessRightsValues() []AccessRights

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

type BaseClient Uses

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

BaseClient is the base client for Servicebus.

func New Uses

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI Uses

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client.

type CheckNameAvailability Uses

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 Uses

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 - READ-ONLY; 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 Uses

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 Uses

func PossibleEntityAvailabilityStatusValues() []EntityAvailabilityStatus

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

type EntityStatus Uses

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 Uses

func PossibleEntityStatusValues() []EntityStatus

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

type MessageCountDetails Uses

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

MessageCountDetails message Count Details.

type NamespaceCreateOrUpdateParameters Uses

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 Uses

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

MarshalJSON is the custom marshaler for NamespaceCreateOrUpdateParameters.

func (*NamespaceCreateOrUpdateParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for NamespaceCreateOrUpdateParameters struct.

type NamespaceListResult Uses

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 Uses

func (nlr NamespaceListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type NamespaceListResultIterator Uses

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

NamespaceListResultIterator provides access to a complete listing of NamespaceResource values.

func NewNamespaceListResultIterator Uses

func NewNamespaceListResultIterator(page NamespaceListResultPage) NamespaceListResultIterator

Creates a new instance of the NamespaceListResultIterator type.

func (*NamespaceListResultIterator) Next Uses

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 Uses

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 Uses

func (iter NamespaceListResultIterator) NotDone() bool

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

func (NamespaceListResultIterator) Response Uses

func (iter NamespaceListResultIterator) Response() NamespaceListResult

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

func (NamespaceListResultIterator) Value Uses

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 Uses

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

NamespaceListResultPage contains a page of NamespaceResource values.

func NewNamespaceListResultPage Uses

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

Creates a new instance of the NamespaceListResultPage type.

func (*NamespaceListResultPage) Next Uses

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 Uses

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 Uses

func (page NamespaceListResultPage) NotDone() bool

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

func (NamespaceListResultPage) Response Uses

func (page NamespaceListResultPage) Response() NamespaceListResult

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

func (NamespaceListResultPage) Values Uses

func (page NamespaceListResultPage) Values() []NamespaceResource

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

type NamespaceProperties Uses

type NamespaceProperties struct {
    // ProvisioningState - READ-ONLY; 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 - READ-ONLY; The time the namespace was created.
    CreatedAt *date.Time `json:"createdAt,omitempty"`
    // UpdatedAt - READ-ONLY; The time the namespace was updated.
    UpdatedAt *date.Time `json:"updatedAt,omitempty"`
    // ServiceBusEndpoint - READ-ONLY; 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 Uses

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 - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - READ-ONLY; Resource name
    Name *string `json:"name,omitempty"`
    // Location - Resource location.
    Location *string `json:"location,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
}

NamespaceResource description of a namespace resource.

func (NamespaceResource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for NamespaceResource.

func (*NamespaceResource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for NamespaceResource struct.

type NamespaceState Uses

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 Uses

func PossibleNamespaceStateValues() []NamespaceState

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

type NamespaceUpdateParameters Uses

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 Uses

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

MarshalJSON is the custom marshaler for NamespaceUpdateParameters.

type NamespacesClient Uses

type NamespacesClient struct {
    BaseClient
}

NamespacesClient is the azure Service Bus client

func NewNamespacesClient Uses

func NewNamespacesClient(subscriptionID string) NamespacesClient

NewNamespacesClient creates an instance of the NamespacesClient client.

func NewNamespacesClientWithBaseURI Uses

func NewNamespacesClientWithBaseURI(baseURI string, subscriptionID string) NamespacesClient

NewNamespacesClientWithBaseURI creates an instance of the NamespacesClient client.

func (NamespacesClient) CheckNameAvailabilityMethod Uses

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 Uses

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

CheckNameAvailabilityMethodPreparer prepares the CheckNameAvailabilityMethod request.

func (NamespacesClient) CheckNameAvailabilityMethodResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (NamespacesClient) CreateOrUpdateResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

func (client NamespacesClient) DeleteAuthorizationRulePreparer(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)

DeleteAuthorizationRulePreparer prepares the DeleteAuthorizationRule request.

func (NamespacesClient) DeleteAuthorizationRuleResponder Uses

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 Uses

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 Uses

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

DeletePreparer prepares the Delete request.

func (NamespacesClient) DeleteResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.

func (NamespacesClient) GetAuthorizationRuleResponder Uses

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 Uses

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 Uses

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

GetPreparer prepares the Get request.

func (NamespacesClient) GetResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.

func (NamespacesClient) ListAuthorizationRulesResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

func (client NamespacesClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error)

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (NamespacesClient) ListByResourceGroupResponder Uses

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 Uses

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 Uses

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 Uses

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

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

func (NamespacesClient) ListBySubscriptionPreparer Uses

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

ListBySubscriptionPreparer prepares the ListBySubscription request.

func (NamespacesClient) ListBySubscriptionResponder Uses

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 Uses

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 Uses

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 Uses

func (client NamespacesClient) ListKeysPreparer(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)

ListKeysPreparer prepares the ListKeys request.

func (NamespacesClient) ListKeysResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

UpdatePreparer prepares the Update request.

func (NamespacesClient) UpdateResponder Uses

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 Uses

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 Uses

type NamespacesCreateOrUpdateFuture struct {
    azure.Future
}

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

func (*NamespacesCreateOrUpdateFuture) Result Uses

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 Uses

type NamespacesDeleteFuture struct {
    azure.Future
}

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

func (*NamespacesDeleteFuture) Result Uses

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 Uses

type Operation struct {
    // Name - READ-ONLY; 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 Uses

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

OperationDisplay the object that represents the operation.

type OperationListResult Uses

type OperationListResult struct {
    autorest.Response `json:"-"`
    // Value - READ-ONLY; List of ServiceBus operations supported by the Microsoft.ServiceBus resource provider.
    Value *[]Operation `json:"value,omitempty"`
    // NextLink - READ-ONLY; 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 Uses

func (olr OperationListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type OperationListResultIterator Uses

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

OperationListResultIterator provides access to a complete listing of Operation values.

func NewOperationListResultIterator Uses

func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator

Creates a new instance of the OperationListResultIterator type.

func (*OperationListResultIterator) Next Uses

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 Uses

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 Uses

func (iter OperationListResultIterator) NotDone() bool

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

func (OperationListResultIterator) Response Uses

func (iter OperationListResultIterator) Response() OperationListResult

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

func (OperationListResultIterator) Value Uses

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 Uses

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

OperationListResultPage contains a page of Operation values.

func NewOperationListResultPage Uses

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

Creates a new instance of the OperationListResultPage type.

func (*OperationListResultPage) Next Uses

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 Uses

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 Uses

func (page OperationListResultPage) NotDone() bool

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

func (OperationListResultPage) Response Uses

func (page OperationListResultPage) Response() OperationListResult

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

func (OperationListResultPage) Values Uses

func (page OperationListResultPage) Values() []Operation

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

type OperationsClient Uses

type OperationsClient struct {
    BaseClient
}

OperationsClient is the azure Service Bus client

func NewOperationsClient Uses

func NewOperationsClient(subscriptionID string) OperationsClient

NewOperationsClient creates an instance of the OperationsClient client.

func NewOperationsClientWithBaseURI Uses

func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient

NewOperationsClientWithBaseURI creates an instance of the OperationsClient client.

func (OperationsClient) List Uses

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

List lists all of the available ServiceBus REST API operations.

func (OperationsClient) ListComplete Uses

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

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

func (OperationsClient) ListPreparer Uses

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

ListPreparer prepares the List request.

func (OperationsClient) ListResponder Uses

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 Uses

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 Uses

type Policykey string

Policykey enumerates the values for policykey.

const (
    // PrimaryKey ...
    PrimaryKey Policykey = "PrimaryKey"
    // SecondaryKey ...
    SecondaryKey Policykey = "SecondaryKey"
)

func PossiblePolicykeyValues Uses

func PossiblePolicykeyValues() []Policykey

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

type QueueCreateOrUpdateParameters Uses

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 Uses

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

MarshalJSON is the custom marshaler for QueueCreateOrUpdateParameters.

func (*QueueCreateOrUpdateParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for QueueCreateOrUpdateParameters struct.

type QueueListResult Uses

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 Uses

func (qlr QueueListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type QueueListResultIterator Uses

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

QueueListResultIterator provides access to a complete listing of QueueResource values.

func NewQueueListResultIterator Uses

func NewQueueListResultIterator(page QueueListResultPage) QueueListResultIterator

Creates a new instance of the QueueListResultIterator type.

func (*QueueListResultIterator) Next Uses

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 Uses

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 Uses

func (iter QueueListResultIterator) NotDone() bool

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

func (QueueListResultIterator) Response Uses

func (iter QueueListResultIterator) Response() QueueListResult

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

func (QueueListResultIterator) Value Uses

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 Uses

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

QueueListResultPage contains a page of QueueResource values.

func NewQueueListResultPage Uses

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

Creates a new instance of the QueueListResultPage type.

func (*QueueListResultPage) Next Uses

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 Uses

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 Uses

func (page QueueListResultPage) NotDone() bool

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

func (QueueListResultPage) Response Uses

func (page QueueListResultPage) Response() QueueListResult

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

func (QueueListResultPage) Values Uses

func (page QueueListResultPage) Values() []QueueResource

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

type QueueProperties Uses

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 - READ-ONLY; 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 - READ-ONLY; 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 - READ-ONLY; The number of messages in the queue.
    MessageCount *int64 `json:"messageCount,omitempty"`
    // CountDetails - READ-ONLY
    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 - READ-ONLY; 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 - READ-ONLY; The exact time the message was updated.
    UpdatedAt *date.Time `json:"updatedAt,omitempty"`
}

QueueProperties the Queue Properties definition.

type QueueResource Uses

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

QueueResource description of queue Resource.

func (QueueResource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for QueueResource.

func (*QueueResource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for QueueResource struct.

type QueuesClient Uses

type QueuesClient struct {
    BaseClient
}

QueuesClient is the azure Service Bus client

func NewQueuesClient Uses

func NewQueuesClient(subscriptionID string) QueuesClient

NewQueuesClient creates an instance of the QueuesClient client.

func NewQueuesClientWithBaseURI Uses

func NewQueuesClientWithBaseURI(baseURI string, subscriptionID string) QueuesClient

NewQueuesClientWithBaseURI creates an instance of the QueuesClient client.

func (QueuesClient) CreateOrUpdate Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

DeletePreparer prepares the Delete request.

func (QueuesClient) DeleteResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

GetPreparer prepares the Get request.

func (QueuesClient) GetResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListAllPreparer prepares the ListAll request.

func (QueuesClient) ListAllResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.

func (QueuesClient) ListAuthorizationRulesResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

Resource the Resource definition for other than namespace.

type ResourceListKeys Uses

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 Uses

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 Uses

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

MarshalJSON is the custom marshaler for SharedAccessAuthorizationRuleCreateOrUpdateParameters.

func (*SharedAccessAuthorizationRuleCreateOrUpdateParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for SharedAccessAuthorizationRuleCreateOrUpdateParameters struct.

type SharedAccessAuthorizationRuleListResult Uses

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 Uses

func (saarlr SharedAccessAuthorizationRuleListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type SharedAccessAuthorizationRuleListResultIterator Uses

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

SharedAccessAuthorizationRuleListResultIterator provides access to a complete listing of SharedAccessAuthorizationRuleResource values.

func NewSharedAccessAuthorizationRuleListResultIterator Uses

func NewSharedAccessAuthorizationRuleListResultIterator(page SharedAccessAuthorizationRuleListResultPage) SharedAccessAuthorizationRuleListResultIterator

Creates a new instance of the SharedAccessAuthorizationRuleListResultIterator type.

func (*SharedAccessAuthorizationRuleListResultIterator) Next Uses

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 Uses

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 Uses

func (iter SharedAccessAuthorizationRuleListResultIterator) NotDone() bool

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

func (SharedAccessAuthorizationRuleListResultIterator) Response Uses

func (iter SharedAccessAuthorizationRuleListResultIterator) Response() SharedAccessAuthorizationRuleListResult

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

func (SharedAccessAuthorizationRuleListResultIterator) Value Uses

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 Uses

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

SharedAccessAuthorizationRuleListResultPage contains a page of SharedAccessAuthorizationRuleResource values.

func NewSharedAccessAuthorizationRuleListResultPage Uses

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

Creates a new instance of the SharedAccessAuthorizationRuleListResultPage type.

func (*SharedAccessAuthorizationRuleListResultPage) Next Uses

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 Uses

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 Uses

func (page SharedAccessAuthorizationRuleListResultPage) NotDone() bool

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

func (SharedAccessAuthorizationRuleListResultPage) Response Uses

func (page SharedAccessAuthorizationRuleListResultPage) Response() SharedAccessAuthorizationRuleListResult

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

func (SharedAccessAuthorizationRuleListResultPage) Values Uses

func (page SharedAccessAuthorizationRuleListResultPage) Values() []SharedAccessAuthorizationRuleResource

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

type SharedAccessAuthorizationRuleProperties Uses

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

SharedAccessAuthorizationRuleProperties sharedAccessAuthorizationRule properties.

type SharedAccessAuthorizationRuleResource Uses

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

SharedAccessAuthorizationRuleResource description of a namespace authorization rule.

func (SharedAccessAuthorizationRuleResource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for SharedAccessAuthorizationRuleResource.

func (*SharedAccessAuthorizationRuleResource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for SharedAccessAuthorizationRuleResource struct.

type Sku Uses

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 Uses

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 Uses

func PossibleSkuNameValues() []SkuName

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

type SkuTier Uses

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 Uses

func PossibleSkuTierValues() []SkuTier

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

type SubscriptionCreateOrUpdateParameters Uses

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 Uses

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

MarshalJSON is the custom marshaler for SubscriptionCreateOrUpdateParameters.

func (*SubscriptionCreateOrUpdateParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for SubscriptionCreateOrUpdateParameters struct.

type SubscriptionListResult Uses

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 Uses

func (slr SubscriptionListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type SubscriptionListResultIterator Uses

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

SubscriptionListResultIterator provides access to a complete listing of SubscriptionResource values.

func NewSubscriptionListResultIterator Uses

func NewSubscriptionListResultIterator(page SubscriptionListResultPage) SubscriptionListResultIterator

Creates a new instance of the SubscriptionListResultIterator type.

func (*SubscriptionListResultIterator) Next Uses

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 Uses

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 Uses

func (iter SubscriptionListResultIterator) NotDone() bool

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

func (SubscriptionListResultIterator) Response Uses

func (iter SubscriptionListResultIterator) Response() SubscriptionListResult

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

func (SubscriptionListResultIterator) Value Uses

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 Uses

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

SubscriptionListResultPage contains a page of SubscriptionResource values.

func NewSubscriptionListResultPage Uses

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

Creates a new instance of the SubscriptionListResultPage type.

func (*SubscriptionListResultPage) Next Uses

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 Uses

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 Uses

func (page SubscriptionListResultPage) NotDone() bool

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

func (SubscriptionListResultPage) Response Uses

func (page SubscriptionListResultPage) Response() SubscriptionListResult

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

func (SubscriptionListResultPage) Values Uses

func (page SubscriptionListResultPage) Values() []SubscriptionResource

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

type SubscriptionProperties Uses

type SubscriptionProperties struct {
    // AccessedAt - READ-ONLY; 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 - READ-ONLY
    CountDetails *MessageCountDetails `json:"countDetails,omitempty"`
    // CreatedAt - READ-ONLY; 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 - READ-ONLY; 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 - READ-ONLY; The exact time the message was updated.
    UpdatedAt *date.Time `json:"updatedAt,omitempty"`
}

SubscriptionProperties description of Subscription Resource.

type SubscriptionResource Uses

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

SubscriptionResource description of subscription resource.

func (SubscriptionResource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for SubscriptionResource.

func (*SubscriptionResource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for SubscriptionResource struct.

type SubscriptionsClient Uses

type SubscriptionsClient struct {
    BaseClient
}

SubscriptionsClient is the azure Service Bus client

func NewSubscriptionsClient Uses

func NewSubscriptionsClient(subscriptionID string) SubscriptionsClient

NewSubscriptionsClient creates an instance of the SubscriptionsClient client.

func NewSubscriptionsClientWithBaseURI Uses

func NewSubscriptionsClientWithBaseURI(baseURI string, subscriptionID string) SubscriptionsClient

NewSubscriptionsClientWithBaseURI creates an instance of the SubscriptionsClient client.

func (SubscriptionsClient) CreateOrUpdate Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListAllPreparer prepares the ListAll request.

func (SubscriptionsClient) ListAllResponder Uses

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 Uses

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 Uses

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 Uses

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

MarshalJSON is the custom marshaler for TopicCreateOrUpdateParameters.

func (*TopicCreateOrUpdateParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for TopicCreateOrUpdateParameters struct.

type TopicListResult Uses

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 Uses

func (tlr TopicListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type TopicListResultIterator Uses

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

TopicListResultIterator provides access to a complete listing of TopicResource values.

func NewTopicListResultIterator Uses

func NewTopicListResultIterator(page TopicListResultPage) TopicListResultIterator

Creates a new instance of the TopicListResultIterator type.

func (*TopicListResultIterator) Next Uses

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 Uses

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 Uses

func (iter TopicListResultIterator) NotDone() bool

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

func (TopicListResultIterator) Response Uses

func (iter TopicListResultIterator) Response() TopicListResult

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

func (TopicListResultIterator) Value Uses

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 Uses

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

TopicListResultPage contains a page of TopicResource values.

func NewTopicListResultPage Uses

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

Creates a new instance of the TopicListResultPage type.

func (*TopicListResultPage) Next Uses

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 Uses

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 Uses

func (page TopicListResultPage) NotDone() bool

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

func (TopicListResultPage) Response Uses

func (page TopicListResultPage) Response() TopicListResult

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

func (TopicListResultPage) Values Uses

func (page TopicListResultPage) Values() []TopicResource

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

type TopicProperties Uses

type TopicProperties struct {
    // AccessedAt - READ-ONLY; 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 - READ-ONLY; Exact time the message was created.
    CreatedAt *date.Time `json:"createdAt,omitempty"`
    // CountDetails - READ-ONLY
    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 - READ-ONLY; 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 - READ-ONLY; Number of subscriptions.
    SubscriptionCount *int32 `json:"subscriptionCount,omitempty"`
    // SupportOrdering - Value that indicates whether the topic supports ordering.
    SupportOrdering *bool `json:"supportOrdering,omitempty"`
    // UpdatedAt - READ-ONLY; The exact time the message was updated.
    UpdatedAt *date.Time `json:"updatedAt,omitempty"`
}

TopicProperties the Topic Properties definition.

type TopicResource Uses

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

TopicResource description of topic resource.

func (TopicResource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for TopicResource.

func (*TopicResource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for TopicResource struct.

type TopicsClient Uses

type TopicsClient struct {
    BaseClient
}

TopicsClient is the azure Service Bus client

func NewTopicsClient Uses

func NewTopicsClient(subscriptionID string) TopicsClient

NewTopicsClient creates an instance of the TopicsClient client.

func NewTopicsClientWithBaseURI Uses

func NewTopicsClientWithBaseURI(baseURI string, subscriptionID string) TopicsClient

NewTopicsClientWithBaseURI creates an instance of the TopicsClient client.

func (TopicsClient) CreateOrUpdate Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

DeletePreparer prepares the Delete request.

func (TopicsClient) DeleteResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

GetPreparer prepares the Get request.

func (TopicsClient) GetResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListAllPreparer prepares the ListAll request.

func (TopicsClient) ListAllResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.

func (TopicsClient) ListAuthorizationRulesResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

TrackedResource the Resource definition.

func (TrackedResource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for TrackedResource.

type UnavailableReason Uses

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 Uses

func PossibleUnavailableReasonValues() []UnavailableReason

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

Directories

PathSynopsis
servicebusapi

Package servicebus imports 10 packages (graph) and is imported by 4 packages. Updated 2019-08-10. Refresh now. Tools for package owners.