eventhub

package
v11.2.0-beta+incompatible Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2017 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package eventhub implements the Azure ARM Eventhub service API version 2017-04-01.

Azure Event Hubs client

Index

Constants

View Source 
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 AccessKeys 

type AccessKeys 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"`
}

AccessKeys is namespace/EventHub Connection String

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 AuthorizationRule 

type AuthorizationRule struct {
	autorest.Response            `json:"-"`
	ID                           *string `json:"id,omitempty"`
	Name                         *string `json:"name,omitempty"`
	Type                         *string `json:"type,omitempty"`
	*AuthorizationRuleProperties `json:"properties,omitempty"`
}

AuthorizationRule is single item in a List or Get AuthorizationRule operation

type AuthorizationRuleListResult 

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

AuthorizationRuleListResult is the response from the List namespace operation.

func (AuthorizationRuleListResult) AuthorizationRuleListResultPreparer 

func (client AuthorizationRuleListResult) AuthorizationRuleListResultPreparer() (*http.Request, error)

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

type AuthorizationRuleProperties 

type AuthorizationRuleProperties struct {
	Rights *[]AccessRights `json:"rights,omitempty"`
}

AuthorizationRuleProperties is properties supplied to create or update AuthorizationRule

type CaptureDescription 

type CaptureDescription struct {
	Enabled           *bool                      `json:"enabled,omitempty"`
	Encoding          EncodingCaptureDescription `json:"encoding,omitempty"`
	IntervalInSeconds *int32                     `json:"intervalInSeconds,omitempty"`
	SizeLimitInBytes  *int32                     `json:"sizeLimitInBytes,omitempty"`
	Destination       *Destination               `json:"destination,omitempty"`
}

CaptureDescription is properties to configure capture description for eventhub

type CheckNameAvailabilityParameter 

type CheckNameAvailabilityParameter struct {
	Name *string `json:"name,omitempty"`
}

CheckNameAvailabilityParameter is parameter supplied to check Namespace name availability operation

type CheckNameAvailabilityResult 

type CheckNameAvailabilityResult struct {
	autorest.Response `json:"-"`
	Message           *string           `json:"message,omitempty"`
	NameAvailable     *bool             `json:"nameAvailable,omitempty"`
	Reason            UnavailableReason `json:"reason,omitempty"`
}

CheckNameAvailabilityResult is the Result of the CheckNameAvailability operation

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 single item in List or Get Consumer group operation

type ConsumerGroupListResult 

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

ConsumerGroupListResult is the result 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"`
	UpdatedAt    *date.Time `json:"updatedAt,omitempty"`
	UserMetadata *string    `json:"userMetadata,omitempty"`
}

ConsumerGroupProperties is single item in List or Get Consumer group operation

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 Event Hub name consumerGroupName is the consumer group name parameters is parameters supplied to create or update 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 

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 name of the resource group within the azure subscription. namespaceName is the Namespace name eventHubName is the Event Hub 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 

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 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 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 ConsumerGroup, 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) ListByEventHub 

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

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

resourceGroupName is name of the resource group within the azure subscription. namespaceName is the Namespace name eventHubName is the Event Hub name

func (ConsumerGroupsClient) ListByEventHubComplete 

func (client ConsumerGroupsClient) ListByEventHubComplete(resourceGroupName string, namespaceName string, eventHubName string, cancel <-chan struct{}) (<-chan ConsumerGroup, <-chan error)

ListByEventHubComplete gets all elements from the list without paging.

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 

func (client ConsumerGroupsClient) ListByEventHubSender(req *http.Request) (*http.Response, error)

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

type Destination 

type Destination struct {
	Name                   *string `json:"name,omitempty"`
	*DestinationProperties `json:"properties,omitempty"`
}

Destination is capture storage details for capture description

type DestinationProperties 

type DestinationProperties struct {
	StorageAccountResourceID *string `json:"storageAccountResourceId,omitempty"`
	BlobContainer            *string `json:"blobContainer,omitempty"`
	ArchiveNameFormat        *string `json:"archiveNameFormat,omitempty"`
}

DestinationProperties is properties describing the storage account, blob container and acrchive anme format for capture destination

type EHNamespace 

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

EHNamespace is single Namespace item in List or Get Operation

type EHNamespaceListResult 

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

EHNamespaceListResult is the response of the List Namespace operation

func (EHNamespaceListResult) EHNamespaceListResultPreparer 

func (client EHNamespaceListResult) EHNamespaceListResultPreparer() (*http.Request, error)

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

type EHNamespaceProperties 

type EHNamespaceProperties struct {
	ProvisioningState      *string    `json:"provisioningState,omitempty"`
	CreatedAt              *date.Time `json:"createdAt,omitempty"`
	UpdatedAt              *date.Time `json:"updatedAt,omitempty"`
	ServiceBusEndpoint     *string    `json:"serviceBusEndpoint,omitempty"`
	MetricID               *string    `json:"metricId,omitempty"`
	IsAutoInflateEnabled   *bool      `json:"isAutoInflateEnabled,omitempty"`
	MaximumThroughputUnits *int32     `json:"maximumThroughputUnits,omitempty"`
}

EHNamespaceProperties is namespace properties supplied for create namespace operation.

type EncodingCaptureDescription 

type EncodingCaptureDescription string

EncodingCaptureDescription enumerates the values for encoding capture description. 

const (
	// Avro specifies the avro state for encoding capture description.
	Avro EncodingCaptureDescription = "Avro"
	// AvroDeflate specifies the avro deflate state for encoding capture description.
	AvroDeflate EncodingCaptureDescription = "AvroDeflate"
)

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 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 Model) (result Model, 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 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 AuthorizationRule) (result AuthorizationRule, err error)

CreateOrUpdateAuthorizationRule creates or updates an AuthorizationRule for the specified Event Hub.

resourceGroupName is name of the resource group within the azure subscription. namespaceName is the Namespace name eventHubName is the Event Hub name authorizationRuleName is the authorization rule name. parameters is the shared access AuthorizationRule.

func (EventHubsClient) CreateOrUpdateAuthorizationRulePreparer 

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

CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.

func (EventHubsClient) CreateOrUpdateAuthorizationRuleResponder 

func (client EventHubsClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result AuthorizationRule, 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 Model) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (EventHubsClient) CreateOrUpdateResponder 

func (client EventHubsClient) CreateOrUpdateResponder(resp *http.Response) (result Model, 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 name of the resource group within the azure subscription. namespaceName is the Namespace name eventHubName is the Event Hub 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 Hub AuthorizationRule.

resourceGroupName is name of the resource group within the azure subscription. 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 Model, 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 Event Hub name

func (EventHubsClient) GetAuthorizationRule 

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

GetAuthorizationRule gets an AuthorizationRule 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 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 AuthorizationRule, 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 Model, 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) ListAuthorizationRules 

func (client EventHubsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, eventHubName string) (result AuthorizationRuleListResult, 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 Event Hub name

func (EventHubsClient) ListAuthorizationRulesComplete 

func (client EventHubsClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, eventHubName string, cancel <-chan struct{}) (<-chan AuthorizationRule, <-chan error)

ListAuthorizationRulesComplete gets all elements from the list without paging.

func (EventHubsClient) ListAuthorizationRulesNextResults 

func (client EventHubsClient) ListAuthorizationRulesNextResults(lastResults AuthorizationRuleListResult) (result AuthorizationRuleListResult, 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 AuthorizationRuleListResult, 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) ListByNamespaceComplete 

func (client EventHubsClient) ListByNamespaceComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan Model, <-chan error)

ListByNamespaceComplete gets all elements from the list without paging.

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 

func (client EventHubsClient) ListByNamespaceSender(req *http.Request) (*http.Response, error)

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 AccessKeys, 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 Event Hub name authorizationRuleName is the authorization rule 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 AccessKeys, 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 RegenerateAccessKeyParameters) (result AccessKeys, 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 Event Hub name authorizationRuleName is the authorization rule name. parameters is parameters supplied to regenerate the AuthorizationRule Keys (PrimaryKey/SecondaryKey).

func (EventHubsClient) RegenerateKeysPreparer 

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

RegenerateKeysPreparer prepares the RegenerateKeys request.

func (EventHubsClient) RegenerateKeysResponder 

func (client EventHubsClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, 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 KeyType 

type KeyType string

KeyType enumerates the values for key type. 

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

type ListResult 

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

ListResult is the result of the List EventHubs 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
	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 Model 

type Model struct {
	autorest.Response `json:"-"`
	ID                *string `json:"id,omitempty"`
	Name              *string `json:"name,omitempty"`
	Type              *string `json:"type,omitempty"`
	*Properties       `json:"properties,omitempty"`
}

Model is single item in List or Get Event Hub 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) CheckNameAvailability 

func (client NamespacesClient) CheckNameAvailability(parameters CheckNameAvailabilityParameter) (result CheckNameAvailabilityResult, err error)

CheckNameAvailability check the give Namespace name availability.

parameters is parameters to check availability of the given Namespace name

func (NamespacesClient) CheckNameAvailabilityPreparer 

func (client NamespacesClient) CheckNameAvailabilityPreparer(parameters CheckNameAvailabilityParameter) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (NamespacesClient) CheckNameAvailabilityResponder 

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

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (NamespacesClient) CheckNameAvailabilitySender 

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

CheckNameAvailabilitySender sends the CheckNameAvailability 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 EHNamespace, cancel <-chan struct{}) (<-chan EHNamespace, <-chan 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 AuthorizationRule) (result AuthorizationRule, err error)

CreateOrUpdateAuthorizationRule creates or updates an AuthorizationRule for a Namespace.

resourceGroupName is name of the resource group within the azure subscription. namespaceName is the Namespace name authorizationRuleName is the authorization rule name. parameters is the shared access AuthorizationRule.

func (NamespacesClient) CreateOrUpdateAuthorizationRulePreparer 

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

CreateOrUpdateAuthorizationRulePreparer prepares the CreateOrUpdateAuthorizationRule request.

func (NamespacesClient) CreateOrUpdateAuthorizationRuleResponder 

func (client NamespacesClient) CreateOrUpdateAuthorizationRuleResponder(resp *http.Response) (result AuthorizationRule, 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 EHNamespace, cancel <-chan struct{}) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (NamespacesClient) CreateOrUpdateResponder 

func (client NamespacesClient) CreateOrUpdateResponder(resp *http.Response) (result EHNamespace, 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{}) (<-chan autorest.Response, <-chan 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 AuthorizationRule for a Namespace.

resourceGroupName is name of the resource group within the azure subscription. namespaceName is the Namespace name authorizationRuleName is the 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 EHNamespace, 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 AuthorizationRule, err error)

GetAuthorizationRule gets an AuthorizationRule 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 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 AuthorizationRule, 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 EHNamespace, 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) List 

func (client NamespacesClient) List() (result EHNamespaceListResult, 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 AuthorizationRuleListResult, 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) ListAuthorizationRulesComplete 

func (client NamespacesClient) ListAuthorizationRulesComplete(resourceGroupName string, namespaceName string, cancel <-chan struct{}) (<-chan AuthorizationRule, <-chan error)

ListAuthorizationRulesComplete gets all elements from the list without paging.

func (NamespacesClient) ListAuthorizationRulesNextResults 

func (client NamespacesClient) ListAuthorizationRulesNextResults(lastResults AuthorizationRuleListResult) (result AuthorizationRuleListResult, 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 AuthorizationRuleListResult, 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 EHNamespaceListResult, err error)

ListByResourceGroup lists the available Namespaces within a resource group.

resourceGroupName is name of the resource group within the azure subscription.

func (NamespacesClient) ListByResourceGroupComplete 

func (client NamespacesClient) ListByResourceGroupComplete(resourceGroupName string, cancel <-chan struct{}) (<-chan EHNamespace, <-chan error)

ListByResourceGroupComplete gets all elements from the list without paging.

func (NamespacesClient) ListByResourceGroupNextResults 

func (client NamespacesClient) ListByResourceGroupNextResults(lastResults EHNamespaceListResult) (result EHNamespaceListResult, 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 EHNamespaceListResult, 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) ListComplete 

func (client NamespacesClient) ListComplete(cancel <-chan struct{}) (<-chan EHNamespace, <-chan error)

ListComplete gets all elements from the list without paging.

func (NamespacesClient) ListKeys 

func (client NamespacesClient) ListKeys(resourceGroupName string, namespaceName string, authorizationRuleName string) (result AccessKeys, 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 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 AccessKeys, 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) ListNextResults 

func (client NamespacesClient) ListNextResults(lastResults EHNamespaceListResult) (result EHNamespaceListResult, 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 EHNamespaceListResult, err error)

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

func (NamespacesClient) ListSender 

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

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

func (NamespacesClient) RegenerateKeys 

func (client NamespacesClient) RegenerateKeys(resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters) (result AccessKeys, 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 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 RegenerateAccessKeyParameters) (*http.Request, error)

RegenerateKeysPreparer prepares the RegenerateKeys request.

func (NamespacesClient) RegenerateKeysResponder 

func (client NamespacesClient) RegenerateKeysResponder(resp *http.Response) (result AccessKeys, err error)

RegenerateKeysResponder handles the response to the RegenerateKeys request. The method always closes the http.Response Body.

func (NamespacesClient) RegenerateKeysSender 

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

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

func (NamespacesClient) Update 

func (client NamespacesClient) Update(resourceGroupName string, namespaceName string, parameters EHNamespace) (result EHNamespace, 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 EHNamespace) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (NamespacesClient) UpdateResponder 

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

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

func (NamespacesClient) UpdateSender 

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

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

type Operation 

type Operation struct {
	Name    *string           `json:"name,omitempty"`
	Display *OperationDisplay `json:"display,omitempty"`
}

Operation is a Event Hub 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 Event Hub 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) ListComplete 

func (client OperationsClient) ListComplete(cancel <-chan struct{}) (<-chan Operation, <-chan error)

ListComplete gets all elements from the list without paging.

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 

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

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

type Properties 

type Properties struct {
	PartitionIds           *[]string           `json:"partitionIds,omitempty"`
	CreatedAt              *date.Time          `json:"createdAt,omitempty"`
	UpdatedAt              *date.Time          `json:"updatedAt,omitempty"`
	MessageRetentionInDays *int64              `json:"messageRetentionInDays,omitempty"`
	PartitionCount         *int64              `json:"partitionCount,omitempty"`
	Status                 EntityStatus        `json:"status,omitempty"`
	CaptureDescription     *CaptureDescription `json:"captureDescription,omitempty"`
}

Properties is properties supplied to the Create Or Update Event Hub operation.

type RegenerateAccessKeyParameters 

type RegenerateAccessKeyParameters struct {
	KeyType KeyType `json:"keyType,omitempty"`
	Key     *string `json:"key,omitempty"`
}

RegenerateAccessKeyParameters is parameters supplied to the Regenerate Authorization Rule operation, specifies which key neeeds to be reset.

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 Sku 

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

Sku is SKU parameters supplied to the create namespace operation

type SkuName 

type SkuName string

SkuName enumerates the values for sku name. 

const (
	// Basic specifies the basic state for sku name.
	Basic SkuName = "Basic"
	// 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"
	// 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"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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