armeventhub

package module
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2021 License: MIT Imports: 16 Imported by: 31

README

Azure Event Hubs Module for Go

PkgGoDev

The armeventhub module provides operations for working with Azure Event Hubs.

Source code

Getting started

Prerequisites

Install the package

This project uses Go modules for versioning and dependency management.

Install the Azure Event Hubs module:

go get github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub

Authorization

When creating a client, you will need to provide a credential for authenticating with Azure Event Hubs. The azidentity module provides facilities for various ways of authenticating with Azure including client/secret, certificate, managed identity, and more.

cred, err := azidentity.NewDefaultAzureCredential(nil)

For more information on authentication, please see the documentation for azidentity at pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/azidentity.

Connecting to Azure Event Hubs

Once you have a credential, create a connection to the desired ARM endpoint. The github.com/Azure/azure-sdk-for-go/sdk/azcore/arm package provides facilities for connecting with ARM endpoints including public and sovereign clouds as well as Azure Stack.

con := arm.NewDefaultConnection(cred, nil)

For more information on ARM connections, please see the documentation for azcore at pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/azcore.

Clients

Azure Event Hubs modules consist of one or more clients. A client groups a set of related APIs, providing access to its functionality within the specified subscription. Create one or more clients to access the APIs you require using your arm.Connection.

client := armeventhub.NewPrivateEndpointConnectionsClient(con, "<subscription ID>")

Provide Feedback

If you encounter bugs or have suggestions, please open an issue and assign the Event Hubs label.

Contributing

This project welcomes contributions and suggestions. Most contributions require you to agree to a Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us the rights to use your contribution. For details, visit https://cla.microsoft.com.

When you submit a pull request, a CLA-bot will automatically determine whether you need to provide a CLA and decorate the PR appropriately (e.g., label, comment). Simply follow the instructions provided by the bot. You will only need to do this once across all repos using our CLA.

This project has adopted the Microsoft Open Source Code of Conduct. For more information, see the Code of Conduct FAQ or contact opencode@microsoft.com with any additional questions or comments.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessKeys 

type AccessKeys struct {
	// READ-ONLY; Primary connection string of the alias if GEO DR is enabled
	AliasPrimaryConnectionString *string `json:"aliasPrimaryConnectionString,omitempty" azure:"ro"`

	// READ-ONLY; Secondary connection string of the alias if GEO DR is enabled
	AliasSecondaryConnectionString *string `json:"aliasSecondaryConnectionString,omitempty" azure:"ro"`

	// READ-ONLY; A string that describes the AuthorizationRule.
	KeyName *string `json:"keyName,omitempty" azure:"ro"`

	// READ-ONLY; Primary connection string of the created namespace AuthorizationRule.
	PrimaryConnectionString *string `json:"primaryConnectionString,omitempty" azure:"ro"`

	// READ-ONLY; A base64-encoded 256-bit primary key for signing and validating the SAS token.
	PrimaryKey *string `json:"primaryKey,omitempty" azure:"ro"`

	// READ-ONLY; Secondary connection string of the created namespace AuthorizationRule.
	SecondaryConnectionString *string `json:"secondaryConnectionString,omitempty" azure:"ro"`

	// READ-ONLY; A base64-encoded 256-bit primary key for signing and validating the SAS token.
	SecondaryKey *string `json:"secondaryKey,omitempty" azure:"ro"`
}

AccessKeys - Namespace/EventHub Connection String

type AccessRights 

type AccessRights string
const (
	AccessRightsListen AccessRights = "Listen"
	AccessRightsManage AccessRights = "Manage"
	AccessRightsSend   AccessRights = "Send"
)

func PossibleAccessRightsValues 

func PossibleAccessRightsValues() []AccessRights

PossibleAccessRightsValues returns the possible values for the AccessRights const type.

func (AccessRights) ToPtr 

func (c AccessRights) ToPtr() *AccessRights

ToPtr returns a *AccessRights pointing to the current value.

type ArmDisasterRecovery 

type ArmDisasterRecovery struct {
	Resource
	// Properties required to the Create Or Update Alias(Disaster Recovery configurations)
	Properties *ArmDisasterRecoveryProperties `json:"properties,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

ArmDisasterRecovery - Single item in List or Get Alias(Disaster Recovery configuration) operation

func (ArmDisasterRecovery) MarshalJSON 

func (a ArmDisasterRecovery) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ArmDisasterRecovery.

type ArmDisasterRecoveryListResult 

type ArmDisasterRecoveryListResult struct {
	// List of Alias(Disaster Recovery configurations)
	Value []*ArmDisasterRecovery `json:"value,omitempty"`

	// READ-ONLY; Link to the next set of results. Not empty if Value contains incomplete list of Alias(Disaster Recovery configuration)
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`
}

ArmDisasterRecoveryListResult - The result of the List Alias(Disaster Recovery configuration) operation.

func (ArmDisasterRecoveryListResult) MarshalJSON 

func (a ArmDisasterRecoveryListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ArmDisasterRecoveryListResult.

type ArmDisasterRecoveryProperties 

type ArmDisasterRecoveryProperties struct {
	// Alternate name specified when alias and namespace names are same.
	AlternateName *string `json:"alternateName,omitempty"`

	// ARM Id of the Primary/Secondary eventhub namespace name, which is part of GEO DR pairing
	PartnerNamespace *string `json:"partnerNamespace,omitempty"`

	// READ-ONLY; Number of entities pending to be replicated.
	PendingReplicationOperationsCount *int64 `json:"pendingReplicationOperationsCount,omitempty" azure:"ro"`

	// READ-ONLY; Provisioning state of the Alias(Disaster Recovery configuration) - possible values 'Accepted' or 'Succeeded' or 'Failed'
	ProvisioningState *ProvisioningStateDR `json:"provisioningState,omitempty" azure:"ro"`

	// READ-ONLY; role of namespace in GEO DR - possible values 'Primary' or 'PrimaryNotReplicating' or 'Secondary'
	Role *RoleDisasterRecovery `json:"role,omitempty" azure:"ro"`
}

ArmDisasterRecoveryProperties - Properties required to the Create Or Update Alias(Disaster Recovery configurations)

type AuthorizationRule 

type AuthorizationRule struct {
	Resource
	// Properties supplied to create or update AuthorizationRule
	Properties *AuthorizationRuleProperties `json:"properties,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

AuthorizationRule - Single item in a List or Get AuthorizationRule operation

func (AuthorizationRule) MarshalJSON 

func (a AuthorizationRule) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AuthorizationRule.

type AuthorizationRuleListResult 

type AuthorizationRuleListResult struct {
	// Link to the next set of results. Not empty if Value contains an incomplete list of Authorization Rules
	NextLink *string `json:"nextLink,omitempty"`

	// Result of the List Authorization Rules operation.
	Value []*AuthorizationRule `json:"value,omitempty"`
}

AuthorizationRuleListResult - The response from the List namespace operation.

func (AuthorizationRuleListResult) MarshalJSON 

func (a AuthorizationRuleListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AuthorizationRuleListResult.

type AuthorizationRuleProperties 

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

AuthorizationRuleProperties - Properties supplied to create or update AuthorizationRule

func (AuthorizationRuleProperties) MarshalJSON 

func (a AuthorizationRuleProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AuthorizationRuleProperties.

type AvailableCluster 

type AvailableCluster struct {
	// Location fo the Available Cluster
	Location *string `json:"location,omitempty"`
}

AvailableCluster - Pre-provisioned and readily available Event Hubs Cluster count per region.

type AvailableClustersList 

type AvailableClustersList struct {
	// The count of readily available and pre-provisioned Event Hubs Clusters per region.
	Value []*AvailableCluster `json:"value,omitempty"`
}

AvailableClustersList - The response of the List Available Clusters operation.

func (AvailableClustersList) MarshalJSON 

func (a AvailableClustersList) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type AvailableClustersList.

type CaptureDescription 

type CaptureDescription struct {
	// Properties of Destination where capture will be stored. (Storage Account, Blob Names)
	Destination *Destination `json:"destination,omitempty"`

	// A value that indicates whether capture description is enabled.
	Enabled *bool `json:"enabled,omitempty"`

	// Enumerates the possible values for the encoding format of capture description. Note: 'AvroDeflate' will be deprecated in New API Version
	Encoding *EncodingCaptureDescription `json:"encoding,omitempty"`

	// The time window allows you to set the frequency with which the capture to Azure Blobs will happen, value should between 60 to 900 seconds
	IntervalInSeconds *int32 `json:"intervalInSeconds,omitempty"`

	// The size window defines the amount of data built up in your Event Hub before an capture operation, value should be between 10485760 to 524288000 bytes
	SizeLimitInBytes *int32 `json:"sizeLimitInBytes,omitempty"`

	// A value that indicates whether to Skip Empty Archives
	SkipEmptyArchives *bool `json:"skipEmptyArchives,omitempty"`
}

CaptureDescription - Properties to configure capture description for eventhub

type CheckNameAvailabilityParameter 

type CheckNameAvailabilityParameter struct {
	// REQUIRED; Name to check the namespace name availability
	Name *string `json:"name,omitempty"`
}

CheckNameAvailabilityParameter - Parameter supplied to check Namespace name availability operation

type CheckNameAvailabilityResult 

type CheckNameAvailabilityResult struct {
	// Value indicating Namespace is availability, true if the Namespace is available; otherwise, false.
	NameAvailable *bool `json:"nameAvailable,omitempty"`

	// The reason for unavailability of a Namespace.
	Reason *UnavailableReason `json:"reason,omitempty"`

	// READ-ONLY; The detailed info regarding the reason associated with the Namespace.
	Message *string `json:"message,omitempty" azure:"ro"`
}

CheckNameAvailabilityResult - The Result of the CheckNameAvailability operation

type Cluster 

type Cluster struct {
	TrackedResource
	// Event Hubs Cluster properties supplied in responses in List or Get operations.
	Properties *ClusterProperties `json:"properties,omitempty"`

	// Properties of the cluster SKU.
	SKU *ClusterSKU `json:"sku,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

Cluster - Single Event Hubs Cluster resource in List or Get operations.

func (Cluster) MarshalJSON 

func (c Cluster) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Cluster.

type ClusterListResult 

type ClusterListResult struct {
	// Link to the next set of results. Empty unless the value parameter contains an incomplete list of Event Hubs Clusters.
	NextLink *string `json:"nextLink,omitempty"`

	// The Event Hubs Clusters present in the List Event Hubs operation results.
	Value []*Cluster `json:"value,omitempty"`
}

ClusterListResult - The response of the List Event Hubs Clusters operation.

func (ClusterListResult) MarshalJSON 

func (c ClusterListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ClusterListResult.

type ClusterProperties 

type ClusterProperties struct {
	// READ-ONLY; The UTC time when the Event Hubs Cluster was created.
	CreatedAt *string `json:"createdAt,omitempty" azure:"ro"`

	// READ-ONLY; The metric ID of the cluster resource. Provided by the service and not modifiable by the user.
	MetricID *string `json:"metricId,omitempty" azure:"ro"`

	// READ-ONLY; Status of the Cluster resource
	Status *string `json:"status,omitempty" azure:"ro"`

	// READ-ONLY; The UTC time when the Event Hubs Cluster was last updated.
	UpdatedAt *string `json:"updatedAt,omitempty" azure:"ro"`
}

ClusterProperties - Event Hubs Cluster properties supplied in responses in List or Get operations.

type ClusterQuotaConfigurationProperties 

type ClusterQuotaConfigurationProperties struct {
	// All possible Cluster settings - a collection of key/value paired settings which apply to quotas and configurations imposed on the cluster.
	Settings map[string]*string `json:"settings,omitempty"`
}

ClusterQuotaConfigurationProperties - Contains all settings for the cluster.

func (ClusterQuotaConfigurationProperties) MarshalJSON 

func (c ClusterQuotaConfigurationProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ClusterQuotaConfigurationProperties.

type ClusterSKU 

type ClusterSKU struct {
	// REQUIRED; Name of this SKU.
	Name *ClusterSKUName `json:"name,omitempty"`

	// The quantity of Event Hubs Cluster Capacity Units contained in this cluster.
	Capacity *int32 `json:"capacity,omitempty"`
}

ClusterSKU - SKU parameters particular to a cluster instance.

type ClusterSKUName 

type ClusterSKUName string

ClusterSKUName - Name of this SKU. 

const (
	ClusterSKUNameDedicated ClusterSKUName = "Dedicated"
)

func PossibleClusterSKUNameValues 

func PossibleClusterSKUNameValues() []ClusterSKUName

PossibleClusterSKUNameValues returns the possible values for the ClusterSKUName const type.

func (ClusterSKUName) ToPtr 

func (c ClusterSKUName) ToPtr() *ClusterSKUName

ToPtr returns a *ClusterSKUName pointing to the current value.

type ClustersBeginCreateOrUpdateOptions 

type ClustersBeginCreateOrUpdateOptions struct {
}

ClustersBeginCreateOrUpdateOptions contains the optional parameters for the Clusters.BeginCreateOrUpdate method.

type ClustersBeginDeleteOptions 

type ClustersBeginDeleteOptions struct {
}

ClustersBeginDeleteOptions contains the optional parameters for the Clusters.BeginDelete method.

type ClustersBeginUpdateOptions 

type ClustersBeginUpdateOptions struct {
}

ClustersBeginUpdateOptions contains the optional parameters for the Clusters.BeginUpdate method.

type ClustersClient 

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

ClustersClient contains the methods for the Clusters group. Don't use this type directly, use NewClustersClient() instead.

func NewClustersClient 

func NewClustersClient(con *arm.Connection, subscriptionID string) *ClustersClient

NewClustersClient creates a new instance of ClustersClient with the specified values.

func (*ClustersClient) BeginCreateOrUpdate 

func (client *ClustersClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, options *ClustersBeginCreateOrUpdateOptions) (ClustersCreateOrUpdatePollerResponse, error)

BeginCreateOrUpdate - Creates or updates an instance of an Event Hubs Cluster. If the operation fails it returns the *ErrorResponse error type.

func (*ClustersClient) BeginDelete 

func (client *ClustersClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersBeginDeleteOptions) (ClustersDeletePollerResponse, error)

BeginDelete - Deletes an existing Event Hubs Cluster. This operation is idempotent. If the operation fails it returns the *ErrorResponse error type.

func (*ClustersClient) BeginUpdate 

func (client *ClustersClient) BeginUpdate(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, options *ClustersBeginUpdateOptions) (ClustersUpdatePollerResponse, error)

BeginUpdate - Modifies mutable properties on the Event Hubs Cluster. This operation is idempotent. If the operation fails it returns the *ErrorResponse error type.

func (*ClustersClient) Get 

func (client *ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersGetOptions) (ClustersGetResponse, error)

Get - Gets the resource description of the specified Event Hubs Cluster. If the operation fails it returns the *ErrorResponse error type.

func (*ClustersClient) ListAvailableClusterRegion 

func (client *ClustersClient) ListAvailableClusterRegion(ctx context.Context, options *ClustersListAvailableClusterRegionOptions) (ClustersListAvailableClusterRegionResponse, error)

ListAvailableClusterRegion - List the quantity of available pre-provisioned Event Hubs Clusters, indexed by Azure region. If the operation fails it returns the *ErrorResponse error type.

func (*ClustersClient) ListByResourceGroup 

func (client *ClustersClient) ListByResourceGroup(resourceGroupName string, options *ClustersListByResourceGroupOptions) *ClustersListByResourceGroupPager

ListByResourceGroup - Lists the available Event Hubs Clusters within an ARM resource group If the operation fails it returns the *ErrorResponse error type.

func (*ClustersClient) ListBySubscription 

func (client *ClustersClient) ListBySubscription(options *ClustersListBySubscriptionOptions) *ClustersListBySubscriptionPager

ListBySubscription - Lists the available Event Hubs Clusters within an ARM resource group If the operation fails it returns the *ErrorResponse error type.

func (*ClustersClient) ListNamespaces 

func (client *ClustersClient) ListNamespaces(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersListNamespacesOptions) (ClustersListNamespacesResponse, error)

ListNamespaces - List all Event Hubs Namespace IDs in an Event Hubs Dedicated Cluster. If the operation fails it returns the *ErrorResponse error type.

type ClustersCreateOrUpdatePoller 

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

ClustersCreateOrUpdatePoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersCreateOrUpdatePoller) Done 

func (p *ClustersCreateOrUpdatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersCreateOrUpdatePoller) FinalResponse 

func (p *ClustersCreateOrUpdatePoller) FinalResponse(ctx context.Context) (ClustersCreateOrUpdateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersCreateOrUpdateResponse will be returned.

func (*ClustersCreateOrUpdatePoller) Poll 

func (p *ClustersCreateOrUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersCreateOrUpdatePoller) ResumeToken 

func (p *ClustersCreateOrUpdatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersCreateOrUpdatePollerResponse 

type ClustersCreateOrUpdatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersCreateOrUpdatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersCreateOrUpdatePollerResponse contains the response from method Clusters.CreateOrUpdate.

func (ClustersCreateOrUpdatePollerResponse) PollUntilDone 

func (l ClustersCreateOrUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersCreateOrUpdateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received.

func (*ClustersCreateOrUpdatePollerResponse) Resume 

func (l *ClustersCreateOrUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersCreateOrUpdatePollerResponse from the provided client and resume token.

type ClustersCreateOrUpdateResponse 

type ClustersCreateOrUpdateResponse struct {
	ClustersCreateOrUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersCreateOrUpdateResponse contains the response from method Clusters.CreateOrUpdate.

type ClustersCreateOrUpdateResult 

type ClustersCreateOrUpdateResult struct {
	Cluster
}

ClustersCreateOrUpdateResult contains the result from method Clusters.CreateOrUpdate.

type ClustersDeletePoller 

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

ClustersDeletePoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersDeletePoller) Done 

func (p *ClustersDeletePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersDeletePoller) FinalResponse 

func (p *ClustersDeletePoller) FinalResponse(ctx context.Context) (ClustersDeleteResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersDeleteResponse will be returned.

func (*ClustersDeletePoller) Poll 

func (p *ClustersDeletePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersDeletePoller) ResumeToken 

func (p *ClustersDeletePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersDeletePollerResponse 

type ClustersDeletePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersDeletePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersDeletePollerResponse contains the response from method Clusters.Delete.

func (ClustersDeletePollerResponse) PollUntilDone 

func (l ClustersDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersDeleteResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received.

func (*ClustersDeletePollerResponse) Resume 

func (l *ClustersDeletePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersDeletePollerResponse from the provided client and resume token.

type ClustersDeleteResponse 

type ClustersDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersDeleteResponse contains the response from method Clusters.Delete.

type ClustersGetOptions 

type ClustersGetOptions struct {
}

ClustersGetOptions contains the optional parameters for the Clusters.Get method.

type ClustersGetResponse 

type ClustersGetResponse struct {
	ClustersGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersGetResponse contains the response from method Clusters.Get.

type ClustersGetResult 

type ClustersGetResult struct {
	Cluster
}

ClustersGetResult contains the result from method Clusters.Get.

type ClustersListAvailableClusterRegionOptions 

type ClustersListAvailableClusterRegionOptions struct {
}

ClustersListAvailableClusterRegionOptions contains the optional parameters for the Clusters.ListAvailableClusterRegion method.

type ClustersListAvailableClusterRegionResponse 

type ClustersListAvailableClusterRegionResponse struct {
	ClustersListAvailableClusterRegionResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersListAvailableClusterRegionResponse contains the response from method Clusters.ListAvailableClusterRegion.

type ClustersListAvailableClusterRegionResult 

type ClustersListAvailableClusterRegionResult struct {
	AvailableClustersList
}

ClustersListAvailableClusterRegionResult contains the result from method Clusters.ListAvailableClusterRegion.

type ClustersListByResourceGroupOptions 

type ClustersListByResourceGroupOptions struct {
}

ClustersListByResourceGroupOptions contains the optional parameters for the Clusters.ListByResourceGroup method.

type ClustersListByResourceGroupPager 

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

ClustersListByResourceGroupPager provides operations for iterating over paged responses.

func (*ClustersListByResourceGroupPager) Err 

func (p *ClustersListByResourceGroupPager) Err() error

Err returns the last error encountered while paging.

func (*ClustersListByResourceGroupPager) NextPage 

func (p *ClustersListByResourceGroupPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ClustersListByResourceGroupPager) PageResponse 

func (p *ClustersListByResourceGroupPager) PageResponse() ClustersListByResourceGroupResponse

PageResponse returns the current ClustersListByResourceGroupResponse page.

type ClustersListByResourceGroupResponse 

type ClustersListByResourceGroupResponse struct {
	ClustersListByResourceGroupResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersListByResourceGroupResponse contains the response from method Clusters.ListByResourceGroup.

type ClustersListByResourceGroupResult 

type ClustersListByResourceGroupResult struct {
	ClusterListResult
}

ClustersListByResourceGroupResult contains the result from method Clusters.ListByResourceGroup.

type ClustersListBySubscriptionOptions 

type ClustersListBySubscriptionOptions struct {
}

ClustersListBySubscriptionOptions contains the optional parameters for the Clusters.ListBySubscription method.

type ClustersListBySubscriptionPager 

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

ClustersListBySubscriptionPager provides operations for iterating over paged responses.

func (*ClustersListBySubscriptionPager) Err 

func (p *ClustersListBySubscriptionPager) Err() error

Err returns the last error encountered while paging.

func (*ClustersListBySubscriptionPager) NextPage 

func (p *ClustersListBySubscriptionPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ClustersListBySubscriptionPager) PageResponse 

func (p *ClustersListBySubscriptionPager) PageResponse() ClustersListBySubscriptionResponse

PageResponse returns the current ClustersListBySubscriptionResponse page.

type ClustersListBySubscriptionResponse 

type ClustersListBySubscriptionResponse struct {
	ClustersListBySubscriptionResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersListBySubscriptionResponse contains the response from method Clusters.ListBySubscription.

type ClustersListBySubscriptionResult 

type ClustersListBySubscriptionResult struct {
	ClusterListResult
}

ClustersListBySubscriptionResult contains the result from method Clusters.ListBySubscription.

type ClustersListNamespacesOptions 

type ClustersListNamespacesOptions struct {
}

ClustersListNamespacesOptions contains the optional parameters for the Clusters.ListNamespaces method.

type ClustersListNamespacesResponse 

type ClustersListNamespacesResponse struct {
	ClustersListNamespacesResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersListNamespacesResponse contains the response from method Clusters.ListNamespaces.

type ClustersListNamespacesResult 

type ClustersListNamespacesResult struct {
	EHNamespaceIDListResult
}

ClustersListNamespacesResult contains the result from method Clusters.ListNamespaces.

type ClustersUpdatePoller 

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

ClustersUpdatePoller provides polling facilities until the operation reaches a terminal state.

func (*ClustersUpdatePoller) Done 

func (p *ClustersUpdatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*ClustersUpdatePoller) FinalResponse 

func (p *ClustersUpdatePoller) FinalResponse(ctx context.Context) (ClustersUpdateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final ClustersUpdateResponse will be returned.

func (*ClustersUpdatePoller) Poll 

func (p *ClustersUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*ClustersUpdatePoller) ResumeToken 

func (p *ClustersUpdatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type ClustersUpdatePollerResponse 

type ClustersUpdatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *ClustersUpdatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersUpdatePollerResponse contains the response from method Clusters.Update.

func (ClustersUpdatePollerResponse) PollUntilDone 

func (l ClustersUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersUpdateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received.

func (*ClustersUpdatePollerResponse) Resume 

func (l *ClustersUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error

Resume rehydrates a ClustersUpdatePollerResponse from the provided client and resume token.

type ClustersUpdateResponse 

type ClustersUpdateResponse struct {
	ClustersUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ClustersUpdateResponse contains the response from method Clusters.Update.

type ClustersUpdateResult 

type ClustersUpdateResult struct {
	Cluster
}

ClustersUpdateResult contains the result from method Clusters.Update.

type ConfigurationClient 

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

ConfigurationClient contains the methods for the Configuration group. Don't use this type directly, use NewConfigurationClient() instead.

func NewConfigurationClient 

func NewConfigurationClient(con *arm.Connection, subscriptionID string) *ConfigurationClient

NewConfigurationClient creates a new instance of ConfigurationClient with the specified values.

func (*ConfigurationClient) Get 

func (client *ConfigurationClient) Get(ctx context.Context, resourceGroupName string, clusterName string, options *ConfigurationGetOptions) (ConfigurationGetResponse, error)

Get - Get all Event Hubs Cluster settings - a collection of key/value pairs which represent the quotas and settings imposed on the cluster. If the operation fails it returns the *ErrorResponse error type.

func (*ConfigurationClient) Patch 

func (client *ConfigurationClient) Patch(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterQuotaConfigurationProperties, options *ConfigurationPatchOptions) (ConfigurationPatchResponse, error)

Patch - Replace all specified Event Hubs Cluster settings with those contained in the request body. Leaves the settings not specified in the request body unmodified. If the operation fails it returns the *ErrorResponse error type.

type ConfigurationGetOptions 

type ConfigurationGetOptions struct {
}

ConfigurationGetOptions contains the optional parameters for the Configuration.Get method.

type ConfigurationGetResponse 

type ConfigurationGetResponse struct {
	ConfigurationGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConfigurationGetResponse contains the response from method Configuration.Get.

type ConfigurationGetResult 

type ConfigurationGetResult struct {
	ClusterQuotaConfigurationProperties
}

ConfigurationGetResult contains the result from method Configuration.Get.

type ConfigurationPatchOptions 

type ConfigurationPatchOptions struct {
}

ConfigurationPatchOptions contains the optional parameters for the Configuration.Patch method.

type ConfigurationPatchResponse 

type ConfigurationPatchResponse struct {
	ConfigurationPatchResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConfigurationPatchResponse contains the response from method Configuration.Patch.

type ConfigurationPatchResult 

type ConfigurationPatchResult struct {
	ClusterQuotaConfigurationProperties
}

ConfigurationPatchResult contains the result from method Configuration.Patch.

type ConnectionState 

type ConnectionState struct {
	// Description of the connection state.
	Description *string `json:"description,omitempty"`

	// Status of the connection.
	Status *PrivateLinkConnectionStatus `json:"status,omitempty"`
}

ConnectionState information.

type ConsumerGroup 

type ConsumerGroup struct {
	Resource
	// Single item in List or Get Consumer group operation
	Properties *ConsumerGroupProperties `json:"properties,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

ConsumerGroup - Single item in List or Get Consumer group operation

func (ConsumerGroup) MarshalJSON 

func (c ConsumerGroup) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ConsumerGroup.

type ConsumerGroupListResult 

type ConsumerGroupListResult struct {
	// Link to the next set of results. Not empty if Value contains incomplete list of Consumer Group
	NextLink *string `json:"nextLink,omitempty"`

	// Result of the List Consumer Group operation.
	Value []*ConsumerGroup `json:"value,omitempty"`
}

ConsumerGroupListResult - The result to the List Consumer Group operation.

func (ConsumerGroupListResult) MarshalJSON 

func (c ConsumerGroupListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ConsumerGroupListResult.

type ConsumerGroupProperties 

type ConsumerGroupProperties struct {
	// User Metadata is a placeholder to store user-defined string data with maximum length 1024. e.g. it can be used to store descriptive data, such as list
	// of teams and their contact information also
	// user-defined configuration settings can be stored.
	UserMetadata *string `json:"userMetadata,omitempty"`

	// READ-ONLY; Exact time the message was created.
	CreatedAt *time.Time `json:"createdAt,omitempty" azure:"ro"`

	// READ-ONLY; The exact time the message was updated.
	UpdatedAt *time.Time `json:"updatedAt,omitempty" azure:"ro"`
}

ConsumerGroupProperties - Single item in List or Get Consumer group operation

func (ConsumerGroupProperties) MarshalJSON 

func (c ConsumerGroupProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type ConsumerGroupProperties.

func (*ConsumerGroupProperties) UnmarshalJSON 

func (c *ConsumerGroupProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type ConsumerGroupProperties.

type ConsumerGroupsClient 

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

ConsumerGroupsClient contains the methods for the ConsumerGroups group. Don't use this type directly, use NewConsumerGroupsClient() instead.

func NewConsumerGroupsClient 

func NewConsumerGroupsClient(con *arm.Connection, subscriptionID string) *ConsumerGroupsClient

NewConsumerGroupsClient creates a new instance of ConsumerGroupsClient with the specified values.

func (*ConsumerGroupsClient) CreateOrUpdate 

func (client *ConsumerGroupsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, parameters ConsumerGroup, options *ConsumerGroupsCreateOrUpdateOptions) (ConsumerGroupsCreateOrUpdateResponse, error)

CreateOrUpdate - Creates or updates an Event Hubs consumer group as a nested resource within a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*ConsumerGroupsClient) Delete 

func (client *ConsumerGroupsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, options *ConsumerGroupsDeleteOptions) (ConsumerGroupsDeleteResponse, error)

Delete - Deletes a consumer group from the specified Event Hub and resource group. If the operation fails it returns the *ErrorResponse error type.

func (*ConsumerGroupsClient) Get 

func (client *ConsumerGroupsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, options *ConsumerGroupsGetOptions) (ConsumerGroupsGetResponse, error)

Get - Gets a description for the specified consumer group. If the operation fails it returns the *ErrorResponse error type.

func (*ConsumerGroupsClient) ListByEventHub 

func (client *ConsumerGroupsClient) ListByEventHub(resourceGroupName string, namespaceName string, eventHubName string, options *ConsumerGroupsListByEventHubOptions) *ConsumerGroupsListByEventHubPager

ListByEventHub - Gets all the consumer groups in a Namespace. An empty feed is returned if no consumer group exists in the Namespace. If the operation fails it returns the *ErrorResponse error type.

type ConsumerGroupsCreateOrUpdateOptions 

type ConsumerGroupsCreateOrUpdateOptions struct {
}

ConsumerGroupsCreateOrUpdateOptions contains the optional parameters for the ConsumerGroups.CreateOrUpdate method.

type ConsumerGroupsCreateOrUpdateResponse 

type ConsumerGroupsCreateOrUpdateResponse struct {
	ConsumerGroupsCreateOrUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConsumerGroupsCreateOrUpdateResponse contains the response from method ConsumerGroups.CreateOrUpdate.

type ConsumerGroupsCreateOrUpdateResult 

type ConsumerGroupsCreateOrUpdateResult struct {
	ConsumerGroup
}

ConsumerGroupsCreateOrUpdateResult contains the result from method ConsumerGroups.CreateOrUpdate.

type ConsumerGroupsDeleteOptions 

type ConsumerGroupsDeleteOptions struct {
}

ConsumerGroupsDeleteOptions contains the optional parameters for the ConsumerGroups.Delete method.

type ConsumerGroupsDeleteResponse 

type ConsumerGroupsDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConsumerGroupsDeleteResponse contains the response from method ConsumerGroups.Delete.

type ConsumerGroupsGetOptions 

type ConsumerGroupsGetOptions struct {
}

ConsumerGroupsGetOptions contains the optional parameters for the ConsumerGroups.Get method.

type ConsumerGroupsGetResponse 

type ConsumerGroupsGetResponse struct {
	ConsumerGroupsGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConsumerGroupsGetResponse contains the response from method ConsumerGroups.Get.

type ConsumerGroupsGetResult 

type ConsumerGroupsGetResult struct {
	ConsumerGroup
}

ConsumerGroupsGetResult contains the result from method ConsumerGroups.Get.

type ConsumerGroupsListByEventHubOptions 

type ConsumerGroupsListByEventHubOptions struct {
	// Skip is only used if a previous operation returned a partial result. If a previous response contains a nextLink element, the value of the nextLink element
	// will include a skip parameter that specifies a starting point to use for subsequent calls.
	Skip *int32
	// May be used to limit the number of results to the most recent N usageDetails.
	Top *int32
}

ConsumerGroupsListByEventHubOptions contains the optional parameters for the ConsumerGroups.ListByEventHub method.

type ConsumerGroupsListByEventHubPager 

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

ConsumerGroupsListByEventHubPager provides operations for iterating over paged responses.

func (*ConsumerGroupsListByEventHubPager) Err 

func (p *ConsumerGroupsListByEventHubPager) Err() error

Err returns the last error encountered while paging.

func (*ConsumerGroupsListByEventHubPager) NextPage 

func (p *ConsumerGroupsListByEventHubPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*ConsumerGroupsListByEventHubPager) PageResponse 

func (p *ConsumerGroupsListByEventHubPager) PageResponse() ConsumerGroupsListByEventHubResponse

PageResponse returns the current ConsumerGroupsListByEventHubResponse page.

type ConsumerGroupsListByEventHubResponse 

type ConsumerGroupsListByEventHubResponse struct {
	ConsumerGroupsListByEventHubResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

ConsumerGroupsListByEventHubResponse contains the response from method ConsumerGroups.ListByEventHub.

type ConsumerGroupsListByEventHubResult 

type ConsumerGroupsListByEventHubResult struct {
	ConsumerGroupListResult
}

ConsumerGroupsListByEventHubResult contains the result from method ConsumerGroups.ListByEventHub.

type CreatedByType 

type CreatedByType string

CreatedByType - The type of identity that created the resource. 

const (
	CreatedByTypeApplication     CreatedByType = "Application"
	CreatedByTypeKey             CreatedByType = "Key"
	CreatedByTypeManagedIdentity CreatedByType = "ManagedIdentity"
	CreatedByTypeUser            CreatedByType = "User"
)

func PossibleCreatedByTypeValues 

func PossibleCreatedByTypeValues() []CreatedByType

PossibleCreatedByTypeValues returns the possible values for the CreatedByType const type.

func (CreatedByType) ToPtr 

func (c CreatedByType) ToPtr() *CreatedByType

ToPtr returns a *CreatedByType pointing to the current value.

type DefaultAction 

type DefaultAction string

DefaultAction - Default Action for Network Rule Set 

const (
	DefaultActionAllow DefaultAction = "Allow"
	DefaultActionDeny  DefaultAction = "Deny"
)

func PossibleDefaultActionValues 

func PossibleDefaultActionValues() []DefaultAction

PossibleDefaultActionValues returns the possible values for the DefaultAction const type.

func (DefaultAction) ToPtr 

func (c DefaultAction) ToPtr() *DefaultAction

ToPtr returns a *DefaultAction pointing to the current value.

type Destination 

type Destination struct {
	// Name for capture destination
	Name *string `json:"name,omitempty"`

	// Properties describing the storage account, blob container and archive name format for capture destination
	Properties *DestinationProperties `json:"properties,omitempty"`
}

Destination - Capture storage details for capture description

type DestinationProperties 

type DestinationProperties struct {
	// Blob naming convention for archive, e.g. {Namespace}/{EventHub}/{PartitionId}/{Year}/{Month}/{Day}/{Hour}/{Minute}/{Second}. Here all the parameters
	// (Namespace,EventHub .. etc) are mandatory
	// irrespective of order
	ArchiveNameFormat *string `json:"archiveNameFormat,omitempty"`

	// Blob container Name
	BlobContainer *string `json:"blobContainer,omitempty"`

	// Resource id of the storage account to be used to create the blobs
	StorageAccountResourceID *string `json:"storageAccountResourceId,omitempty"`
}

DestinationProperties - Properties describing the storage account, blob container and archive name format for capture destination

type DisasterRecoveryConfigsBreakPairingOptions 

type DisasterRecoveryConfigsBreakPairingOptions struct {
}

DisasterRecoveryConfigsBreakPairingOptions contains the optional parameters for the DisasterRecoveryConfigs.BreakPairing method.

type DisasterRecoveryConfigsBreakPairingResponse 

type DisasterRecoveryConfigsBreakPairingResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsBreakPairingResponse contains the response from method DisasterRecoveryConfigs.BreakPairing.

type DisasterRecoveryConfigsCheckNameAvailabilityOptions 

type DisasterRecoveryConfigsCheckNameAvailabilityOptions struct {
}

DisasterRecoveryConfigsCheckNameAvailabilityOptions contains the optional parameters for the DisasterRecoveryConfigs.CheckNameAvailability method.

type DisasterRecoveryConfigsCheckNameAvailabilityResponse 

type DisasterRecoveryConfigsCheckNameAvailabilityResponse struct {
	DisasterRecoveryConfigsCheckNameAvailabilityResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsCheckNameAvailabilityResponse contains the response from method DisasterRecoveryConfigs.CheckNameAvailability.

type DisasterRecoveryConfigsCheckNameAvailabilityResult 

type DisasterRecoveryConfigsCheckNameAvailabilityResult struct {
	CheckNameAvailabilityResult
}

DisasterRecoveryConfigsCheckNameAvailabilityResult contains the result from method DisasterRecoveryConfigs.CheckNameAvailability.

type DisasterRecoveryConfigsClient 

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

DisasterRecoveryConfigsClient contains the methods for the DisasterRecoveryConfigs group. Don't use this type directly, use NewDisasterRecoveryConfigsClient() instead.

func NewDisasterRecoveryConfigsClient 

func NewDisasterRecoveryConfigsClient(con *arm.Connection, subscriptionID string) *DisasterRecoveryConfigsClient

NewDisasterRecoveryConfigsClient creates a new instance of DisasterRecoveryConfigsClient with the specified values.

func (*DisasterRecoveryConfigsClient) BreakPairing 

func (client *DisasterRecoveryConfigsClient) BreakPairing(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsBreakPairingOptions) (DisasterRecoveryConfigsBreakPairingResponse, error)

BreakPairing - This operation disables the Disaster Recovery and stops replicating changes from primary to secondary namespaces If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) CheckNameAvailability 

func (client *DisasterRecoveryConfigsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, namespaceName string, parameters CheckNameAvailabilityParameter, options *DisasterRecoveryConfigsCheckNameAvailabilityOptions) (DisasterRecoveryConfigsCheckNameAvailabilityResponse, error)

CheckNameAvailability - Check the give Namespace name availability. If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) CreateOrUpdate 

func (client *DisasterRecoveryConfigsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, alias string, parameters ArmDisasterRecovery, options *DisasterRecoveryConfigsCreateOrUpdateOptions) (DisasterRecoveryConfigsCreateOrUpdateResponse, error)

CreateOrUpdate - Creates or updates a new Alias(Disaster Recovery configuration) If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) Delete 

func (client *DisasterRecoveryConfigsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsDeleteOptions) (DisasterRecoveryConfigsDeleteResponse, error)

Delete - Deletes an Alias(Disaster Recovery configuration) If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) FailOver 

func (client *DisasterRecoveryConfigsClient) FailOver(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsFailOverOptions) (DisasterRecoveryConfigsFailOverResponse, error)

FailOver - Invokes GEO DR failover and reconfigure the alias to point to the secondary namespace If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) Get 

func (client *DisasterRecoveryConfigsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsGetOptions) (DisasterRecoveryConfigsGetResponse, error)

Get - Retrieves Alias(Disaster Recovery configuration) for primary or secondary namespace If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) GetAuthorizationRule 

func (client *DisasterRecoveryConfigsClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, alias string, authorizationRuleName string, options *DisasterRecoveryConfigsGetAuthorizationRuleOptions) (DisasterRecoveryConfigsGetAuthorizationRuleResponse, error)

GetAuthorizationRule - Gets an AuthorizationRule for a Namespace by rule name. If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) List 

func (client *DisasterRecoveryConfigsClient) List(resourceGroupName string, namespaceName string, options *DisasterRecoveryConfigsListOptions) *DisasterRecoveryConfigsListPager

List - Gets all Alias(Disaster Recovery configurations) If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) ListAuthorizationRules 

func (client *DisasterRecoveryConfigsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsListAuthorizationRulesOptions) *DisasterRecoveryConfigsListAuthorizationRulesPager

ListAuthorizationRules - Gets a list of authorization rules for a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*DisasterRecoveryConfigsClient) ListKeys 

func (client *DisasterRecoveryConfigsClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, alias string, authorizationRuleName string, options *DisasterRecoveryConfigsListKeysOptions) (DisasterRecoveryConfigsListKeysResponse, error)

ListKeys - Gets the primary and secondary connection strings for the Namespace. If the operation fails it returns the *ErrorResponse error type.

type DisasterRecoveryConfigsCreateOrUpdateOptions 

type DisasterRecoveryConfigsCreateOrUpdateOptions struct {
}

DisasterRecoveryConfigsCreateOrUpdateOptions contains the optional parameters for the DisasterRecoveryConfigs.CreateOrUpdate method.

type DisasterRecoveryConfigsCreateOrUpdateResponse 

type DisasterRecoveryConfigsCreateOrUpdateResponse struct {
	DisasterRecoveryConfigsCreateOrUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsCreateOrUpdateResponse contains the response from method DisasterRecoveryConfigs.CreateOrUpdate.

type DisasterRecoveryConfigsCreateOrUpdateResult 

type DisasterRecoveryConfigsCreateOrUpdateResult struct {
	ArmDisasterRecovery
}

DisasterRecoveryConfigsCreateOrUpdateResult contains the result from method DisasterRecoveryConfigs.CreateOrUpdate.

type DisasterRecoveryConfigsDeleteOptions 

type DisasterRecoveryConfigsDeleteOptions struct {
}

DisasterRecoveryConfigsDeleteOptions contains the optional parameters for the DisasterRecoveryConfigs.Delete method.

type DisasterRecoveryConfigsDeleteResponse 

type DisasterRecoveryConfigsDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsDeleteResponse contains the response from method DisasterRecoveryConfigs.Delete.

type DisasterRecoveryConfigsFailOverOptions 

type DisasterRecoveryConfigsFailOverOptions struct {
}

DisasterRecoveryConfigsFailOverOptions contains the optional parameters for the DisasterRecoveryConfigs.FailOver method.

type DisasterRecoveryConfigsFailOverResponse 

type DisasterRecoveryConfigsFailOverResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsFailOverResponse contains the response from method DisasterRecoveryConfigs.FailOver.

type DisasterRecoveryConfigsGetAuthorizationRuleOptions 

type DisasterRecoveryConfigsGetAuthorizationRuleOptions struct {
}

DisasterRecoveryConfigsGetAuthorizationRuleOptions contains the optional parameters for the DisasterRecoveryConfigs.GetAuthorizationRule method.

type DisasterRecoveryConfigsGetAuthorizationRuleResponse 

type DisasterRecoveryConfigsGetAuthorizationRuleResponse struct {
	DisasterRecoveryConfigsGetAuthorizationRuleResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsGetAuthorizationRuleResponse contains the response from method DisasterRecoveryConfigs.GetAuthorizationRule.

type DisasterRecoveryConfigsGetAuthorizationRuleResult 

type DisasterRecoveryConfigsGetAuthorizationRuleResult struct {
	AuthorizationRule
}

DisasterRecoveryConfigsGetAuthorizationRuleResult contains the result from method DisasterRecoveryConfigs.GetAuthorizationRule.

type DisasterRecoveryConfigsGetOptions 

type DisasterRecoveryConfigsGetOptions struct {
}

DisasterRecoveryConfigsGetOptions contains the optional parameters for the DisasterRecoveryConfigs.Get method.

type DisasterRecoveryConfigsGetResponse 

type DisasterRecoveryConfigsGetResponse struct {
	DisasterRecoveryConfigsGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsGetResponse contains the response from method DisasterRecoveryConfigs.Get.

type DisasterRecoveryConfigsGetResult 

type DisasterRecoveryConfigsGetResult struct {
	ArmDisasterRecovery
}

DisasterRecoveryConfigsGetResult contains the result from method DisasterRecoveryConfigs.Get.

type DisasterRecoveryConfigsListAuthorizationRulesOptions 

type DisasterRecoveryConfigsListAuthorizationRulesOptions struct {
}

DisasterRecoveryConfigsListAuthorizationRulesOptions contains the optional parameters for the DisasterRecoveryConfigs.ListAuthorizationRules method.

type DisasterRecoveryConfigsListAuthorizationRulesPager 

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

DisasterRecoveryConfigsListAuthorizationRulesPager provides operations for iterating over paged responses.

func (*DisasterRecoveryConfigsListAuthorizationRulesPager) Err 

func (p *DisasterRecoveryConfigsListAuthorizationRulesPager) Err() error

Err returns the last error encountered while paging.

func (*DisasterRecoveryConfigsListAuthorizationRulesPager) NextPage 

func (p *DisasterRecoveryConfigsListAuthorizationRulesPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*DisasterRecoveryConfigsListAuthorizationRulesPager) PageResponse 

func (p *DisasterRecoveryConfigsListAuthorizationRulesPager) PageResponse() DisasterRecoveryConfigsListAuthorizationRulesResponse

PageResponse returns the current DisasterRecoveryConfigsListAuthorizationRulesResponse page.

type DisasterRecoveryConfigsListAuthorizationRulesResponse 

type DisasterRecoveryConfigsListAuthorizationRulesResponse struct {
	DisasterRecoveryConfigsListAuthorizationRulesResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsListAuthorizationRulesResponse contains the response from method DisasterRecoveryConfigs.ListAuthorizationRules.

type DisasterRecoveryConfigsListAuthorizationRulesResult 

type DisasterRecoveryConfigsListAuthorizationRulesResult struct {
	AuthorizationRuleListResult
}

DisasterRecoveryConfigsListAuthorizationRulesResult contains the result from method DisasterRecoveryConfigs.ListAuthorizationRules.

type DisasterRecoveryConfigsListKeysOptions 

type DisasterRecoveryConfigsListKeysOptions struct {
}

DisasterRecoveryConfigsListKeysOptions contains the optional parameters for the DisasterRecoveryConfigs.ListKeys method.

type DisasterRecoveryConfigsListKeysResponse 

type DisasterRecoveryConfigsListKeysResponse struct {
	DisasterRecoveryConfigsListKeysResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsListKeysResponse contains the response from method DisasterRecoveryConfigs.ListKeys.

type DisasterRecoveryConfigsListKeysResult 

type DisasterRecoveryConfigsListKeysResult struct {
	AccessKeys
}

DisasterRecoveryConfigsListKeysResult contains the result from method DisasterRecoveryConfigs.ListKeys.

type DisasterRecoveryConfigsListOptions 

type DisasterRecoveryConfigsListOptions struct {
}

DisasterRecoveryConfigsListOptions contains the optional parameters for the DisasterRecoveryConfigs.List method.

type DisasterRecoveryConfigsListPager 

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

DisasterRecoveryConfigsListPager provides operations for iterating over paged responses.

func (*DisasterRecoveryConfigsListPager) Err 

func (p *DisasterRecoveryConfigsListPager) Err() error

Err returns the last error encountered while paging.

func (*DisasterRecoveryConfigsListPager) NextPage 

func (p *DisasterRecoveryConfigsListPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*DisasterRecoveryConfigsListPager) PageResponse 

func (p *DisasterRecoveryConfigsListPager) PageResponse() DisasterRecoveryConfigsListResponse

PageResponse returns the current DisasterRecoveryConfigsListResponse page.

type DisasterRecoveryConfigsListResponse 

type DisasterRecoveryConfigsListResponse struct {
	DisasterRecoveryConfigsListResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

DisasterRecoveryConfigsListResponse contains the response from method DisasterRecoveryConfigs.List.

type DisasterRecoveryConfigsListResult 

type DisasterRecoveryConfigsListResult struct {
	ArmDisasterRecoveryListResult
}

DisasterRecoveryConfigsListResult contains the result from method DisasterRecoveryConfigs.List.

type EHNamespace 

type EHNamespace struct {
	TrackedResource
	// Properties of BYOK Identity description
	Identity *Identity `json:"identity,omitempty"`

	// Namespace properties supplied for create namespace operation.
	Properties *EHNamespaceProperties `json:"properties,omitempty"`

	// Properties of sku resource
	SKU *SKU `json:"sku,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

EHNamespace - Single Namespace item in List or Get Operation

func (EHNamespace) MarshalJSON 

func (e EHNamespace) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EHNamespace.

type EHNamespaceIDContainer 

type EHNamespaceIDContainer struct {
	// id parameter
	ID *string `json:"id,omitempty"`
}

EHNamespaceIDContainer - The full ARM ID of an Event Hubs Namespace

type EHNamespaceIDListResult 

type EHNamespaceIDListResult struct {
	// Result of the List Namespace IDs operation
	Value []*EHNamespaceIDContainer `json:"value,omitempty"`
}

EHNamespaceIDListResult - The response of the List Namespace IDs operation

func (EHNamespaceIDListResult) MarshalJSON 

func (e EHNamespaceIDListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EHNamespaceIDListResult.

type EHNamespaceListResult 

type EHNamespaceListResult struct {
	// Link to the next set of results. Not empty if Value contains incomplete list of namespaces.
	NextLink *string `json:"nextLink,omitempty"`

	// Result of the List Namespace operation
	Value []*EHNamespace `json:"value,omitempty"`
}

EHNamespaceListResult - The response of the List Namespace operation

func (EHNamespaceListResult) MarshalJSON 

func (e EHNamespaceListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EHNamespaceListResult.

type EHNamespaceProperties 

type EHNamespaceProperties struct {
	// Cluster ARM ID of the Namespace.
	ClusterArmID *string `json:"clusterArmId,omitempty"`

	// This property disables SAS authentication for the Event Hubs namespace.
	DisableLocalAuth *bool `json:"disableLocalAuth,omitempty"`

	// Properties of BYOK Encryption description
	Encryption *Encryption `json:"encryption,omitempty"`

	// Value that indicates whether AutoInflate is enabled for eventhub namespace.
	IsAutoInflateEnabled *bool `json:"isAutoInflateEnabled,omitempty"`

	// Value that indicates whether Kafka is enabled for eventhub namespace.
	KafkaEnabled *bool `json:"kafkaEnabled,omitempty"`

	// Upper limit of throughput units when AutoInflate is enabled, value should be within 0 to 20 throughput units. ( '0' if AutoInflateEnabled = true)
	MaximumThroughputUnits *int32 `json:"maximumThroughputUnits,omitempty"`

	// List of private endpoint connections.
	PrivateEndpointConnections []*PrivateEndpointConnection `json:"privateEndpointConnections,omitempty"`

	// Enabling this property creates a Standard Event Hubs Namespace in regions supported availability zones.
	ZoneRedundant *bool `json:"zoneRedundant,omitempty"`

	// READ-ONLY; The time the Namespace was created.
	CreatedAt *time.Time `json:"createdAt,omitempty" azure:"ro"`

	// READ-ONLY; Identifier for Azure Insights metrics.
	MetricID *string `json:"metricId,omitempty" azure:"ro"`

	// READ-ONLY; Provisioning state of the Namespace.
	ProvisioningState *string `json:"provisioningState,omitempty" azure:"ro"`

	// READ-ONLY; Endpoint you can use to perform Service Bus operations.
	ServiceBusEndpoint *string `json:"serviceBusEndpoint,omitempty" azure:"ro"`

	// READ-ONLY; Status of the Namespace.
	Status *string `json:"status,omitempty" azure:"ro"`

	// READ-ONLY; The time the Namespace was updated.
	UpdatedAt *time.Time `json:"updatedAt,omitempty" azure:"ro"`
}

EHNamespaceProperties - Namespace properties supplied for create namespace operation.

func (EHNamespaceProperties) MarshalJSON 

func (e EHNamespaceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EHNamespaceProperties.

func (*EHNamespaceProperties) UnmarshalJSON 

func (e *EHNamespaceProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EHNamespaceProperties.

type EncodingCaptureDescription 

type EncodingCaptureDescription string

EncodingCaptureDescription - Enumerates the possible values for the encoding format of capture description. Note: 'AvroDeflate' will be deprecated in New API Version 

const (
	EncodingCaptureDescriptionAvro        EncodingCaptureDescription = "Avro"
	EncodingCaptureDescriptionAvroDeflate EncodingCaptureDescription = "AvroDeflate"
)

func PossibleEncodingCaptureDescriptionValues 

func PossibleEncodingCaptureDescriptionValues() []EncodingCaptureDescription

PossibleEncodingCaptureDescriptionValues returns the possible values for the EncodingCaptureDescription const type.

func (EncodingCaptureDescription) ToPtr 

func (c EncodingCaptureDescription) ToPtr() *EncodingCaptureDescription

ToPtr returns a *EncodingCaptureDescription pointing to the current value.

type Encryption 

type Encryption struct {
	// Enumerates the possible value of keySource for Encryption
	KeySource *string `json:"keySource,omitempty"`

	// Properties of KeyVault
	KeyVaultProperties []*KeyVaultProperties `json:"keyVaultProperties,omitempty"`

	// Enable Infrastructure Encryption (Double Encryption)
	RequireInfrastructureEncryption *bool `json:"requireInfrastructureEncryption,omitempty"`
}

Encryption - Properties to configure Encryption

func (Encryption) MarshalJSON 

func (e Encryption) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Encryption.

type EndPointProvisioningState 

type EndPointProvisioningState string

EndPointProvisioningState - Provisioning state of the Private Endpoint Connection. 

const (
	EndPointProvisioningStateCanceled  EndPointProvisioningState = "Canceled"
	EndPointProvisioningStateCreating  EndPointProvisioningState = "Creating"
	EndPointProvisioningStateDeleting  EndPointProvisioningState = "Deleting"
	EndPointProvisioningStateFailed    EndPointProvisioningState = "Failed"
	EndPointProvisioningStateSucceeded EndPointProvisioningState = "Succeeded"
	EndPointProvisioningStateUpdating  EndPointProvisioningState = "Updating"
)

func PossibleEndPointProvisioningStateValues 

func PossibleEndPointProvisioningStateValues() []EndPointProvisioningState

PossibleEndPointProvisioningStateValues returns the possible values for the EndPointProvisioningState const type.

func (EndPointProvisioningState) ToPtr 

func (c EndPointProvisioningState) ToPtr() *EndPointProvisioningState

ToPtr returns a *EndPointProvisioningState pointing to the current value.

type EntityStatus 

type EntityStatus string

EntityStatus - Enumerates the possible values for the status of the Event Hub. 

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

func PossibleEntityStatusValues 

func PossibleEntityStatusValues() []EntityStatus

PossibleEntityStatusValues returns the possible values for the EntityStatus const type.

func (EntityStatus) ToPtr 

func (c EntityStatus) ToPtr() *EntityStatus

ToPtr returns a *EntityStatus pointing to the current value.

type ErrorResponse 

type ErrorResponse struct {

	// Error code.
	Code *string `json:"code,omitempty"`

	// Error message indicating why the operation failed.
	Message *string `json:"message,omitempty"`
	// contains filtered or unexported fields
}

ErrorResponse - Error response indicates Event Hub service is not able to process the incoming request. The reason is provided in the error message. Implements the error and azcore.HTTPResponse interfaces.

func (ErrorResponse) Error 

func (e ErrorResponse) Error() string

Error implements the error interface for type ErrorResponse. The contents of the error text are not contractual and subject to change.

type EventHubListResult 

type EventHubListResult struct {
	// Link to the next set of results. Not empty if Value contains incomplete list of EventHubs.
	NextLink *string `json:"nextLink,omitempty"`

	// Result of the List EventHubs operation.
	Value []*Eventhub `json:"value,omitempty"`
}

EventHubListResult - The result of the List EventHubs operation.

func (EventHubListResult) MarshalJSON 

func (e EventHubListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventHubListResult.

type EventHubsClient 

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

EventHubsClient contains the methods for the EventHubs group. Don't use this type directly, use NewEventHubsClient() instead.

func NewEventHubsClient 

func NewEventHubsClient(con *arm.Connection, subscriptionID string) *EventHubsClient

NewEventHubsClient creates a new instance of EventHubsClient with the specified values.

func (*EventHubsClient) CreateOrUpdate 

func (client *EventHubsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, parameters Eventhub, options *EventHubsCreateOrUpdateOptions) (EventHubsCreateOrUpdateResponse, error)

CreateOrUpdate - Creates or updates a new Event Hub as a nested resource within a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) CreateOrUpdateAuthorizationRule 

func (client *EventHubsClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters AuthorizationRule, options *EventHubsCreateOrUpdateAuthorizationRuleOptions) (EventHubsCreateOrUpdateAuthorizationRuleResponse, error)

CreateOrUpdateAuthorizationRule - Creates or updates an AuthorizationRule for the specified Event Hub. Creation/update of the AuthorizationRule will take a few seconds to take effect. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) Delete 

func (client *EventHubsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, options *EventHubsDeleteOptions) (EventHubsDeleteResponse, error)

Delete - Deletes an Event Hub from the specified Namespace and resource group. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) DeleteAuthorizationRule 

func (client *EventHubsClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *EventHubsDeleteAuthorizationRuleOptions) (EventHubsDeleteAuthorizationRuleResponse, error)

DeleteAuthorizationRule - Deletes an Event Hub AuthorizationRule. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) Get 

func (client *EventHubsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, options *EventHubsGetOptions) (EventHubsGetResponse, error)

Get - Gets an Event Hubs description for the specified Event Hub. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) GetAuthorizationRule 

func (client *EventHubsClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *EventHubsGetAuthorizationRuleOptions) (EventHubsGetAuthorizationRuleResponse, error)

GetAuthorizationRule - Gets an AuthorizationRule for an Event Hub by rule name. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) ListAuthorizationRules 

func (client *EventHubsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, eventHubName string, options *EventHubsListAuthorizationRulesOptions) *EventHubsListAuthorizationRulesPager

ListAuthorizationRules - Gets the authorization rules for an Event Hub. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) ListByNamespace 

func (client *EventHubsClient) ListByNamespace(resourceGroupName string, namespaceName string, options *EventHubsListByNamespaceOptions) *EventHubsListByNamespacePager

ListByNamespace - Gets all the Event Hubs in a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) ListKeys 

func (client *EventHubsClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *EventHubsListKeysOptions) (EventHubsListKeysResponse, error)

ListKeys - Gets the ACS and SAS connection strings for the Event Hub. If the operation fails it returns the *ErrorResponse error type.

func (*EventHubsClient) RegenerateKeys 

func (client *EventHubsClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters, options *EventHubsRegenerateKeysOptions) (EventHubsRegenerateKeysResponse, error)

RegenerateKeys - Regenerates the ACS and SAS connection strings for the Event Hub. If the operation fails it returns the *ErrorResponse error type.

type EventHubsCreateOrUpdateAuthorizationRuleOptions 

type EventHubsCreateOrUpdateAuthorizationRuleOptions struct {
}

EventHubsCreateOrUpdateAuthorizationRuleOptions contains the optional parameters for the EventHubs.CreateOrUpdateAuthorizationRule method.

type EventHubsCreateOrUpdateAuthorizationRuleResponse 

type EventHubsCreateOrUpdateAuthorizationRuleResponse struct {
	EventHubsCreateOrUpdateAuthorizationRuleResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsCreateOrUpdateAuthorizationRuleResponse contains the response from method EventHubs.CreateOrUpdateAuthorizationRule.

type EventHubsCreateOrUpdateAuthorizationRuleResult 

type EventHubsCreateOrUpdateAuthorizationRuleResult struct {
	AuthorizationRule
}

EventHubsCreateOrUpdateAuthorizationRuleResult contains the result from method EventHubs.CreateOrUpdateAuthorizationRule.

type EventHubsCreateOrUpdateOptions 

type EventHubsCreateOrUpdateOptions struct {
}

EventHubsCreateOrUpdateOptions contains the optional parameters for the EventHubs.CreateOrUpdate method.

type EventHubsCreateOrUpdateResponse 

type EventHubsCreateOrUpdateResponse struct {
	EventHubsCreateOrUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsCreateOrUpdateResponse contains the response from method EventHubs.CreateOrUpdate.

type EventHubsCreateOrUpdateResult 

type EventHubsCreateOrUpdateResult struct {
	Eventhub
}

EventHubsCreateOrUpdateResult contains the result from method EventHubs.CreateOrUpdate.

type EventHubsDeleteAuthorizationRuleOptions 

type EventHubsDeleteAuthorizationRuleOptions struct {
}

EventHubsDeleteAuthorizationRuleOptions contains the optional parameters for the EventHubs.DeleteAuthorizationRule method.

type EventHubsDeleteAuthorizationRuleResponse 

type EventHubsDeleteAuthorizationRuleResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsDeleteAuthorizationRuleResponse contains the response from method EventHubs.DeleteAuthorizationRule.

type EventHubsDeleteOptions 

type EventHubsDeleteOptions struct {
}

EventHubsDeleteOptions contains the optional parameters for the EventHubs.Delete method.

type EventHubsDeleteResponse 

type EventHubsDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsDeleteResponse contains the response from method EventHubs.Delete.

type EventHubsGetAuthorizationRuleOptions 

type EventHubsGetAuthorizationRuleOptions struct {
}

EventHubsGetAuthorizationRuleOptions contains the optional parameters for the EventHubs.GetAuthorizationRule method.

type EventHubsGetAuthorizationRuleResponse 

type EventHubsGetAuthorizationRuleResponse struct {
	EventHubsGetAuthorizationRuleResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsGetAuthorizationRuleResponse contains the response from method EventHubs.GetAuthorizationRule.

type EventHubsGetAuthorizationRuleResult 

type EventHubsGetAuthorizationRuleResult struct {
	AuthorizationRule
}

EventHubsGetAuthorizationRuleResult contains the result from method EventHubs.GetAuthorizationRule.

type EventHubsGetOptions 

type EventHubsGetOptions struct {
}

EventHubsGetOptions contains the optional parameters for the EventHubs.Get method.

type EventHubsGetResponse 

type EventHubsGetResponse struct {
	EventHubsGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsGetResponse contains the response from method EventHubs.Get.

type EventHubsGetResult 

type EventHubsGetResult struct {
	Eventhub
}

EventHubsGetResult contains the result from method EventHubs.Get.

type EventHubsListAuthorizationRulesOptions 

type EventHubsListAuthorizationRulesOptions struct {
}

EventHubsListAuthorizationRulesOptions contains the optional parameters for the EventHubs.ListAuthorizationRules method.

type EventHubsListAuthorizationRulesPager 

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

EventHubsListAuthorizationRulesPager provides operations for iterating over paged responses.

func (*EventHubsListAuthorizationRulesPager) Err 

func (p *EventHubsListAuthorizationRulesPager) Err() error

Err returns the last error encountered while paging.

func (*EventHubsListAuthorizationRulesPager) NextPage 

func (p *EventHubsListAuthorizationRulesPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*EventHubsListAuthorizationRulesPager) PageResponse 

func (p *EventHubsListAuthorizationRulesPager) PageResponse() EventHubsListAuthorizationRulesResponse

PageResponse returns the current EventHubsListAuthorizationRulesResponse page.

type EventHubsListAuthorizationRulesResponse 

type EventHubsListAuthorizationRulesResponse struct {
	EventHubsListAuthorizationRulesResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsListAuthorizationRulesResponse contains the response from method EventHubs.ListAuthorizationRules.

type EventHubsListAuthorizationRulesResult 

type EventHubsListAuthorizationRulesResult struct {
	AuthorizationRuleListResult
}

EventHubsListAuthorizationRulesResult contains the result from method EventHubs.ListAuthorizationRules.

type EventHubsListByNamespaceOptions 

type EventHubsListByNamespaceOptions struct {
	// Skip is only used if a previous operation returned a partial result. If a previous response contains a nextLink element, the value of the nextLink element
	// will include a skip parameter that specifies a starting point to use for subsequent calls.
	Skip *int32
	// May be used to limit the number of results to the most recent N usageDetails.
	Top *int32
}

EventHubsListByNamespaceOptions contains the optional parameters for the EventHubs.ListByNamespace method.

type EventHubsListByNamespacePager 

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

EventHubsListByNamespacePager provides operations for iterating over paged responses.

func (*EventHubsListByNamespacePager) Err 

func (p *EventHubsListByNamespacePager) Err() error

Err returns the last error encountered while paging.

func (*EventHubsListByNamespacePager) NextPage 

func (p *EventHubsListByNamespacePager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*EventHubsListByNamespacePager) PageResponse 

func (p *EventHubsListByNamespacePager) PageResponse() EventHubsListByNamespaceResponse

PageResponse returns the current EventHubsListByNamespaceResponse page.

type EventHubsListByNamespaceResponse 

type EventHubsListByNamespaceResponse struct {
	EventHubsListByNamespaceResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsListByNamespaceResponse contains the response from method EventHubs.ListByNamespace.

type EventHubsListByNamespaceResult 

type EventHubsListByNamespaceResult struct {
	EventHubListResult
}

EventHubsListByNamespaceResult contains the result from method EventHubs.ListByNamespace.

type EventHubsListKeysOptions 

type EventHubsListKeysOptions struct {
}

EventHubsListKeysOptions contains the optional parameters for the EventHubs.ListKeys method.

type EventHubsListKeysResponse 

type EventHubsListKeysResponse struct {
	EventHubsListKeysResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsListKeysResponse contains the response from method EventHubs.ListKeys.

type EventHubsListKeysResult 

type EventHubsListKeysResult struct {
	AccessKeys
}

EventHubsListKeysResult contains the result from method EventHubs.ListKeys.

type EventHubsRegenerateKeysOptions 

type EventHubsRegenerateKeysOptions struct {
}

EventHubsRegenerateKeysOptions contains the optional parameters for the EventHubs.RegenerateKeys method.

type EventHubsRegenerateKeysResponse 

type EventHubsRegenerateKeysResponse struct {
	EventHubsRegenerateKeysResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

EventHubsRegenerateKeysResponse contains the response from method EventHubs.RegenerateKeys.

type EventHubsRegenerateKeysResult 

type EventHubsRegenerateKeysResult struct {
	AccessKeys
}

EventHubsRegenerateKeysResult contains the result from method EventHubs.RegenerateKeys.

type Eventhub 

type Eventhub struct {
	Resource
	// Properties supplied to the Create Or Update Event Hub operation.
	Properties *EventhubProperties `json:"properties,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

Eventhub - Single item in List or Get Event Hub operation

func (Eventhub) MarshalJSON 

func (e Eventhub) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Eventhub.

type EventhubProperties 

type EventhubProperties struct {
	// Properties of capture description
	CaptureDescription *CaptureDescription `json:"captureDescription,omitempty"`

	// Number of days to retain the events for this Event Hub, value should be 1 to 7 days
	MessageRetentionInDays *int64 `json:"messageRetentionInDays,omitempty"`

	// Number of partitions created for the Event Hub, allowed values are from 1 to 32 partitions.
	PartitionCount *int64 `json:"partitionCount,omitempty"`

	// Enumerates the possible values for the status of the Event Hub.
	Status *EntityStatus `json:"status,omitempty"`

	// READ-ONLY; Exact time the Event Hub was created.
	CreatedAt *time.Time `json:"createdAt,omitempty" azure:"ro"`

	// READ-ONLY; Current number of shards on the Event Hub.
	PartitionIDs []*string `json:"partitionIds,omitempty" azure:"ro"`

	// READ-ONLY; The exact time the message was updated.
	UpdatedAt *time.Time `json:"updatedAt,omitempty" azure:"ro"`
}

EventhubProperties - Properties supplied to the Create Or Update Event Hub operation.

func (EventhubProperties) MarshalJSON 

func (e EventhubProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type EventhubProperties.

func (*EventhubProperties) UnmarshalJSON 

func (e *EventhubProperties) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type EventhubProperties.

type Identity 

type Identity struct {
	// Type of managed service identity.
	Type *ManagedServiceIdentityType `json:"type,omitempty"`

	// Properties for User Assigned Identities
	UserAssignedIdentities map[string]*UserAssignedIdentity `json:"userAssignedIdentities,omitempty"`

	// READ-ONLY; ObjectId from the KeyVault
	PrincipalID *string `json:"principalId,omitempty" azure:"ro"`

	// READ-ONLY; TenantId from the KeyVault
	TenantID *string `json:"tenantId,omitempty" azure:"ro"`
}

Identity - Properties to configure Identity for Bring your Own Keys

func (Identity) MarshalJSON 

func (i Identity) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Identity.

type KeyType 

type KeyType string

KeyType - The access key to regenerate. 

const (
	KeyTypePrimaryKey   KeyType = "PrimaryKey"
	KeyTypeSecondaryKey KeyType = "SecondaryKey"
)

func PossibleKeyTypeValues 

func PossibleKeyTypeValues() []KeyType

PossibleKeyTypeValues returns the possible values for the KeyType const type.

func (KeyType) ToPtr 

func (c KeyType) ToPtr() *KeyType

ToPtr returns a *KeyType pointing to the current value.

type KeyVaultProperties 

type KeyVaultProperties struct {
	Identity *UserAssignedIdentityProperties `json:"identity,omitempty"`

	// Name of the Key from KeyVault
	KeyName *string `json:"keyName,omitempty"`

	// Uri of KeyVault
	KeyVaultURI *string `json:"keyVaultUri,omitempty"`

	// Key Version
	KeyVersion *string `json:"keyVersion,omitempty"`
}

KeyVaultProperties - Properties to configure keyVault Properties

type ManagedServiceIdentityType 

type ManagedServiceIdentityType string

ManagedServiceIdentityType - Type of managed service identity. 

const (
	ManagedServiceIdentityTypeSystemAssigned             ManagedServiceIdentityType = "SystemAssigned"
	ManagedServiceIdentityTypeUserAssigned               ManagedServiceIdentityType = "UserAssigned"
	ManagedServiceIdentityTypeSystemAssignedUserAssigned ManagedServiceIdentityType = "SystemAssigned, UserAssigned"
	ManagedServiceIdentityTypeNone                       ManagedServiceIdentityType = "None"
)

func PossibleManagedServiceIdentityTypeValues 

func PossibleManagedServiceIdentityTypeValues() []ManagedServiceIdentityType

PossibleManagedServiceIdentityTypeValues returns the possible values for the ManagedServiceIdentityType const type.

func (ManagedServiceIdentityType) ToPtr 

func (c ManagedServiceIdentityType) ToPtr() *ManagedServiceIdentityType

ToPtr returns a *ManagedServiceIdentityType pointing to the current value.

type NWRuleSetIPRules 

type NWRuleSetIPRules struct {
	// The IP Filter Action
	Action *NetworkRuleIPAction `json:"action,omitempty"`

	// IP Mask
	IPMask *string `json:"ipMask,omitempty"`
}

NWRuleSetIPRules - The response from the List namespace operation.

type NWRuleSetVirtualNetworkRules 

type NWRuleSetVirtualNetworkRules struct {
	// Value that indicates whether to ignore missing Vnet Service Endpoint
	IgnoreMissingVnetServiceEndpoint *bool `json:"ignoreMissingVnetServiceEndpoint,omitempty"`

	// Subnet properties
	Subnet *Subnet `json:"subnet,omitempty"`
}

NWRuleSetVirtualNetworkRules - The response from the List namespace operation.

type NamespacesBeginCreateOrUpdateOptions 

type NamespacesBeginCreateOrUpdateOptions struct {
}

NamespacesBeginCreateOrUpdateOptions contains the optional parameters for the Namespaces.BeginCreateOrUpdate method.

type NamespacesBeginDeleteOptions 

type NamespacesBeginDeleteOptions struct {
}

NamespacesBeginDeleteOptions contains the optional parameters for the Namespaces.BeginDelete method.

type NamespacesCheckNameAvailabilityOptions 

type NamespacesCheckNameAvailabilityOptions struct {
}

NamespacesCheckNameAvailabilityOptions contains the optional parameters for the Namespaces.CheckNameAvailability method.

type NamespacesCheckNameAvailabilityResponse 

type NamespacesCheckNameAvailabilityResponse struct {
	NamespacesCheckNameAvailabilityResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesCheckNameAvailabilityResponse contains the response from method Namespaces.CheckNameAvailability.

type NamespacesCheckNameAvailabilityResult 

type NamespacesCheckNameAvailabilityResult struct {
	CheckNameAvailabilityResult
}

NamespacesCheckNameAvailabilityResult contains the result from method Namespaces.CheckNameAvailability.

type NamespacesClient 

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

NamespacesClient contains the methods for the Namespaces group. Don't use this type directly, use NewNamespacesClient() instead.

func NewNamespacesClient 

func NewNamespacesClient(con *arm.Connection, subscriptionID string) *NamespacesClient

NewNamespacesClient creates a new instance of NamespacesClient with the specified values.

func (*NamespacesClient) BeginCreateOrUpdate 

func (client *NamespacesClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, parameters EHNamespace, options *NamespacesBeginCreateOrUpdateOptions) (NamespacesCreateOrUpdatePollerResponse, error)

BeginCreateOrUpdate - Creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) BeginDelete 

func (client *NamespacesClient) BeginDelete(ctx context.Context, resourceGroupName string, namespaceName string, options *NamespacesBeginDeleteOptions) (NamespacesDeletePollerResponse, error)

BeginDelete - Deletes an existing namespace. This operation also removes all associated resources under the namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) CheckNameAvailability 

func (client *NamespacesClient) CheckNameAvailability(ctx context.Context, parameters CheckNameAvailabilityParameter, options *NamespacesCheckNameAvailabilityOptions) (NamespacesCheckNameAvailabilityResponse, error)

CheckNameAvailability - Check the give Namespace name availability. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) CreateOrUpdateAuthorizationRule 

func (client *NamespacesClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters AuthorizationRule, options *NamespacesCreateOrUpdateAuthorizationRuleOptions) (NamespacesCreateOrUpdateAuthorizationRuleResponse, error)

CreateOrUpdateAuthorizationRule - Creates or updates an AuthorizationRule for a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) CreateOrUpdateNetworkRuleSet 

func (client *NamespacesClient) CreateOrUpdateNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, parameters NetworkRuleSet, options *NamespacesCreateOrUpdateNetworkRuleSetOptions) (NamespacesCreateOrUpdateNetworkRuleSetResponse, error)

CreateOrUpdateNetworkRuleSet - Create or update NetworkRuleSet for a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) DeleteAuthorizationRule 

func (client *NamespacesClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *NamespacesDeleteAuthorizationRuleOptions) (NamespacesDeleteAuthorizationRuleResponse, error)

DeleteAuthorizationRule - Deletes an AuthorizationRule for a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) Get 

func (client *NamespacesClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, options *NamespacesGetOptions) (NamespacesGetResponse, error)

Get - Gets the description of the specified namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) GetAuthorizationRule 

func (client *NamespacesClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *NamespacesGetAuthorizationRuleOptions) (NamespacesGetAuthorizationRuleResponse, error)

GetAuthorizationRule - Gets an AuthorizationRule for a Namespace by rule name. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) GetNetworkRuleSet 

func (client *NamespacesClient) GetNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, options *NamespacesGetNetworkRuleSetOptions) (NamespacesGetNetworkRuleSetResponse, error)

GetNetworkRuleSet - Gets NetworkRuleSet for a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) List 

func (client *NamespacesClient) List(options *NamespacesListOptions) *NamespacesListPager

List - Lists all the available Namespaces within a subscription, irrespective of the resource groups. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) ListAuthorizationRules 

func (client *NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, options *NamespacesListAuthorizationRulesOptions) *NamespacesListAuthorizationRulesPager

ListAuthorizationRules - Gets a list of authorization rules for a Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) ListByResourceGroup 

func (client *NamespacesClient) ListByResourceGroup(resourceGroupName string, options *NamespacesListByResourceGroupOptions) *NamespacesListByResourceGroupPager

ListByResourceGroup - Lists the available Namespaces within a resource group. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) ListKeys 

func (client *NamespacesClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *NamespacesListKeysOptions) (NamespacesListKeysResponse, error)

ListKeys - Gets the primary and secondary connection strings for the Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) RegenerateKeys 

func (client *NamespacesClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters, options *NamespacesRegenerateKeysOptions) (NamespacesRegenerateKeysResponse, error)

RegenerateKeys - Regenerates the primary or secondary connection strings for the specified Namespace. If the operation fails it returns the *ErrorResponse error type.

func (*NamespacesClient) Update 

func (client *NamespacesClient) Update(ctx context.Context, resourceGroupName string, namespaceName string, parameters EHNamespace, options *NamespacesUpdateOptions) (NamespacesUpdateResponse, error)

Update - Creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is idempotent. If the operation fails it returns the *ErrorResponse error type.

type NamespacesCreateOrUpdateAuthorizationRuleOptions 

type NamespacesCreateOrUpdateAuthorizationRuleOptions struct {
}

NamespacesCreateOrUpdateAuthorizationRuleOptions contains the optional parameters for the Namespaces.CreateOrUpdateAuthorizationRule method.

type NamespacesCreateOrUpdateAuthorizationRuleResponse 

type NamespacesCreateOrUpdateAuthorizationRuleResponse struct {
	NamespacesCreateOrUpdateAuthorizationRuleResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesCreateOrUpdateAuthorizationRuleResponse contains the response from method Namespaces.CreateOrUpdateAuthorizationRule.

type NamespacesCreateOrUpdateAuthorizationRuleResult 

type NamespacesCreateOrUpdateAuthorizationRuleResult struct {
	AuthorizationRule
}

NamespacesCreateOrUpdateAuthorizationRuleResult contains the result from method Namespaces.CreateOrUpdateAuthorizationRule.

type NamespacesCreateOrUpdateNetworkRuleSetOptions 

type NamespacesCreateOrUpdateNetworkRuleSetOptions struct {
}

NamespacesCreateOrUpdateNetworkRuleSetOptions contains the optional parameters for the Namespaces.CreateOrUpdateNetworkRuleSet method.

type NamespacesCreateOrUpdateNetworkRuleSetResponse 

type NamespacesCreateOrUpdateNetworkRuleSetResponse struct {
	NamespacesCreateOrUpdateNetworkRuleSetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesCreateOrUpdateNetworkRuleSetResponse contains the response from method Namespaces.CreateOrUpdateNetworkRuleSet.

type NamespacesCreateOrUpdateNetworkRuleSetResult 

type NamespacesCreateOrUpdateNetworkRuleSetResult struct {
	NetworkRuleSet
}

NamespacesCreateOrUpdateNetworkRuleSetResult contains the result from method Namespaces.CreateOrUpdateNetworkRuleSet.

type NamespacesCreateOrUpdatePoller 

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

NamespacesCreateOrUpdatePoller provides polling facilities until the operation reaches a terminal state.

func (*NamespacesCreateOrUpdatePoller) Done 

func (p *NamespacesCreateOrUpdatePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*NamespacesCreateOrUpdatePoller) FinalResponse 

func (p *NamespacesCreateOrUpdatePoller) FinalResponse(ctx context.Context) (NamespacesCreateOrUpdateResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final NamespacesCreateOrUpdateResponse will be returned.

func (*NamespacesCreateOrUpdatePoller) Poll 

func (p *NamespacesCreateOrUpdatePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*NamespacesCreateOrUpdatePoller) ResumeToken 

func (p *NamespacesCreateOrUpdatePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type NamespacesCreateOrUpdatePollerResponse 

type NamespacesCreateOrUpdatePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *NamespacesCreateOrUpdatePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesCreateOrUpdatePollerResponse contains the response from method Namespaces.CreateOrUpdate.

func (NamespacesCreateOrUpdatePollerResponse) PollUntilDone 

func (l NamespacesCreateOrUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (NamespacesCreateOrUpdateResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received.

func (*NamespacesCreateOrUpdatePollerResponse) Resume 

func (l *NamespacesCreateOrUpdatePollerResponse) Resume(ctx context.Context, client *NamespacesClient, token string) error

Resume rehydrates a NamespacesCreateOrUpdatePollerResponse from the provided client and resume token.

type NamespacesCreateOrUpdateResponse 

type NamespacesCreateOrUpdateResponse struct {
	NamespacesCreateOrUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesCreateOrUpdateResponse contains the response from method Namespaces.CreateOrUpdate.

type NamespacesCreateOrUpdateResult 

type NamespacesCreateOrUpdateResult struct {
	EHNamespace
}

NamespacesCreateOrUpdateResult contains the result from method Namespaces.CreateOrUpdate.

type NamespacesDeleteAuthorizationRuleOptions 

type NamespacesDeleteAuthorizationRuleOptions struct {
}

NamespacesDeleteAuthorizationRuleOptions contains the optional parameters for the Namespaces.DeleteAuthorizationRule method.

type NamespacesDeleteAuthorizationRuleResponse 

type NamespacesDeleteAuthorizationRuleResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesDeleteAuthorizationRuleResponse contains the response from method Namespaces.DeleteAuthorizationRule.

type NamespacesDeletePoller 

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

NamespacesDeletePoller provides polling facilities until the operation reaches a terminal state.

func (*NamespacesDeletePoller) Done 

func (p *NamespacesDeletePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*NamespacesDeletePoller) FinalResponse 

func (p *NamespacesDeletePoller) FinalResponse(ctx context.Context) (NamespacesDeleteResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final NamespacesDeleteResponse will be returned.

func (*NamespacesDeletePoller) Poll 

func (p *NamespacesDeletePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*NamespacesDeletePoller) ResumeToken 

func (p *NamespacesDeletePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type NamespacesDeletePollerResponse 

type NamespacesDeletePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *NamespacesDeletePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesDeletePollerResponse contains the response from method Namespaces.Delete.

func (NamespacesDeletePollerResponse) PollUntilDone 

func (l NamespacesDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (NamespacesDeleteResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received.

func (*NamespacesDeletePollerResponse) Resume 

func (l *NamespacesDeletePollerResponse) Resume(ctx context.Context, client *NamespacesClient, token string) error

Resume rehydrates a NamespacesDeletePollerResponse from the provided client and resume token.

type NamespacesDeleteResponse 

type NamespacesDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesDeleteResponse contains the response from method Namespaces.Delete.

type NamespacesGetAuthorizationRuleOptions 

type NamespacesGetAuthorizationRuleOptions struct {
}

NamespacesGetAuthorizationRuleOptions contains the optional parameters for the Namespaces.GetAuthorizationRule method.

type NamespacesGetAuthorizationRuleResponse 

type NamespacesGetAuthorizationRuleResponse struct {
	NamespacesGetAuthorizationRuleResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesGetAuthorizationRuleResponse contains the response from method Namespaces.GetAuthorizationRule.

type NamespacesGetAuthorizationRuleResult 

type NamespacesGetAuthorizationRuleResult struct {
	AuthorizationRule
}

NamespacesGetAuthorizationRuleResult contains the result from method Namespaces.GetAuthorizationRule.

type NamespacesGetNetworkRuleSetOptions 

type NamespacesGetNetworkRuleSetOptions struct {
}

NamespacesGetNetworkRuleSetOptions contains the optional parameters for the Namespaces.GetNetworkRuleSet method.

type NamespacesGetNetworkRuleSetResponse 

type NamespacesGetNetworkRuleSetResponse struct {
	NamespacesGetNetworkRuleSetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesGetNetworkRuleSetResponse contains the response from method Namespaces.GetNetworkRuleSet.

type NamespacesGetNetworkRuleSetResult 

type NamespacesGetNetworkRuleSetResult struct {
	NetworkRuleSet
}

NamespacesGetNetworkRuleSetResult contains the result from method Namespaces.GetNetworkRuleSet.

type NamespacesGetOptions 

type NamespacesGetOptions struct {
}

NamespacesGetOptions contains the optional parameters for the Namespaces.Get method.

type NamespacesGetResponse 

type NamespacesGetResponse struct {
	NamespacesGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesGetResponse contains the response from method Namespaces.Get.

type NamespacesGetResult 

type NamespacesGetResult struct {
	EHNamespace
}

NamespacesGetResult contains the result from method Namespaces.Get.

type NamespacesListAuthorizationRulesOptions 

type NamespacesListAuthorizationRulesOptions struct {
}

NamespacesListAuthorizationRulesOptions contains the optional parameters for the Namespaces.ListAuthorizationRules method.

type NamespacesListAuthorizationRulesPager 

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

NamespacesListAuthorizationRulesPager provides operations for iterating over paged responses.

func (*NamespacesListAuthorizationRulesPager) Err 

func (p *NamespacesListAuthorizationRulesPager) Err() error

Err returns the last error encountered while paging.

func (*NamespacesListAuthorizationRulesPager) NextPage 

func (p *NamespacesListAuthorizationRulesPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*NamespacesListAuthorizationRulesPager) PageResponse 

func (p *NamespacesListAuthorizationRulesPager) PageResponse() NamespacesListAuthorizationRulesResponse

PageResponse returns the current NamespacesListAuthorizationRulesResponse page.

type NamespacesListAuthorizationRulesResponse 

type NamespacesListAuthorizationRulesResponse struct {
	NamespacesListAuthorizationRulesResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesListAuthorizationRulesResponse contains the response from method Namespaces.ListAuthorizationRules.

type NamespacesListAuthorizationRulesResult 

type NamespacesListAuthorizationRulesResult struct {
	AuthorizationRuleListResult
}

NamespacesListAuthorizationRulesResult contains the result from method Namespaces.ListAuthorizationRules.

type NamespacesListByResourceGroupOptions 

type NamespacesListByResourceGroupOptions struct {
}

NamespacesListByResourceGroupOptions contains the optional parameters for the Namespaces.ListByResourceGroup method.

type NamespacesListByResourceGroupPager 

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

NamespacesListByResourceGroupPager provides operations for iterating over paged responses.

func (*NamespacesListByResourceGroupPager) Err 

func (p *NamespacesListByResourceGroupPager) Err() error

Err returns the last error encountered while paging.

func (*NamespacesListByResourceGroupPager) NextPage 

func (p *NamespacesListByResourceGroupPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*NamespacesListByResourceGroupPager) PageResponse 

func (p *NamespacesListByResourceGroupPager) PageResponse() NamespacesListByResourceGroupResponse

PageResponse returns the current NamespacesListByResourceGroupResponse page.

type NamespacesListByResourceGroupResponse 

type NamespacesListByResourceGroupResponse struct {
	NamespacesListByResourceGroupResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesListByResourceGroupResponse contains the response from method Namespaces.ListByResourceGroup.

type NamespacesListByResourceGroupResult 

type NamespacesListByResourceGroupResult struct {
	EHNamespaceListResult
}

NamespacesListByResourceGroupResult contains the result from method Namespaces.ListByResourceGroup.

type NamespacesListKeysOptions 

type NamespacesListKeysOptions struct {
}

NamespacesListKeysOptions contains the optional parameters for the Namespaces.ListKeys method.

type NamespacesListKeysResponse 

type NamespacesListKeysResponse struct {
	NamespacesListKeysResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesListKeysResponse contains the response from method Namespaces.ListKeys.

type NamespacesListKeysResult 

type NamespacesListKeysResult struct {
	AccessKeys
}

NamespacesListKeysResult contains the result from method Namespaces.ListKeys.

type NamespacesListOptions 

type NamespacesListOptions struct {
}

NamespacesListOptions contains the optional parameters for the Namespaces.List method.

type NamespacesListPager 

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

NamespacesListPager provides operations for iterating over paged responses.

func (*NamespacesListPager) Err 

func (p *NamespacesListPager) Err() error

Err returns the last error encountered while paging.

func (*NamespacesListPager) NextPage 

func (p *NamespacesListPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*NamespacesListPager) PageResponse 

func (p *NamespacesListPager) PageResponse() NamespacesListResponse

PageResponse returns the current NamespacesListResponse page.

type NamespacesListResponse 

type NamespacesListResponse struct {
	NamespacesListResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesListResponse contains the response from method Namespaces.List.

type NamespacesListResult 

type NamespacesListResult struct {
	EHNamespaceListResult
}

NamespacesListResult contains the result from method Namespaces.List.

type NamespacesRegenerateKeysOptions 

type NamespacesRegenerateKeysOptions struct {
}

NamespacesRegenerateKeysOptions contains the optional parameters for the Namespaces.RegenerateKeys method.

type NamespacesRegenerateKeysResponse 

type NamespacesRegenerateKeysResponse struct {
	NamespacesRegenerateKeysResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesRegenerateKeysResponse contains the response from method Namespaces.RegenerateKeys.

type NamespacesRegenerateKeysResult 

type NamespacesRegenerateKeysResult struct {
	AccessKeys
}

NamespacesRegenerateKeysResult contains the result from method Namespaces.RegenerateKeys.

type NamespacesUpdateOptions 

type NamespacesUpdateOptions struct {
}

NamespacesUpdateOptions contains the optional parameters for the Namespaces.Update method.

type NamespacesUpdateResponse 

type NamespacesUpdateResponse struct {
	NamespacesUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

NamespacesUpdateResponse contains the response from method Namespaces.Update.

type NamespacesUpdateResult 

type NamespacesUpdateResult struct {
	EHNamespace
}

NamespacesUpdateResult contains the result from method Namespaces.Update.

type NetworkRuleIPAction 

type NetworkRuleIPAction string

NetworkRuleIPAction - The IP Filter Action 

const (
	NetworkRuleIPActionAllow NetworkRuleIPAction = "Allow"
)

func PossibleNetworkRuleIPActionValues 

func PossibleNetworkRuleIPActionValues() []NetworkRuleIPAction

PossibleNetworkRuleIPActionValues returns the possible values for the NetworkRuleIPAction const type.

func (NetworkRuleIPAction) ToPtr 

func (c NetworkRuleIPAction) ToPtr() *NetworkRuleIPAction

ToPtr returns a *NetworkRuleIPAction pointing to the current value.

type NetworkRuleSet 

type NetworkRuleSet struct {
	Resource
	// NetworkRuleSet properties
	Properties *NetworkRuleSetProperties `json:"properties,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

NetworkRuleSet - Description of topic resource.

func (NetworkRuleSet) MarshalJSON 

func (n NetworkRuleSet) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type NetworkRuleSet.

type NetworkRuleSetProperties 

type NetworkRuleSetProperties struct {
	// Default Action for Network Rule Set
	DefaultAction *DefaultAction `json:"defaultAction,omitempty"`

	// List of IpRules
	IPRules []*NWRuleSetIPRules `json:"ipRules,omitempty"`

	// This determines if traffic is allowed over public network. By default it is enabled.
	PublicNetworkAccess *PublicNetworkAccessFlag `json:"publicNetworkAccess,omitempty"`

	// Value that indicates whether Trusted Service Access is Enabled or not.
	TrustedServiceAccessEnabled *bool `json:"trustedServiceAccessEnabled,omitempty"`

	// List VirtualNetwork Rules
	VirtualNetworkRules []*NWRuleSetVirtualNetworkRules `json:"virtualNetworkRules,omitempty"`
}

NetworkRuleSetProperties - NetworkRuleSet properties

func (NetworkRuleSetProperties) MarshalJSON 

func (n NetworkRuleSetProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type NetworkRuleSetProperties.

type Operation 

type Operation struct {
	// The object that represents the operation.
	Display *OperationDisplay `json:"display,omitempty"`

	// READ-ONLY; Operation name: {provider}/{resource}/{operation}
	Name *string `json:"name,omitempty" azure:"ro"`
}

Operation - A Event Hub REST API operation

type OperationDisplay 

type OperationDisplay struct {
	// READ-ONLY; Operation type: Read, write, delete, etc.
	Operation *string `json:"operation,omitempty" azure:"ro"`

	// READ-ONLY; Service provider: Microsoft.EventHub
	Provider *string `json:"provider,omitempty" azure:"ro"`

	// READ-ONLY; Resource on which the operation is performed: Invoice, etc.
	Resource *string `json:"resource,omitempty" azure:"ro"`
}

OperationDisplay - The object that represents the operation.

type OperationListResult 

type OperationListResult struct {
	// READ-ONLY; URL to get the next set of operation list results if there are any.
	NextLink *string `json:"nextLink,omitempty" azure:"ro"`

	// READ-ONLY; List of Event Hub operations supported by the Microsoft.EventHub resource provider.
	Value []*Operation `json:"value,omitempty" azure:"ro"`
}

OperationListResult - 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) MarshalJSON 

func (o OperationListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type OperationListResult.

type OperationsClient 

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

OperationsClient contains the methods for the Operations group. Don't use this type directly, use NewOperationsClient() instead.

func NewOperationsClient 

func NewOperationsClient(con *arm.Connection) *OperationsClient

NewOperationsClient creates a new instance of OperationsClient with the specified values.

func (*OperationsClient) List 

func (client *OperationsClient) List(options *OperationsListOptions) *OperationsListPager

List - Lists all of the available Event Hub REST API operations. If the operation fails it returns the *ErrorResponse error type.

type OperationsListOptions 

type OperationsListOptions struct {
}

OperationsListOptions contains the optional parameters for the Operations.List method.

type OperationsListPager 

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

OperationsListPager provides operations for iterating over paged responses.

func (*OperationsListPager) Err 

func (p *OperationsListPager) Err() error

Err returns the last error encountered while paging.

func (*OperationsListPager) NextPage 

func (p *OperationsListPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*OperationsListPager) PageResponse 

func (p *OperationsListPager) PageResponse() OperationsListResponse

PageResponse returns the current OperationsListResponse page.

type OperationsListResponse 

type OperationsListResponse struct {
	OperationsListResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

OperationsListResponse contains the response from method Operations.List.

type OperationsListResult 

type OperationsListResult struct {
	OperationListResult
}

OperationsListResult contains the result from method Operations.List.

type PrivateEndpoint 

type PrivateEndpoint struct {
	// The ARM identifier for Private Endpoint.
	ID *string `json:"id,omitempty"`
}

PrivateEndpoint information.

type PrivateEndpointConnection 

type PrivateEndpointConnection struct {
	Resource
	// Properties of the PrivateEndpointConnection.
	Properties *PrivateEndpointConnectionProperties `json:"properties,omitempty"`

	// READ-ONLY; The system meta data relating to this resource.
	SystemData *SystemData `json:"systemData,omitempty" azure:"ro"`
}

PrivateEndpointConnection - Properties of the PrivateEndpointConnection.

func (PrivateEndpointConnection) MarshalJSON 

func (p PrivateEndpointConnection) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateEndpointConnection.

type PrivateEndpointConnectionListResult 

type PrivateEndpointConnectionListResult struct {
	// A link for the next page of private endpoint connection resources.
	NextLink *string `json:"nextLink,omitempty"`

	// A collection of private endpoint connection resources.
	Value []*PrivateEndpointConnection `json:"value,omitempty"`
}

PrivateEndpointConnectionListResult - Result of the list of all private endpoint connections operation.

func (PrivateEndpointConnectionListResult) MarshalJSON 

func (p PrivateEndpointConnectionListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateEndpointConnectionListResult.

type PrivateEndpointConnectionProperties 

type PrivateEndpointConnectionProperties struct {
	// The Private Endpoint resource for this Connection.
	PrivateEndpoint *PrivateEndpoint `json:"privateEndpoint,omitempty"`

	// Details about the state of the connection.
	PrivateLinkServiceConnectionState *ConnectionState `json:"privateLinkServiceConnectionState,omitempty"`

	// Provisioning state of the Private Endpoint Connection.
	ProvisioningState *EndPointProvisioningState `json:"provisioningState,omitempty"`
}

PrivateEndpointConnectionProperties - Properties of the private endpoint connection resource.

type PrivateEndpointConnectionsBeginDeleteOptions 

type PrivateEndpointConnectionsBeginDeleteOptions struct {
}

PrivateEndpointConnectionsBeginDeleteOptions contains the optional parameters for the PrivateEndpointConnections.BeginDelete method.

type PrivateEndpointConnectionsClient 

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

PrivateEndpointConnectionsClient contains the methods for the PrivateEndpointConnections group. Don't use this type directly, use NewPrivateEndpointConnectionsClient() instead.

func NewPrivateEndpointConnectionsClient 

func NewPrivateEndpointConnectionsClient(con *arm.Connection, subscriptionID string) *PrivateEndpointConnectionsClient

NewPrivateEndpointConnectionsClient creates a new instance of PrivateEndpointConnectionsClient with the specified values.

func (*PrivateEndpointConnectionsClient) BeginDelete 

func (client *PrivateEndpointConnectionsClient) BeginDelete(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsBeginDeleteOptions) (PrivateEndpointConnectionsDeletePollerResponse, error)

BeginDelete - Deletes an existing namespace. This operation also removes all associated resources under the namespace. If the operation fails it returns the *ErrorResponse error type.

func (*PrivateEndpointConnectionsClient) CreateOrUpdate 

func (client *PrivateEndpointConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection, options *PrivateEndpointConnectionsCreateOrUpdateOptions) (PrivateEndpointConnectionsCreateOrUpdateResponse, error)

CreateOrUpdate - Creates or updates PrivateEndpointConnections of service namespace. If the operation fails it returns the *ErrorResponse error type.

func (*PrivateEndpointConnectionsClient) Get 

func (client *PrivateEndpointConnectionsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsGetOptions) (PrivateEndpointConnectionsGetResponse, error)

Get - Gets a description for the specified Private Endpoint Connection name. If the operation fails it returns the *ErrorResponse error type.

func (*PrivateEndpointConnectionsClient) List 

func (client *PrivateEndpointConnectionsClient) List(resourceGroupName string, namespaceName string, options *PrivateEndpointConnectionsListOptions) *PrivateEndpointConnectionsListPager

List - Gets the available PrivateEndpointConnections within a namespace. If the operation fails it returns the *ErrorResponse error type.

type PrivateEndpointConnectionsCreateOrUpdateOptions 

type PrivateEndpointConnectionsCreateOrUpdateOptions struct {
}

PrivateEndpointConnectionsCreateOrUpdateOptions contains the optional parameters for the PrivateEndpointConnections.CreateOrUpdate method.

type PrivateEndpointConnectionsCreateOrUpdateResponse 

type PrivateEndpointConnectionsCreateOrUpdateResponse struct {
	PrivateEndpointConnectionsCreateOrUpdateResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsCreateOrUpdateResponse contains the response from method PrivateEndpointConnections.CreateOrUpdate.

type PrivateEndpointConnectionsCreateOrUpdateResult 

type PrivateEndpointConnectionsCreateOrUpdateResult struct {
	PrivateEndpointConnection
}

PrivateEndpointConnectionsCreateOrUpdateResult contains the result from method PrivateEndpointConnections.CreateOrUpdate.

type PrivateEndpointConnectionsDeletePoller 

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

PrivateEndpointConnectionsDeletePoller provides polling facilities until the operation reaches a terminal state.

func (*PrivateEndpointConnectionsDeletePoller) Done 

func (p *PrivateEndpointConnectionsDeletePoller) Done() bool

Done returns true if the LRO has reached a terminal state.

func (*PrivateEndpointConnectionsDeletePoller) FinalResponse 

func (p *PrivateEndpointConnectionsDeletePoller) FinalResponse(ctx context.Context) (PrivateEndpointConnectionsDeleteResponse, error)

FinalResponse performs a final GET to the service and returns the final response for the polling operation. If there is an error performing the final GET then an error is returned. If the final GET succeeded then the final PrivateEndpointConnectionsDeleteResponse will be returned.

func (*PrivateEndpointConnectionsDeletePoller) Poll 

func (p *PrivateEndpointConnectionsDeletePoller) Poll(ctx context.Context) (*http.Response, error)

Poll fetches the latest state of the LRO. It returns an HTTP response or error. If the LRO has completed successfully, the poller's state is updated and the HTTP response is returned. If the LRO has completed with failure or was cancelled, the poller's state is updated and the error is returned. If the LRO has not reached a terminal state, the poller's state is updated and the latest HTTP response is returned. If Poll fails, the poller's state is unmodified and the error is returned. Calling Poll on an LRO that has reached a terminal state will return the final HTTP response or error.

func (*PrivateEndpointConnectionsDeletePoller) ResumeToken 

func (p *PrivateEndpointConnectionsDeletePoller) ResumeToken() (string, error)

ResumeToken returns a value representing the poller that can be used to resume the LRO at a later time. ResumeTokens are unique per service operation.

type PrivateEndpointConnectionsDeletePollerResponse 

type PrivateEndpointConnectionsDeletePollerResponse struct {
	// Poller contains an initialized poller.
	Poller *PrivateEndpointConnectionsDeletePoller

	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsDeletePollerResponse contains the response from method PrivateEndpointConnections.Delete.

func (PrivateEndpointConnectionsDeletePollerResponse) PollUntilDone 

func (l PrivateEndpointConnectionsDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (PrivateEndpointConnectionsDeleteResponse, error)

PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received.

func (*PrivateEndpointConnectionsDeletePollerResponse) Resume 

func (l *PrivateEndpointConnectionsDeletePollerResponse) Resume(ctx context.Context, client *PrivateEndpointConnectionsClient, token string) error

Resume rehydrates a PrivateEndpointConnectionsDeletePollerResponse from the provided client and resume token.

type PrivateEndpointConnectionsDeleteResponse 

type PrivateEndpointConnectionsDeleteResponse struct {
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsDeleteResponse contains the response from method PrivateEndpointConnections.Delete.

type PrivateEndpointConnectionsGetOptions 

type PrivateEndpointConnectionsGetOptions struct {
}

PrivateEndpointConnectionsGetOptions contains the optional parameters for the PrivateEndpointConnections.Get method.

type PrivateEndpointConnectionsGetResponse 

type PrivateEndpointConnectionsGetResponse struct {
	PrivateEndpointConnectionsGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsGetResponse contains the response from method PrivateEndpointConnections.Get.

type PrivateEndpointConnectionsGetResult 

type PrivateEndpointConnectionsGetResult struct {
	PrivateEndpointConnection
}

PrivateEndpointConnectionsGetResult contains the result from method PrivateEndpointConnections.Get.

type PrivateEndpointConnectionsListOptions 

type PrivateEndpointConnectionsListOptions struct {
}

PrivateEndpointConnectionsListOptions contains the optional parameters for the PrivateEndpointConnections.List method.

type PrivateEndpointConnectionsListPager 

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

PrivateEndpointConnectionsListPager provides operations for iterating over paged responses.

func (*PrivateEndpointConnectionsListPager) Err 

func (p *PrivateEndpointConnectionsListPager) Err() error

Err returns the last error encountered while paging.

func (*PrivateEndpointConnectionsListPager) NextPage 

func (p *PrivateEndpointConnectionsListPager) NextPage(ctx context.Context) bool

NextPage returns true if the pager advanced to the next page. Returns false if there are no more pages or an error occurred.

func (*PrivateEndpointConnectionsListPager) PageResponse 

func (p *PrivateEndpointConnectionsListPager) PageResponse() PrivateEndpointConnectionsListResponse

PageResponse returns the current PrivateEndpointConnectionsListResponse page.

type PrivateEndpointConnectionsListResponse 

type PrivateEndpointConnectionsListResponse struct {
	PrivateEndpointConnectionsListResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateEndpointConnectionsListResponse contains the response from method PrivateEndpointConnections.List.

type PrivateEndpointConnectionsListResult 

type PrivateEndpointConnectionsListResult struct {
	PrivateEndpointConnectionListResult
}

PrivateEndpointConnectionsListResult contains the result from method PrivateEndpointConnections.List.

type PrivateLinkConnectionStatus 

type PrivateLinkConnectionStatus string

PrivateLinkConnectionStatus - Status of the connection. 

const (
	PrivateLinkConnectionStatusApproved     PrivateLinkConnectionStatus = "Approved"
	PrivateLinkConnectionStatusDisconnected PrivateLinkConnectionStatus = "Disconnected"
	PrivateLinkConnectionStatusPending      PrivateLinkConnectionStatus = "Pending"
	PrivateLinkConnectionStatusRejected     PrivateLinkConnectionStatus = "Rejected"
)

func PossiblePrivateLinkConnectionStatusValues 

func PossiblePrivateLinkConnectionStatusValues() []PrivateLinkConnectionStatus

PossiblePrivateLinkConnectionStatusValues returns the possible values for the PrivateLinkConnectionStatus const type.

func (PrivateLinkConnectionStatus) ToPtr 

func (c PrivateLinkConnectionStatus) ToPtr() *PrivateLinkConnectionStatus

ToPtr returns a *PrivateLinkConnectionStatus pointing to the current value.

type PrivateLinkResource 

type PrivateLinkResource struct {
	// Fully qualified identifier of the resource.
	ID *string `json:"id,omitempty"`

	// Name of the resource
	Name *string `json:"name,omitempty"`

	// Properties of the private link resource.
	Properties *PrivateLinkResourceProperties `json:"properties,omitempty"`

	// Type of the resource
	Type *string `json:"type,omitempty"`
}

PrivateLinkResource - Information of the private link resource.

type PrivateLinkResourceProperties 

type PrivateLinkResourceProperties struct {
	// The private link resource group id.
	GroupID *string `json:"groupId,omitempty"`

	// The private link resource required member names.
	RequiredMembers []*string `json:"requiredMembers,omitempty"`

	// The private link resource Private link DNS zone name.
	RequiredZoneNames []*string `json:"requiredZoneNames,omitempty"`
}

PrivateLinkResourceProperties - Properties of PrivateLinkResource

func (PrivateLinkResourceProperties) MarshalJSON 

func (p PrivateLinkResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateLinkResourceProperties.

type PrivateLinkResourcesClient 

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

PrivateLinkResourcesClient contains the methods for the PrivateLinkResources group. Don't use this type directly, use NewPrivateLinkResourcesClient() instead.

func NewPrivateLinkResourcesClient 

func NewPrivateLinkResourcesClient(con *arm.Connection, subscriptionID string) *PrivateLinkResourcesClient

NewPrivateLinkResourcesClient creates a new instance of PrivateLinkResourcesClient with the specified values.

func (*PrivateLinkResourcesClient) Get 

func (client *PrivateLinkResourcesClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, options *PrivateLinkResourcesGetOptions) (PrivateLinkResourcesGetResponse, error)

Get - Gets lists of resources that supports Privatelinks. If the operation fails it returns the *ErrorResponse error type.

type PrivateLinkResourcesGetOptions 

type PrivateLinkResourcesGetOptions struct {
}

PrivateLinkResourcesGetOptions contains the optional parameters for the PrivateLinkResources.Get method.

type PrivateLinkResourcesGetResponse 

type PrivateLinkResourcesGetResponse struct {
	PrivateLinkResourcesGetResult
	// RawResponse contains the underlying HTTP response.
	RawResponse *http.Response
}

PrivateLinkResourcesGetResponse contains the response from method PrivateLinkResources.Get.

type PrivateLinkResourcesGetResult 

type PrivateLinkResourcesGetResult struct {
	PrivateLinkResourcesListResult
}

PrivateLinkResourcesGetResult contains the result from method PrivateLinkResources.Get.

type PrivateLinkResourcesListResult 

type PrivateLinkResourcesListResult struct {
	// A link for the next page of private link resources.
	NextLink *string `json:"nextLink,omitempty"`

	// A collection of private link resources
	Value []*PrivateLinkResource `json:"value,omitempty"`
}

PrivateLinkResourcesListResult - Result of the List private link resources operation.

func (PrivateLinkResourcesListResult) MarshalJSON 

func (p PrivateLinkResourcesListResult) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type PrivateLinkResourcesListResult.

type ProvisioningStateDR 

type ProvisioningStateDR string

ProvisioningStateDR - Provisioning state of the Alias(Disaster Recovery configuration) - possible values 'Accepted' or 'Succeeded' or 'Failed' 

const (
	ProvisioningStateDRAccepted  ProvisioningStateDR = "Accepted"
	ProvisioningStateDRSucceeded ProvisioningStateDR = "Succeeded"
	ProvisioningStateDRFailed    ProvisioningStateDR = "Failed"
)

func PossibleProvisioningStateDRValues 

func PossibleProvisioningStateDRValues() []ProvisioningStateDR

PossibleProvisioningStateDRValues returns the possible values for the ProvisioningStateDR const type.

func (ProvisioningStateDR) ToPtr 

func (c ProvisioningStateDR) ToPtr() *ProvisioningStateDR

ToPtr returns a *ProvisioningStateDR pointing to the current value.

type PublicNetworkAccessFlag 

type PublicNetworkAccessFlag string

PublicNetworkAccessFlag - This determines if traffic is allowed over public network. By default it is enabled. 

const (
	PublicNetworkAccessFlagDisabled PublicNetworkAccessFlag = "Disabled"
	PublicNetworkAccessFlagEnabled  PublicNetworkAccessFlag = "Enabled"
)

func PossiblePublicNetworkAccessFlagValues 

func PossiblePublicNetworkAccessFlagValues() []PublicNetworkAccessFlag

PossiblePublicNetworkAccessFlagValues returns the possible values for the PublicNetworkAccessFlag const type.

func (PublicNetworkAccessFlag) ToPtr 

func (c PublicNetworkAccessFlag) ToPtr() *PublicNetworkAccessFlag

ToPtr returns a *PublicNetworkAccessFlag pointing to the current value.

type RegenerateAccessKeyParameters 

type RegenerateAccessKeyParameters struct {
	// REQUIRED; The access key to regenerate.
	KeyType *KeyType `json:"keyType,omitempty"`

	// Optional, if the key value provided, is set for KeyType or autogenerated Key value set for keyType
	Key *string `json:"key,omitempty"`
}

RegenerateAccessKeyParameters - Parameters supplied to the Regenerate Authorization Rule operation, specifies which key needs to be reset.

type Resource 

type Resource struct {
	// READ-ONLY; Resource ID.
	ID *string `json:"id,omitempty" azure:"ro"`

	// READ-ONLY; Resource name.
	Name *string `json:"name,omitempty" azure:"ro"`

	// READ-ONLY; Resource type.
	Type *string `json:"type,omitempty" azure:"ro"`
}

Resource - The resource definition.

func (Resource) MarshalJSON 

func (r Resource) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type Resource.

type RoleDisasterRecovery 

type RoleDisasterRecovery string

RoleDisasterRecovery - role of namespace in GEO DR - possible values 'Primary' or 'PrimaryNotReplicating' or 'Secondary' 

const (
	RoleDisasterRecoveryPrimary               RoleDisasterRecovery = "Primary"
	RoleDisasterRecoveryPrimaryNotReplicating RoleDisasterRecovery = "PrimaryNotReplicating"
	RoleDisasterRecoverySecondary             RoleDisasterRecovery = "Secondary"
)

func PossibleRoleDisasterRecoveryValues 

func PossibleRoleDisasterRecoveryValues() []RoleDisasterRecovery

PossibleRoleDisasterRecoveryValues returns the possible values for the RoleDisasterRecovery const type.

func (RoleDisasterRecovery) ToPtr 

func (c RoleDisasterRecovery) ToPtr() *RoleDisasterRecovery

ToPtr returns a *RoleDisasterRecovery pointing to the current value.

type SKU 

type SKU struct {
	// REQUIRED; Name of this SKU.
	Name *SKUName `json:"name,omitempty"`

	// The Event Hubs throughput units for Basic or Standard tiers, where value should be 0 to 20 throughput units. The Event Hubs premium units for Premium
	// tier, where value should be 0 to 10 premium units.
	Capacity *int32 `json:"capacity,omitempty"`

	// The billing tier of this particular SKU.
	Tier *SKUTier `json:"tier,omitempty"`
}

SKU parameters supplied to the create namespace operation

type SKUName 

type SKUName string

SKUName - Name of this SKU. 

const (
	SKUNameBasic    SKUName = "Basic"
	SKUNamePremium  SKUName = "Premium"
	SKUNameStandard SKUName = "Standard"
)

func PossibleSKUNameValues 

func PossibleSKUNameValues() []SKUName

PossibleSKUNameValues returns the possible values for the SKUName const type.

func (SKUName) ToPtr 

func (c SKUName) ToPtr() *SKUName

ToPtr returns a *SKUName pointing to the current value.

type SKUTier 

type SKUTier string

SKUTier - The billing tier of this particular SKU. 

const (
	SKUTierBasic    SKUTier = "Basic"
	SKUTierPremium  SKUTier = "Premium"
	SKUTierStandard SKUTier = "Standard"
)

func PossibleSKUTierValues 

func PossibleSKUTierValues() []SKUTier

PossibleSKUTierValues returns the possible values for the SKUTier const type.

func (SKUTier) ToPtr 

func (c SKUTier) ToPtr() *SKUTier

ToPtr returns a *SKUTier pointing to the current value.

type Subnet 

type Subnet struct {
	// Resource ID of Virtual Network Subnet
	ID *string `json:"id,omitempty"`
}

Subnet - Properties supplied for Subnet

type SystemData 

type SystemData struct {
	// The timestamp of resource creation (UTC).
	CreatedAt *time.Time `json:"createdAt,omitempty"`

	// The identity that created the resource.
	CreatedBy *string `json:"createdBy,omitempty"`

	// The type of identity that created the resource.
	CreatedByType *CreatedByType `json:"createdByType,omitempty"`

	// The type of identity that last modified the resource.
	LastModifiedAt *time.Time `json:"lastModifiedAt,omitempty"`

	// The identity that last modified the resource.
	LastModifiedBy *string `json:"lastModifiedBy,omitempty"`

	// The type of identity that last modified the resource.
	LastModifiedByType *CreatedByType `json:"lastModifiedByType,omitempty"`
}

SystemData - Metadata pertaining to creation and last modification of the resource.

func (SystemData) MarshalJSON 

func (s SystemData) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface for type SystemData.

func (*SystemData) UnmarshalJSON 

func (s *SystemData) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaller interface for type SystemData.

type TrackedResource 

type TrackedResource struct {
	Resource
	// Resource location.
	Location *string `json:"location,omitempty"`

	// Resource tags.
	Tags map[string]*string `json:"tags,omitempty"`
}

TrackedResource - Definition of resource.

func (TrackedResource) MarshalJSON 

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

MarshalJSON implements the json.Marshaller interface for type TrackedResource.

type UnavailableReason 

type UnavailableReason string

UnavailableReason - Specifies the reason for the unavailability of the service. 

const (
	UnavailableReasonNone                                  UnavailableReason = "None"
	UnavailableReasonInvalidName                           UnavailableReason = "InvalidName"
	UnavailableReasonSubscriptionIsDisabled                UnavailableReason = "SubscriptionIsDisabled"
	UnavailableReasonNameInUse                             UnavailableReason = "NameInUse"
	UnavailableReasonNameInLockdown                        UnavailableReason = "NameInLockdown"
	UnavailableReasonTooManyNamespaceInCurrentSubscription UnavailableReason = "TooManyNamespaceInCurrentSubscription"
)

func PossibleUnavailableReasonValues 

func PossibleUnavailableReasonValues() []UnavailableReason

PossibleUnavailableReasonValues returns the possible values for the UnavailableReason const type.

func (UnavailableReason) ToPtr 

func (c UnavailableReason) ToPtr() *UnavailableReason

ToPtr returns a *UnavailableReason pointing to the current value.

type UserAssignedIdentity 

type UserAssignedIdentity struct {
	// READ-ONLY; Client Id of user assigned identity
	ClientID *string `json:"clientId,omitempty" azure:"ro"`

	// READ-ONLY; Principal Id of user assigned identity
	PrincipalID *string `json:"principalId,omitempty" azure:"ro"`
}

UserAssignedIdentity - Recognized Dictionary value.

type UserAssignedIdentityProperties 

type UserAssignedIdentityProperties struct {
	// ARM ID of user Identity selected for encryption
	UserAssignedIdentity *string `json:"userAssignedIdentity,omitempty"`
}

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.