eventhub

package
v8.0.0-beta+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 8, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package eventhub implements the Azure ARM Eventhub service API version 2015-08-01.

Azure Event Hubs client

Index

Constants

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

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

type ConsumerGroupCreateOrUpdateParameters struct {
	Location                 *string `json:"location,omitempty"`
	Type                     *string `json:"type,omitempty"`
	Name                     *string `json:"name,omitempty"`
	*ConsumerGroupProperties `json:"properties,omitempty"`
}

ConsumerGroupCreateOrUpdateParameters is parameters supplied to the Create Or Update Consumer Group operation.

type ConsumerGroupListResult

type ConsumerGroupListResult struct {
	autorest.Response `json:"-"`
	Value             *[]ConsumerGroupResource `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

type ConsumerGroupResource

type ConsumerGroupResource 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"`
	*ConsumerGroupProperties `json:"properties,omitempty"`
}

ConsumerGroupResource is description of the consumer group resource.

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 ConsumerGroupCreateOrUpdateParameters) (result ConsumerGroupResource, err error)

CreateOrUpdate creates or updates an Event Hubs consumer group as a nested resource within a namespace.

resourceGroupName is the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub 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 ConsumerGroupCreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (ConsumerGroupsClient) CreateOrUpdateResponder

func (client ConsumerGroupsClient) CreateOrUpdateResponder(resp *http.Response) (result ConsumerGroupResource, err error)

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

func (ConsumerGroupsClient) CreateOrUpdateSender

func (client ConsumerGroupsClient) 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 (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 the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub name. consumerGroupName is the Cconsumer 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

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

func (client ConsumerGroupsClient) Get(resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string) (result ConsumerGroupResource, err error)

Get gets a description for the specified consumer group.

resourceGroupName is the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub 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 ConsumerGroupResource, err error)

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

func (ConsumerGroupsClient) GetSender

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

func (client ConsumerGroupsClient) ListAll(resourceGroupName string, namespaceName string, eventHubName string) (result ConsumerGroupListResult, err error)

ListAll gets all the consumer groups in a namespace. An empty feed is returned if no consumer group exists in the namespace.

resourceGroupName is the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub name.

func (ConsumerGroupsClient) ListAllNextResults

func (client ConsumerGroupsClient) ListAllNextResults(lastResults ConsumerGroupListResult) (result ConsumerGroupListResult, err error)

ListAllNextResults retrieves the next set of results, if any.

func (ConsumerGroupsClient) ListAllPreparer

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

ListAllPreparer prepares the ListAll request.

func (ConsumerGroupsClient) ListAllResponder

func (client ConsumerGroupsClient) ListAllResponder(resp *http.Response) (result ConsumerGroupListResult, err error)

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

func (ConsumerGroupsClient) ListAllSender

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

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

CreateOrUpdateParameters is parameters supplied to the Create Or Update Event Hub operation.

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 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 CreateOrUpdateParameters) (result ResourceType, err error)

CreateOrUpdate creates or updates a new Event Hub as a nested resource within a namespace.

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

CreateOrUpdateAuthorizationRule creates or updates an authorization rule for the specified Event Hub.

resourceGroupName is the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub name. authorizationRuleName is the authorization rule name. parameters is the shared access authorization rule.

func (EventHubsClient) CreateOrUpdateAuthorizationRulePreparer

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

CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.

func (EventHubsClient) CreateOrUpdateAuthorizationRuleResponder

func (client EventHubsClient) 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 (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 CreateOrUpdateParameters) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (EventHubsClient) CreateOrUpdateResponder

func (client EventHubsClient) CreateOrUpdateResponder(resp *http.Response) (result ResourceType, err error)

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

func (EventHubsClient) CreateOrUpdateSender

func (client EventHubsClient) 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 (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 the name of the resource group. namespaceName is the namespace name. eventHubName is the name of the Event Hub to delete.

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 the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub name. authorizationRuleName is the authorization rule 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

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

func (client EventHubsClient) Get(resourceGroupName string, namespaceName string, eventHubName string) (result ResourceType, err error)

Get gets an Event Hubs description for the specified Event Hub.

resourceGroupName is the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub name.

func (EventHubsClient) GetAuthorizationRule

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

GetAuthorizationRule gets an authorization rule for an Event Hub by rule name.

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

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

func (EventHubsClient) GetAuthorizationRuleSender

func (client EventHubsClient) 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 (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 ResourceType, err error)

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

func (EventHubsClient) GetSender

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

func (client EventHubsClient) ListAll(resourceGroupName string, namespaceName string) (result ListResult, err error)

ListAll gets all the Event Hubs in a namespace.

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

func (EventHubsClient) ListAllNextResults

func (client EventHubsClient) ListAllNextResults(lastResults ListResult) (result ListResult, err error)

ListAllNextResults retrieves the next set of results, if any.

func (EventHubsClient) ListAllPreparer

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

ListAllPreparer prepares the ListAll request.

func (EventHubsClient) ListAllResponder

func (client EventHubsClient) ListAllResponder(resp *http.Response) (result ListResult, err error)

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

func (EventHubsClient) ListAllSender

func (client EventHubsClient) 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 (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 the name of the resource group. namespaceName is the namespace name eventHubName is the Event Hub 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) 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 the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub name. authorizationRuleName is the connection string of the namespace for the specified authorization rule.

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

func (client EventHubsClient) 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 (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 the name of the resource group. namespaceName is the namespace name. eventHubName is the Event Hub name. authorizationRuleName is the connection string of the Event Hub for the specified authorization rule. 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

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

type ListResult struct {
	autorest.Response `json:"-"`
	Value             *[]ResourceType `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

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

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 NamespaceCreateOrUpdateParameters

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

NamespaceCreateOrUpdateParameters is parameters supplied to the Create Or Update Namespace operation.

type NamespaceListResult

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

NamespaceListResult is the response of the List Namespace operation.

func (NamespaceListResult) NamespaceListResultPreparer

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

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

type NamespaceProperties

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

NamespaceProperties is properties of the namespace.

type NamespaceResource

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

NamespaceResource is description of a namespace resource.

type NamespaceState

type NamespaceState string

NamespaceState enumerates the values for namespace state.

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

type NamespacesClient

type NamespacesClient struct {
	ManagementClient
}

NamespacesClient is the azure 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) CreateOrUpdate

func (client NamespacesClient) CreateOrUpdate(resourceGroupName string, namespaceName string, parameters NamespaceCreateOrUpdateParameters, 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 the name of the resource group. 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 SharedAccessAuthorizationRuleCreateOrUpdateParameters) (result SharedAccessAuthorizationRuleResource, err error)

CreateOrUpdateAuthorizationRule creates or updates an authorization rule for a namespace.

resourceGroupName is the name of the resource group in which the namespace lives. namespaceName is the namespace name. authorizationRuleName is namespace authorization rule name. parameters is the shared access authorization rule.

func (NamespacesClient) CreateOrUpdateAuthorizationRulePreparer

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

CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.

func (NamespacesClient) CreateOrUpdateAuthorizationRuleResponder

func (client NamespacesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result SharedAccessAuthorizationRuleResource, err error)

CreateOrUpdateAuthorizationRuleResponder handles the response to the CreateOrUpdateAuthorizationRule request. The method always closes the http.Response Body.

func (NamespacesClient) CreateOrUpdateAuthorizationRuleSender

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

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

func (NamespacesClient) CreateOrUpdatePreparer

func (client NamespacesClient) CreateOrUpdatePreparer(resourceGroupName string, namespaceName string, parameters NamespaceCreateOrUpdateParameters, cancel <-chan struct{}) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (NamespacesClient) CreateOrUpdateResponder

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

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

func (NamespacesClient) CreateOrUpdateSender

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

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

func (NamespacesClient) Delete

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

Delete deletes an existing namespace. This operation also removes all associated resources under the namespace. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group in which the namespace lives. namespaceName is the name of the namespace to delete.

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 the name of the resource group in which the namespace lives. namespaceName is the namespace name. authorizationRuleName is authorization rule name.

func (NamespacesClient) DeleteAuthorizationRulePreparer

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

DeleteAuthorizationRulePreparer prepares the DeleteAuthorizationRule request.

func (NamespacesClient) DeleteAuthorizationRuleResponder

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

DeleteAuthorizationRuleResponder handles the response to the DeleteAuthorizationRule request. The method always closes the http.Response Body.

func (NamespacesClient) DeleteAuthorizationRuleSender

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

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

func (NamespacesClient) DeletePreparer

func (client NamespacesClient) DeletePreparer(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (NamespacesClient) DeleteResponder

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

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

func (NamespacesClient) DeleteSender

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

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

func (NamespacesClient) Get

func (client NamespacesClient) Get(resourceGroupName string, namespaceName string) (result NamespaceResource, err error)

Get gets the description of the specified namespace.

resourceGroupName is the name of the resource group in which the namespace lives. namespaceName is the name of the specified namespace.

func (NamespacesClient) GetAuthorizationRule

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

GetAuthorizationRule gets an authorization rule for a namespace by rule name.

resourceGroupName is the name of the resource group in which the namespace lives. namespaceName is the namespace name. authorizationRuleName is authorization rule name.

func (NamespacesClient) GetAuthorizationRulePreparer

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

GetAuthorizationRulePreparer prepares the GetAuthorizationRule request.

func (NamespacesClient) GetAuthorizationRuleResponder

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

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

func (NamespacesClient) GetAuthorizationRuleSender

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

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

func (NamespacesClient) GetPreparer

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

GetPreparer prepares the Get request.

func (NamespacesClient) GetResponder

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

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

func (NamespacesClient) GetSender

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

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

func (NamespacesClient) ListAuthorizationRules

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

ListAuthorizationRules gets a list of authorization rules for a namespace.

resourceGroupName is the name of the resource group in which the namespace lives. 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 the name of the resource group.

func (NamespacesClient) ListByResourceGroupNextResults

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

ListByResourceGroupNextResults retrieves the next set of results, if any.

func (NamespacesClient) ListByResourceGroupPreparer

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

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (NamespacesClient) ListByResourceGroupResponder

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

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

func (NamespacesClient) ListByResourceGroupSender

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

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

func (NamespacesClient) ListBySubscription

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

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

func (NamespacesClient) ListBySubscriptionNextResults

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

ListBySubscriptionNextResults retrieves the next set of results, if any.

func (NamespacesClient) ListBySubscriptionPreparer

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

ListBySubscriptionPreparer prepares the ListBySubscription request.

func (NamespacesClient) ListBySubscriptionResponder

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

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

func (NamespacesClient) ListBySubscriptionSender

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

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

func (NamespacesClient) ListKeys

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

ListKeys gets the primary and secondary connection strings for the namespace.

resourceGroupName is the name of the resource group in which the namespace lives. namespaceName is the namespace name. authorizationRuleName is the authorization rule name.

func (NamespacesClient) ListKeysPreparer

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

ListKeysPreparer prepares the ListKeys request.

func (NamespacesClient) ListKeysResponder

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

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

func (NamespacesClient) ListKeysSender

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

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

func (NamespacesClient) RegenerateKeys

func (client NamespacesClient) RegenerateKeys(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateKeysParameters) (result ResourceListKeys, err error)

RegenerateKeys regenerates the primary or secondary connection strings for the specified namespace.

resourceGroupName is the name of the resource group in which the namespace lives. namespaceName is the namespace name. authorizationRuleName is the authorization rule 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

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

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

type Policykey

type Policykey string

Policykey enumerates the values for policykey.

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

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

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"`
	Location *string             `json:"location,omitempty"`
	Tags     *map[string]*string `json:"tags,omitempty"`
}

Resource is

type ResourceListKeys

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

ResourceListKeys is namespace/EventHub Connection String

type ResourceType

type ResourceType struct {
	autorest.Response `json:"-"`
	ID                *string             `json:"id,omitempty"`
	Name              *string             `json:"name,omitempty"`
	Type              *string             `json:"type,omitempty"`
	Location          *string             `json:"location,omitempty"`
	Tags              *map[string]*string `json:"tags,omitempty"`
	*Properties       `json:"properties,omitempty"`
}

ResourceType is description of the Event Hub resource.

type SharedAccessAuthorizationRuleCreateOrUpdateParameters

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

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

type SharedAccessAuthorizationRuleListResult

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

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 {
	Rights *[]AccessRights `json:"rights,omitempty"`
}

SharedAccessAuthorizationRuleProperties is sharedAccessAuthorizationRule properties.

type SharedAccessAuthorizationRuleResource

type SharedAccessAuthorizationRuleResource struct {
	autorest.Response                        `json:"-"`
	ID                                       *string             `json:"id,omitempty"`
	Name                                     *string             `json:"name,omitempty"`
	Type                                     *string             `json:"type,omitempty"`
	Location                                 *string             `json:"location,omitempty"`
	Tags                                     *map[string]*string `json:"tags,omitempty"`
	*SharedAccessAuthorizationRuleProperties `json:"properties,omitempty"`
}

SharedAccessAuthorizationRuleResource is description of a namespace authorization rule.

type Sku

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

Sku is sKU of the namespace.

type SkuName

type SkuName string

SkuName enumerates the values for sku name.

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

type SkuTier

type SkuTier string

SkuTier enumerates the values for sku tier.

const (
	// SkuTierBasic specifies the sku tier basic state for sku tier.
	SkuTierBasic SkuTier = "Basic"
	// SkuTierPremium specifies the sku tier premium state for sku tier.
	SkuTierPremium SkuTier = "Premium"
	// SkuTierStandard specifies the sku tier standard state for sku tier.
	SkuTierStandard SkuTier = "Standard"
)

Jump to

Keyboard shortcuts

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