Documentation ¶
Overview ¶
Package eventhub implements the Azure ARM Eventhub service API version 2015-08-01.
Azure Event Hubs client
Index ¶
- Constants
- func UserAgent() string
- func Version() string
- type AccessRights
- type CheckNameAvailability
- type CheckNameAvailabilityResult
- type ConsumerGroup
- type ConsumerGroupListResult
- type ConsumerGroupProperties
- type ConsumerGroupsClient
- func (client ConsumerGroupsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, eventHubName string, ...) (result ConsumerGroup, err error)
- func (client ConsumerGroupsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client ConsumerGroupsClient) CreateOrUpdateResponder(resp *http.Response) (result ConsumerGroup, err error)
- func (client ConsumerGroupsClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client ConsumerGroupsClient) Delete(resourceGroupName string, namespaceName string, eventHubName string, ...) (result autorest.Response, err error)
- func (client ConsumerGroupsClient) DeletePreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client ConsumerGroupsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ConsumerGroupsClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client ConsumerGroupsClient) Get(resourceGroupName string, namespaceName string, eventHubName string, ...) (result ConsumerGroup, err error)
- func (client ConsumerGroupsClient) GetPreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client ConsumerGroupsClient) GetResponder(resp *http.Response) (result ConsumerGroup, err error)
- func (client ConsumerGroupsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ConsumerGroupsClient) ListByEventHub(resourceGroupName string, namespaceName string, eventHubName string) (result ConsumerGroupListResult, err error)
- func (client ConsumerGroupsClient) ListByEventHubNextResults(lastResults ConsumerGroupListResult) (result ConsumerGroupListResult, err error)
- func (client ConsumerGroupsClient) ListByEventHubPreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
- func (client ConsumerGroupsClient) ListByEventHubResponder(resp *http.Response) (result ConsumerGroupListResult, err error)
- func (client ConsumerGroupsClient) ListByEventHubSender(req *http.Request) (*http.Response, error)
- type EntityStatus
- type ErrorResponse
- type EventHub
- type EventHubsClient
- func (client EventHubsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, eventHubName string, ...) (result EventHub, err error)
- func (client EventHubsClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, eventHubName string, ...) (result SharedAccessAuthorizationRule, err error)
- func (client EventHubsClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client EventHubsClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
- func (client EventHubsClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client EventHubsClient) CreateOrUpdateResponder(resp *http.Response) (result EventHub, err error)
- func (client EventHubsClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) Delete(resourceGroupName string, namespaceName string, eventHubName string) (result autorest.Response, err error)
- func (client EventHubsClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, eventHubName string, ...) (result autorest.Response, err error)
- func (client EventHubsClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client EventHubsClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
- func (client EventHubsClient) DeleteAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) DeletePreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
- func (client EventHubsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client EventHubsClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) Get(resourceGroupName string, namespaceName string, eventHubName string) (result EventHub, err error)
- func (client EventHubsClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, eventHubName string, ...) (result SharedAccessAuthorizationRule, err error)
- func (client EventHubsClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client EventHubsClient) GetAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
- func (client EventHubsClient) GetAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) GetPreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
- func (client EventHubsClient) GetResponder(resp *http.Response) (result EventHub, err error)
- func (client EventHubsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, eventHubName string) (result SharedAccessAuthorizationRuleListResult, err error)
- func (client EventHubsClient) ListAuthorizationRulesNextResults(lastResults SharedAccessAuthorizationRuleListResult) (result SharedAccessAuthorizationRuleListResult, err error)
- func (client EventHubsClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
- func (client EventHubsClient) ListAuthorizationRulesResponder(resp *http.Response) (result SharedAccessAuthorizationRuleListResult, err error)
- func (client EventHubsClient) ListAuthorizationRulesSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) ListByNamespace(resourceGroupName string, namespaceName string) (result ListResult, err error)
- func (client EventHubsClient) ListByNamespaceNextResults(lastResults ListResult) (result ListResult, err error)
- func (client EventHubsClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client EventHubsClient) ListByNamespaceResponder(resp *http.Response) (result ListResult, err error)
- func (client EventHubsClient) ListByNamespaceSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) ListKeys(resourceGroupName string, namespaceName string, eventHubName string, ...) (result ResourceListKeys, err error)
- func (client EventHubsClient) ListKeysPreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client EventHubsClient) ListKeysResponder(resp *http.Response) (result ResourceListKeys, err error)
- func (client EventHubsClient) ListKeysSender(req *http.Request) (*http.Response, error)
- func (client EventHubsClient) RegenerateKeys(resourceGroupName string, namespaceName string, eventHubName string, ...) (result ResourceListKeys, err error)
- func (client EventHubsClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, eventHubName string, ...) (*http.Request, error)
- func (client EventHubsClient) RegenerateKeysResponder(resp *http.Response) (result ResourceListKeys, err error)
- func (client EventHubsClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)
- type ListResult
- type ManagementClient
- type Namespace
- type NamespaceListResult
- type NamespaceProperties
- type NamespaceUpdateParameter
- type NamespacesClient
- func (client NamespacesClient) CheckNameAvailabilityMethod(parameters CheckNameAvailability) (result CheckNameAvailabilityResult, err error)
- func (client NamespacesClient) CheckNameAvailabilityMethodPreparer(parameters CheckNameAvailability) (*http.Request, error)
- func (client NamespacesClient) CheckNameAvailabilityMethodResponder(resp *http.Response) (result CheckNameAvailabilityResult, err error)
- func (client NamespacesClient) CheckNameAvailabilityMethodSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, parameters Namespace, ...) (result autorest.Response, err error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (result SharedAccessAuthorizationRule, err error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (*http.Request, error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
- func (client NamespacesClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, parameters Namespace, ...) (*http.Request, error)
- func (client NamespacesClient) CreateOrUpdateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client NamespacesClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) Delete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (result autorest.Response, err error)
- func (client NamespacesClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result autorest.Response, err error)
- func (client NamespacesClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
- func (client NamespacesClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
- func (client NamespacesClient) DeleteAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) DeletePreparer(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (*http.Request, error)
- func (client NamespacesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client NamespacesClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) Get(resourceGroupName string, namespaceName string) (result Namespace, err error)
- func (client NamespacesClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result SharedAccessAuthorizationRule, err error)
- func (client NamespacesClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
- func (client NamespacesClient) GetAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
- func (client NamespacesClient) GetAuthorizationRuleSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) GetPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client NamespacesClient) GetResponder(resp *http.Response) (result Namespace, err error)
- func (client NamespacesClient) GetSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) List() (result NamespaceListResult, err error)
- func (client NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string) (result SharedAccessAuthorizationRuleListResult, err error)
- func (client NamespacesClient) ListAuthorizationRulesNextResults(lastResults SharedAccessAuthorizationRuleListResult) (result SharedAccessAuthorizationRuleListResult, err error)
- func (client NamespacesClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
- func (client NamespacesClient) ListAuthorizationRulesResponder(resp *http.Response) (result SharedAccessAuthorizationRuleListResult, err error)
- func (client NamespacesClient) ListAuthorizationRulesSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) ListByResourceGroup(resourceGroupName string) (result NamespaceListResult, err error)
- func (client NamespacesClient) ListByResourceGroupNextResults(lastResults NamespaceListResult) (result NamespaceListResult, err error)
- func (client NamespacesClient) ListByResourceGroupPreparer(resourceGroupName string) (*http.Request, error)
- func (client NamespacesClient) ListByResourceGroupResponder(resp *http.Response) (result NamespaceListResult, err error)
- func (client NamespacesClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) ListKeys(resourceGroupName string, namespaceName string, authorizationRuleName string) (result ResourceListKeys, err error)
- func (client NamespacesClient) ListKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
- func (client NamespacesClient) ListKeysResponder(resp *http.Response) (result ResourceListKeys, err error)
- func (client NamespacesClient) ListKeysSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) ListNextResults(lastResults NamespaceListResult) (result NamespaceListResult, err error)
- func (client NamespacesClient) ListPreparer() (*http.Request, error)
- func (client NamespacesClient) ListResponder(resp *http.Response) (result NamespaceListResult, err error)
- func (client NamespacesClient) ListSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) RegenerateKeys(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (result ResourceListKeys, err error)
- func (client NamespacesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, ...) (*http.Request, error)
- func (client NamespacesClient) RegenerateKeysResponder(resp *http.Response) (result ResourceListKeys, err error)
- func (client NamespacesClient) RegenerateKeysSender(req *http.Request) (*http.Response, error)
- func (client NamespacesClient) Update(resourceGroupName string, namespaceName string, ...) (result Namespace, err error)
- func (client NamespacesClient) UpdatePreparer(resourceGroupName string, namespaceName string, ...) (*http.Request, error)
- func (client NamespacesClient) UpdateResponder(resp *http.Response) (result Namespace, err error)
- func (client NamespacesClient) UpdateSender(req *http.Request) (*http.Response, error)
- type Operation
- type OperationDisplay
- type OperationListResult
- type OperationsClient
- func (client OperationsClient) List() (result OperationListResult, err error)
- func (client OperationsClient) ListNextResults(lastResults OperationListResult) (result OperationListResult, err error)
- func (client OperationsClient) ListPreparer() (*http.Request, error)
- func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)
- func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)
- type Policykey
- type Properties
- type RegenerateKeysParameters
- type Resource
- type ResourceListKeys
- type SharedAccessAuthorizationRule
- type SharedAccessAuthorizationRuleListResult
- type SharedAccessAuthorizationRuleProperties
- type Sku
- type SkuName
- type SkuTier
- type TrackedResource
- type UnavailableReason
Constants ¶
const (
// DefaultBaseURI is the default URI used for the service Eventhub
DefaultBaseURI = "https://management.azure.com"
)
Variables ¶
This section is empty.
Functions ¶
func UserAgent ¶
func UserAgent() string
UserAgent returns the UserAgent string to use when sending http.Requests.
func Version ¶
func Version() string
Version returns the semantic version (see http://semver.org) of the client.
Types ¶
type AccessRights ¶
type AccessRights string
AccessRights enumerates the values for access rights.
const ( // Listen specifies the listen state for access rights. Listen AccessRights = "Listen" // Manage specifies the manage state for access rights. Manage AccessRights = "Manage" // Send specifies the send state for access rights. Send AccessRights = "Send" )
type CheckNameAvailability ¶
type CheckNameAvailability struct {
Name *string `json:"name,omitempty"`
}
CheckNameAvailability is description of a Check Name availability request properties.
type CheckNameAvailabilityResult ¶
type CheckNameAvailabilityResult struct { autorest.Response `json:"-"` NameAvailable *bool `json:"nameAvailable,omitempty"` Reason UnavailableReason `json:"reason,omitempty"` Message *string `json:"message,omitempty"` }
CheckNameAvailabilityResult is description of a Check Name availability request properties.
type ConsumerGroup ¶
type ConsumerGroup struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *ConsumerGroupProperties `json:"properties,omitempty"` }
ConsumerGroup is description of the consumer group resource.
type ConsumerGroupListResult ¶
type ConsumerGroupListResult struct { autorest.Response `json:"-"` Value *[]ConsumerGroup `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
ConsumerGroupListResult is the response to the List Consumer Group operation.
func (ConsumerGroupListResult) ConsumerGroupListResultPreparer ¶
func (client ConsumerGroupListResult) ConsumerGroupListResultPreparer() (*http.Request, error)
ConsumerGroupListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type ConsumerGroupProperties ¶
type ConsumerGroupProperties struct { CreatedAt *date.Time `json:"createdAt,omitempty"` EventHubPath *string `json:"eventHubPath,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` UserMetadata *string `json:"userMetadata,omitempty"` }
ConsumerGroupProperties is description of a Consumer Group properties.
type ConsumerGroupsClient ¶
type ConsumerGroupsClient struct {
ManagementClient
}
ConsumerGroupsClient is the azure Event Hubs client
func NewConsumerGroupsClient ¶
func NewConsumerGroupsClient(subscriptionID string) ConsumerGroupsClient
NewConsumerGroupsClient creates an instance of the ConsumerGroupsClient client.
func NewConsumerGroupsClientWithBaseURI ¶
func NewConsumerGroupsClientWithBaseURI(baseURI string, subscriptionID string) ConsumerGroupsClient
NewConsumerGroupsClientWithBaseURI creates an instance of the ConsumerGroupsClient client.
func (ConsumerGroupsClient) CreateOrUpdate ¶
func (client ConsumerGroupsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, parameters ConsumerGroup) (result ConsumerGroup, err error)
CreateOrUpdate creates or updates an Event Hubs consumer group as a nested resource within a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name consumerGroupName is the consumer group name parameters is parameters supplied to create a consumer group resource.
func (ConsumerGroupsClient) CreateOrUpdatePreparer ¶
func (client ConsumerGroupsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, parameters ConsumerGroup) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (ConsumerGroupsClient) CreateOrUpdateResponder ¶
func (client ConsumerGroupsClient) CreateOrUpdateResponder(resp *http.Response) (result ConsumerGroup, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (ConsumerGroupsClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (ConsumerGroupsClient) Delete ¶
func (client ConsumerGroupsClient) Delete(resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string) (result autorest.Response, err error)
Delete deletes a consumer group from the specified Event Hub and resource group.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name consumerGroupName is the consumer group name
func (ConsumerGroupsClient) DeletePreparer ¶
func (client ConsumerGroupsClient) DeletePreparer(resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ConsumerGroupsClient) DeleteResponder ¶
func (client ConsumerGroupsClient) 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 (ConsumerGroupsClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (ConsumerGroupsClient) Get ¶
func (client ConsumerGroupsClient) Get(resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string) (result ConsumerGroup, err error)
Get gets a description for the specified consumer group.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name consumerGroupName is the consumer group name
func (ConsumerGroupsClient) GetPreparer ¶
func (client ConsumerGroupsClient) GetPreparer(resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (ConsumerGroupsClient) GetResponder ¶
func (client ConsumerGroupsClient) GetResponder(resp *http.Response) (result ConsumerGroup, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ConsumerGroupsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (ConsumerGroupsClient) ListByEventHub ¶
func (client ConsumerGroupsClient) ListByEventHub(resourceGroupName string, namespaceName string, eventHubName string) (result ConsumerGroupListResult, err error)
ListByEventHub gets all the consumer groups in a eventhub. An empty feed is returned if no consumer group exists in the eventhub.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name
func (ConsumerGroupsClient) ListByEventHubNextResults ¶
func (client ConsumerGroupsClient) ListByEventHubNextResults(lastResults ConsumerGroupListResult) (result ConsumerGroupListResult, err error)
ListByEventHubNextResults retrieves the next set of results, if any.
func (ConsumerGroupsClient) ListByEventHubPreparer ¶
func (client ConsumerGroupsClient) ListByEventHubPreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
ListByEventHubPreparer prepares the ListByEventHub request.
func (ConsumerGroupsClient) ListByEventHubResponder ¶
func (client ConsumerGroupsClient) ListByEventHubResponder(resp *http.Response) (result ConsumerGroupListResult, err error)
ListByEventHubResponder handles the response to the ListByEventHub request. The method always closes the http.Response Body.
func (ConsumerGroupsClient) ListByEventHubSender ¶
ListByEventHubSender sends the ListByEventHub request. The method will close the http.Response Body if it receives an error.
type EntityStatus ¶
type EntityStatus string
EntityStatus enumerates the values for entity status.
const ( // Active specifies the active state for entity status. Active EntityStatus = "Active" // Creating specifies the creating state for entity status. Creating EntityStatus = "Creating" // Deleting specifies the deleting state for entity status. Deleting EntityStatus = "Deleting" // Disabled specifies the disabled state for entity status. Disabled EntityStatus = "Disabled" // ReceiveDisabled specifies the receive disabled state for entity status. ReceiveDisabled EntityStatus = "ReceiveDisabled" // Renaming specifies the renaming state for entity status. Renaming EntityStatus = "Renaming" // Restoring specifies the restoring state for entity status. Restoring EntityStatus = "Restoring" // SendDisabled specifies the send disabled state for entity status. SendDisabled EntityStatus = "SendDisabled" // Unknown specifies the unknown state for entity status. Unknown EntityStatus = "Unknown" )
type ErrorResponse ¶
type ErrorResponse struct { Code *string `json:"code,omitempty"` Message *string `json:"message,omitempty"` }
ErrorResponse is error reponse indicates EventHub service is not able to process the incoming request. The reason is provided in the error message.
type EventHub ¶
type EventHub struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` *Properties `json:"properties,omitempty"` }
EventHub is description of the Event Hub resource.
type EventHubsClient ¶
type EventHubsClient struct {
ManagementClient
}
EventHubsClient is the azure Event Hubs client
func NewEventHubsClient ¶
func NewEventHubsClient(subscriptionID string) EventHubsClient
NewEventHubsClient creates an instance of the EventHubsClient client.
func NewEventHubsClientWithBaseURI ¶
func NewEventHubsClientWithBaseURI(baseURI string, subscriptionID string) EventHubsClient
NewEventHubsClientWithBaseURI creates an instance of the EventHubsClient client.
func (EventHubsClient) CreateOrUpdate ¶
func (client EventHubsClient) CreateOrUpdate(resourceGroupName string, namespaceName string, eventHubName string, parameters EventHub) (result EventHub, err error)
CreateOrUpdate creates or updates a new Event Hub as a nested resource within a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name parameters is parameters supplied to create an Event Hub resource.
func (EventHubsClient) CreateOrUpdateAuthorizationRule ¶
func (client EventHubsClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters SharedAccessAuthorizationRule) (result SharedAccessAuthorizationRule, err error)
CreateOrUpdateAuthorizationRule creates or updates an authorization rule for the specified Event Hub.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name authorizationRuleName is the authorizationrule name. parameters is the shared access authorization rule.
func (EventHubsClient) CreateOrUpdateAuthorizationRulePreparer ¶
func (client EventHubsClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters SharedAccessAuthorizationRule) (*http.Request, error)
CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.
func (EventHubsClient) CreateOrUpdateAuthorizationRuleResponder ¶
func (client EventHubsClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
CreateOrUpdateAuthorizationRuleResponder handles the response to the CreateOrUpdateAuthorizationRule request. The method always closes the http.Response Body.
func (EventHubsClient) CreateOrUpdateAuthorizationRuleSender ¶
func (client EventHubsClient) 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 (EventHubsClient) CreateOrUpdatePreparer ¶
func (client EventHubsClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, eventHubName string, parameters EventHub) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (EventHubsClient) CreateOrUpdateResponder ¶
func (client EventHubsClient) CreateOrUpdateResponder(resp *http.Response) (result EventHub, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (EventHubsClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (EventHubsClient) Delete ¶
func (client EventHubsClient) Delete(resourceGroupName string, namespaceName string, eventHubName string) (result autorest.Response, err error)
Delete deletes an Event Hub from the specified namespace and resource group.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name
func (EventHubsClient) DeleteAuthorizationRule ¶
func (client EventHubsClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string) (result autorest.Response, err error)
DeleteAuthorizationRule deletes an Event Hubs authorization rule.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name authorizationRuleName is the authorizationrule name.
func (EventHubsClient) DeleteAuthorizationRulePreparer ¶
func (client EventHubsClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string) (*http.Request, error)
DeleteAuthorizationRulePreparer prepares the DeleteAuthorizationRule request.
func (EventHubsClient) DeleteAuthorizationRuleResponder ¶
func (client EventHubsClient) 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 (EventHubsClient) DeleteAuthorizationRuleSender ¶
func (client EventHubsClient) 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 (EventHubsClient) DeletePreparer ¶
func (client EventHubsClient) DeletePreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (EventHubsClient) DeleteResponder ¶
func (client EventHubsClient) 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 (EventHubsClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (EventHubsClient) Get ¶
func (client EventHubsClient) Get(resourceGroupName string, namespaceName string, eventHubName string) (result EventHub, err error)
Get gets an Event Hubs description for the specified Event Hub.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name
func (EventHubsClient) GetAuthorizationRule ¶
func (client EventHubsClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string) (result SharedAccessAuthorizationRule, err error)
GetAuthorizationRule gets an authorization rule for an Event Hub by rule name.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name authorizationRuleName is the authorizationrule name.
func (EventHubsClient) GetAuthorizationRulePreparer ¶
func (client EventHubsClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string) (*http.Request, error)
GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.
func (EventHubsClient) GetAuthorizationRuleResponder ¶
func (client EventHubsClient) GetAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
GetAuthorizationRuleResponder handles the response to the GetAuthorizationRule request. The method always closes the http.Response Body.
func (EventHubsClient) GetAuthorizationRuleSender ¶
GetAuthorizationRuleSender sends the GetAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (EventHubsClient) GetPreparer ¶
func (client EventHubsClient) GetPreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (EventHubsClient) GetResponder ¶
func (client EventHubsClient) GetResponder(resp *http.Response) (result EventHub, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (EventHubsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (EventHubsClient) ListAuthorizationRules ¶
func (client EventHubsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, eventHubName string) (result SharedAccessAuthorizationRuleListResult, err error)
ListAuthorizationRules gets the authorization rules for an Event Hub.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name
func (EventHubsClient) ListAuthorizationRulesNextResults ¶
func (client EventHubsClient) ListAuthorizationRulesNextResults(lastResults SharedAccessAuthorizationRuleListResult) (result SharedAccessAuthorizationRuleListResult, err error)
ListAuthorizationRulesNextResults retrieves the next set of results, if any.
func (EventHubsClient) ListAuthorizationRulesPreparer ¶
func (client EventHubsClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string, eventHubName string) (*http.Request, error)
ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.
func (EventHubsClient) ListAuthorizationRulesResponder ¶
func (client EventHubsClient) 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 (EventHubsClient) ListAuthorizationRulesSender ¶
func (client EventHubsClient) 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 (EventHubsClient) ListByNamespace ¶
func (client EventHubsClient) ListByNamespace(resourceGroupName string, namespaceName string) (result ListResult, err error)
ListByNamespace gets all the Event Hubs in a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (EventHubsClient) ListByNamespaceNextResults ¶
func (client EventHubsClient) ListByNamespaceNextResults(lastResults ListResult) (result ListResult, err error)
ListByNamespaceNextResults retrieves the next set of results, if any.
func (EventHubsClient) ListByNamespacePreparer ¶
func (client EventHubsClient) ListByNamespacePreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
ListByNamespacePreparer prepares the ListByNamespace request.
func (EventHubsClient) ListByNamespaceResponder ¶
func (client EventHubsClient) ListByNamespaceResponder(resp *http.Response) (result ListResult, err error)
ListByNamespaceResponder handles the response to the ListByNamespace request. The method always closes the http.Response Body.
func (EventHubsClient) ListByNamespaceSender ¶
ListByNamespaceSender sends the ListByNamespace request. The method will close the http.Response Body if it receives an error.
func (EventHubsClient) ListKeys ¶
func (client EventHubsClient) ListKeys(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string) (result ResourceListKeys, err error)
ListKeys gets the ACS and SAS connection strings for the Event Hub.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name authorizationRuleName is the authorizationrule name.
func (EventHubsClient) ListKeysPreparer ¶
func (client EventHubsClient) ListKeysPreparer(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string) (*http.Request, error)
ListKeysPreparer prepares the ListKeys request.
func (EventHubsClient) ListKeysResponder ¶
func (client EventHubsClient) 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 (EventHubsClient) ListKeysSender ¶
ListKeysSender sends the ListKeys request. The method will close the http.Response Body if it receives an error.
func (EventHubsClient) RegenerateKeys ¶
func (client EventHubsClient) RegenerateKeys(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters RegenerateKeysParameters) (result ResourceListKeys, err error)
RegenerateKeys regenerates the ACS and SAS connection strings for the Event Hub.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name eventHubName is the eventhub name authorizationRuleName is the authorizationrule name. parameters is parameters supplied to regenerate the authorization rule.
func (EventHubsClient) RegenerateKeysPreparer ¶
func (client EventHubsClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters RegenerateKeysParameters) (*http.Request, error)
RegenerateKeysPreparer prepares the RegenerateKeys request.
func (EventHubsClient) RegenerateKeysResponder ¶
func (client EventHubsClient) 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 (EventHubsClient) RegenerateKeysSender ¶
RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.
type ListResult ¶
type ListResult struct { autorest.Response `json:"-"` Value *[]EventHub `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
ListResult is the response of the List Event Hubs operation.
func (ListResult) ListResultPreparer ¶
func (client ListResult) ListResultPreparer() (*http.Request, error)
ListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type ManagementClient ¶
ManagementClient is the base client for Eventhub.
func New ¶
func New(subscriptionID string) ManagementClient
New creates an instance of the ManagementClient client.
func NewWithBaseURI ¶
func NewWithBaseURI(baseURI string, subscriptionID string) ManagementClient
NewWithBaseURI creates an instance of the ManagementClient client.
type Namespace ¶
type Namespace struct { autorest.Response `json:"-"` ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` Location *string `json:"location,omitempty"` Tags *map[string]*string `json:"tags,omitempty"` Sku *Sku `json:"sku,omitempty"` *NamespaceProperties `json:"properties,omitempty"` }
Namespace is description of a namespace resource.
type NamespaceListResult ¶
type NamespaceListResult struct { autorest.Response `json:"-"` Value *[]Namespace `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
NamespaceListResult is the response of the List Namespace operation.
func (NamespaceListResult) NamespaceListResultPreparer ¶
func (client NamespaceListResult) NamespaceListResultPreparer() (*http.Request, error)
NamespaceListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type NamespaceProperties ¶
type NamespaceProperties struct { ProvisioningState *string `json:"provisioningState,omitempty"` CreatedAt *date.Time `json:"createdAt,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` ServiceBusEndpoint *string `json:"serviceBusEndpoint,omitempty"` }
NamespaceProperties is properties of the namespace.
type NamespaceUpdateParameter ¶
type NamespaceUpdateParameter struct { Tags *map[string]*string `json:"tags,omitempty"` Sku *Sku `json:"sku,omitempty"` }
NamespaceUpdateParameter is parameters supplied to the Patch Namespace operation.
type NamespacesClient ¶
type NamespacesClient struct {
ManagementClient
}
NamespacesClient is the azure Event Hubs client
func NewNamespacesClient ¶
func NewNamespacesClient(subscriptionID string) NamespacesClient
NewNamespacesClient creates an instance of the NamespacesClient client.
func NewNamespacesClientWithBaseURI ¶
func NewNamespacesClientWithBaseURI(baseURI string, subscriptionID string) NamespacesClient
NewNamespacesClientWithBaseURI creates an instance of the NamespacesClient client.
func (NamespacesClient) CheckNameAvailabilityMethod ¶
func (client NamespacesClient) CheckNameAvailabilityMethod(parameters CheckNameAvailability) (result CheckNameAvailabilityResult, err error)
CheckNameAvailabilityMethod check the give namespace name availability.
parameters is parameters to check availability of the given namespace name
func (NamespacesClient) CheckNameAvailabilityMethodPreparer ¶
func (client NamespacesClient) CheckNameAvailabilityMethodPreparer(parameters CheckNameAvailability) (*http.Request, error)
CheckNameAvailabilityMethodPreparer prepares the CheckNameAvailabilityMethod request.
func (NamespacesClient) CheckNameAvailabilityMethodResponder ¶
func (client NamespacesClient) CheckNameAvailabilityMethodResponder(resp *http.Response) (result CheckNameAvailabilityResult, err error)
CheckNameAvailabilityMethodResponder handles the response to the CheckNameAvailabilityMethod request. The method always closes the http.Response Body.
func (NamespacesClient) CheckNameAvailabilityMethodSender ¶
func (client NamespacesClient) CheckNameAvailabilityMethodSender(req *http.Request) (*http.Response, error)
CheckNameAvailabilityMethodSender sends the CheckNameAvailabilityMethod request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) CreateOrUpdate ¶
func (client NamespacesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, parameters Namespace, cancel <-chan struct{}) (result autorest.Response, err error)
CreateOrUpdate creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name parameters is parameters for creating a namespace resource.
func (NamespacesClient) CreateOrUpdateAuthorizationRule ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters SharedAccessAuthorizationRule) (result SharedAccessAuthorizationRule, err error)
CreateOrUpdateAuthorizationRule creates or updates an authorization rule for a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name. parameters is the shared access authorization rule.
func (NamespacesClient) CreateOrUpdateAuthorizationRulePreparer ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters SharedAccessAuthorizationRule) (*http.Request, error)
CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.
func (NamespacesClient) CreateOrUpdateAuthorizationRuleResponder ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
CreateOrUpdateAuthorizationRuleResponder handles the response to the CreateOrUpdateAuthorizationRule request. The method always closes the http.Response Body.
func (NamespacesClient) CreateOrUpdateAuthorizationRuleSender ¶
func (client NamespacesClient) CreateOrUpdateAuthorizationRuleSender(req *http.Request) (*http.Response, error)
CreateOrUpdateAuthorizationRuleSender sends the CreateOrUpdateAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) CreateOrUpdatePreparer ¶
func (client NamespacesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, parameters Namespace, cancel <-chan struct{}) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (NamespacesClient) CreateOrUpdateResponder ¶
func (client NamespacesClient) CreateOrUpdateResponder(resp *http.Response) (result autorest.Response, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (NamespacesClient) CreateOrUpdateSender ¶
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) Delete ¶
func (client NamespacesClient) Delete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (result autorest.Response, err error)
Delete deletes an existing namespace. This operation also removes all associated resources under the namespace. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (NamespacesClient) DeleteAuthorizationRule ¶
func (client NamespacesClient) DeleteAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result autorest.Response, err error)
DeleteAuthorizationRule deletes an authorization rule for a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name.
func (NamespacesClient) DeleteAuthorizationRulePreparer ¶
func (client NamespacesClient) DeleteAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
DeleteAuthorizationRulePreparer prepares the DeleteAuthorizationRule request.
func (NamespacesClient) DeleteAuthorizationRuleResponder ¶
func (client NamespacesClient) DeleteAuthorizationRuleResponder(resp *http.Response) (result autorest.Response, err error)
DeleteAuthorizationRuleResponder handles the response to the DeleteAuthorizationRule request. The method always closes the http.Response Body.
func (NamespacesClient) DeleteAuthorizationRuleSender ¶
func (client NamespacesClient) DeleteAuthorizationRuleSender(req *http.Request) (*http.Response, error)
DeleteAuthorizationRuleSender sends the DeleteAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) DeletePreparer ¶
func (client NamespacesClient) DeletePreparer(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (NamespacesClient) DeleteResponder ¶
func (client NamespacesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (NamespacesClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) Get ¶
func (client NamespacesClient) Get(resourceGroupName string, namespaceName string) (result Namespace, err error)
Get gets the description of the specified namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (NamespacesClient) GetAuthorizationRule ¶
func (client NamespacesClient) GetAuthorizationRule(resourceGroupName string, namespaceName string, authorizationRuleName string) (result SharedAccessAuthorizationRule, err error)
GetAuthorizationRule gets an authorization rule for a namespace by rule name.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name.
func (NamespacesClient) GetAuthorizationRulePreparer ¶
func (client NamespacesClient) GetAuthorizationRulePreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.
func (NamespacesClient) GetAuthorizationRuleResponder ¶
func (client NamespacesClient) GetAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRule, err error)
GetAuthorizationRuleResponder handles the response to the GetAuthorizationRule request. The method always closes the http.Response Body.
func (NamespacesClient) GetAuthorizationRuleSender ¶
func (client NamespacesClient) GetAuthorizationRuleSender(req *http.Request) (*http.Response, error)
GetAuthorizationRuleSender sends the GetAuthorizationRule request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) GetPreparer ¶
func (client NamespacesClient) GetPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (NamespacesClient) GetResponder ¶
func (client NamespacesClient) GetResponder(resp *http.Response) (result Namespace, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (NamespacesClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) List ¶
func (client NamespacesClient) List() (result NamespaceListResult, err error)
List lists all the available namespaces within a subscription, irrespective of the resource groups.
func (NamespacesClient) ListAuthorizationRules ¶
func (client NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string) (result SharedAccessAuthorizationRuleListResult, err error)
ListAuthorizationRules gets a list of authorization rules for a namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name
func (NamespacesClient) ListAuthorizationRulesNextResults ¶
func (client NamespacesClient) ListAuthorizationRulesNextResults(lastResults SharedAccessAuthorizationRuleListResult) (result SharedAccessAuthorizationRuleListResult, err error)
ListAuthorizationRulesNextResults retrieves the next set of results, if any.
func (NamespacesClient) ListAuthorizationRulesPreparer ¶
func (client NamespacesClient) ListAuthorizationRulesPreparer(resourceGroupName string, namespaceName string) (*http.Request, error)
ListAuthorizationRulesPreparer prepares the ListAuthorizationRules request.
func (NamespacesClient) ListAuthorizationRulesResponder ¶
func (client NamespacesClient) ListAuthorizationRulesResponder(resp *http.Response) (result SharedAccessAuthorizationRuleListResult, err error)
ListAuthorizationRulesResponder handles the response to the ListAuthorizationRules request. The method always closes the http.Response Body.
func (NamespacesClient) ListAuthorizationRulesSender ¶
func (client NamespacesClient) ListAuthorizationRulesSender(req *http.Request) (*http.Response, error)
ListAuthorizationRulesSender sends the ListAuthorizationRules request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) ListByResourceGroup ¶
func (client NamespacesClient) ListByResourceGroup(resourceGroupName string) (result NamespaceListResult, err error)
ListByResourceGroup lists the available namespaces within a resource group.
resourceGroupName is name of the Resource group within the Azure subscription.
func (NamespacesClient) ListByResourceGroupNextResults ¶
func (client NamespacesClient) ListByResourceGroupNextResults(lastResults NamespaceListResult) (result NamespaceListResult, err error)
ListByResourceGroupNextResults retrieves the next set of results, if any.
func (NamespacesClient) ListByResourceGroupPreparer ¶
func (client NamespacesClient) ListByResourceGroupPreparer(resourceGroupName string) (*http.Request, error)
ListByResourceGroupPreparer prepares the ListByResourceGroup request.
func (NamespacesClient) ListByResourceGroupResponder ¶
func (client NamespacesClient) ListByResourceGroupResponder(resp *http.Response) (result NamespaceListResult, err error)
ListByResourceGroupResponder handles the response to the ListByResourceGroup request. The method always closes the http.Response Body.
func (NamespacesClient) ListByResourceGroupSender ¶
ListByResourceGroupSender sends the ListByResourceGroup request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) ListKeys ¶
func (client NamespacesClient) ListKeys(resourceGroupName string, namespaceName string, authorizationRuleName string) (result ResourceListKeys, err error)
ListKeys gets the primary and secondary connection strings for the namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name.
func (NamespacesClient) ListKeysPreparer ¶
func (client NamespacesClient) ListKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string) (*http.Request, error)
ListKeysPreparer prepares the ListKeys request.
func (NamespacesClient) ListKeysResponder ¶
func (client NamespacesClient) ListKeysResponder(resp *http.Response) (result ResourceListKeys, err error)
ListKeysResponder handles the response to the ListKeys request. The method always closes the http.Response Body.
func (NamespacesClient) ListKeysSender ¶
ListKeysSender sends the ListKeys request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) ListNextResults ¶
func (client NamespacesClient) ListNextResults(lastResults NamespaceListResult) (result NamespaceListResult, err error)
ListNextResults retrieves the next set of results, if any.
func (NamespacesClient) ListPreparer ¶
func (client NamespacesClient) ListPreparer() (*http.Request, error)
ListPreparer prepares the List request.
func (NamespacesClient) ListResponder ¶
func (client NamespacesClient) ListResponder(resp *http.Response) (result NamespaceListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (NamespacesClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) RegenerateKeys ¶
func (client NamespacesClient) RegenerateKeys(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateKeysParameters) (result ResourceListKeys, err error)
RegenerateKeys regenerates the primary or secondary connection strings for the specified namespace.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name authorizationRuleName is the authorizationrule name. parameters is parameters required to regenerate the connection string.
func (NamespacesClient) RegenerateKeysPreparer ¶
func (client NamespacesClient) RegenerateKeysPreparer(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateKeysParameters) (*http.Request, error)
RegenerateKeysPreparer prepares the RegenerateKeys request.
func (NamespacesClient) RegenerateKeysResponder ¶
func (client NamespacesClient) RegenerateKeysResponder(resp *http.Response) (result ResourceListKeys, err error)
RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.
func (NamespacesClient) RegenerateKeysSender ¶
RegenerateKeysSender sends the RegenerateKeys request. The method will close the http.Response Body if it receives an error.
func (NamespacesClient) Update ¶
func (client NamespacesClient) Update(resourceGroupName string, namespaceName string, parameters NamespaceUpdateParameter) (result Namespace, err error)
Update creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent.
resourceGroupName is name of the Resource group within the Azure subscription. namespaceName is the namespace name parameters is parameters for updating a namespace resource.
func (NamespacesClient) UpdatePreparer ¶
func (client NamespacesClient) UpdatePreparer(resourceGroupName string, namespaceName string, parameters NamespaceUpdateParameter) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (NamespacesClient) UpdateResponder ¶
func (client NamespacesClient) UpdateResponder(resp *http.Response) (result Namespace, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (NamespacesClient) UpdateSender ¶
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type Operation ¶
type Operation struct { Name *string `json:"name,omitempty"` Display *OperationDisplay `json:"display,omitempty"` }
Operation is a EventHub REST API operation
type OperationDisplay ¶
type OperationDisplay struct { Provider *string `json:"provider,omitempty"` Resource *string `json:"resource,omitempty"` Operation *string `json:"operation,omitempty"` }
OperationDisplay is the object that represents the operation.
type OperationListResult ¶
type OperationListResult struct { autorest.Response `json:"-"` Value *[]Operation `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
OperationListResult is result of the request to list EventHub operations. It contains a list of operations and a URL link to get the next set of results.
func (OperationListResult) OperationListResultPreparer ¶
func (client OperationListResult) OperationListResultPreparer() (*http.Request, error)
OperationListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type OperationsClient ¶
type OperationsClient struct {
ManagementClient
}
OperationsClient is the azure Event Hubs client
func NewOperationsClient ¶
func NewOperationsClient(subscriptionID string) OperationsClient
NewOperationsClient creates an instance of the OperationsClient client.
func NewOperationsClientWithBaseURI ¶
func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient
NewOperationsClientWithBaseURI creates an instance of the OperationsClient client.
func (OperationsClient) List ¶
func (client OperationsClient) List() (result OperationListResult, err error)
List lists all of the available event hub REST API operations.
func (OperationsClient) ListNextResults ¶
func (client OperationsClient) ListNextResults(lastResults OperationListResult) (result OperationListResult, err error)
ListNextResults retrieves the next set of results, if any.
func (OperationsClient) ListPreparer ¶
func (client OperationsClient) ListPreparer() (*http.Request, error)
ListPreparer prepares the List request.
func (OperationsClient) ListResponder ¶
func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (OperationsClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type Properties ¶
type Properties struct { CreatedAt *date.Time `json:"createdAt,omitempty"` MessageRetentionInDays *int64 `json:"messageRetentionInDays,omitempty"` PartitionCount *int64 `json:"partitionCount,omitempty"` PartitionIds *[]string `json:"partitionIds,omitempty"` Status EntityStatus `json:"status,omitempty"` UpdatedAt *date.Time `json:"updatedAt,omitempty"` }
Properties is description of a EventHub Properties.
type RegenerateKeysParameters ¶
type RegenerateKeysParameters struct {
Policykey Policykey `json:"policykey,omitempty"`
}
RegenerateKeysParameters is parameters supplied to the Regenerate Authorization Rule operation.
type Resource ¶
type Resource struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` }
Resource is the Resource definition
type ResourceListKeys ¶
type ResourceListKeys struct { autorest.Response `json:"-"` PrimaryConnectionString *string `json:"primaryConnectionString,omitempty"` SecondaryConnectionString *string `json:"secondaryConnectionString,omitempty"` PrimaryKey *string `json:"primaryKey,omitempty"` SecondaryKey *string `json:"secondaryKey,omitempty"` KeyName *string `json:"keyName,omitempty"` }
ResourceListKeys is namespace/EventHub Connection String
type SharedAccessAuthorizationRule ¶
type SharedAccessAuthorizationRule struct {}
SharedAccessAuthorizationRule is description of a namespace authorization rule.
type SharedAccessAuthorizationRuleListResult ¶
type SharedAccessAuthorizationRuleListResult struct {}
SharedAccessAuthorizationRuleListResult is the response from the List Namespace operation.
func (SharedAccessAuthorizationRuleListResult) SharedAccessAuthorizationRuleListResultPreparer ¶
func (client SharedAccessAuthorizationRuleListResult) SharedAccessAuthorizationRuleListResultPreparer() (*http.Request, error)
SharedAccessAuthorizationRuleListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.
type SharedAccessAuthorizationRuleProperties ¶
type SharedAccessAuthorizationRuleProperties struct {
}SharedAccessAuthorizationRuleProperties is sharedAccessAuthorizationRule properties.
type Sku ¶
type Sku struct { Name SkuName `json:"name,omitempty"` Tier SkuTier `json:"tier,omitempty"` Capacity *int32 `json:"capacity,omitempty"` }
Sku is sKU of the namespace.
type SkuTier ¶
type SkuTier string
SkuTier enumerates the values for sku tier.
const ( // SkuTierBasic specifies the sku tier basic state for sku tier. SkuTierBasic SkuTier = "Basic" // SkuTierPremium specifies the sku tier premium state for sku tier. SkuTierPremium SkuTier = "Premium" // SkuTierStandard specifies the sku tier standard state for sku tier. SkuTierStandard SkuTier = "Standard" )
type TrackedResource ¶
type TrackedResource struct { ID *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` Location *string `json:"location,omitempty"` Tags *map[string]*string `json:"tags,omitempty"` }
TrackedResource is definition of Resource
type UnavailableReason ¶
type UnavailableReason string
UnavailableReason enumerates the values for unavailable reason.
const ( // InvalidName specifies the invalid name state for unavailable reason. InvalidName UnavailableReason = "InvalidName" // NameInLockdown specifies the name in lockdown state for unavailable // reason. NameInLockdown UnavailableReason = "NameInLockdown" // NameInUse specifies the name in use state for unavailable reason. NameInUse UnavailableReason = "NameInUse" // None specifies the none state for unavailable reason. None UnavailableReason = "None" // SubscriptionIsDisabled specifies the subscription is disabled state for // unavailable reason. SubscriptionIsDisabled UnavailableReason = "SubscriptionIsDisabled" // TooManyNamespaceInCurrentSubscription specifies the too many namespace // in current subscription state for unavailable reason. TooManyNamespaceInCurrentSubscription UnavailableReason = "TooManyNamespaceInCurrentSubscription" )