Documentation ¶
Index ¶
- type AccessKeys
- type AccessRights
- type ArmDisasterRecovery
- type ArmDisasterRecoveryListResult
- type ArmDisasterRecoveryProperties
- type AuthorizationRule
- type AuthorizationRuleListResult
- type AuthorizationRuleProperties
- type AvailableCluster
- type AvailableClustersList
- type CaptureDescription
- type CheckNameAvailabilityParameter
- type CheckNameAvailabilityResult
- type Cluster
- type ClusterListResult
- type ClusterProperties
- type ClusterQuotaConfigurationProperties
- type ClusterSKU
- type ClusterSKUName
- type ClustersClient
- func (client *ClustersClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersClientCreateOrUpdatePollerResponse, error)
- func (client *ClustersClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersClientDeletePollerResponse, error)
- func (client *ClustersClient) BeginUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersClientUpdatePollerResponse, error)
- func (client *ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersClientGetResponse, error)
- func (client *ClustersClient) ListAvailableClusterRegion(ctx context.Context, options *ClustersClientListAvailableClusterRegionOptions) (ClustersClientListAvailableClusterRegionResponse, error)
- func (client *ClustersClient) ListByResourceGroup(resourceGroupName string, options *ClustersClientListByResourceGroupOptions) *ClustersClientListByResourceGroupPager
- func (client *ClustersClient) ListBySubscription(options *ClustersClientListBySubscriptionOptions) *ClustersClientListBySubscriptionPager
- func (client *ClustersClient) ListNamespaces(ctx context.Context, resourceGroupName string, clusterName string, ...) (ClustersClientListNamespacesResponse, error)
- type ClustersClientBeginCreateOrUpdateOptions
- type ClustersClientBeginDeleteOptions
- type ClustersClientBeginUpdateOptions
- type ClustersClientCreateOrUpdatePoller
- func (p *ClustersClientCreateOrUpdatePoller) Done() bool
- func (p *ClustersClientCreateOrUpdatePoller) FinalResponse(ctx context.Context) (ClustersClientCreateOrUpdateResponse, error)
- func (p *ClustersClientCreateOrUpdatePoller) Poll(ctx context.Context) (*http.Response, error)
- func (p *ClustersClientCreateOrUpdatePoller) ResumeToken() (string, error)
- type ClustersClientCreateOrUpdatePollerResponse
- type ClustersClientCreateOrUpdateResponse
- type ClustersClientCreateOrUpdateResult
- type ClustersClientDeletePoller
- func (p *ClustersClientDeletePoller) Done() bool
- func (p *ClustersClientDeletePoller) FinalResponse(ctx context.Context) (ClustersClientDeleteResponse, error)
- func (p *ClustersClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)
- func (p *ClustersClientDeletePoller) ResumeToken() (string, error)
- type ClustersClientDeletePollerResponse
- type ClustersClientDeleteResponse
- type ClustersClientGetOptions
- type ClustersClientGetResponse
- type ClustersClientGetResult
- type ClustersClientListAvailableClusterRegionOptions
- type ClustersClientListAvailableClusterRegionResponse
- type ClustersClientListAvailableClusterRegionResult
- type ClustersClientListByResourceGroupOptions
- type ClustersClientListByResourceGroupPager
- type ClustersClientListByResourceGroupResponse
- type ClustersClientListByResourceGroupResult
- type ClustersClientListBySubscriptionOptions
- type ClustersClientListBySubscriptionPager
- type ClustersClientListBySubscriptionResponse
- type ClustersClientListBySubscriptionResult
- type ClustersClientListNamespacesOptions
- type ClustersClientListNamespacesResponse
- type ClustersClientListNamespacesResult
- type ClustersClientUpdatePoller
- func (p *ClustersClientUpdatePoller) Done() bool
- func (p *ClustersClientUpdatePoller) FinalResponse(ctx context.Context) (ClustersClientUpdateResponse, error)
- func (p *ClustersClientUpdatePoller) Poll(ctx context.Context) (*http.Response, error)
- func (p *ClustersClientUpdatePoller) ResumeToken() (string, error)
- type ClustersClientUpdatePollerResponse
- type ClustersClientUpdateResponse
- type ClustersClientUpdateResult
- type ConfigurationClient
- func (client *ConfigurationClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (ConfigurationClientGetResponse, error)
- func (client *ConfigurationClient) Patch(ctx context.Context, resourceGroupName string, clusterName string, ...) (ConfigurationClientPatchResponse, error)
- type ConfigurationClientGetOptions
- type ConfigurationClientGetResponse
- type ConfigurationClientGetResult
- type ConfigurationClientPatchOptions
- type ConfigurationClientPatchResponse
- type ConfigurationClientPatchResult
- type ConnectionState
- type ConsumerGroup
- type ConsumerGroupListResult
- type ConsumerGroupProperties
- type ConsumerGroupsClient
- func (client *ConsumerGroupsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, ...) (ConsumerGroupsClientCreateOrUpdateResponse, error)
- func (client *ConsumerGroupsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, ...) (ConsumerGroupsClientDeleteResponse, error)
- func (client *ConsumerGroupsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, ...) (ConsumerGroupsClientGetResponse, error)
- func (client *ConsumerGroupsClient) ListByEventHub(resourceGroupName string, namespaceName string, eventHubName string, ...) *ConsumerGroupsClientListByEventHubPager
- type ConsumerGroupsClientCreateOrUpdateOptions
- type ConsumerGroupsClientCreateOrUpdateResponse
- type ConsumerGroupsClientCreateOrUpdateResult
- type ConsumerGroupsClientDeleteOptions
- type ConsumerGroupsClientDeleteResponse
- type ConsumerGroupsClientGetOptions
- type ConsumerGroupsClientGetResponse
- type ConsumerGroupsClientGetResult
- type ConsumerGroupsClientListByEventHubOptions
- type ConsumerGroupsClientListByEventHubPager
- type ConsumerGroupsClientListByEventHubResponse
- type ConsumerGroupsClientListByEventHubResult
- type CreatedByType
- type DefaultAction
- type Destination
- type DestinationProperties
- type DisasterRecoveryConfigsClient
- func (client *DisasterRecoveryConfigsClient) BreakPairing(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientBreakPairingResponse, error)
- func (client *DisasterRecoveryConfigsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientCheckNameAvailabilityResponse, error)
- func (client *DisasterRecoveryConfigsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientCreateOrUpdateResponse, error)
- func (client *DisasterRecoveryConfigsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientDeleteResponse, error)
- func (client *DisasterRecoveryConfigsClient) FailOver(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientFailOverResponse, error)
- func (client *DisasterRecoveryConfigsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientGetResponse, error)
- func (client *DisasterRecoveryConfigsClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientGetAuthorizationRuleResponse, error)
- func (client *DisasterRecoveryConfigsClient) List(resourceGroupName string, namespaceName string, ...) *DisasterRecoveryConfigsClientListPager
- func (client *DisasterRecoveryConfigsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, alias string, ...) *DisasterRecoveryConfigsClientListAuthorizationRulesPager
- func (client *DisasterRecoveryConfigsClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, ...) (DisasterRecoveryConfigsClientListKeysResponse, error)
- type DisasterRecoveryConfigsClientBreakPairingOptions
- type DisasterRecoveryConfigsClientBreakPairingResponse
- type DisasterRecoveryConfigsClientCheckNameAvailabilityOptions
- type DisasterRecoveryConfigsClientCheckNameAvailabilityResponse
- type DisasterRecoveryConfigsClientCheckNameAvailabilityResult
- type DisasterRecoveryConfigsClientCreateOrUpdateOptions
- type DisasterRecoveryConfigsClientCreateOrUpdateResponse
- type DisasterRecoveryConfigsClientCreateOrUpdateResult
- type DisasterRecoveryConfigsClientDeleteOptions
- type DisasterRecoveryConfigsClientDeleteResponse
- type DisasterRecoveryConfigsClientFailOverOptions
- type DisasterRecoveryConfigsClientFailOverResponse
- type DisasterRecoveryConfigsClientGetAuthorizationRuleOptions
- type DisasterRecoveryConfigsClientGetAuthorizationRuleResponse
- type DisasterRecoveryConfigsClientGetAuthorizationRuleResult
- type DisasterRecoveryConfigsClientGetOptions
- type DisasterRecoveryConfigsClientGetResponse
- type DisasterRecoveryConfigsClientGetResult
- type DisasterRecoveryConfigsClientListAuthorizationRulesOptions
- type DisasterRecoveryConfigsClientListAuthorizationRulesPager
- func (p *DisasterRecoveryConfigsClientListAuthorizationRulesPager) Err() error
- func (p *DisasterRecoveryConfigsClientListAuthorizationRulesPager) NextPage(ctx context.Context) bool
- func (p *DisasterRecoveryConfigsClientListAuthorizationRulesPager) PageResponse() DisasterRecoveryConfigsClientListAuthorizationRulesResponse
- type DisasterRecoveryConfigsClientListAuthorizationRulesResponse
- type DisasterRecoveryConfigsClientListAuthorizationRulesResult
- type DisasterRecoveryConfigsClientListKeysOptions
- type DisasterRecoveryConfigsClientListKeysResponse
- type DisasterRecoveryConfigsClientListKeysResult
- type DisasterRecoveryConfigsClientListOptions
- type DisasterRecoveryConfigsClientListPager
- type DisasterRecoveryConfigsClientListResponse
- type DisasterRecoveryConfigsClientListResult
- type EHNamespace
- type EHNamespaceIDContainer
- type EHNamespaceIDListResult
- type EHNamespaceListResult
- type EHNamespaceProperties
- type EncodingCaptureDescription
- type Encryption
- type EndPointProvisioningState
- type EntityStatus
- type ErrorAdditionalInfo
- type ErrorDetail
- type ErrorResponse
- type EventHubsClient
- func (client *EventHubsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientCreateOrUpdateResponse, error)
- func (client *EventHubsClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientCreateOrUpdateAuthorizationRuleResponse, error)
- func (client *EventHubsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientDeleteResponse, error)
- func (client *EventHubsClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientDeleteAuthorizationRuleResponse, error)
- func (client *EventHubsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientGetResponse, error)
- func (client *EventHubsClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientGetAuthorizationRuleResponse, error)
- func (client *EventHubsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, eventHubName string, ...) *EventHubsClientListAuthorizationRulesPager
- func (client *EventHubsClient) ListByNamespace(resourceGroupName string, namespaceName string, ...) *EventHubsClientListByNamespacePager
- func (client *EventHubsClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientListKeysResponse, error)
- func (client *EventHubsClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, ...) (EventHubsClientRegenerateKeysResponse, error)
- type EventHubsClientCreateOrUpdateAuthorizationRuleOptions
- type EventHubsClientCreateOrUpdateAuthorizationRuleResponse
- type EventHubsClientCreateOrUpdateAuthorizationRuleResult
- type EventHubsClientCreateOrUpdateOptions
- type EventHubsClientCreateOrUpdateResponse
- type EventHubsClientCreateOrUpdateResult
- type EventHubsClientDeleteAuthorizationRuleOptions
- type EventHubsClientDeleteAuthorizationRuleResponse
- type EventHubsClientDeleteOptions
- type EventHubsClientDeleteResponse
- type EventHubsClientGetAuthorizationRuleOptions
- type EventHubsClientGetAuthorizationRuleResponse
- type EventHubsClientGetAuthorizationRuleResult
- type EventHubsClientGetOptions
- type EventHubsClientGetResponse
- type EventHubsClientGetResult
- type EventHubsClientListAuthorizationRulesOptions
- type EventHubsClientListAuthorizationRulesPager
- type EventHubsClientListAuthorizationRulesResponse
- type EventHubsClientListAuthorizationRulesResult
- type EventHubsClientListByNamespaceOptions
- type EventHubsClientListByNamespacePager
- type EventHubsClientListByNamespaceResponse
- type EventHubsClientListByNamespaceResult
- type EventHubsClientListKeysOptions
- type EventHubsClientListKeysResponse
- type EventHubsClientListKeysResult
- type EventHubsClientRegenerateKeysOptions
- type EventHubsClientRegenerateKeysResponse
- type EventHubsClientRegenerateKeysResult
- type Eventhub
- type Identity
- type KeyType
- type KeyVaultProperties
- type ListResult
- type ManagedServiceIdentityType
- type NWRuleSetIPRules
- type NWRuleSetVirtualNetworkRules
- type NamespacesClient
- func (client *NamespacesClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientCreateOrUpdatePollerResponse, error)
- func (client *NamespacesClient) BeginDelete(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientDeletePollerResponse, error)
- func (client *NamespacesClient) CheckNameAvailability(ctx context.Context, parameters CheckNameAvailabilityParameter, ...) (NamespacesClientCheckNameAvailabilityResponse, error)
- func (client *NamespacesClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientCreateOrUpdateAuthorizationRuleResponse, error)
- func (client *NamespacesClient) CreateOrUpdateNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientCreateOrUpdateNetworkRuleSetResponse, error)
- func (client *NamespacesClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientDeleteAuthorizationRuleResponse, error)
- func (client *NamespacesClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientGetResponse, error)
- func (client *NamespacesClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientGetAuthorizationRuleResponse, error)
- func (client *NamespacesClient) GetNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientGetNetworkRuleSetResponse, error)
- func (client *NamespacesClient) List(options *NamespacesClientListOptions) *NamespacesClientListPager
- func (client *NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, ...) *NamespacesClientListAuthorizationRulesPager
- func (client *NamespacesClient) ListByResourceGroup(resourceGroupName string, options *NamespacesClientListByResourceGroupOptions) *NamespacesClientListByResourceGroupPager
- func (client *NamespacesClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientListKeysResponse, error)
- func (client *NamespacesClient) ListNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientListNetworkRuleSetResponse, error)
- func (client *NamespacesClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientRegenerateKeysResponse, error)
- func (client *NamespacesClient) Update(ctx context.Context, resourceGroupName string, namespaceName string, ...) (NamespacesClientUpdateResponse, error)
- type NamespacesClientBeginCreateOrUpdateOptions
- type NamespacesClientBeginDeleteOptions
- type NamespacesClientCheckNameAvailabilityOptions
- type NamespacesClientCheckNameAvailabilityResponse
- type NamespacesClientCheckNameAvailabilityResult
- type NamespacesClientCreateOrUpdateAuthorizationRuleOptions
- type NamespacesClientCreateOrUpdateAuthorizationRuleResponse
- type NamespacesClientCreateOrUpdateAuthorizationRuleResult
- type NamespacesClientCreateOrUpdateNetworkRuleSetOptions
- type NamespacesClientCreateOrUpdateNetworkRuleSetResponse
- type NamespacesClientCreateOrUpdateNetworkRuleSetResult
- type NamespacesClientCreateOrUpdatePoller
- func (p *NamespacesClientCreateOrUpdatePoller) Done() bool
- func (p *NamespacesClientCreateOrUpdatePoller) FinalResponse(ctx context.Context) (NamespacesClientCreateOrUpdateResponse, error)
- func (p *NamespacesClientCreateOrUpdatePoller) Poll(ctx context.Context) (*http.Response, error)
- func (p *NamespacesClientCreateOrUpdatePoller) ResumeToken() (string, error)
- type NamespacesClientCreateOrUpdatePollerResponse
- type NamespacesClientCreateOrUpdateResponse
- type NamespacesClientCreateOrUpdateResult
- type NamespacesClientDeleteAuthorizationRuleOptions
- type NamespacesClientDeleteAuthorizationRuleResponse
- type NamespacesClientDeletePoller
- func (p *NamespacesClientDeletePoller) Done() bool
- func (p *NamespacesClientDeletePoller) FinalResponse(ctx context.Context) (NamespacesClientDeleteResponse, error)
- func (p *NamespacesClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)
- func (p *NamespacesClientDeletePoller) ResumeToken() (string, error)
- type NamespacesClientDeletePollerResponse
- type NamespacesClientDeleteResponse
- type NamespacesClientGetAuthorizationRuleOptions
- type NamespacesClientGetAuthorizationRuleResponse
- type NamespacesClientGetAuthorizationRuleResult
- type NamespacesClientGetNetworkRuleSetOptions
- type NamespacesClientGetNetworkRuleSetResponse
- type NamespacesClientGetNetworkRuleSetResult
- type NamespacesClientGetOptions
- type NamespacesClientGetResponse
- type NamespacesClientGetResult
- type NamespacesClientListAuthorizationRulesOptions
- type NamespacesClientListAuthorizationRulesPager
- type NamespacesClientListAuthorizationRulesResponse
- type NamespacesClientListAuthorizationRulesResult
- type NamespacesClientListByResourceGroupOptions
- type NamespacesClientListByResourceGroupPager
- type NamespacesClientListByResourceGroupResponse
- type NamespacesClientListByResourceGroupResult
- type NamespacesClientListKeysOptions
- type NamespacesClientListKeysResponse
- type NamespacesClientListKeysResult
- type NamespacesClientListNetworkRuleSetOptions
- type NamespacesClientListNetworkRuleSetResponse
- type NamespacesClientListNetworkRuleSetResult
- type NamespacesClientListOptions
- type NamespacesClientListPager
- type NamespacesClientListResponse
- type NamespacesClientListResult
- type NamespacesClientRegenerateKeysOptions
- type NamespacesClientRegenerateKeysResponse
- type NamespacesClientRegenerateKeysResult
- type NamespacesClientUpdateOptions
- type NamespacesClientUpdateResponse
- type NamespacesClientUpdateResult
- type NetworkRuleIPAction
- type NetworkRuleSet
- type NetworkRuleSetListResult
- type NetworkRuleSetProperties
- type Operation
- type OperationDisplay
- type OperationListResult
- type OperationsClient
- type OperationsClientListOptions
- type OperationsClientListPager
- type OperationsClientListResponse
- type OperationsClientListResult
- type PrivateEndpoint
- type PrivateEndpointConnection
- type PrivateEndpointConnectionListResult
- type PrivateEndpointConnectionProperties
- type PrivateEndpointConnectionsClient
- func (client *PrivateEndpointConnectionsClient) BeginDelete(ctx context.Context, resourceGroupName string, namespaceName string, ...) (PrivateEndpointConnectionsClientDeletePollerResponse, error)
- func (client *PrivateEndpointConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, ...) (PrivateEndpointConnectionsClientCreateOrUpdateResponse, error)
- func (client *PrivateEndpointConnectionsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, ...) (PrivateEndpointConnectionsClientGetResponse, error)
- func (client *PrivateEndpointConnectionsClient) List(resourceGroupName string, namespaceName string, ...) *PrivateEndpointConnectionsClientListPager
- type PrivateEndpointConnectionsClientBeginDeleteOptions
- type PrivateEndpointConnectionsClientCreateOrUpdateOptions
- type PrivateEndpointConnectionsClientCreateOrUpdateResponse
- type PrivateEndpointConnectionsClientCreateOrUpdateResult
- type PrivateEndpointConnectionsClientDeletePoller
- func (p *PrivateEndpointConnectionsClientDeletePoller) Done() bool
- func (p *PrivateEndpointConnectionsClientDeletePoller) FinalResponse(ctx context.Context) (PrivateEndpointConnectionsClientDeleteResponse, error)
- func (p *PrivateEndpointConnectionsClientDeletePoller) Poll(ctx context.Context) (*http.Response, error)
- func (p *PrivateEndpointConnectionsClientDeletePoller) ResumeToken() (string, error)
- type PrivateEndpointConnectionsClientDeletePollerResponse
- func (l PrivateEndpointConnectionsClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (PrivateEndpointConnectionsClientDeleteResponse, error)
- func (l *PrivateEndpointConnectionsClientDeletePollerResponse) Resume(ctx context.Context, client *PrivateEndpointConnectionsClient, token string) error
- type PrivateEndpointConnectionsClientDeleteResponse
- type PrivateEndpointConnectionsClientGetOptions
- type PrivateEndpointConnectionsClientGetResponse
- type PrivateEndpointConnectionsClientGetResult
- type PrivateEndpointConnectionsClientListOptions
- type PrivateEndpointConnectionsClientListPager
- type PrivateEndpointConnectionsClientListResponse
- type PrivateEndpointConnectionsClientListResult
- type PrivateLinkConnectionStatus
- type PrivateLinkResource
- type PrivateLinkResourceProperties
- type PrivateLinkResourcesClient
- type PrivateLinkResourcesClientGetOptions
- type PrivateLinkResourcesClientGetResponse
- type PrivateLinkResourcesClientGetResult
- type PrivateLinkResourcesListResult
- type Properties
- type ProvisioningStateDR
- type ProxyResource
- type PublicNetworkAccessFlag
- type RegenerateAccessKeyParameters
- type Resource
- type RoleDisasterRecovery
- type SKU
- type SKUName
- type SKUTier
- type SchemaCompatibility
- type SchemaGroup
- type SchemaGroupListResult
- type SchemaGroupProperties
- type SchemaRegistryClient
- func (client *SchemaRegistryClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, ...) (SchemaRegistryClientCreateOrUpdateResponse, error)
- func (client *SchemaRegistryClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, ...) (SchemaRegistryClientDeleteResponse, error)
- func (client *SchemaRegistryClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, ...) (SchemaRegistryClientGetResponse, error)
- func (client *SchemaRegistryClient) ListByNamespace(resourceGroupName string, namespaceName string, ...) *SchemaRegistryClientListByNamespacePager
- type SchemaRegistryClientCreateOrUpdateOptions
- type SchemaRegistryClientCreateOrUpdateResponse
- type SchemaRegistryClientCreateOrUpdateResult
- type SchemaRegistryClientDeleteOptions
- type SchemaRegistryClientDeleteResponse
- type SchemaRegistryClientGetOptions
- type SchemaRegistryClientGetResponse
- type SchemaRegistryClientGetResult
- type SchemaRegistryClientListByNamespaceOptions
- type SchemaRegistryClientListByNamespacePager
- type SchemaRegistryClientListByNamespaceResponse
- type SchemaRegistryClientListByNamespaceResult
- type SchemaType
- type Subnet
- type SystemData
- type TrackedResource
- type UnavailableReason
- type UserAssignedIdentity
- type UserAssignedIdentityProperties
Examples ¶
- ClustersClient.BeginCreateOrUpdate
- ClustersClient.BeginDelete
- ClustersClient.BeginUpdate
- ClustersClient.Get
- ClustersClient.ListAvailableClusterRegion
- ClustersClient.ListByResourceGroup
- ClustersClient.ListBySubscription
- ClustersClient.ListNamespaces
- ConfigurationClient.Get
- ConfigurationClient.Patch
- ConsumerGroupsClient.CreateOrUpdate
- ConsumerGroupsClient.Delete
- ConsumerGroupsClient.Get
- ConsumerGroupsClient.ListByEventHub
- DisasterRecoveryConfigsClient.BreakPairing
- DisasterRecoveryConfigsClient.CheckNameAvailability
- DisasterRecoveryConfigsClient.CreateOrUpdate
- DisasterRecoveryConfigsClient.Delete
- DisasterRecoveryConfigsClient.FailOver
- DisasterRecoveryConfigsClient.Get
- DisasterRecoveryConfigsClient.GetAuthorizationRule
- DisasterRecoveryConfigsClient.List
- DisasterRecoveryConfigsClient.ListAuthorizationRules
- DisasterRecoveryConfigsClient.ListKeys
- EventHubsClient.CreateOrUpdate
- EventHubsClient.CreateOrUpdateAuthorizationRule
- EventHubsClient.Delete
- EventHubsClient.DeleteAuthorizationRule
- EventHubsClient.Get
- EventHubsClient.GetAuthorizationRule
- EventHubsClient.ListAuthorizationRules
- EventHubsClient.ListByNamespace
- EventHubsClient.ListKeys
- EventHubsClient.RegenerateKeys
- NamespacesClient.BeginCreateOrUpdate
- NamespacesClient.BeginDelete
- NamespacesClient.CheckNameAvailability
- NamespacesClient.CreateOrUpdateAuthorizationRule
- NamespacesClient.CreateOrUpdateNetworkRuleSet
- NamespacesClient.DeleteAuthorizationRule
- NamespacesClient.Get
- NamespacesClient.GetAuthorizationRule
- NamespacesClient.GetNetworkRuleSet
- NamespacesClient.List
- NamespacesClient.ListAuthorizationRules
- NamespacesClient.ListByResourceGroup
- NamespacesClient.ListKeys
- NamespacesClient.ListNetworkRuleSet
- NamespacesClient.RegenerateKeys
- NamespacesClient.Update
- OperationsClient.List
- PrivateEndpointConnectionsClient.BeginDelete
- PrivateEndpointConnectionsClient.CreateOrUpdate
- PrivateEndpointConnectionsClient.Get
- PrivateEndpointConnectionsClient.List
- PrivateLinkResourcesClient.Get
- SchemaRegistryClient.CreateOrUpdate
- SchemaRegistryClient.Delete
- SchemaRegistryClient.Get
- SchemaRegistryClient.ListByNamespace
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 { // Properties required to the Create Or Update Alias(Disaster Recovery configurations) Properties *ArmDisasterRecoveryProperties `json:"properties,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
ArmDisasterRecovery - Single item in List or Get Alias(Disaster Recovery configuration) operation
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 { // Properties supplied to create or update AuthorizationRule Properties *AuthorizationRuleProperties `json:"properties,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
AuthorizationRule - Single item in a List or Get AuthorizationRule operation
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 { // Resource location. Location *string `json:"location,omitempty"` // 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"` // Resource tags. Tags map[string]*string `json:"tags,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty" azure:"ro"` }
Cluster - Single Event Hubs Cluster resource in List or Get operations.
func (Cluster) MarshalJSON ¶
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 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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ClustersClient
NewClustersClient creates a new instance of ClustersClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*ClustersClient) BeginCreateOrUpdate ¶
func (client *ClustersClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, options *ClustersClientBeginCreateOrUpdateOptions) (ClustersClientCreateOrUpdatePollerResponse, error)
BeginCreateOrUpdate - Creates or updates an instance of an Event Hubs Cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. clusterName - The name of the Event Hubs Cluster. parameters - Parameters for creating a eventhub cluster resource. options - ClustersClientBeginCreateOrUpdateOptions contains the optional parameters for the ClustersClient.BeginCreateOrUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClusterPut.json
package main import ( "context" "log" "time" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) poller, err := client.BeginCreateOrUpdate(ctx, "<resource-group-name>", "<cluster-name>", armeventhub.Cluster{ Location: to.StringPtr("<location>"), Tags: map[string]*string{ "tag1": to.StringPtr("value1"), "tag2": to.StringPtr("value2"), }, SKU: &armeventhub.ClusterSKU{ Name: armeventhub.ClusterSKUName("Dedicated").ToPtr(), Capacity: to.Int32Ptr(1), }, }, nil) if err != nil { log.Fatal(err) } res, err := poller.PollUntilDone(ctx, 30*time.Second) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ClustersClientCreateOrUpdateResult) }
Output:
func (*ClustersClient) BeginDelete ¶
func (client *ClustersClient) BeginDelete(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientBeginDeleteOptions) (ClustersClientDeletePollerResponse, error)
BeginDelete - Deletes an existing Event Hubs Cluster. This operation is idempotent. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. clusterName - The name of the Event Hubs Cluster. options - ClustersClientBeginDeleteOptions contains the optional parameters for the ClustersClient.BeginDelete method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClusterDelete.json
package main import ( "context" "log" "time" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) poller, err := client.BeginDelete(ctx, "<resource-group-name>", "<cluster-name>", nil) if err != nil { log.Fatal(err) } _, err = poller.PollUntilDone(ctx, 30*time.Second) if err != nil { log.Fatal(err) } }
Output:
func (*ClustersClient) BeginUpdate ¶
func (client *ClustersClient) BeginUpdate(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, options *ClustersClientBeginUpdateOptions) (ClustersClientUpdatePollerResponse, error)
BeginUpdate - Modifies mutable properties on the Event Hubs Cluster. This operation is idempotent. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. clusterName - The name of the Event Hubs Cluster. parameters - The properties of the Event Hubs Cluster which should be updated. options - ClustersClientBeginUpdateOptions contains the optional parameters for the ClustersClient.BeginUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClusterPatch.json
package main import ( "context" "log" "time" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) poller, err := client.BeginUpdate(ctx, "<resource-group-name>", "<cluster-name>", armeventhub.Cluster{ Location: to.StringPtr("<location>"), Tags: map[string]*string{ "tag3": to.StringPtr("value3"), "tag4": to.StringPtr("value4"), }, }, nil) if err != nil { log.Fatal(err) } res, err := poller.PollUntilDone(ctx, 30*time.Second) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ClustersClientUpdateResult) }
Output:
func (*ClustersClient) Get ¶
func (client *ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientGetOptions) (ClustersClientGetResponse, error)
Get - Gets the resource description of the specified Event Hubs Cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. clusterName - The name of the Event Hubs Cluster. options - ClustersClientGetOptions contains the optional parameters for the ClustersClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClusterGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<cluster-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ClustersClientGetResult) }
Output:
func (*ClustersClient) ListAvailableClusterRegion ¶
func (client *ClustersClient) ListAvailableClusterRegion(ctx context.Context, options *ClustersClientListAvailableClusterRegionOptions) (ClustersClientListAvailableClusterRegionResponse, error)
ListAvailableClusterRegion - List the quantity of available pre-provisioned Event Hubs Clusters, indexed by Azure region. If the operation fails it returns an *azcore.ResponseError type. options - ClustersClientListAvailableClusterRegionOptions contains the optional parameters for the ClustersClient.ListAvailableClusterRegion method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ListAvailableClustersGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) res, err := client.ListAvailableClusterRegion(ctx, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ClustersClientListAvailableClusterRegionResult) }
Output:
func (*ClustersClient) ListByResourceGroup ¶
func (client *ClustersClient) ListByResourceGroup(resourceGroupName string, options *ClustersClientListByResourceGroupOptions) *ClustersClientListByResourceGroupPager
ListByResourceGroup - Lists the available Event Hubs Clusters within an ARM resource group If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. options - ClustersClientListByResourceGroupOptions contains the optional parameters for the ClustersClient.ListByResourceGroup method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClustersListByResourceGroup.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) pager := client.ListByResourceGroup("<resource-group-name>", nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*ClustersClient) ListBySubscription ¶
func (client *ClustersClient) ListBySubscription(options *ClustersClientListBySubscriptionOptions) *ClustersClientListBySubscriptionPager
ListBySubscription - Lists the available Event Hubs Clusters within an ARM resource group If the operation fails it returns an *azcore.ResponseError type. options - ClustersClientListBySubscriptionOptions contains the optional parameters for the ClustersClient.ListBySubscription method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClustersListBySubscription.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) pager := client.ListBySubscription(nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*ClustersClient) ListNamespaces ¶
func (client *ClustersClient) ListNamespaces(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientListNamespacesOptions) (ClustersClientListNamespacesResponse, error)
ListNamespaces - List all Event Hubs Namespace IDs in an Event Hubs Dedicated Cluster. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. clusterName - The name of the Event Hubs Cluster. options - ClustersClientListNamespacesOptions contains the optional parameters for the ClustersClient.ListNamespaces method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ListNamespacesInClusterGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewClustersClient("<subscription-id>", cred, nil) res, err := client.ListNamespaces(ctx, "<resource-group-name>", "<cluster-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ClustersClientListNamespacesResult) }
Output:
type ClustersClientBeginCreateOrUpdateOptions ¶ added in v0.3.0
type ClustersClientBeginCreateOrUpdateOptions struct { }
ClustersClientBeginCreateOrUpdateOptions contains the optional parameters for the ClustersClient.BeginCreateOrUpdate method.
type ClustersClientBeginDeleteOptions ¶ added in v0.3.0
type ClustersClientBeginDeleteOptions struct { }
ClustersClientBeginDeleteOptions contains the optional parameters for the ClustersClient.BeginDelete method.
type ClustersClientBeginUpdateOptions ¶ added in v0.3.0
type ClustersClientBeginUpdateOptions struct { }
ClustersClientBeginUpdateOptions contains the optional parameters for the ClustersClient.BeginUpdate method.
type ClustersClientCreateOrUpdatePoller ¶ added in v0.3.0
type ClustersClientCreateOrUpdatePoller struct {
// contains filtered or unexported fields
}
ClustersClientCreateOrUpdatePoller provides polling facilities until the operation reaches a terminal state.
func (*ClustersClientCreateOrUpdatePoller) Done ¶ added in v0.3.0
func (p *ClustersClientCreateOrUpdatePoller) Done() bool
Done returns true if the LRO has reached a terminal state.
func (*ClustersClientCreateOrUpdatePoller) FinalResponse ¶ added in v0.3.0
func (p *ClustersClientCreateOrUpdatePoller) FinalResponse(ctx context.Context) (ClustersClientCreateOrUpdateResponse, 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 ClustersClientCreateOrUpdateResponse will be returned.
func (*ClustersClientCreateOrUpdatePoller) Poll ¶ added in v0.3.0
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 (*ClustersClientCreateOrUpdatePoller) ResumeToken ¶ added in v0.3.0
func (p *ClustersClientCreateOrUpdatePoller) 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 ClustersClientCreateOrUpdatePollerResponse ¶ added in v0.3.0
type ClustersClientCreateOrUpdatePollerResponse struct { // Poller contains an initialized poller. Poller *ClustersClientCreateOrUpdatePoller // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientCreateOrUpdatePollerResponse contains the response from method ClustersClient.CreateOrUpdate.
func (ClustersClientCreateOrUpdatePollerResponse) PollUntilDone ¶ added in v0.3.0
func (l ClustersClientCreateOrUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientCreateOrUpdateResponse, error)
PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.
func (*ClustersClientCreateOrUpdatePollerResponse) Resume ¶ added in v0.3.0
func (l *ClustersClientCreateOrUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error
Resume rehydrates a ClustersClientCreateOrUpdatePollerResponse from the provided client and resume token.
type ClustersClientCreateOrUpdateResponse ¶ added in v0.3.0
type ClustersClientCreateOrUpdateResponse struct { ClustersClientCreateOrUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientCreateOrUpdateResponse contains the response from method ClustersClient.CreateOrUpdate.
type ClustersClientCreateOrUpdateResult ¶ added in v0.3.0
type ClustersClientCreateOrUpdateResult struct {
Cluster
}
ClustersClientCreateOrUpdateResult contains the result from method ClustersClient.CreateOrUpdate.
type ClustersClientDeletePoller ¶ added in v0.3.0
type ClustersClientDeletePoller struct {
// contains filtered or unexported fields
}
ClustersClientDeletePoller provides polling facilities until the operation reaches a terminal state.
func (*ClustersClientDeletePoller) Done ¶ added in v0.3.0
func (p *ClustersClientDeletePoller) Done() bool
Done returns true if the LRO has reached a terminal state.
func (*ClustersClientDeletePoller) FinalResponse ¶ added in v0.3.0
func (p *ClustersClientDeletePoller) FinalResponse(ctx context.Context) (ClustersClientDeleteResponse, 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 ClustersClientDeleteResponse will be returned.
func (*ClustersClientDeletePoller) Poll ¶ added in v0.3.0
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 (*ClustersClientDeletePoller) ResumeToken ¶ added in v0.3.0
func (p *ClustersClientDeletePoller) 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 ClustersClientDeletePollerResponse ¶ added in v0.3.0
type ClustersClientDeletePollerResponse struct { // Poller contains an initialized poller. Poller *ClustersClientDeletePoller // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientDeletePollerResponse contains the response from method ClustersClient.Delete.
func (ClustersClientDeletePollerResponse) PollUntilDone ¶ added in v0.3.0
func (l ClustersClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientDeleteResponse, error)
PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.
func (*ClustersClientDeletePollerResponse) Resume ¶ added in v0.3.0
func (l *ClustersClientDeletePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error
Resume rehydrates a ClustersClientDeletePollerResponse from the provided client and resume token.
type ClustersClientDeleteResponse ¶ added in v0.3.0
type ClustersClientDeleteResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientDeleteResponse contains the response from method ClustersClient.Delete.
type ClustersClientGetOptions ¶ added in v0.3.0
type ClustersClientGetOptions struct { }
ClustersClientGetOptions contains the optional parameters for the ClustersClient.Get method.
type ClustersClientGetResponse ¶ added in v0.3.0
type ClustersClientGetResponse struct { ClustersClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientGetResponse contains the response from method ClustersClient.Get.
type ClustersClientGetResult ¶ added in v0.3.0
type ClustersClientGetResult struct {
Cluster
}
ClustersClientGetResult contains the result from method ClustersClient.Get.
type ClustersClientListAvailableClusterRegionOptions ¶ added in v0.3.0
type ClustersClientListAvailableClusterRegionOptions struct { }
ClustersClientListAvailableClusterRegionOptions contains the optional parameters for the ClustersClient.ListAvailableClusterRegion method.
type ClustersClientListAvailableClusterRegionResponse ¶ added in v0.3.0
type ClustersClientListAvailableClusterRegionResponse struct { ClustersClientListAvailableClusterRegionResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientListAvailableClusterRegionResponse contains the response from method ClustersClient.ListAvailableClusterRegion.
type ClustersClientListAvailableClusterRegionResult ¶ added in v0.3.0
type ClustersClientListAvailableClusterRegionResult struct {
AvailableClustersList
}
ClustersClientListAvailableClusterRegionResult contains the result from method ClustersClient.ListAvailableClusterRegion.
type ClustersClientListByResourceGroupOptions ¶ added in v0.3.0
type ClustersClientListByResourceGroupOptions struct { }
ClustersClientListByResourceGroupOptions contains the optional parameters for the ClustersClient.ListByResourceGroup method.
type ClustersClientListByResourceGroupPager ¶ added in v0.3.0
type ClustersClientListByResourceGroupPager struct {
// contains filtered or unexported fields
}
ClustersClientListByResourceGroupPager provides operations for iterating over paged responses.
func (*ClustersClientListByResourceGroupPager) Err ¶ added in v0.3.0
func (p *ClustersClientListByResourceGroupPager) Err() error
Err returns the last error encountered while paging.
func (*ClustersClientListByResourceGroupPager) NextPage ¶ added in v0.3.0
func (p *ClustersClientListByResourceGroupPager) 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 (*ClustersClientListByResourceGroupPager) PageResponse ¶ added in v0.3.0
func (p *ClustersClientListByResourceGroupPager) PageResponse() ClustersClientListByResourceGroupResponse
PageResponse returns the current ClustersClientListByResourceGroupResponse page.
type ClustersClientListByResourceGroupResponse ¶ added in v0.3.0
type ClustersClientListByResourceGroupResponse struct { ClustersClientListByResourceGroupResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientListByResourceGroupResponse contains the response from method ClustersClient.ListByResourceGroup.
type ClustersClientListByResourceGroupResult ¶ added in v0.3.0
type ClustersClientListByResourceGroupResult struct {
ClusterListResult
}
ClustersClientListByResourceGroupResult contains the result from method ClustersClient.ListByResourceGroup.
type ClustersClientListBySubscriptionOptions ¶ added in v0.3.0
type ClustersClientListBySubscriptionOptions struct { }
ClustersClientListBySubscriptionOptions contains the optional parameters for the ClustersClient.ListBySubscription method.
type ClustersClientListBySubscriptionPager ¶ added in v0.3.0
type ClustersClientListBySubscriptionPager struct {
// contains filtered or unexported fields
}
ClustersClientListBySubscriptionPager provides operations for iterating over paged responses.
func (*ClustersClientListBySubscriptionPager) Err ¶ added in v0.3.0
func (p *ClustersClientListBySubscriptionPager) Err() error
Err returns the last error encountered while paging.
func (*ClustersClientListBySubscriptionPager) NextPage ¶ added in v0.3.0
func (p *ClustersClientListBySubscriptionPager) 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 (*ClustersClientListBySubscriptionPager) PageResponse ¶ added in v0.3.0
func (p *ClustersClientListBySubscriptionPager) PageResponse() ClustersClientListBySubscriptionResponse
PageResponse returns the current ClustersClientListBySubscriptionResponse page.
type ClustersClientListBySubscriptionResponse ¶ added in v0.3.0
type ClustersClientListBySubscriptionResponse struct { ClustersClientListBySubscriptionResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientListBySubscriptionResponse contains the response from method ClustersClient.ListBySubscription.
type ClustersClientListBySubscriptionResult ¶ added in v0.3.0
type ClustersClientListBySubscriptionResult struct {
ClusterListResult
}
ClustersClientListBySubscriptionResult contains the result from method ClustersClient.ListBySubscription.
type ClustersClientListNamespacesOptions ¶ added in v0.3.0
type ClustersClientListNamespacesOptions struct { }
ClustersClientListNamespacesOptions contains the optional parameters for the ClustersClient.ListNamespaces method.
type ClustersClientListNamespacesResponse ¶ added in v0.3.0
type ClustersClientListNamespacesResponse struct { ClustersClientListNamespacesResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientListNamespacesResponse contains the response from method ClustersClient.ListNamespaces.
type ClustersClientListNamespacesResult ¶ added in v0.3.0
type ClustersClientListNamespacesResult struct {
EHNamespaceIDListResult
}
ClustersClientListNamespacesResult contains the result from method ClustersClient.ListNamespaces.
type ClustersClientUpdatePoller ¶ added in v0.3.0
type ClustersClientUpdatePoller struct {
// contains filtered or unexported fields
}
ClustersClientUpdatePoller provides polling facilities until the operation reaches a terminal state.
func (*ClustersClientUpdatePoller) Done ¶ added in v0.3.0
func (p *ClustersClientUpdatePoller) Done() bool
Done returns true if the LRO has reached a terminal state.
func (*ClustersClientUpdatePoller) FinalResponse ¶ added in v0.3.0
func (p *ClustersClientUpdatePoller) FinalResponse(ctx context.Context) (ClustersClientUpdateResponse, 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 ClustersClientUpdateResponse will be returned.
func (*ClustersClientUpdatePoller) Poll ¶ added in v0.3.0
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 (*ClustersClientUpdatePoller) ResumeToken ¶ added in v0.3.0
func (p *ClustersClientUpdatePoller) 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 ClustersClientUpdatePollerResponse ¶ added in v0.3.0
type ClustersClientUpdatePollerResponse struct { // Poller contains an initialized poller. Poller *ClustersClientUpdatePoller // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientUpdatePollerResponse contains the response from method ClustersClient.Update.
func (ClustersClientUpdatePollerResponse) PollUntilDone ¶ added in v0.3.0
func (l ClustersClientUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (ClustersClientUpdateResponse, error)
PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.
func (*ClustersClientUpdatePollerResponse) Resume ¶ added in v0.3.0
func (l *ClustersClientUpdatePollerResponse) Resume(ctx context.Context, client *ClustersClient, token string) error
Resume rehydrates a ClustersClientUpdatePollerResponse from the provided client and resume token.
type ClustersClientUpdateResponse ¶ added in v0.3.0
type ClustersClientUpdateResponse struct { ClustersClientUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ClustersClientUpdateResponse contains the response from method ClustersClient.Update.
type ClustersClientUpdateResult ¶ added in v0.3.0
type ClustersClientUpdateResult struct {
Cluster
}
ClustersClientUpdateResult contains the result from method ClustersClient.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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ConfigurationClient
NewConfigurationClient creates a new instance of ConfigurationClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*ConfigurationClient) Get ¶
func (client *ConfigurationClient) Get(ctx context.Context, resourceGroupName string, clusterName string, options *ConfigurationClientGetOptions) (ConfigurationClientGetResponse, 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 an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. clusterName - The name of the Event Hubs Cluster. options - ConfigurationClientGetOptions contains the optional parameters for the ConfigurationClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClusterQuotaConfigurationGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewConfigurationClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<cluster-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ConfigurationClientGetResult) }
Output:
func (*ConfigurationClient) Patch ¶
func (client *ConfigurationClient) Patch(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterQuotaConfigurationProperties, options *ConfigurationClientPatchOptions) (ConfigurationClientPatchResponse, 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 an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. clusterName - The name of the Event Hubs Cluster. parameters - Parameters for creating an Event Hubs Cluster resource. options - ConfigurationClientPatchOptions contains the optional parameters for the ConfigurationClient.Patch method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/Clusters/ClusterQuotaConfigurationPatch.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewConfigurationClient("<subscription-id>", cred, nil) res, err := client.Patch(ctx, "<resource-group-name>", "<cluster-name>", armeventhub.ClusterQuotaConfigurationProperties{ Settings: map[string]*string{ "eventhub-per-namespace-quota": to.StringPtr("20"), "namespaces-per-cluster-quota": to.StringPtr("200"), }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ConfigurationClientPatchResult) }
Output:
type ConfigurationClientGetOptions ¶ added in v0.3.0
type ConfigurationClientGetOptions struct { }
ConfigurationClientGetOptions contains the optional parameters for the ConfigurationClient.Get method.
type ConfigurationClientGetResponse ¶ added in v0.3.0
type ConfigurationClientGetResponse struct { ConfigurationClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ConfigurationClientGetResponse contains the response from method ConfigurationClient.Get.
type ConfigurationClientGetResult ¶ added in v0.3.0
type ConfigurationClientGetResult struct {
ClusterQuotaConfigurationProperties
}
ConfigurationClientGetResult contains the result from method ConfigurationClient.Get.
type ConfigurationClientPatchOptions ¶ added in v0.3.0
type ConfigurationClientPatchOptions struct { }
ConfigurationClientPatchOptions contains the optional parameters for the ConfigurationClient.Patch method.
type ConfigurationClientPatchResponse ¶ added in v0.3.0
type ConfigurationClientPatchResponse struct { ConfigurationClientPatchResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ConfigurationClientPatchResponse contains the response from method ConfigurationClient.Patch.
type ConfigurationClientPatchResult ¶ added in v0.3.0
type ConfigurationClientPatchResult struct {
ClusterQuotaConfigurationProperties
}
ConfigurationClientPatchResult contains the result from method ConfigurationClient.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 { // Single item in List or Get Consumer group operation Properties *ConsumerGroupProperties `json:"properties,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
ConsumerGroup - Single item in List or Get Consumer group operation
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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *ConsumerGroupsClient
NewConsumerGroupsClient creates a new instance of ConsumerGroupsClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*ConsumerGroupsClient) CreateOrUpdate ¶
func (client *ConsumerGroupsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, parameters ConsumerGroup, options *ConsumerGroupsClientCreateOrUpdateOptions) (ConsumerGroupsClientCreateOrUpdateResponse, error)
CreateOrUpdate - Creates or updates an Event Hubs consumer group as a nested resource within a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name consumerGroupName - The consumer group name parameters - Parameters supplied to create or update a consumer group resource. options - ConsumerGroupsClientCreateOrUpdateOptions contains the optional parameters for the ConsumerGroupsClient.CreateOrUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/ConsumerGroup/EHConsumerGroupCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewConsumerGroupsClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdate(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<consumer-group-name>", armeventhub.ConsumerGroup{ Properties: &armeventhub.ConsumerGroupProperties{ UserMetadata: to.StringPtr("<user-metadata>"), }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ConsumerGroupsClientCreateOrUpdateResult) }
Output:
func (*ConsumerGroupsClient) Delete ¶
func (client *ConsumerGroupsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, options *ConsumerGroupsClientDeleteOptions) (ConsumerGroupsClientDeleteResponse, error)
Delete - Deletes a consumer group from the specified Event Hub and resource group. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name consumerGroupName - The consumer group name options - ConsumerGroupsClientDeleteOptions contains the optional parameters for the ConsumerGroupsClient.Delete method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/ConsumerGroup/EHConsumerGroupDelete.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewConsumerGroupsClient("<subscription-id>", cred, nil) _, err = client.Delete(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<consumer-group-name>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*ConsumerGroupsClient) Get ¶
func (client *ConsumerGroupsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, consumerGroupName string, options *ConsumerGroupsClientGetOptions) (ConsumerGroupsClientGetResponse, error)
Get - Gets a description for the specified consumer group. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name consumerGroupName - The consumer group name options - ConsumerGroupsClientGetOptions contains the optional parameters for the ConsumerGroupsClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/ConsumerGroup/EHConsumerGroupGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewConsumerGroupsClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<consumer-group-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.ConsumerGroupsClientGetResult) }
Output:
func (*ConsumerGroupsClient) ListByEventHub ¶
func (client *ConsumerGroupsClient) ListByEventHub(resourceGroupName string, namespaceName string, eventHubName string, options *ConsumerGroupsClientListByEventHubOptions) *ConsumerGroupsClientListByEventHubPager
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 an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name options - ConsumerGroupsClientListByEventHubOptions contains the optional parameters for the ConsumerGroupsClient.ListByEventHub method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/ConsumerGroup/EHConsumerGroupListByEventHub.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewConsumerGroupsClient("<subscription-id>", cred, nil) pager := client.ListByEventHub("<resource-group-name>", "<namespace-name>", "<event-hub-name>", &armeventhub.ConsumerGroupsClientListByEventHubOptions{Skip: nil, Top: nil, }) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
type ConsumerGroupsClientCreateOrUpdateOptions ¶ added in v0.3.0
type ConsumerGroupsClientCreateOrUpdateOptions struct { }
ConsumerGroupsClientCreateOrUpdateOptions contains the optional parameters for the ConsumerGroupsClient.CreateOrUpdate method.
type ConsumerGroupsClientCreateOrUpdateResponse ¶ added in v0.3.0
type ConsumerGroupsClientCreateOrUpdateResponse struct { ConsumerGroupsClientCreateOrUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ConsumerGroupsClientCreateOrUpdateResponse contains the response from method ConsumerGroupsClient.CreateOrUpdate.
type ConsumerGroupsClientCreateOrUpdateResult ¶ added in v0.3.0
type ConsumerGroupsClientCreateOrUpdateResult struct {
ConsumerGroup
}
ConsumerGroupsClientCreateOrUpdateResult contains the result from method ConsumerGroupsClient.CreateOrUpdate.
type ConsumerGroupsClientDeleteOptions ¶ added in v0.3.0
type ConsumerGroupsClientDeleteOptions struct { }
ConsumerGroupsClientDeleteOptions contains the optional parameters for the ConsumerGroupsClient.Delete method.
type ConsumerGroupsClientDeleteResponse ¶ added in v0.3.0
type ConsumerGroupsClientDeleteResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ConsumerGroupsClientDeleteResponse contains the response from method ConsumerGroupsClient.Delete.
type ConsumerGroupsClientGetOptions ¶ added in v0.3.0
type ConsumerGroupsClientGetOptions struct { }
ConsumerGroupsClientGetOptions contains the optional parameters for the ConsumerGroupsClient.Get method.
type ConsumerGroupsClientGetResponse ¶ added in v0.3.0
type ConsumerGroupsClientGetResponse struct { ConsumerGroupsClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ConsumerGroupsClientGetResponse contains the response from method ConsumerGroupsClient.Get.
type ConsumerGroupsClientGetResult ¶ added in v0.3.0
type ConsumerGroupsClientGetResult struct {
ConsumerGroup
}
ConsumerGroupsClientGetResult contains the result from method ConsumerGroupsClient.Get.
type ConsumerGroupsClientListByEventHubOptions ¶ added in v0.3.0
type ConsumerGroupsClientListByEventHubOptions 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 }
ConsumerGroupsClientListByEventHubOptions contains the optional parameters for the ConsumerGroupsClient.ListByEventHub method.
type ConsumerGroupsClientListByEventHubPager ¶ added in v0.3.0
type ConsumerGroupsClientListByEventHubPager struct {
// contains filtered or unexported fields
}
ConsumerGroupsClientListByEventHubPager provides operations for iterating over paged responses.
func (*ConsumerGroupsClientListByEventHubPager) Err ¶ added in v0.3.0
func (p *ConsumerGroupsClientListByEventHubPager) Err() error
Err returns the last error encountered while paging.
func (*ConsumerGroupsClientListByEventHubPager) NextPage ¶ added in v0.3.0
func (p *ConsumerGroupsClientListByEventHubPager) 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 (*ConsumerGroupsClientListByEventHubPager) PageResponse ¶ added in v0.3.0
func (p *ConsumerGroupsClientListByEventHubPager) PageResponse() ConsumerGroupsClientListByEventHubResponse
PageResponse returns the current ConsumerGroupsClientListByEventHubResponse page.
type ConsumerGroupsClientListByEventHubResponse ¶ added in v0.3.0
type ConsumerGroupsClientListByEventHubResponse struct { ConsumerGroupsClientListByEventHubResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
ConsumerGroupsClientListByEventHubResponse contains the response from method ConsumerGroupsClient.ListByEventHub.
type ConsumerGroupsClientListByEventHubResult ¶ added in v0.3.0
type ConsumerGroupsClientListByEventHubResult struct {
ConsumerGroupListResult
}
ConsumerGroupsClientListByEventHubResult contains the result from method ConsumerGroupsClient.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"` // The Azure Data Lake Store name for the captured events DataLakeAccountName *string `json:"dataLakeAccountName,omitempty"` // The destination folder path for the captured events DataLakeFolderPath *string `json:"dataLakeFolderPath,omitempty"` // Subscription Id of Azure Data Lake Store DataLakeSubscriptionID *string `json:"dataLakeSubscriptionId,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 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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *DisasterRecoveryConfigsClient
NewDisasterRecoveryConfigsClient creates a new instance of DisasterRecoveryConfigsClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*DisasterRecoveryConfigsClient) BreakPairing ¶
func (client *DisasterRecoveryConfigsClient) BreakPairing(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsClientBreakPairingOptions) (DisasterRecoveryConfigsClientBreakPairingResponse, error)
BreakPairing - This operation disables the Disaster Recovery and stops replicating changes from primary to secondary namespaces If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name options - DisasterRecoveryConfigsClientBreakPairingOptions contains the optional parameters for the DisasterRecoveryConfigsClient.BreakPairing method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasBreakPairing.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) _, err = client.BreakPairing(ctx, "<resource-group-name>", "<namespace-name>", "<alias>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*DisasterRecoveryConfigsClient) CheckNameAvailability ¶
func (client *DisasterRecoveryConfigsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, namespaceName string, parameters CheckNameAvailabilityParameter, options *DisasterRecoveryConfigsClientCheckNameAvailabilityOptions) (DisasterRecoveryConfigsClientCheckNameAvailabilityResponse, error)
CheckNameAvailability - Check the give Namespace name availability. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name parameters - Parameters to check availability of the given Alias name options - DisasterRecoveryConfigsClientCheckNameAvailabilityOptions contains the optional parameters for the DisasterRecoveryConfigsClient.CheckNameAvailability method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasCheckNameAvailability.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) res, err := client.CheckNameAvailability(ctx, "<resource-group-name>", "<namespace-name>", armeventhub.CheckNameAvailabilityParameter{ Name: to.StringPtr("<name>"), }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.DisasterRecoveryConfigsClientCheckNameAvailabilityResult) }
Output:
func (*DisasterRecoveryConfigsClient) CreateOrUpdate ¶
func (client *DisasterRecoveryConfigsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, alias string, parameters ArmDisasterRecovery, options *DisasterRecoveryConfigsClientCreateOrUpdateOptions) (DisasterRecoveryConfigsClientCreateOrUpdateResponse, error)
CreateOrUpdate - Creates or updates a new Alias(Disaster Recovery configuration) If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name parameters - Parameters required to create an Alias(Disaster Recovery configuration) options - DisasterRecoveryConfigsClientCreateOrUpdateOptions contains the optional parameters for the DisasterRecoveryConfigsClient.CreateOrUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdate(ctx, "<resource-group-name>", "<namespace-name>", "<alias>", armeventhub.ArmDisasterRecovery{ Properties: &armeventhub.ArmDisasterRecoveryProperties{ PartnerNamespace: to.StringPtr("<partner-namespace>"), }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.DisasterRecoveryConfigsClientCreateOrUpdateResult) }
Output:
func (*DisasterRecoveryConfigsClient) Delete ¶
func (client *DisasterRecoveryConfigsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsClientDeleteOptions) (DisasterRecoveryConfigsClientDeleteResponse, error)
Delete - Deletes an Alias(Disaster Recovery configuration) If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name options - DisasterRecoveryConfigsClientDeleteOptions contains the optional parameters for the DisasterRecoveryConfigsClient.Delete method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasDelete.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) _, err = client.Delete(ctx, "<resource-group-name>", "<namespace-name>", "<alias>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*DisasterRecoveryConfigsClient) FailOver ¶
func (client *DisasterRecoveryConfigsClient) FailOver(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsClientFailOverOptions) (DisasterRecoveryConfigsClientFailOverResponse, error)
FailOver - Invokes GEO DR failover and reconfigure the alias to point to the secondary namespace If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name options - DisasterRecoveryConfigsClientFailOverOptions contains the optional parameters for the DisasterRecoveryConfigsClient.FailOver method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasFailOver.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) _, err = client.FailOver(ctx, "<resource-group-name>", "<namespace-name>", "<alias>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*DisasterRecoveryConfigsClient) Get ¶
func (client *DisasterRecoveryConfigsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsClientGetOptions) (DisasterRecoveryConfigsClientGetResponse, error)
Get - Retrieves Alias(Disaster Recovery configuration) for primary or secondary namespace If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name options - DisasterRecoveryConfigsClientGetOptions contains the optional parameters for the DisasterRecoveryConfigsClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<namespace-name>", "<alias>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.DisasterRecoveryConfigsClientGetResult) }
Output:
func (*DisasterRecoveryConfigsClient) GetAuthorizationRule ¶
func (client *DisasterRecoveryConfigsClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, alias string, authorizationRuleName string, options *DisasterRecoveryConfigsClientGetAuthorizationRuleOptions) (DisasterRecoveryConfigsClientGetAuthorizationRuleResponse, error)
GetAuthorizationRule - Gets an AuthorizationRule for a Namespace by rule name. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name authorizationRuleName - The authorization rule name. options - DisasterRecoveryConfigsClientGetAuthorizationRuleOptions contains the optional parameters for the DisasterRecoveryConfigsClient.GetAuthorizationRule method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasAuthorizationRuleGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) res, err := client.GetAuthorizationRule(ctx, "<resource-group-name>", "<namespace-name>", "<alias>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.DisasterRecoveryConfigsClientGetAuthorizationRuleResult) }
Output:
func (*DisasterRecoveryConfigsClient) List ¶
func (client *DisasterRecoveryConfigsClient) List(resourceGroupName string, namespaceName string, options *DisasterRecoveryConfigsClientListOptions) *DisasterRecoveryConfigsClientListPager
List - Gets all Alias(Disaster Recovery configurations) If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - DisasterRecoveryConfigsClientListOptions contains the optional parameters for the DisasterRecoveryConfigsClient.List method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasList.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) pager := client.List("<resource-group-name>", "<namespace-name>", nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*DisasterRecoveryConfigsClient) ListAuthorizationRules ¶
func (client *DisasterRecoveryConfigsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, alias string, options *DisasterRecoveryConfigsClientListAuthorizationRulesOptions) *DisasterRecoveryConfigsClientListAuthorizationRulesPager
ListAuthorizationRules - Gets a list of authorization rules for a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name options - DisasterRecoveryConfigsClientListAuthorizationRulesOptions contains the optional parameters for the DisasterRecoveryConfigsClient.ListAuthorizationRules method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasAuthorizationRuleListAll.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) pager := client.ListAuthorizationRules("<resource-group-name>", "<namespace-name>", "<alias>", nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*DisasterRecoveryConfigsClient) ListKeys ¶
func (client *DisasterRecoveryConfigsClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, alias string, authorizationRuleName string, options *DisasterRecoveryConfigsClientListKeysOptions) (DisasterRecoveryConfigsClientListKeysResponse, error)
ListKeys - Gets the primary and secondary connection strings for the Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name alias - The Disaster Recovery configuration name authorizationRuleName - The authorization rule name. options - DisasterRecoveryConfigsClientListKeysOptions contains the optional parameters for the DisasterRecoveryConfigsClient.ListKeys method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/disasterRecoveryConfigs/EHAliasAuthorizationRuleListKey.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewDisasterRecoveryConfigsClient("<subscription-id>", cred, nil) res, err := client.ListKeys(ctx, "<resource-group-name>", "<namespace-name>", "<alias>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.DisasterRecoveryConfigsClientListKeysResult) }
Output:
type DisasterRecoveryConfigsClientBreakPairingOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientBreakPairingOptions struct { }
DisasterRecoveryConfigsClientBreakPairingOptions contains the optional parameters for the DisasterRecoveryConfigsClient.BreakPairing method.
type DisasterRecoveryConfigsClientBreakPairingResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientBreakPairingResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientBreakPairingResponse contains the response from method DisasterRecoveryConfigsClient.BreakPairing.
type DisasterRecoveryConfigsClientCheckNameAvailabilityOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientCheckNameAvailabilityOptions struct { }
DisasterRecoveryConfigsClientCheckNameAvailabilityOptions contains the optional parameters for the DisasterRecoveryConfigsClient.CheckNameAvailability method.
type DisasterRecoveryConfigsClientCheckNameAvailabilityResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientCheckNameAvailabilityResponse struct { DisasterRecoveryConfigsClientCheckNameAvailabilityResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientCheckNameAvailabilityResponse contains the response from method DisasterRecoveryConfigsClient.CheckNameAvailability.
type DisasterRecoveryConfigsClientCheckNameAvailabilityResult ¶ added in v0.3.0
type DisasterRecoveryConfigsClientCheckNameAvailabilityResult struct {
CheckNameAvailabilityResult
}
DisasterRecoveryConfigsClientCheckNameAvailabilityResult contains the result from method DisasterRecoveryConfigsClient.CheckNameAvailability.
type DisasterRecoveryConfigsClientCreateOrUpdateOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientCreateOrUpdateOptions struct { }
DisasterRecoveryConfigsClientCreateOrUpdateOptions contains the optional parameters for the DisasterRecoveryConfigsClient.CreateOrUpdate method.
type DisasterRecoveryConfigsClientCreateOrUpdateResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientCreateOrUpdateResponse struct { DisasterRecoveryConfigsClientCreateOrUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientCreateOrUpdateResponse contains the response from method DisasterRecoveryConfigsClient.CreateOrUpdate.
type DisasterRecoveryConfigsClientCreateOrUpdateResult ¶ added in v0.3.0
type DisasterRecoveryConfigsClientCreateOrUpdateResult struct {
ArmDisasterRecovery
}
DisasterRecoveryConfigsClientCreateOrUpdateResult contains the result from method DisasterRecoveryConfigsClient.CreateOrUpdate.
type DisasterRecoveryConfigsClientDeleteOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientDeleteOptions struct { }
DisasterRecoveryConfigsClientDeleteOptions contains the optional parameters for the DisasterRecoveryConfigsClient.Delete method.
type DisasterRecoveryConfigsClientDeleteResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientDeleteResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientDeleteResponse contains the response from method DisasterRecoveryConfigsClient.Delete.
type DisasterRecoveryConfigsClientFailOverOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientFailOverOptions struct { }
DisasterRecoveryConfigsClientFailOverOptions contains the optional parameters for the DisasterRecoveryConfigsClient.FailOver method.
type DisasterRecoveryConfigsClientFailOverResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientFailOverResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientFailOverResponse contains the response from method DisasterRecoveryConfigsClient.FailOver.
type DisasterRecoveryConfigsClientGetAuthorizationRuleOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientGetAuthorizationRuleOptions struct { }
DisasterRecoveryConfigsClientGetAuthorizationRuleOptions contains the optional parameters for the DisasterRecoveryConfigsClient.GetAuthorizationRule method.
type DisasterRecoveryConfigsClientGetAuthorizationRuleResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientGetAuthorizationRuleResponse struct { DisasterRecoveryConfigsClientGetAuthorizationRuleResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientGetAuthorizationRuleResponse contains the response from method DisasterRecoveryConfigsClient.GetAuthorizationRule.
type DisasterRecoveryConfigsClientGetAuthorizationRuleResult ¶ added in v0.3.0
type DisasterRecoveryConfigsClientGetAuthorizationRuleResult struct {
AuthorizationRule
}
DisasterRecoveryConfigsClientGetAuthorizationRuleResult contains the result from method DisasterRecoveryConfigsClient.GetAuthorizationRule.
type DisasterRecoveryConfigsClientGetOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientGetOptions struct { }
DisasterRecoveryConfigsClientGetOptions contains the optional parameters for the DisasterRecoveryConfigsClient.Get method.
type DisasterRecoveryConfigsClientGetResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientGetResponse struct { DisasterRecoveryConfigsClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientGetResponse contains the response from method DisasterRecoveryConfigsClient.Get.
type DisasterRecoveryConfigsClientGetResult ¶ added in v0.3.0
type DisasterRecoveryConfigsClientGetResult struct {
ArmDisasterRecovery
}
DisasterRecoveryConfigsClientGetResult contains the result from method DisasterRecoveryConfigsClient.Get.
type DisasterRecoveryConfigsClientListAuthorizationRulesOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListAuthorizationRulesOptions struct { }
DisasterRecoveryConfigsClientListAuthorizationRulesOptions contains the optional parameters for the DisasterRecoveryConfigsClient.ListAuthorizationRules method.
type DisasterRecoveryConfigsClientListAuthorizationRulesPager ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListAuthorizationRulesPager struct {
// contains filtered or unexported fields
}
DisasterRecoveryConfigsClientListAuthorizationRulesPager provides operations for iterating over paged responses.
func (*DisasterRecoveryConfigsClientListAuthorizationRulesPager) Err ¶ added in v0.3.0
func (p *DisasterRecoveryConfigsClientListAuthorizationRulesPager) Err() error
Err returns the last error encountered while paging.
func (*DisasterRecoveryConfigsClientListAuthorizationRulesPager) NextPage ¶ added in v0.3.0
func (p *DisasterRecoveryConfigsClientListAuthorizationRulesPager) 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 (*DisasterRecoveryConfigsClientListAuthorizationRulesPager) PageResponse ¶ added in v0.3.0
func (p *DisasterRecoveryConfigsClientListAuthorizationRulesPager) PageResponse() DisasterRecoveryConfigsClientListAuthorizationRulesResponse
PageResponse returns the current DisasterRecoveryConfigsClientListAuthorizationRulesResponse page.
type DisasterRecoveryConfigsClientListAuthorizationRulesResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListAuthorizationRulesResponse struct { DisasterRecoveryConfigsClientListAuthorizationRulesResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientListAuthorizationRulesResponse contains the response from method DisasterRecoveryConfigsClient.ListAuthorizationRules.
type DisasterRecoveryConfigsClientListAuthorizationRulesResult ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListAuthorizationRulesResult struct {
AuthorizationRuleListResult
}
DisasterRecoveryConfigsClientListAuthorizationRulesResult contains the result from method DisasterRecoveryConfigsClient.ListAuthorizationRules.
type DisasterRecoveryConfigsClientListKeysOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListKeysOptions struct { }
DisasterRecoveryConfigsClientListKeysOptions contains the optional parameters for the DisasterRecoveryConfigsClient.ListKeys method.
type DisasterRecoveryConfigsClientListKeysResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListKeysResponse struct { DisasterRecoveryConfigsClientListKeysResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientListKeysResponse contains the response from method DisasterRecoveryConfigsClient.ListKeys.
type DisasterRecoveryConfigsClientListKeysResult ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListKeysResult struct {
AccessKeys
}
DisasterRecoveryConfigsClientListKeysResult contains the result from method DisasterRecoveryConfigsClient.ListKeys.
type DisasterRecoveryConfigsClientListOptions ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListOptions struct { }
DisasterRecoveryConfigsClientListOptions contains the optional parameters for the DisasterRecoveryConfigsClient.List method.
type DisasterRecoveryConfigsClientListPager ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListPager struct {
// contains filtered or unexported fields
}
DisasterRecoveryConfigsClientListPager provides operations for iterating over paged responses.
func (*DisasterRecoveryConfigsClientListPager) Err ¶ added in v0.3.0
func (p *DisasterRecoveryConfigsClientListPager) Err() error
Err returns the last error encountered while paging.
func (*DisasterRecoveryConfigsClientListPager) NextPage ¶ added in v0.3.0
func (p *DisasterRecoveryConfigsClientListPager) 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 (*DisasterRecoveryConfigsClientListPager) PageResponse ¶ added in v0.3.0
func (p *DisasterRecoveryConfigsClientListPager) PageResponse() DisasterRecoveryConfigsClientListResponse
PageResponse returns the current DisasterRecoveryConfigsClientListResponse page.
type DisasterRecoveryConfigsClientListResponse ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListResponse struct { DisasterRecoveryConfigsClientListResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
DisasterRecoveryConfigsClientListResponse contains the response from method DisasterRecoveryConfigsClient.List.
type DisasterRecoveryConfigsClientListResult ¶ added in v0.3.0
type DisasterRecoveryConfigsClientListResult struct {
ArmDisasterRecoveryListResult
}
DisasterRecoveryConfigsClientListResult contains the result from method DisasterRecoveryConfigsClient.List.
type EHNamespace ¶
type EHNamespace struct { // Properties of BYOK Identity description Identity *Identity `json:"identity,omitempty"` // Resource location. Location *string `json:"location,omitempty"` // Namespace properties supplied for create namespace operation. Properties *EHNamespaceProperties `json:"properties,omitempty"` // Properties of sku resource SKU *SKU `json:"sku,omitempty"` // Resource tags. Tags map[string]*string `json:"tags,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,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 { // Alternate name specified when alias and namespace names are same. AlternateName *string `json:"alternateName,omitempty"` // 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 ErrorAdditionalInfo ¶ added in v0.2.0
type ErrorAdditionalInfo struct { // READ-ONLY; The additional info. Info map[string]interface{} `json:"info,omitempty" azure:"ro"` // READ-ONLY; The additional info type. Type *string `json:"type,omitempty" azure:"ro"` }
ErrorAdditionalInfo - The resource management error additional info.
type ErrorDetail ¶ added in v0.2.0
type ErrorDetail struct { // READ-ONLY; The error additional info. AdditionalInfo []*ErrorAdditionalInfo `json:"additionalInfo,omitempty" azure:"ro"` // READ-ONLY; The error code. Code *string `json:"code,omitempty" azure:"ro"` // READ-ONLY; The error details. Details []*ErrorDetail `json:"details,omitempty" azure:"ro"` // READ-ONLY; The error message. Message *string `json:"message,omitempty" azure:"ro"` // READ-ONLY; The error target. Target *string `json:"target,omitempty" azure:"ro"` }
ErrorDetail - The error detail.
func (ErrorDetail) MarshalJSON ¶ added in v0.2.0
func (e ErrorDetail) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type ErrorDetail.
type ErrorResponse ¶
type ErrorResponse struct { // The error object. Error *ErrorDetail `json:"error,omitempty"` }
ErrorResponse - Error response indicates Event Hub service is not able to process the incoming request. The reason is provided in the error message.
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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *EventHubsClient
NewEventHubsClient creates a new instance of EventHubsClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*EventHubsClient) CreateOrUpdate ¶
func (client *EventHubsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, parameters Eventhub, options *EventHubsClientCreateOrUpdateOptions) (EventHubsClientCreateOrUpdateResponse, error)
CreateOrUpdate - Creates or updates a new Event Hub as a nested resource within a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name parameters - Parameters supplied to create an Event Hub resource. options - EventHubsClientCreateOrUpdateOptions contains the optional parameters for the EventHubsClient.CreateOrUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdate(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", armeventhub.Eventhub{ Properties: &armeventhub.Properties{ CaptureDescription: &armeventhub.CaptureDescription{ Destination: &armeventhub.Destination{ Name: to.StringPtr("<name>"), Properties: &armeventhub.DestinationProperties{ ArchiveNameFormat: to.StringPtr("<archive-name-format>"), BlobContainer: to.StringPtr("<blob-container>"), StorageAccountResourceID: to.StringPtr("<storage-account-resource-id>"), }, }, Enabled: to.BoolPtr(true), Encoding: armeventhub.EncodingCaptureDescriptionAvro.ToPtr(), IntervalInSeconds: to.Int32Ptr(120), SizeLimitInBytes: to.Int32Ptr(10485763), }, MessageRetentionInDays: to.Int64Ptr(4), PartitionCount: to.Int64Ptr(4), Status: armeventhub.EntityStatusActive.ToPtr(), }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.EventHubsClientCreateOrUpdateResult) }
Output:
func (*EventHubsClient) CreateOrUpdateAuthorizationRule ¶
func (client *EventHubsClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters AuthorizationRule, options *EventHubsClientCreateOrUpdateAuthorizationRuleOptions) (EventHubsClientCreateOrUpdateAuthorizationRuleResponse, 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 an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name authorizationRuleName - The authorization rule name. parameters - The shared access AuthorizationRule. options - EventHubsClientCreateOrUpdateAuthorizationRuleOptions contains the optional parameters for the EventHubsClient.CreateOrUpdateAuthorizationRule method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubAuthorizationRuleCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdateAuthorizationRule(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<authorization-rule-name>", armeventhub.AuthorizationRule{ Properties: &armeventhub.AuthorizationRuleProperties{ Rights: []*armeventhub.AccessRights{ armeventhub.AccessRights("Listen").ToPtr(), armeventhub.AccessRights("Send").ToPtr()}, }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.EventHubsClientCreateOrUpdateAuthorizationRuleResult) }
Output:
func (*EventHubsClient) Delete ¶
func (client *EventHubsClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, options *EventHubsClientDeleteOptions) (EventHubsClientDeleteResponse, error)
Delete - Deletes an Event Hub from the specified Namespace and resource group. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name options - EventHubsClientDeleteOptions contains the optional parameters for the EventHubsClient.Delete method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubDelete.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) _, err = client.Delete(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*EventHubsClient) DeleteAuthorizationRule ¶
func (client *EventHubsClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *EventHubsClientDeleteAuthorizationRuleOptions) (EventHubsClientDeleteAuthorizationRuleResponse, error)
DeleteAuthorizationRule - Deletes an Event Hub AuthorizationRule. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name authorizationRuleName - The authorization rule name. options - EventHubsClientDeleteAuthorizationRuleOptions contains the optional parameters for the EventHubsClient.DeleteAuthorizationRule method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubAuthorizationRuleDelete.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) _, err = client.DeleteAuthorizationRule(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*EventHubsClient) Get ¶
func (client *EventHubsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, options *EventHubsClientGetOptions) (EventHubsClientGetResponse, error)
Get - Gets an Event Hubs description for the specified Event Hub. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name options - EventHubsClientGetOptions contains the optional parameters for the EventHubsClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.EventHubsClientGetResult) }
Output:
func (*EventHubsClient) GetAuthorizationRule ¶
func (client *EventHubsClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *EventHubsClientGetAuthorizationRuleOptions) (EventHubsClientGetAuthorizationRuleResponse, error)
GetAuthorizationRule - Gets an AuthorizationRule for an Event Hub by rule name. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name authorizationRuleName - The authorization rule name. options - EventHubsClientGetAuthorizationRuleOptions contains the optional parameters for the EventHubsClient.GetAuthorizationRule method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubAuthorizationRuleGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) res, err := client.GetAuthorizationRule(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.EventHubsClientGetAuthorizationRuleResult) }
Output:
func (*EventHubsClient) ListAuthorizationRules ¶
func (client *EventHubsClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, eventHubName string, options *EventHubsClientListAuthorizationRulesOptions) *EventHubsClientListAuthorizationRulesPager
ListAuthorizationRules - Gets the authorization rules for an Event Hub. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name options - EventHubsClientListAuthorizationRulesOptions contains the optional parameters for the EventHubsClient.ListAuthorizationRules method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubAuthorizationRuleListAll.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) pager := client.ListAuthorizationRules("<resource-group-name>", "<namespace-name>", "<event-hub-name>", nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*EventHubsClient) ListByNamespace ¶
func (client *EventHubsClient) ListByNamespace(resourceGroupName string, namespaceName string, options *EventHubsClientListByNamespaceOptions) *EventHubsClientListByNamespacePager
ListByNamespace - Gets all the Event Hubs in a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - EventHubsClientListByNamespaceOptions contains the optional parameters for the EventHubsClient.ListByNamespace method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubListByNameSpace.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) pager := client.ListByNamespace("<resource-group-name>", "<namespace-name>", &armeventhub.EventHubsClientListByNamespaceOptions{Skip: nil, Top: nil, }) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*EventHubsClient) ListKeys ¶
func (client *EventHubsClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, options *EventHubsClientListKeysOptions) (EventHubsClientListKeysResponse, error)
ListKeys - Gets the ACS and SAS connection strings for the Event Hub. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name authorizationRuleName - The authorization rule name. options - EventHubsClientListKeysOptions contains the optional parameters for the EventHubsClient.ListKeys method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubAuthorizationRuleListKey.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) res, err := client.ListKeys(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.EventHubsClientListKeysResult) }
Output:
func (*EventHubsClient) RegenerateKeys ¶
func (client *EventHubsClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, eventHubName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters, options *EventHubsClientRegenerateKeysOptions) (EventHubsClientRegenerateKeysResponse, error)
RegenerateKeys - Regenerates the ACS and SAS connection strings for the Event Hub. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name eventHubName - The Event Hub name authorizationRuleName - The authorization rule name. parameters - Parameters supplied to regenerate the AuthorizationRule Keys (PrimaryKey/SecondaryKey). options - EventHubsClientRegenerateKeysOptions contains the optional parameters for the EventHubsClient.RegenerateKeys method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EventHubs/EHEventHubAuthorizationRuleRegenerateKey.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewEventHubsClient("<subscription-id>", cred, nil) res, err := client.RegenerateKeys(ctx, "<resource-group-name>", "<namespace-name>", "<event-hub-name>", "<authorization-rule-name>", armeventhub.RegenerateAccessKeyParameters{ KeyType: armeventhub.KeyType("PrimaryKey").ToPtr(), }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.EventHubsClientRegenerateKeysResult) }
Output:
type EventHubsClientCreateOrUpdateAuthorizationRuleOptions ¶ added in v0.3.0
type EventHubsClientCreateOrUpdateAuthorizationRuleOptions struct { }
EventHubsClientCreateOrUpdateAuthorizationRuleOptions contains the optional parameters for the EventHubsClient.CreateOrUpdateAuthorizationRule method.
type EventHubsClientCreateOrUpdateAuthorizationRuleResponse ¶ added in v0.3.0
type EventHubsClientCreateOrUpdateAuthorizationRuleResponse struct { EventHubsClientCreateOrUpdateAuthorizationRuleResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientCreateOrUpdateAuthorizationRuleResponse contains the response from method EventHubsClient.CreateOrUpdateAuthorizationRule.
type EventHubsClientCreateOrUpdateAuthorizationRuleResult ¶ added in v0.3.0
type EventHubsClientCreateOrUpdateAuthorizationRuleResult struct {
AuthorizationRule
}
EventHubsClientCreateOrUpdateAuthorizationRuleResult contains the result from method EventHubsClient.CreateOrUpdateAuthorizationRule.
type EventHubsClientCreateOrUpdateOptions ¶ added in v0.3.0
type EventHubsClientCreateOrUpdateOptions struct { }
EventHubsClientCreateOrUpdateOptions contains the optional parameters for the EventHubsClient.CreateOrUpdate method.
type EventHubsClientCreateOrUpdateResponse ¶ added in v0.3.0
type EventHubsClientCreateOrUpdateResponse struct { EventHubsClientCreateOrUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientCreateOrUpdateResponse contains the response from method EventHubsClient.CreateOrUpdate.
type EventHubsClientCreateOrUpdateResult ¶ added in v0.3.0
type EventHubsClientCreateOrUpdateResult struct {
Eventhub
}
EventHubsClientCreateOrUpdateResult contains the result from method EventHubsClient.CreateOrUpdate.
type EventHubsClientDeleteAuthorizationRuleOptions ¶ added in v0.3.0
type EventHubsClientDeleteAuthorizationRuleOptions struct { }
EventHubsClientDeleteAuthorizationRuleOptions contains the optional parameters for the EventHubsClient.DeleteAuthorizationRule method.
type EventHubsClientDeleteAuthorizationRuleResponse ¶ added in v0.3.0
type EventHubsClientDeleteAuthorizationRuleResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientDeleteAuthorizationRuleResponse contains the response from method EventHubsClient.DeleteAuthorizationRule.
type EventHubsClientDeleteOptions ¶ added in v0.3.0
type EventHubsClientDeleteOptions struct { }
EventHubsClientDeleteOptions contains the optional parameters for the EventHubsClient.Delete method.
type EventHubsClientDeleteResponse ¶ added in v0.3.0
type EventHubsClientDeleteResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientDeleteResponse contains the response from method EventHubsClient.Delete.
type EventHubsClientGetAuthorizationRuleOptions ¶ added in v0.3.0
type EventHubsClientGetAuthorizationRuleOptions struct { }
EventHubsClientGetAuthorizationRuleOptions contains the optional parameters for the EventHubsClient.GetAuthorizationRule method.
type EventHubsClientGetAuthorizationRuleResponse ¶ added in v0.3.0
type EventHubsClientGetAuthorizationRuleResponse struct { EventHubsClientGetAuthorizationRuleResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientGetAuthorizationRuleResponse contains the response from method EventHubsClient.GetAuthorizationRule.
type EventHubsClientGetAuthorizationRuleResult ¶ added in v0.3.0
type EventHubsClientGetAuthorizationRuleResult struct {
AuthorizationRule
}
EventHubsClientGetAuthorizationRuleResult contains the result from method EventHubsClient.GetAuthorizationRule.
type EventHubsClientGetOptions ¶ added in v0.3.0
type EventHubsClientGetOptions struct { }
EventHubsClientGetOptions contains the optional parameters for the EventHubsClient.Get method.
type EventHubsClientGetResponse ¶ added in v0.3.0
type EventHubsClientGetResponse struct { EventHubsClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientGetResponse contains the response from method EventHubsClient.Get.
type EventHubsClientGetResult ¶ added in v0.3.0
type EventHubsClientGetResult struct {
Eventhub
}
EventHubsClientGetResult contains the result from method EventHubsClient.Get.
type EventHubsClientListAuthorizationRulesOptions ¶ added in v0.3.0
type EventHubsClientListAuthorizationRulesOptions struct { }
EventHubsClientListAuthorizationRulesOptions contains the optional parameters for the EventHubsClient.ListAuthorizationRules method.
type EventHubsClientListAuthorizationRulesPager ¶ added in v0.3.0
type EventHubsClientListAuthorizationRulesPager struct {
// contains filtered or unexported fields
}
EventHubsClientListAuthorizationRulesPager provides operations for iterating over paged responses.
func (*EventHubsClientListAuthorizationRulesPager) Err ¶ added in v0.3.0
func (p *EventHubsClientListAuthorizationRulesPager) Err() error
Err returns the last error encountered while paging.
func (*EventHubsClientListAuthorizationRulesPager) NextPage ¶ added in v0.3.0
func (p *EventHubsClientListAuthorizationRulesPager) 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 (*EventHubsClientListAuthorizationRulesPager) PageResponse ¶ added in v0.3.0
func (p *EventHubsClientListAuthorizationRulesPager) PageResponse() EventHubsClientListAuthorizationRulesResponse
PageResponse returns the current EventHubsClientListAuthorizationRulesResponse page.
type EventHubsClientListAuthorizationRulesResponse ¶ added in v0.3.0
type EventHubsClientListAuthorizationRulesResponse struct { EventHubsClientListAuthorizationRulesResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientListAuthorizationRulesResponse contains the response from method EventHubsClient.ListAuthorizationRules.
type EventHubsClientListAuthorizationRulesResult ¶ added in v0.3.0
type EventHubsClientListAuthorizationRulesResult struct {
AuthorizationRuleListResult
}
EventHubsClientListAuthorizationRulesResult contains the result from method EventHubsClient.ListAuthorizationRules.
type EventHubsClientListByNamespaceOptions ¶ added in v0.3.0
type EventHubsClientListByNamespaceOptions 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 }
EventHubsClientListByNamespaceOptions contains the optional parameters for the EventHubsClient.ListByNamespace method.
type EventHubsClientListByNamespacePager ¶ added in v0.3.0
type EventHubsClientListByNamespacePager struct {
// contains filtered or unexported fields
}
EventHubsClientListByNamespacePager provides operations for iterating over paged responses.
func (*EventHubsClientListByNamespacePager) Err ¶ added in v0.3.0
func (p *EventHubsClientListByNamespacePager) Err() error
Err returns the last error encountered while paging.
func (*EventHubsClientListByNamespacePager) NextPage ¶ added in v0.3.0
func (p *EventHubsClientListByNamespacePager) 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 (*EventHubsClientListByNamespacePager) PageResponse ¶ added in v0.3.0
func (p *EventHubsClientListByNamespacePager) PageResponse() EventHubsClientListByNamespaceResponse
PageResponse returns the current EventHubsClientListByNamespaceResponse page.
type EventHubsClientListByNamespaceResponse ¶ added in v0.3.0
type EventHubsClientListByNamespaceResponse struct { EventHubsClientListByNamespaceResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientListByNamespaceResponse contains the response from method EventHubsClient.ListByNamespace.
type EventHubsClientListByNamespaceResult ¶ added in v0.3.0
type EventHubsClientListByNamespaceResult struct {
ListResult
}
EventHubsClientListByNamespaceResult contains the result from method EventHubsClient.ListByNamespace.
type EventHubsClientListKeysOptions ¶ added in v0.3.0
type EventHubsClientListKeysOptions struct { }
EventHubsClientListKeysOptions contains the optional parameters for the EventHubsClient.ListKeys method.
type EventHubsClientListKeysResponse ¶ added in v0.3.0
type EventHubsClientListKeysResponse struct { EventHubsClientListKeysResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientListKeysResponse contains the response from method EventHubsClient.ListKeys.
type EventHubsClientListKeysResult ¶ added in v0.3.0
type EventHubsClientListKeysResult struct {
AccessKeys
}
EventHubsClientListKeysResult contains the result from method EventHubsClient.ListKeys.
type EventHubsClientRegenerateKeysOptions ¶ added in v0.3.0
type EventHubsClientRegenerateKeysOptions struct { }
EventHubsClientRegenerateKeysOptions contains the optional parameters for the EventHubsClient.RegenerateKeys method.
type EventHubsClientRegenerateKeysResponse ¶ added in v0.3.0
type EventHubsClientRegenerateKeysResponse struct { EventHubsClientRegenerateKeysResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
EventHubsClientRegenerateKeysResponse contains the response from method EventHubsClient.RegenerateKeys.
type EventHubsClientRegenerateKeysResult ¶ added in v0.3.0
type EventHubsClientRegenerateKeysResult struct {
AccessKeys
}
EventHubsClientRegenerateKeysResult contains the result from method EventHubsClient.RegenerateKeys.
type Eventhub ¶
type Eventhub struct { // Properties supplied to the Create Or Update Event Hub operation. Properties *Properties `json:"properties,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
Eventhub - Single item in List or Get Event Hub operation
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 ¶
MarshalJSON implements the json.Marshaller interface for type Identity.
type KeyType ¶
type KeyType string
KeyType - The access key to regenerate.
func PossibleKeyTypeValues ¶
func PossibleKeyTypeValues() []KeyType
PossibleKeyTypeValues returns the possible values for the KeyType const type.
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 ListResult ¶ added in v0.3.0
type ListResult 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"` }
ListResult - The result of the List EventHubs operation.
func (ListResult) MarshalJSON ¶ added in v0.3.0
func (l ListResult) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type ListResult.
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 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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *NamespacesClient
NewNamespacesClient creates a new instance of NamespacesClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*NamespacesClient) BeginCreateOrUpdate ¶
func (client *NamespacesClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, parameters EHNamespace, options *NamespacesClientBeginCreateOrUpdateOptions) (NamespacesClientCreateOrUpdatePollerResponse, 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 an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name parameters - Parameters for creating a namespace resource. options - NamespacesClientBeginCreateOrUpdateOptions contains the optional parameters for the NamespacesClient.BeginCreateOrUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceCreate.json
package main import ( "context" "log" "time" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) poller, err := client.BeginCreateOrUpdate(ctx, "<resource-group-name>", "<namespace-name>", armeventhub.EHNamespace{ Location: to.StringPtr("<location>"), Identity: &armeventhub.Identity{ Type: armeventhub.ManagedServiceIdentityTypeSystemAssignedUserAssigned.ToPtr(), UserAssignedIdentities: map[string]*armeventhub.UserAssignedIdentity{ "/subscriptions/SampleSubscription/resourceGroups/ResurceGroupSample/providers/Microsoft.ManagedIdentity/userAssignedIdentities/ud1": {}, "/subscriptions/SampleSubscription/resourceGroups/ResurceGroupSample/providers/Microsoft.ManagedIdentity/userAssignedIdentities/ud2": {}, }, }, Properties: &armeventhub.EHNamespaceProperties{ ClusterArmID: to.StringPtr("<cluster-arm-id>"), Encryption: &armeventhub.Encryption{ KeySource: to.StringPtr("<key-source>"), KeyVaultProperties: []*armeventhub.KeyVaultProperties{ { Identity: &armeventhub.UserAssignedIdentityProperties{ UserAssignedIdentity: to.StringPtr("<user-assigned-identity>"), }, KeyName: to.StringPtr("<key-name>"), KeyVaultURI: to.StringPtr("<key-vault-uri>"), }}, }, }, }, nil) if err != nil { log.Fatal(err) } res, err := poller.PollUntilDone(ctx, 30*time.Second) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientCreateOrUpdateResult) }
Output:
func (*NamespacesClient) BeginDelete ¶
func (client *NamespacesClient) BeginDelete(ctx context.Context, resourceGroupName string, namespaceName string, options *NamespacesClientBeginDeleteOptions) (NamespacesClientDeletePollerResponse, error)
BeginDelete - Deletes an existing namespace. This operation also removes all associated resources under the namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - NamespacesClientBeginDeleteOptions contains the optional parameters for the NamespacesClient.BeginDelete method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceDelete.json
package main import ( "context" "log" "time" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) poller, err := client.BeginDelete(ctx, "<resource-group-name>", "<namespace-name>", nil) if err != nil { log.Fatal(err) } _, err = poller.PollUntilDone(ctx, 30*time.Second) if err != nil { log.Fatal(err) } }
Output:
func (*NamespacesClient) CheckNameAvailability ¶
func (client *NamespacesClient) CheckNameAvailability(ctx context.Context, parameters CheckNameAvailabilityParameter, options *NamespacesClientCheckNameAvailabilityOptions) (NamespacesClientCheckNameAvailabilityResponse, error)
CheckNameAvailability - Check the give Namespace name availability. If the operation fails it returns an *azcore.ResponseError type. parameters - Parameters to check availability of the given Namespace name options - NamespacesClientCheckNameAvailabilityOptions contains the optional parameters for the NamespacesClient.CheckNameAvailability method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceCheckNameAvailability.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.CheckNameAvailability(ctx, armeventhub.CheckNameAvailabilityParameter{ Name: to.StringPtr("<name>"), }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientCheckNameAvailabilityResult) }
Output:
func (*NamespacesClient) CreateOrUpdateAuthorizationRule ¶
func (client *NamespacesClient) CreateOrUpdateAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters AuthorizationRule, options *NamespacesClientCreateOrUpdateAuthorizationRuleOptions) (NamespacesClientCreateOrUpdateAuthorizationRuleResponse, error)
CreateOrUpdateAuthorizationRule - Creates or updates an AuthorizationRule for a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name authorizationRuleName - The authorization rule name. parameters - The shared access AuthorizationRule. options - NamespacesClientCreateOrUpdateAuthorizationRuleOptions contains the optional parameters for the NamespacesClient.CreateOrUpdateAuthorizationRule method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceAuthorizationRuleCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdateAuthorizationRule(ctx, "<resource-group-name>", "<namespace-name>", "<authorization-rule-name>", armeventhub.AuthorizationRule{ Properties: &armeventhub.AuthorizationRuleProperties{ Rights: []*armeventhub.AccessRights{ armeventhub.AccessRights("Listen").ToPtr(), armeventhub.AccessRights("Send").ToPtr()}, }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientCreateOrUpdateAuthorizationRuleResult) }
Output:
func (*NamespacesClient) CreateOrUpdateNetworkRuleSet ¶
func (client *NamespacesClient) CreateOrUpdateNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, parameters NetworkRuleSet, options *NamespacesClientCreateOrUpdateNetworkRuleSetOptions) (NamespacesClientCreateOrUpdateNetworkRuleSetResponse, error)
CreateOrUpdateNetworkRuleSet - Create or update NetworkRuleSet for a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name parameters - The Namespace IpFilterRule. options - NamespacesClientCreateOrUpdateNetworkRuleSetOptions contains the optional parameters for the NamespacesClient.CreateOrUpdateNetworkRuleSet method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/VirtualNetworkRule/EHNetworkRuleSetCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdateNetworkRuleSet(ctx, "<resource-group-name>", "<namespace-name>", armeventhub.NetworkRuleSet{ Properties: &armeventhub.NetworkRuleSetProperties{ DefaultAction: armeventhub.DefaultAction("Deny").ToPtr(), IPRules: []*armeventhub.NWRuleSetIPRules{ { Action: armeventhub.NetworkRuleIPAction("Allow").ToPtr(), IPMask: to.StringPtr("<ipmask>"), }, { Action: armeventhub.NetworkRuleIPAction("Allow").ToPtr(), IPMask: to.StringPtr("<ipmask>"), }, { Action: armeventhub.NetworkRuleIPAction("Allow").ToPtr(), IPMask: to.StringPtr("<ipmask>"), }, { Action: armeventhub.NetworkRuleIPAction("Allow").ToPtr(), IPMask: to.StringPtr("<ipmask>"), }, { Action: armeventhub.NetworkRuleIPAction("Allow").ToPtr(), IPMask: to.StringPtr("<ipmask>"), }}, VirtualNetworkRules: []*armeventhub.NWRuleSetVirtualNetworkRules{ { IgnoreMissingVnetServiceEndpoint: to.BoolPtr(true), Subnet: &armeventhub.Subnet{ ID: to.StringPtr("<id>"), }, }, { IgnoreMissingVnetServiceEndpoint: to.BoolPtr(false), Subnet: &armeventhub.Subnet{ ID: to.StringPtr("<id>"), }, }, { IgnoreMissingVnetServiceEndpoint: to.BoolPtr(false), Subnet: &armeventhub.Subnet{ ID: to.StringPtr("<id>"), }, }}, }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientCreateOrUpdateNetworkRuleSetResult) }
Output:
func (*NamespacesClient) DeleteAuthorizationRule ¶
func (client *NamespacesClient) DeleteAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *NamespacesClientDeleteAuthorizationRuleOptions) (NamespacesClientDeleteAuthorizationRuleResponse, error)
DeleteAuthorizationRule - Deletes an AuthorizationRule for a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name authorizationRuleName - The authorization rule name. options - NamespacesClientDeleteAuthorizationRuleOptions contains the optional parameters for the NamespacesClient.DeleteAuthorizationRule method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceAuthorizationRuleDelete.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) _, err = client.DeleteAuthorizationRule(ctx, "<resource-group-name>", "<namespace-name>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*NamespacesClient) Get ¶
func (client *NamespacesClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, options *NamespacesClientGetOptions) (NamespacesClientGetResponse, error)
Get - Gets the description of the specified namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - NamespacesClientGetOptions contains the optional parameters for the NamespacesClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<namespace-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientGetResult) }
Output:
func (*NamespacesClient) GetAuthorizationRule ¶
func (client *NamespacesClient) GetAuthorizationRule(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *NamespacesClientGetAuthorizationRuleOptions) (NamespacesClientGetAuthorizationRuleResponse, error)
GetAuthorizationRule - Gets an AuthorizationRule for a Namespace by rule name. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name authorizationRuleName - The authorization rule name. options - NamespacesClientGetAuthorizationRuleOptions contains the optional parameters for the NamespacesClient.GetAuthorizationRule method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceAuthorizationRuleGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.GetAuthorizationRule(ctx, "<resource-group-name>", "<namespace-name>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientGetAuthorizationRuleResult) }
Output:
func (*NamespacesClient) GetNetworkRuleSet ¶
func (client *NamespacesClient) GetNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, options *NamespacesClientGetNetworkRuleSetOptions) (NamespacesClientGetNetworkRuleSetResponse, error)
GetNetworkRuleSet - Gets NetworkRuleSet for a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - NamespacesClientGetNetworkRuleSetOptions contains the optional parameters for the NamespacesClient.GetNetworkRuleSet method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/VirtualNetworkRule/EHNetworkRuleSetGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.GetNetworkRuleSet(ctx, "<resource-group-name>", "<namespace-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientGetNetworkRuleSetResult) }
Output:
func (*NamespacesClient) List ¶
func (client *NamespacesClient) List(options *NamespacesClientListOptions) *NamespacesClientListPager
List - Lists all the available Namespaces within a subscription, irrespective of the resource groups. If the operation fails it returns an *azcore.ResponseError type. options - NamespacesClientListOptions contains the optional parameters for the NamespacesClient.List method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceList.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) pager := client.List(nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*NamespacesClient) ListAuthorizationRules ¶
func (client *NamespacesClient) ListAuthorizationRules(resourceGroupName string, namespaceName string, options *NamespacesClientListAuthorizationRulesOptions) *NamespacesClientListAuthorizationRulesPager
ListAuthorizationRules - Gets a list of authorization rules for a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - NamespacesClientListAuthorizationRulesOptions contains the optional parameters for the NamespacesClient.ListAuthorizationRules method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceAuthorizationRuleListAll.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) pager := client.ListAuthorizationRules("<resource-group-name>", "<namespace-name>", nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*NamespacesClient) ListByResourceGroup ¶
func (client *NamespacesClient) ListByResourceGroup(resourceGroupName string, options *NamespacesClientListByResourceGroupOptions) *NamespacesClientListByResourceGroupPager
ListByResourceGroup - Lists the available Namespaces within a resource group. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. options - NamespacesClientListByResourceGroupOptions contains the optional parameters for the NamespacesClient.ListByResourceGroup method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceListByResourceGroup.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) pager := client.ListByResourceGroup("<resource-group-name>", nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
func (*NamespacesClient) ListKeys ¶
func (client *NamespacesClient) ListKeys(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, options *NamespacesClientListKeysOptions) (NamespacesClientListKeysResponse, error)
ListKeys - Gets the primary and secondary connection strings for the Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name authorizationRuleName - The authorization rule name. options - NamespacesClientListKeysOptions contains the optional parameters for the NamespacesClient.ListKeys method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceAuthorizationRuleListKey.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.ListKeys(ctx, "<resource-group-name>", "<namespace-name>", "<authorization-rule-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientListKeysResult) }
Output:
func (*NamespacesClient) ListNetworkRuleSet ¶ added in v0.2.0
func (client *NamespacesClient) ListNetworkRuleSet(ctx context.Context, resourceGroupName string, namespaceName string, options *NamespacesClientListNetworkRuleSetOptions) (NamespacesClientListNetworkRuleSetResponse, error)
ListNetworkRuleSet - Gets NetworkRuleSet for a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - NamespacesClientListNetworkRuleSetOptions contains the optional parameters for the NamespacesClient.ListNetworkRuleSet method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/VirtualNetworkRule/EHNetworkRuleSetList.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.ListNetworkRuleSet(ctx, "<resource-group-name>", "<namespace-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientListNetworkRuleSetResult) }
Output:
func (*NamespacesClient) RegenerateKeys ¶
func (client *NamespacesClient) RegenerateKeys(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string, parameters RegenerateAccessKeyParameters, options *NamespacesClientRegenerateKeysOptions) (NamespacesClientRegenerateKeysResponse, error)
RegenerateKeys - Regenerates the primary or secondary connection strings for the specified Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name authorizationRuleName - The authorization rule name. parameters - Parameters required to regenerate the connection string. options - NamespacesClientRegenerateKeysOptions contains the optional parameters for the NamespacesClient.RegenerateKeys method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceAuthorizationRuleRegenerateKey.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.RegenerateKeys(ctx, "<resource-group-name>", "<namespace-name>", "<authorization-rule-name>", armeventhub.RegenerateAccessKeyParameters{ KeyType: armeventhub.KeyType("PrimaryKey").ToPtr(), }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientRegenerateKeysResult) }
Output:
func (*NamespacesClient) Update ¶
func (client *NamespacesClient) Update(ctx context.Context, resourceGroupName string, namespaceName string, parameters EHNamespace, options *NamespacesClientUpdateOptions) (NamespacesClientUpdateResponse, 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 an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name parameters - Parameters for updating a namespace resource. options - NamespacesClientUpdateOptions contains the optional parameters for the NamespacesClient.Update method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/EHNameSpaceUpdate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewNamespacesClient("<subscription-id>", cred, nil) res, err := client.Update(ctx, "<resource-group-name>", "<namespace-name>", armeventhub.EHNamespace{ Location: to.StringPtr("<location>"), Identity: &armeventhub.Identity{ Type: armeventhub.ManagedServiceIdentityTypeSystemAssignedUserAssigned.ToPtr(), UserAssignedIdentities: map[string]*armeventhub.UserAssignedIdentity{ "/subscriptions/SampleSubscription/resourceGroups/ResurceGroupSample/providers/Microsoft.ManagedIdentity/userAssignedIdentities/ud2": nil, }, }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.NamespacesClientUpdateResult) }
Output:
type NamespacesClientBeginCreateOrUpdateOptions ¶ added in v0.3.0
type NamespacesClientBeginCreateOrUpdateOptions struct { }
NamespacesClientBeginCreateOrUpdateOptions contains the optional parameters for the NamespacesClient.BeginCreateOrUpdate method.
type NamespacesClientBeginDeleteOptions ¶ added in v0.3.0
type NamespacesClientBeginDeleteOptions struct { }
NamespacesClientBeginDeleteOptions contains the optional parameters for the NamespacesClient.BeginDelete method.
type NamespacesClientCheckNameAvailabilityOptions ¶ added in v0.3.0
type NamespacesClientCheckNameAvailabilityOptions struct { }
NamespacesClientCheckNameAvailabilityOptions contains the optional parameters for the NamespacesClient.CheckNameAvailability method.
type NamespacesClientCheckNameAvailabilityResponse ¶ added in v0.3.0
type NamespacesClientCheckNameAvailabilityResponse struct { NamespacesClientCheckNameAvailabilityResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientCheckNameAvailabilityResponse contains the response from method NamespacesClient.CheckNameAvailability.
type NamespacesClientCheckNameAvailabilityResult ¶ added in v0.3.0
type NamespacesClientCheckNameAvailabilityResult struct {
CheckNameAvailabilityResult
}
NamespacesClientCheckNameAvailabilityResult contains the result from method NamespacesClient.CheckNameAvailability.
type NamespacesClientCreateOrUpdateAuthorizationRuleOptions ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateAuthorizationRuleOptions struct { }
NamespacesClientCreateOrUpdateAuthorizationRuleOptions contains the optional parameters for the NamespacesClient.CreateOrUpdateAuthorizationRule method.
type NamespacesClientCreateOrUpdateAuthorizationRuleResponse ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateAuthorizationRuleResponse struct { NamespacesClientCreateOrUpdateAuthorizationRuleResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientCreateOrUpdateAuthorizationRuleResponse contains the response from method NamespacesClient.CreateOrUpdateAuthorizationRule.
type NamespacesClientCreateOrUpdateAuthorizationRuleResult ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateAuthorizationRuleResult struct {
AuthorizationRule
}
NamespacesClientCreateOrUpdateAuthorizationRuleResult contains the result from method NamespacesClient.CreateOrUpdateAuthorizationRule.
type NamespacesClientCreateOrUpdateNetworkRuleSetOptions ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateNetworkRuleSetOptions struct { }
NamespacesClientCreateOrUpdateNetworkRuleSetOptions contains the optional parameters for the NamespacesClient.CreateOrUpdateNetworkRuleSet method.
type NamespacesClientCreateOrUpdateNetworkRuleSetResponse ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateNetworkRuleSetResponse struct { NamespacesClientCreateOrUpdateNetworkRuleSetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientCreateOrUpdateNetworkRuleSetResponse contains the response from method NamespacesClient.CreateOrUpdateNetworkRuleSet.
type NamespacesClientCreateOrUpdateNetworkRuleSetResult ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateNetworkRuleSetResult struct {
NetworkRuleSet
}
NamespacesClientCreateOrUpdateNetworkRuleSetResult contains the result from method NamespacesClient.CreateOrUpdateNetworkRuleSet.
type NamespacesClientCreateOrUpdatePoller ¶ added in v0.3.0
type NamespacesClientCreateOrUpdatePoller struct {
// contains filtered or unexported fields
}
NamespacesClientCreateOrUpdatePoller provides polling facilities until the operation reaches a terminal state.
func (*NamespacesClientCreateOrUpdatePoller) Done ¶ added in v0.3.0
func (p *NamespacesClientCreateOrUpdatePoller) Done() bool
Done returns true if the LRO has reached a terminal state.
func (*NamespacesClientCreateOrUpdatePoller) FinalResponse ¶ added in v0.3.0
func (p *NamespacesClientCreateOrUpdatePoller) FinalResponse(ctx context.Context) (NamespacesClientCreateOrUpdateResponse, 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 NamespacesClientCreateOrUpdateResponse will be returned.
func (*NamespacesClientCreateOrUpdatePoller) Poll ¶ added in v0.3.0
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 (*NamespacesClientCreateOrUpdatePoller) ResumeToken ¶ added in v0.3.0
func (p *NamespacesClientCreateOrUpdatePoller) 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 NamespacesClientCreateOrUpdatePollerResponse ¶ added in v0.3.0
type NamespacesClientCreateOrUpdatePollerResponse struct { // Poller contains an initialized poller. Poller *NamespacesClientCreateOrUpdatePoller // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientCreateOrUpdatePollerResponse contains the response from method NamespacesClient.CreateOrUpdate.
func (NamespacesClientCreateOrUpdatePollerResponse) PollUntilDone ¶ added in v0.3.0
func (l NamespacesClientCreateOrUpdatePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (NamespacesClientCreateOrUpdateResponse, error)
PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.
func (*NamespacesClientCreateOrUpdatePollerResponse) Resume ¶ added in v0.3.0
func (l *NamespacesClientCreateOrUpdatePollerResponse) Resume(ctx context.Context, client *NamespacesClient, token string) error
Resume rehydrates a NamespacesClientCreateOrUpdatePollerResponse from the provided client and resume token.
type NamespacesClientCreateOrUpdateResponse ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateResponse struct { NamespacesClientCreateOrUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientCreateOrUpdateResponse contains the response from method NamespacesClient.CreateOrUpdate.
type NamespacesClientCreateOrUpdateResult ¶ added in v0.3.0
type NamespacesClientCreateOrUpdateResult struct {
EHNamespace
}
NamespacesClientCreateOrUpdateResult contains the result from method NamespacesClient.CreateOrUpdate.
type NamespacesClientDeleteAuthorizationRuleOptions ¶ added in v0.3.0
type NamespacesClientDeleteAuthorizationRuleOptions struct { }
NamespacesClientDeleteAuthorizationRuleOptions contains the optional parameters for the NamespacesClient.DeleteAuthorizationRule method.
type NamespacesClientDeleteAuthorizationRuleResponse ¶ added in v0.3.0
type NamespacesClientDeleteAuthorizationRuleResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientDeleteAuthorizationRuleResponse contains the response from method NamespacesClient.DeleteAuthorizationRule.
type NamespacesClientDeletePoller ¶ added in v0.3.0
type NamespacesClientDeletePoller struct {
// contains filtered or unexported fields
}
NamespacesClientDeletePoller provides polling facilities until the operation reaches a terminal state.
func (*NamespacesClientDeletePoller) Done ¶ added in v0.3.0
func (p *NamespacesClientDeletePoller) Done() bool
Done returns true if the LRO has reached a terminal state.
func (*NamespacesClientDeletePoller) FinalResponse ¶ added in v0.3.0
func (p *NamespacesClientDeletePoller) FinalResponse(ctx context.Context) (NamespacesClientDeleteResponse, 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 NamespacesClientDeleteResponse will be returned.
func (*NamespacesClientDeletePoller) Poll ¶ added in v0.3.0
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 (*NamespacesClientDeletePoller) ResumeToken ¶ added in v0.3.0
func (p *NamespacesClientDeletePoller) 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 NamespacesClientDeletePollerResponse ¶ added in v0.3.0
type NamespacesClientDeletePollerResponse struct { // Poller contains an initialized poller. Poller *NamespacesClientDeletePoller // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientDeletePollerResponse contains the response from method NamespacesClient.Delete.
func (NamespacesClientDeletePollerResponse) PollUntilDone ¶ added in v0.3.0
func (l NamespacesClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (NamespacesClientDeleteResponse, error)
PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.
func (*NamespacesClientDeletePollerResponse) Resume ¶ added in v0.3.0
func (l *NamespacesClientDeletePollerResponse) Resume(ctx context.Context, client *NamespacesClient, token string) error
Resume rehydrates a NamespacesClientDeletePollerResponse from the provided client and resume token.
type NamespacesClientDeleteResponse ¶ added in v0.3.0
type NamespacesClientDeleteResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientDeleteResponse contains the response from method NamespacesClient.Delete.
type NamespacesClientGetAuthorizationRuleOptions ¶ added in v0.3.0
type NamespacesClientGetAuthorizationRuleOptions struct { }
NamespacesClientGetAuthorizationRuleOptions contains the optional parameters for the NamespacesClient.GetAuthorizationRule method.
type NamespacesClientGetAuthorizationRuleResponse ¶ added in v0.3.0
type NamespacesClientGetAuthorizationRuleResponse struct { NamespacesClientGetAuthorizationRuleResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientGetAuthorizationRuleResponse contains the response from method NamespacesClient.GetAuthorizationRule.
type NamespacesClientGetAuthorizationRuleResult ¶ added in v0.3.0
type NamespacesClientGetAuthorizationRuleResult struct {
AuthorizationRule
}
NamespacesClientGetAuthorizationRuleResult contains the result from method NamespacesClient.GetAuthorizationRule.
type NamespacesClientGetNetworkRuleSetOptions ¶ added in v0.3.0
type NamespacesClientGetNetworkRuleSetOptions struct { }
NamespacesClientGetNetworkRuleSetOptions contains the optional parameters for the NamespacesClient.GetNetworkRuleSet method.
type NamespacesClientGetNetworkRuleSetResponse ¶ added in v0.3.0
type NamespacesClientGetNetworkRuleSetResponse struct { NamespacesClientGetNetworkRuleSetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientGetNetworkRuleSetResponse contains the response from method NamespacesClient.GetNetworkRuleSet.
type NamespacesClientGetNetworkRuleSetResult ¶ added in v0.3.0
type NamespacesClientGetNetworkRuleSetResult struct {
NetworkRuleSet
}
NamespacesClientGetNetworkRuleSetResult contains the result from method NamespacesClient.GetNetworkRuleSet.
type NamespacesClientGetOptions ¶ added in v0.3.0
type NamespacesClientGetOptions struct { }
NamespacesClientGetOptions contains the optional parameters for the NamespacesClient.Get method.
type NamespacesClientGetResponse ¶ added in v0.3.0
type NamespacesClientGetResponse struct { NamespacesClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientGetResponse contains the response from method NamespacesClient.Get.
type NamespacesClientGetResult ¶ added in v0.3.0
type NamespacesClientGetResult struct {
EHNamespace
}
NamespacesClientGetResult contains the result from method NamespacesClient.Get.
type NamespacesClientListAuthorizationRulesOptions ¶ added in v0.3.0
type NamespacesClientListAuthorizationRulesOptions struct { }
NamespacesClientListAuthorizationRulesOptions contains the optional parameters for the NamespacesClient.ListAuthorizationRules method.
type NamespacesClientListAuthorizationRulesPager ¶ added in v0.3.0
type NamespacesClientListAuthorizationRulesPager struct {
// contains filtered or unexported fields
}
NamespacesClientListAuthorizationRulesPager provides operations for iterating over paged responses.
func (*NamespacesClientListAuthorizationRulesPager) Err ¶ added in v0.3.0
func (p *NamespacesClientListAuthorizationRulesPager) Err() error
Err returns the last error encountered while paging.
func (*NamespacesClientListAuthorizationRulesPager) NextPage ¶ added in v0.3.0
func (p *NamespacesClientListAuthorizationRulesPager) 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 (*NamespacesClientListAuthorizationRulesPager) PageResponse ¶ added in v0.3.0
func (p *NamespacesClientListAuthorizationRulesPager) PageResponse() NamespacesClientListAuthorizationRulesResponse
PageResponse returns the current NamespacesClientListAuthorizationRulesResponse page.
type NamespacesClientListAuthorizationRulesResponse ¶ added in v0.3.0
type NamespacesClientListAuthorizationRulesResponse struct { NamespacesClientListAuthorizationRulesResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientListAuthorizationRulesResponse contains the response from method NamespacesClient.ListAuthorizationRules.
type NamespacesClientListAuthorizationRulesResult ¶ added in v0.3.0
type NamespacesClientListAuthorizationRulesResult struct {
AuthorizationRuleListResult
}
NamespacesClientListAuthorizationRulesResult contains the result from method NamespacesClient.ListAuthorizationRules.
type NamespacesClientListByResourceGroupOptions ¶ added in v0.3.0
type NamespacesClientListByResourceGroupOptions struct { }
NamespacesClientListByResourceGroupOptions contains the optional parameters for the NamespacesClient.ListByResourceGroup method.
type NamespacesClientListByResourceGroupPager ¶ added in v0.3.0
type NamespacesClientListByResourceGroupPager struct {
// contains filtered or unexported fields
}
NamespacesClientListByResourceGroupPager provides operations for iterating over paged responses.
func (*NamespacesClientListByResourceGroupPager) Err ¶ added in v0.3.0
func (p *NamespacesClientListByResourceGroupPager) Err() error
Err returns the last error encountered while paging.
func (*NamespacesClientListByResourceGroupPager) NextPage ¶ added in v0.3.0
func (p *NamespacesClientListByResourceGroupPager) 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 (*NamespacesClientListByResourceGroupPager) PageResponse ¶ added in v0.3.0
func (p *NamespacesClientListByResourceGroupPager) PageResponse() NamespacesClientListByResourceGroupResponse
PageResponse returns the current NamespacesClientListByResourceGroupResponse page.
type NamespacesClientListByResourceGroupResponse ¶ added in v0.3.0
type NamespacesClientListByResourceGroupResponse struct { NamespacesClientListByResourceGroupResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientListByResourceGroupResponse contains the response from method NamespacesClient.ListByResourceGroup.
type NamespacesClientListByResourceGroupResult ¶ added in v0.3.0
type NamespacesClientListByResourceGroupResult struct {
EHNamespaceListResult
}
NamespacesClientListByResourceGroupResult contains the result from method NamespacesClient.ListByResourceGroup.
type NamespacesClientListKeysOptions ¶ added in v0.3.0
type NamespacesClientListKeysOptions struct { }
NamespacesClientListKeysOptions contains the optional parameters for the NamespacesClient.ListKeys method.
type NamespacesClientListKeysResponse ¶ added in v0.3.0
type NamespacesClientListKeysResponse struct { NamespacesClientListKeysResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientListKeysResponse contains the response from method NamespacesClient.ListKeys.
type NamespacesClientListKeysResult ¶ added in v0.3.0
type NamespacesClientListKeysResult struct {
AccessKeys
}
NamespacesClientListKeysResult contains the result from method NamespacesClient.ListKeys.
type NamespacesClientListNetworkRuleSetOptions ¶ added in v0.3.0
type NamespacesClientListNetworkRuleSetOptions struct { }
NamespacesClientListNetworkRuleSetOptions contains the optional parameters for the NamespacesClient.ListNetworkRuleSet method.
type NamespacesClientListNetworkRuleSetResponse ¶ added in v0.3.0
type NamespacesClientListNetworkRuleSetResponse struct { NamespacesClientListNetworkRuleSetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientListNetworkRuleSetResponse contains the response from method NamespacesClient.ListNetworkRuleSet.
type NamespacesClientListNetworkRuleSetResult ¶ added in v0.3.0
type NamespacesClientListNetworkRuleSetResult struct {
NetworkRuleSetListResult
}
NamespacesClientListNetworkRuleSetResult contains the result from method NamespacesClient.ListNetworkRuleSet.
type NamespacesClientListOptions ¶ added in v0.3.0
type NamespacesClientListOptions struct { }
NamespacesClientListOptions contains the optional parameters for the NamespacesClient.List method.
type NamespacesClientListPager ¶ added in v0.3.0
type NamespacesClientListPager struct {
// contains filtered or unexported fields
}
NamespacesClientListPager provides operations for iterating over paged responses.
func (*NamespacesClientListPager) Err ¶ added in v0.3.0
func (p *NamespacesClientListPager) Err() error
Err returns the last error encountered while paging.
func (*NamespacesClientListPager) NextPage ¶ added in v0.3.0
func (p *NamespacesClientListPager) 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 (*NamespacesClientListPager) PageResponse ¶ added in v0.3.0
func (p *NamespacesClientListPager) PageResponse() NamespacesClientListResponse
PageResponse returns the current NamespacesClientListResponse page.
type NamespacesClientListResponse ¶ added in v0.3.0
type NamespacesClientListResponse struct { NamespacesClientListResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientListResponse contains the response from method NamespacesClient.List.
type NamespacesClientListResult ¶ added in v0.3.0
type NamespacesClientListResult struct {
EHNamespaceListResult
}
NamespacesClientListResult contains the result from method NamespacesClient.List.
type NamespacesClientRegenerateKeysOptions ¶ added in v0.3.0
type NamespacesClientRegenerateKeysOptions struct { }
NamespacesClientRegenerateKeysOptions contains the optional parameters for the NamespacesClient.RegenerateKeys method.
type NamespacesClientRegenerateKeysResponse ¶ added in v0.3.0
type NamespacesClientRegenerateKeysResponse struct { NamespacesClientRegenerateKeysResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientRegenerateKeysResponse contains the response from method NamespacesClient.RegenerateKeys.
type NamespacesClientRegenerateKeysResult ¶ added in v0.3.0
type NamespacesClientRegenerateKeysResult struct {
AccessKeys
}
NamespacesClientRegenerateKeysResult contains the result from method NamespacesClient.RegenerateKeys.
type NamespacesClientUpdateOptions ¶ added in v0.3.0
type NamespacesClientUpdateOptions struct { }
NamespacesClientUpdateOptions contains the optional parameters for the NamespacesClient.Update method.
type NamespacesClientUpdateResponse ¶ added in v0.3.0
type NamespacesClientUpdateResponse struct { NamespacesClientUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
NamespacesClientUpdateResponse contains the response from method NamespacesClient.Update.
type NamespacesClientUpdateResult ¶ added in v0.3.0
type NamespacesClientUpdateResult struct {
EHNamespace
}
NamespacesClientUpdateResult contains the result from method NamespacesClient.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 { // NetworkRuleSet properties Properties *NetworkRuleSetProperties `json:"properties,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
NetworkRuleSet - Description of topic resource.
type NetworkRuleSetListResult ¶ added in v0.2.0
type NetworkRuleSetListResult struct { // Link to the next set of results. Not empty if Value contains incomplete list of NetworkRuleSet. NextLink *string `json:"nextLink,omitempty"` // Result of the List NetworkRuleSet operation Value []*NetworkRuleSet `json:"value,omitempty"` }
NetworkRuleSetListResult - The response of the List NetworkRuleSet operation
func (NetworkRuleSetListResult) MarshalJSON ¶ added in v0.2.0
func (n NetworkRuleSetListResult) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type NetworkRuleSetListResult.
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 { // Display of the operation Display *OperationDisplay `json:"display,omitempty"` // Indicates whether the operation is a data action IsDataAction *bool `json:"isDataAction,omitempty"` // Origin of the operation Origin *string `json:"origin,omitempty"` // Properties of the operation Properties map[string]interface{} `json:"properties,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; Localized friendly description for the operation Description *string `json:"description,omitempty" azure:"ro"` // READ-ONLY; Localized friendly name for the operation Operation *string `json:"operation,omitempty" azure:"ro"` // READ-ONLY; Resource provider of the operation Provider *string `json:"provider,omitempty" azure:"ro"` // READ-ONLY; Resource of the operation Resource *string `json:"resource,omitempty" azure:"ro"` }
OperationDisplay - Operation display payload
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(credential azcore.TokenCredential, options *arm.ClientOptions) *OperationsClient
NewOperationsClient creates a new instance of OperationsClient with the specified values. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*OperationsClient) List ¶
func (client *OperationsClient) List(options *OperationsClientListOptions) *OperationsClientListPager
List - Lists all of the available Event Hub REST API operations. If the operation fails it returns an *azcore.ResponseError type. options - OperationsClientListOptions contains the optional parameters for the OperationsClient.List method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/EHOperations_List.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewOperationsClient(cred, nil) pager := client.List(nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
type OperationsClientListOptions ¶ added in v0.3.0
type OperationsClientListOptions struct { }
OperationsClientListOptions contains the optional parameters for the OperationsClient.List method.
type OperationsClientListPager ¶ added in v0.3.0
type OperationsClientListPager struct {
// contains filtered or unexported fields
}
OperationsClientListPager provides operations for iterating over paged responses.
func (*OperationsClientListPager) Err ¶ added in v0.3.0
func (p *OperationsClientListPager) Err() error
Err returns the last error encountered while paging.
func (*OperationsClientListPager) NextPage ¶ added in v0.3.0
func (p *OperationsClientListPager) 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 (*OperationsClientListPager) PageResponse ¶ added in v0.3.0
func (p *OperationsClientListPager) PageResponse() OperationsClientListResponse
PageResponse returns the current OperationsClientListResponse page.
type OperationsClientListResponse ¶ added in v0.3.0
type OperationsClientListResponse struct { OperationsClientListResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
OperationsClientListResponse contains the response from method OperationsClient.List.
type OperationsClientListResult ¶ added in v0.3.0
type OperationsClientListResult struct {
OperationListResult
}
OperationsClientListResult contains the result from method OperationsClient.List.
type PrivateEndpoint ¶
type PrivateEndpoint struct { // The ARM identifier for Private Endpoint. ID *string `json:"id,omitempty"` }
PrivateEndpoint information.
type PrivateEndpointConnection ¶
type PrivateEndpointConnection struct { // Properties of the PrivateEndpointConnection. Properties *PrivateEndpointConnectionProperties `json:"properties,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
PrivateEndpointConnection - Properties of the 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 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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *PrivateEndpointConnectionsClient
NewPrivateEndpointConnectionsClient creates a new instance of PrivateEndpointConnectionsClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*PrivateEndpointConnectionsClient) BeginDelete ¶
func (client *PrivateEndpointConnectionsClient) BeginDelete(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsClientBeginDeleteOptions) (PrivateEndpointConnectionsClientDeletePollerResponse, error)
BeginDelete - Deletes an existing namespace. This operation also removes all associated resources under the namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name privateEndpointConnectionName - The PrivateEndpointConnection name options - PrivateEndpointConnectionsClientBeginDeleteOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginDelete method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/PrivateEndPointConnectionDelete.json
package main import ( "context" "log" "time" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil) poller, err := client.BeginDelete(ctx, "<resource-group-name>", "<namespace-name>", "<private-endpoint-connection-name>", nil) if err != nil { log.Fatal(err) } _, err = poller.PollUntilDone(ctx, 30*time.Second) if err != nil { log.Fatal(err) } }
Output:
func (*PrivateEndpointConnectionsClient) CreateOrUpdate ¶
func (client *PrivateEndpointConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection, options *PrivateEndpointConnectionsClientCreateOrUpdateOptions) (PrivateEndpointConnectionsClientCreateOrUpdateResponse, error)
CreateOrUpdate - Creates or updates PrivateEndpointConnections of service namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name privateEndpointConnectionName - The PrivateEndpointConnection name parameters - Parameters supplied to update Status of PrivateEndPoint Connection to namespace resource. options - PrivateEndpointConnectionsClientCreateOrUpdateOptions contains the optional parameters for the PrivateEndpointConnectionsClient.CreateOrUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/PrivateEndPointConnectionCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdate(ctx, "<resource-group-name>", "<namespace-name>", "<private-endpoint-connection-name>", armeventhub.PrivateEndpointConnection{ Properties: &armeventhub.PrivateEndpointConnectionProperties{ PrivateEndpoint: &armeventhub.PrivateEndpoint{ ID: to.StringPtr("<id>"), }, PrivateLinkServiceConnectionState: &armeventhub.ConnectionState{ Description: to.StringPtr("<description>"), Status: armeventhub.PrivateLinkConnectionStatus("Rejected").ToPtr(), }, ProvisioningState: armeventhub.EndPointProvisioningState("Succeeded").ToPtr(), }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.PrivateEndpointConnectionsClientCreateOrUpdateResult) }
Output:
func (*PrivateEndpointConnectionsClient) Get ¶
func (client *PrivateEndpointConnectionsClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsClientGetOptions) (PrivateEndpointConnectionsClientGetResponse, error)
Get - Gets a description for the specified Private Endpoint Connection name. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name privateEndpointConnectionName - The PrivateEndpointConnection name options - PrivateEndpointConnectionsClientGetOptions contains the optional parameters for the PrivateEndpointConnectionsClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/PrivateEndPointConnectionGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<namespace-name>", "<private-endpoint-connection-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.PrivateEndpointConnectionsClientGetResult) }
Output:
func (*PrivateEndpointConnectionsClient) List ¶
func (client *PrivateEndpointConnectionsClient) List(resourceGroupName string, namespaceName string, options *PrivateEndpointConnectionsClientListOptions) *PrivateEndpointConnectionsClientListPager
List - Gets the available PrivateEndpointConnections within a namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - PrivateEndpointConnectionsClientListOptions contains the optional parameters for the PrivateEndpointConnectionsClient.List method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/PrivateEndPointConnectionList.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewPrivateEndpointConnectionsClient("<subscription-id>", cred, nil) pager := client.List("<resource-group-name>", "<namespace-name>", nil) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
type PrivateEndpointConnectionsClientBeginDeleteOptions ¶ added in v0.3.0
type PrivateEndpointConnectionsClientBeginDeleteOptions struct { }
PrivateEndpointConnectionsClientBeginDeleteOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginDelete method.
type PrivateEndpointConnectionsClientCreateOrUpdateOptions ¶ added in v0.3.0
type PrivateEndpointConnectionsClientCreateOrUpdateOptions struct { }
PrivateEndpointConnectionsClientCreateOrUpdateOptions contains the optional parameters for the PrivateEndpointConnectionsClient.CreateOrUpdate method.
type PrivateEndpointConnectionsClientCreateOrUpdateResponse ¶ added in v0.3.0
type PrivateEndpointConnectionsClientCreateOrUpdateResponse struct { PrivateEndpointConnectionsClientCreateOrUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
PrivateEndpointConnectionsClientCreateOrUpdateResponse contains the response from method PrivateEndpointConnectionsClient.CreateOrUpdate.
type PrivateEndpointConnectionsClientCreateOrUpdateResult ¶ added in v0.3.0
type PrivateEndpointConnectionsClientCreateOrUpdateResult struct {
PrivateEndpointConnection
}
PrivateEndpointConnectionsClientCreateOrUpdateResult contains the result from method PrivateEndpointConnectionsClient.CreateOrUpdate.
type PrivateEndpointConnectionsClientDeletePoller ¶ added in v0.3.0
type PrivateEndpointConnectionsClientDeletePoller struct {
// contains filtered or unexported fields
}
PrivateEndpointConnectionsClientDeletePoller provides polling facilities until the operation reaches a terminal state.
func (*PrivateEndpointConnectionsClientDeletePoller) Done ¶ added in v0.3.0
func (p *PrivateEndpointConnectionsClientDeletePoller) Done() bool
Done returns true if the LRO has reached a terminal state.
func (*PrivateEndpointConnectionsClientDeletePoller) FinalResponse ¶ added in v0.3.0
func (p *PrivateEndpointConnectionsClientDeletePoller) FinalResponse(ctx context.Context) (PrivateEndpointConnectionsClientDeleteResponse, 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 PrivateEndpointConnectionsClientDeleteResponse will be returned.
func (*PrivateEndpointConnectionsClientDeletePoller) Poll ¶ added in v0.3.0
func (p *PrivateEndpointConnectionsClientDeletePoller) 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 (*PrivateEndpointConnectionsClientDeletePoller) ResumeToken ¶ added in v0.3.0
func (p *PrivateEndpointConnectionsClientDeletePoller) 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 PrivateEndpointConnectionsClientDeletePollerResponse ¶ added in v0.3.0
type PrivateEndpointConnectionsClientDeletePollerResponse struct { // Poller contains an initialized poller. Poller *PrivateEndpointConnectionsClientDeletePoller // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
PrivateEndpointConnectionsClientDeletePollerResponse contains the response from method PrivateEndpointConnectionsClient.Delete.
func (PrivateEndpointConnectionsClientDeletePollerResponse) PollUntilDone ¶ added in v0.3.0
func (l PrivateEndpointConnectionsClientDeletePollerResponse) PollUntilDone(ctx context.Context, freq time.Duration) (PrivateEndpointConnectionsClientDeleteResponse, error)
PollUntilDone will poll the service endpoint until a terminal state is reached or an error is received. freq: the time to wait between intervals in absence of a Retry-After header. Allowed minimum is one second. A good starting value is 30 seconds. Note that some resources might benefit from a different value.
func (*PrivateEndpointConnectionsClientDeletePollerResponse) Resume ¶ added in v0.3.0
func (l *PrivateEndpointConnectionsClientDeletePollerResponse) Resume(ctx context.Context, client *PrivateEndpointConnectionsClient, token string) error
Resume rehydrates a PrivateEndpointConnectionsClientDeletePollerResponse from the provided client and resume token.
type PrivateEndpointConnectionsClientDeleteResponse ¶ added in v0.3.0
type PrivateEndpointConnectionsClientDeleteResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
PrivateEndpointConnectionsClientDeleteResponse contains the response from method PrivateEndpointConnectionsClient.Delete.
type PrivateEndpointConnectionsClientGetOptions ¶ added in v0.3.0
type PrivateEndpointConnectionsClientGetOptions struct { }
PrivateEndpointConnectionsClientGetOptions contains the optional parameters for the PrivateEndpointConnectionsClient.Get method.
type PrivateEndpointConnectionsClientGetResponse ¶ added in v0.3.0
type PrivateEndpointConnectionsClientGetResponse struct { PrivateEndpointConnectionsClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
PrivateEndpointConnectionsClientGetResponse contains the response from method PrivateEndpointConnectionsClient.Get.
type PrivateEndpointConnectionsClientGetResult ¶ added in v0.3.0
type PrivateEndpointConnectionsClientGetResult struct {
PrivateEndpointConnection
}
PrivateEndpointConnectionsClientGetResult contains the result from method PrivateEndpointConnectionsClient.Get.
type PrivateEndpointConnectionsClientListOptions ¶ added in v0.3.0
type PrivateEndpointConnectionsClientListOptions struct { }
PrivateEndpointConnectionsClientListOptions contains the optional parameters for the PrivateEndpointConnectionsClient.List method.
type PrivateEndpointConnectionsClientListPager ¶ added in v0.3.0
type PrivateEndpointConnectionsClientListPager struct {
// contains filtered or unexported fields
}
PrivateEndpointConnectionsClientListPager provides operations for iterating over paged responses.
func (*PrivateEndpointConnectionsClientListPager) Err ¶ added in v0.3.0
func (p *PrivateEndpointConnectionsClientListPager) Err() error
Err returns the last error encountered while paging.
func (*PrivateEndpointConnectionsClientListPager) NextPage ¶ added in v0.3.0
func (p *PrivateEndpointConnectionsClientListPager) 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 (*PrivateEndpointConnectionsClientListPager) PageResponse ¶ added in v0.3.0
func (p *PrivateEndpointConnectionsClientListPager) PageResponse() PrivateEndpointConnectionsClientListResponse
PageResponse returns the current PrivateEndpointConnectionsClientListResponse page.
type PrivateEndpointConnectionsClientListResponse ¶ added in v0.3.0
type PrivateEndpointConnectionsClientListResponse struct { PrivateEndpointConnectionsClientListResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
PrivateEndpointConnectionsClientListResponse contains the response from method PrivateEndpointConnectionsClient.List.
type PrivateEndpointConnectionsClientListResult ¶ added in v0.3.0
type PrivateEndpointConnectionsClientListResult struct {
PrivateEndpointConnectionListResult
}
PrivateEndpointConnectionsClientListResult contains the result from method PrivateEndpointConnectionsClient.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(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *PrivateLinkResourcesClient
NewPrivateLinkResourcesClient creates a new instance of PrivateLinkResourcesClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*PrivateLinkResourcesClient) Get ¶
func (client *PrivateLinkResourcesClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, options *PrivateLinkResourcesClientGetOptions) (PrivateLinkResourcesClientGetResponse, error)
Get - Gets lists of resources that supports Privatelinks. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - PrivateLinkResourcesClientGetOptions contains the optional parameters for the PrivateLinkResourcesClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/NameSpaces/PrivateLinkResourcesGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewPrivateLinkResourcesClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<namespace-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.PrivateLinkResourcesClientGetResult) }
Output:
type PrivateLinkResourcesClientGetOptions ¶ added in v0.3.0
type PrivateLinkResourcesClientGetOptions struct { }
PrivateLinkResourcesClientGetOptions contains the optional parameters for the PrivateLinkResourcesClient.Get method.
type PrivateLinkResourcesClientGetResponse ¶ added in v0.3.0
type PrivateLinkResourcesClientGetResponse struct { PrivateLinkResourcesClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
PrivateLinkResourcesClientGetResponse contains the response from method PrivateLinkResourcesClient.Get.
type PrivateLinkResourcesClientGetResult ¶ added in v0.3.0
type PrivateLinkResourcesClientGetResult struct {
PrivateLinkResourcesListResult
}
PrivateLinkResourcesClientGetResult contains the result from method PrivateLinkResourcesClient.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 Properties ¶ added in v0.3.0
type Properties 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"` }
Properties supplied to the Create Or Update Event Hub operation.
func (Properties) MarshalJSON ¶ added in v0.3.0
func (p Properties) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type Properties.
func (*Properties) UnmarshalJSON ¶ added in v0.3.0
func (p *Properties) UnmarshalJSON(data []byte) error
UnmarshalJSON implements the json.Unmarshaller interface for type Properties.
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 ProxyResource ¶ added in v0.2.0
type ProxyResource struct { // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
ProxyResource - Common fields that are returned in the response for all Azure Resource Manager resources
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; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty" azure:"ro"` }
Resource - Common fields that are returned in the response for all Azure Resource Manager resources
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.
func PossibleSKUNameValues ¶
func PossibleSKUNameValues() []SKUName
PossibleSKUNameValues returns the possible values for the SKUName const type.
type SKUTier ¶
type SKUTier string
SKUTier - The billing tier of this particular SKU.
func PossibleSKUTierValues ¶
func PossibleSKUTierValues() []SKUTier
PossibleSKUTierValues returns the possible values for the SKUTier const type.
type SchemaCompatibility ¶ added in v0.2.0
type SchemaCompatibility string
const ( SchemaCompatibilityBackward SchemaCompatibility = "Backward" SchemaCompatibilityForward SchemaCompatibility = "Forward" SchemaCompatibilityNone SchemaCompatibility = "None" )
func PossibleSchemaCompatibilityValues ¶ added in v0.2.0
func PossibleSchemaCompatibilityValues() []SchemaCompatibility
PossibleSchemaCompatibilityValues returns the possible values for the SchemaCompatibility const type.
func (SchemaCompatibility) ToPtr ¶ added in v0.2.0
func (c SchemaCompatibility) ToPtr() *SchemaCompatibility
ToPtr returns a *SchemaCompatibility pointing to the current value.
type SchemaGroup ¶ added in v0.2.0
type SchemaGroup struct { Properties *SchemaGroupProperties `json:"properties,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The geo-location where the resource lives Location *string `json:"location,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The system meta data relating to this resource. SystemData *SystemData `json:"systemData,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.EventHub/Namespaces" or "Microsoft.EventHub/Namespaces/EventHubs" Type *string `json:"type,omitempty" azure:"ro"` }
SchemaGroup - Single item in List or Get Schema Group operation
type SchemaGroupListResult ¶ added in v0.2.0
type SchemaGroupListResult struct { // Link to the next set of results. Not empty if Value contains incomplete list of Schema Groups. NextLink *string `json:"nextLink,omitempty"` // Result of the List SchemaGroups operation. Value []*SchemaGroup `json:"value,omitempty"` }
SchemaGroupListResult - The result of the List SchemaGroup operation.
func (SchemaGroupListResult) MarshalJSON ¶ added in v0.2.0
func (s SchemaGroupListResult) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type SchemaGroupListResult.
type SchemaGroupProperties ¶ added in v0.2.0
type SchemaGroupProperties struct { // dictionary object for SchemaGroup group properties GroupProperties map[string]*string `json:"groupProperties,omitempty"` SchemaCompatibility *SchemaCompatibility `json:"schemaCompatibility,omitempty"` SchemaType *SchemaType `json:"schemaType,omitempty"` // READ-ONLY; Exact time the Schema Group was created. CreatedAtUTC *time.Time `json:"createdAtUtc,omitempty" azure:"ro"` // READ-ONLY; The ETag value. ETag *string `json:"eTag,omitempty" azure:"ro"` // READ-ONLY; Exact time the Schema Group was updated UpdatedAtUTC *time.Time `json:"updatedAtUtc,omitempty" azure:"ro"` }
func (SchemaGroupProperties) MarshalJSON ¶ added in v0.2.0
func (s SchemaGroupProperties) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type SchemaGroupProperties.
func (*SchemaGroupProperties) UnmarshalJSON ¶ added in v0.2.0
func (s *SchemaGroupProperties) UnmarshalJSON(data []byte) error
UnmarshalJSON implements the json.Unmarshaller interface for type SchemaGroupProperties.
type SchemaRegistryClient ¶ added in v0.2.0
type SchemaRegistryClient struct {
// contains filtered or unexported fields
}
SchemaRegistryClient contains the methods for the SchemaRegistry group. Don't use this type directly, use NewSchemaRegistryClient() instead.
func NewSchemaRegistryClient ¶ added in v0.2.0
func NewSchemaRegistryClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) *SchemaRegistryClient
NewSchemaRegistryClient creates a new instance of SchemaRegistryClient with the specified values. subscriptionID - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*SchemaRegistryClient) CreateOrUpdate ¶ added in v0.2.0
func (client *SchemaRegistryClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, namespaceName string, schemaGroupName string, parameters SchemaGroup, options *SchemaRegistryClientCreateOrUpdateOptions) (SchemaRegistryClientCreateOrUpdateResponse, error)
CreateOrUpdate - If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name schemaGroupName - The Schema Group name parameters - Parameters supplied to create an Event Hub resource. options - SchemaRegistryClientCreateOrUpdateOptions contains the optional parameters for the SchemaRegistryClient.CreateOrUpdate method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/SchemaRegistry/SchemaRegistryCreate.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewSchemaRegistryClient("<subscription-id>", cred, nil) res, err := client.CreateOrUpdate(ctx, "<resource-group-name>", "<namespace-name>", "<schema-group-name>", armeventhub.SchemaGroup{ Properties: &armeventhub.SchemaGroupProperties{ GroupProperties: map[string]*string{}, SchemaCompatibility: armeventhub.SchemaCompatibility("Forward").ToPtr(), SchemaType: armeventhub.SchemaType("Avro").ToPtr(), }, }, nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.SchemaRegistryClientCreateOrUpdateResult) }
Output:
func (*SchemaRegistryClient) Delete ¶ added in v0.2.0
func (client *SchemaRegistryClient) Delete(ctx context.Context, resourceGroupName string, namespaceName string, schemaGroupName string, options *SchemaRegistryClientDeleteOptions) (SchemaRegistryClientDeleteResponse, error)
Delete - If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name schemaGroupName - The Schema Group name options - SchemaRegistryClientDeleteOptions contains the optional parameters for the SchemaRegistryClient.Delete method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/SchemaRegistry/SchemaRegistryDelete.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewSchemaRegistryClient("<subscription-id>", cred, nil) _, err = client.Delete(ctx, "<resource-group-name>", "<namespace-name>", "<schema-group-name>", nil) if err != nil { log.Fatal(err) } }
Output:
func (*SchemaRegistryClient) Get ¶ added in v0.2.0
func (client *SchemaRegistryClient) Get(ctx context.Context, resourceGroupName string, namespaceName string, schemaGroupName string, options *SchemaRegistryClientGetOptions) (SchemaRegistryClientGetResponse, error)
Get - If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name schemaGroupName - The Schema Group name options - SchemaRegistryClientGetOptions contains the optional parameters for the SchemaRegistryClient.Get method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/SchemaRegistry/SchemaRegistryGet.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewSchemaRegistryClient("<subscription-id>", cred, nil) res, err := client.Get(ctx, "<resource-group-name>", "<namespace-name>", "<schema-group-name>", nil) if err != nil { log.Fatal(err) } log.Printf("Response result: %#v\n", res.SchemaRegistryClientGetResult) }
Output:
func (*SchemaRegistryClient) ListByNamespace ¶ added in v0.2.0
func (client *SchemaRegistryClient) ListByNamespace(resourceGroupName string, namespaceName string, options *SchemaRegistryClientListByNamespaceOptions) *SchemaRegistryClientListByNamespacePager
ListByNamespace - Gets all the Schema Groups in a Namespace. If the operation fails it returns an *azcore.ResponseError type. resourceGroupName - Name of the resource group within the azure subscription. namespaceName - The Namespace name options - SchemaRegistryClientListByNamespaceOptions contains the optional parameters for the SchemaRegistryClient.ListByNamespace method.
Example ¶
x-ms-original-file: specification/eventhub/resource-manager/Microsoft.EventHub/stable/2021-11-01/examples/SchemaRegistry/SchemaRegistryListByNamespace.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client := armeventhub.NewSchemaRegistryClient("<subscription-id>", cred, nil) pager := client.ListByNamespace("<resource-group-name>", "<namespace-name>", &armeventhub.SchemaRegistryClientListByNamespaceOptions{Skip: nil, Top: nil, }) for { nextResult := pager.NextPage(ctx) if err := pager.Err(); err != nil { log.Fatalf("failed to advance page: %v", err) } if !nextResult { break } for _, v := range pager.PageResponse().Value { log.Printf("Pager result: %#v\n", v) } } }
Output:
type SchemaRegistryClientCreateOrUpdateOptions ¶ added in v0.3.0
type SchemaRegistryClientCreateOrUpdateOptions struct { }
SchemaRegistryClientCreateOrUpdateOptions contains the optional parameters for the SchemaRegistryClient.CreateOrUpdate method.
type SchemaRegistryClientCreateOrUpdateResponse ¶ added in v0.3.0
type SchemaRegistryClientCreateOrUpdateResponse struct { SchemaRegistryClientCreateOrUpdateResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
SchemaRegistryClientCreateOrUpdateResponse contains the response from method SchemaRegistryClient.CreateOrUpdate.
type SchemaRegistryClientCreateOrUpdateResult ¶ added in v0.3.0
type SchemaRegistryClientCreateOrUpdateResult struct {
SchemaGroup
}
SchemaRegistryClientCreateOrUpdateResult contains the result from method SchemaRegistryClient.CreateOrUpdate.
type SchemaRegistryClientDeleteOptions ¶ added in v0.3.0
type SchemaRegistryClientDeleteOptions struct { }
SchemaRegistryClientDeleteOptions contains the optional parameters for the SchemaRegistryClient.Delete method.
type SchemaRegistryClientDeleteResponse ¶ added in v0.3.0
type SchemaRegistryClientDeleteResponse struct { // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
SchemaRegistryClientDeleteResponse contains the response from method SchemaRegistryClient.Delete.
type SchemaRegistryClientGetOptions ¶ added in v0.3.0
type SchemaRegistryClientGetOptions struct { }
SchemaRegistryClientGetOptions contains the optional parameters for the SchemaRegistryClient.Get method.
type SchemaRegistryClientGetResponse ¶ added in v0.3.0
type SchemaRegistryClientGetResponse struct { SchemaRegistryClientGetResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
SchemaRegistryClientGetResponse contains the response from method SchemaRegistryClient.Get.
type SchemaRegistryClientGetResult ¶ added in v0.3.0
type SchemaRegistryClientGetResult struct {
SchemaGroup
}
SchemaRegistryClientGetResult contains the result from method SchemaRegistryClient.Get.
type SchemaRegistryClientListByNamespaceOptions ¶ added in v0.3.0
type SchemaRegistryClientListByNamespaceOptions 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 }
SchemaRegistryClientListByNamespaceOptions contains the optional parameters for the SchemaRegistryClient.ListByNamespace method.
type SchemaRegistryClientListByNamespacePager ¶ added in v0.3.0
type SchemaRegistryClientListByNamespacePager struct {
// contains filtered or unexported fields
}
SchemaRegistryClientListByNamespacePager provides operations for iterating over paged responses.
func (*SchemaRegistryClientListByNamespacePager) Err ¶ added in v0.3.0
func (p *SchemaRegistryClientListByNamespacePager) Err() error
Err returns the last error encountered while paging.
func (*SchemaRegistryClientListByNamespacePager) NextPage ¶ added in v0.3.0
func (p *SchemaRegistryClientListByNamespacePager) 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 (*SchemaRegistryClientListByNamespacePager) PageResponse ¶ added in v0.3.0
func (p *SchemaRegistryClientListByNamespacePager) PageResponse() SchemaRegistryClientListByNamespaceResponse
PageResponse returns the current SchemaRegistryClientListByNamespaceResponse page.
type SchemaRegistryClientListByNamespaceResponse ¶ added in v0.3.0
type SchemaRegistryClientListByNamespaceResponse struct { SchemaRegistryClientListByNamespaceResult // RawResponse contains the underlying HTTP response. RawResponse *http.Response }
SchemaRegistryClientListByNamespaceResponse contains the response from method SchemaRegistryClient.ListByNamespace.
type SchemaRegistryClientListByNamespaceResult ¶ added in v0.3.0
type SchemaRegistryClientListByNamespaceResult struct {
SchemaGroupListResult
}
SchemaRegistryClientListByNamespaceResult contains the result from method SchemaRegistryClient.ListByNamespace.
type SchemaType ¶ added in v0.2.0
type SchemaType string
const ( SchemaTypeAvro SchemaType = "Avro" SchemaTypeUnknown SchemaType = "Unknown" )
func PossibleSchemaTypeValues ¶ added in v0.2.0
func PossibleSchemaTypeValues() []SchemaType
PossibleSchemaTypeValues returns the possible values for the SchemaType const type.
func (SchemaType) ToPtr ¶ added in v0.2.0
func (c SchemaType) ToPtr() *SchemaType
ToPtr returns a *SchemaType 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 location. Location *string `json:"location,omitempty"` // Resource tags. Tags map[string]*string `json:"tags,omitempty"` // READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The name of the resource Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty" azure:"ro"` }
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 ()
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 ¶
- build.go
- zz_generated_clusters_client.go
- zz_generated_configuration_client.go
- zz_generated_constants.go
- zz_generated_consumergroups_client.go
- zz_generated_disasterrecoveryconfigs_client.go
- zz_generated_eventhubs_client.go
- zz_generated_models.go
- zz_generated_namespaces_client.go
- zz_generated_operations_client.go
- zz_generated_pagers.go
- zz_generated_pollers.go
- zz_generated_privateendpointconnections_client.go
- zz_generated_privatelinkresources_client.go
- zz_generated_response_types.go
- zz_generated_schemaregistry_client.go
- zz_generated_time_rfc3339.go