Versions in this module Expand all Collapse all v0 v0.20241126.2320 Nov 26, 2024 v0.20241126.1723 Nov 26, 2024 Changes in this version + func PossibleValuesForDataResidencyBoundary() []string + func PossibleValuesForEventDefinitionKind() []string + func PossibleValuesForIPActionType() []string + func PossibleValuesForInputSchema() []string + func PossibleValuesForInputSchemaMappingType() []string + func PossibleValuesForPersistedConnectionStatus() []string + func PossibleValuesForPublicNetworkAccess() []string + func PossibleValuesForResourceKind() []string + func PossibleValuesForResourceProvisioningState() []string + func PossibleValuesForSku() []string + func PossibleValuesForTlsVersion() []string + func PossibleValuesForTopicProvisioningState() []string + func ValidateTopicID(input interface{}, key string) (warnings []string, errors []error) + type BaseInputSchemaMappingImpl struct + InputSchemaMappingType InputSchemaMappingType + func (s BaseInputSchemaMappingImpl) InputSchemaMapping() BaseInputSchemaMappingImpl + type ConnectionState struct + ActionsRequired *string + Description *string + Status *PersistedConnectionStatus + type CreateOrUpdateOperationResponse struct + HttpResponse *http.Response + Model *Topic + OData *odata.OData + Poller pollers.Poller + type DataResidencyBoundary string + const DataResidencyBoundaryWithinGeopair + const DataResidencyBoundaryWithinRegion + func (s *DataResidencyBoundary) UnmarshalJSON(bytes []byte) error + type DeleteOperationResponse struct + HttpResponse *http.Response + OData *odata.OData + Poller pollers.Poller + type EventDefinitionKind string + const EventDefinitionKindInline + func (s *EventDefinitionKind) UnmarshalJSON(bytes []byte) error + type EventType struct + Id *string + Name *string + Properties *EventTypeProperties + Type *string + type EventTypeInfo struct + InlineEventTypes *map[string]InlineEventProperties + Kind *EventDefinitionKind + type EventTypeProperties struct + Description *string + DisplayName *string + IsInDefaultSet *bool + SchemaURL *string + type EventTypesListResult struct + Value *[]EventType + type ExtendedLocation struct + Name *string + Type *string + type ExtensionTopic struct + Id *string + Name *string + Properties *ExtensionTopicProperties + SystemData *systemdata.SystemData + Type *string + type ExtensionTopicProperties struct + Description *string + SystemTopic *string + type ExtensionTopicsGetOperationResponse struct + HttpResponse *http.Response + Model *ExtensionTopic + OData *odata.OData + type GetOperationResponse struct + HttpResponse *http.Response + Model *Topic + OData *odata.OData + type IPActionType string + const IPActionTypeAllow + func (s *IPActionType) UnmarshalJSON(bytes []byte) error + type InboundIPRule struct + Action *IPActionType + IPMask *string + type InlineEventProperties struct + DataSchemaURL *string + Description *string + DisplayName *string + DocumentationURL *string + type InputSchema string + const InputSchemaCloudEventSchemaVOneZero + const InputSchemaCustomEventSchema + const InputSchemaEventGridSchema + func (s *InputSchema) UnmarshalJSON(bytes []byte) error + type InputSchemaMapping interface + InputSchemaMapping func() BaseInputSchemaMappingImpl + func UnmarshalInputSchemaMappingImplementation(input []byte) (InputSchemaMapping, error) + type InputSchemaMappingType string + const InputSchemaMappingTypeJson + func (s *InputSchemaMappingType) UnmarshalJSON(bytes []byte) error + type JsonField struct + SourceField *string + type JsonFieldWithDefault struct + DefaultValue *string + SourceField *string + type JsonInputSchemaMapping struct + InputSchemaMappingType InputSchemaMappingType + Properties *JsonInputSchemaMappingProperties + func (s JsonInputSchemaMapping) InputSchemaMapping() BaseInputSchemaMappingImpl + func (s JsonInputSchemaMapping) MarshalJSON() ([]byte, error) + type JsonInputSchemaMappingProperties struct + DataVersion *JsonFieldWithDefault + EventTime *JsonField + EventType *JsonFieldWithDefault + Id *JsonField + Subject *JsonFieldWithDefault + Topic *JsonField + type ListByResourceGroupCompleteResult struct + Items []Topic + LatestHttpResponse *http.Response + type ListByResourceGroupCustomPager struct + NextLink *odata.Link + func (p *ListByResourceGroupCustomPager) NextPageLink() *odata.Link + type ListByResourceGroupOperationOptions struct + Filter *string + Top *int64 + func DefaultListByResourceGroupOperationOptions() ListByResourceGroupOperationOptions + func (o ListByResourceGroupOperationOptions) ToHeaders() *client.Headers + func (o ListByResourceGroupOperationOptions) ToOData() *odata.Query + func (o ListByResourceGroupOperationOptions) ToQuery() *client.QueryParams + type ListByResourceGroupOperationResponse struct + HttpResponse *http.Response + Model *[]Topic + OData *odata.OData + type ListBySubscriptionCompleteResult struct + Items []Topic + LatestHttpResponse *http.Response + type ListBySubscriptionCustomPager struct + NextLink *odata.Link + func (p *ListBySubscriptionCustomPager) NextPageLink() *odata.Link + type ListBySubscriptionOperationOptions struct + Filter *string + Top *int64 + func DefaultListBySubscriptionOperationOptions() ListBySubscriptionOperationOptions + func (o ListBySubscriptionOperationOptions) ToHeaders() *client.Headers + func (o ListBySubscriptionOperationOptions) ToOData() *odata.Query + func (o ListBySubscriptionOperationOptions) ToQuery() *client.QueryParams + type ListBySubscriptionOperationResponse struct + HttpResponse *http.Response + Model *[]Topic + OData *odata.OData + type ListEventTypesOperationResponse struct + HttpResponse *http.Response + Model *EventTypesListResult + OData *odata.OData + type ListSharedAccessKeysOperationResponse struct + HttpResponse *http.Response + Model *TopicSharedAccessKeys + OData *odata.OData + type PersistedConnectionStatus string + const PersistedConnectionStatusApproved + const PersistedConnectionStatusDisconnected + const PersistedConnectionStatusPending + const PersistedConnectionStatusRejected + func (s *PersistedConnectionStatus) UnmarshalJSON(bytes []byte) error + type PrivateEndpoint struct + Id *string + type PrivateEndpointConnection struct + Id *string + Name *string + Properties *PrivateEndpointConnectionProperties + Type *string + type PrivateEndpointConnectionProperties struct + GroupIds *[]string + PrivateEndpoint *PrivateEndpoint + PrivateLinkServiceConnectionState *ConnectionState + ProvisioningState *ResourceProvisioningState + type PublicNetworkAccess string + const PublicNetworkAccessDisabled + const PublicNetworkAccessEnabled + const PublicNetworkAccessSecuredByPerimeter + func (s *PublicNetworkAccess) UnmarshalJSON(bytes []byte) error + type RawInputSchemaMappingImpl struct + Type string + Values map[string]interface{} + func (s RawInputSchemaMappingImpl) InputSchemaMapping() BaseInputSchemaMappingImpl + type RegenerateKeyOperationResponse struct + HttpResponse *http.Response + Model *TopicSharedAccessKeys + OData *odata.OData + Poller pollers.Poller + type ResourceKind string + const ResourceKindAzure + const ResourceKindAzureArc + func (s *ResourceKind) UnmarshalJSON(bytes []byte) error + type ResourceProvisioningState string + const ResourceProvisioningStateCanceled + const ResourceProvisioningStateCreating + const ResourceProvisioningStateDeleting + const ResourceProvisioningStateFailed + const ResourceProvisioningStateSucceeded + const ResourceProvisioningStateUpdating + func (s *ResourceProvisioningState) UnmarshalJSON(bytes []byte) error + type ResourceSku struct + Name *Sku + type Sku string + const SkuBasic + const SkuPremium + func (s *Sku) UnmarshalJSON(bytes []byte) error + type TlsVersion string + const TlsVersionOnePointOne + const TlsVersionOnePointTwo + const TlsVersionOnePointZero + func (s *TlsVersion) UnmarshalJSON(bytes []byte) error + type Topic struct + ExtendedLocation *ExtendedLocation + Id *string + Identity *identity.SystemAndUserAssignedMap + Kind *ResourceKind + Location string + Name *string + Properties *TopicProperties + Sku *ResourceSku + SystemData *systemdata.SystemData + Tags *map[string]string + Type *string + type TopicId struct + ResourceGroupName string + SubscriptionId string + TopicName string + func NewTopicID(subscriptionId string, resourceGroupName string, topicName string) TopicId + func ParseTopicID(input string) (*TopicId, error) + func ParseTopicIDInsensitively(input string) (*TopicId, error) + func (id *TopicId) FromParseResult(input resourceids.ParseResult) error + func (id TopicId) ID() string + func (id TopicId) Segments() []resourceids.Segment + func (id TopicId) String() string + type TopicOperationPredicate struct + Id *string + Location *string + Name *string + Type *string + func (p TopicOperationPredicate) Matches(input Topic) bool + type TopicProperties struct + DataResidencyBoundary *DataResidencyBoundary + DisableLocalAuth *bool + Endpoint *string + EventTypeInfo *EventTypeInfo + InboundIPRules *[]InboundIPRule + InputSchema *InputSchema + InputSchemaMapping InputSchemaMapping + MetricResourceId *string + MinimumTlsVersionAllowed *TlsVersion + PrivateEndpointConnections *[]PrivateEndpointConnection + ProvisioningState *TopicProvisioningState + PublicNetworkAccess *PublicNetworkAccess + func (s *TopicProperties) UnmarshalJSON(bytes []byte) error + type TopicProvisioningState string + const TopicProvisioningStateCanceled + const TopicProvisioningStateCreating + const TopicProvisioningStateDeleting + const TopicProvisioningStateFailed + const TopicProvisioningStateSucceeded + const TopicProvisioningStateUpdating + func (s *TopicProvisioningState) UnmarshalJSON(bytes []byte) error + type TopicRegenerateKeyRequest struct + KeyName string + type TopicSharedAccessKeys struct + Key1 *string + Key2 *string + type TopicUpdateParameterProperties struct + DataResidencyBoundary *DataResidencyBoundary + DisableLocalAuth *bool + EventTypeInfo *EventTypeInfo + InboundIPRules *[]InboundIPRule + MinimumTlsVersionAllowed *TlsVersion + PublicNetworkAccess *PublicNetworkAccess + type TopicUpdateParameters struct + Identity *identity.SystemAndUserAssignedMap + Properties *TopicUpdateParameterProperties + Sku *ResourceSku + Tags *map[string]string + type TopicsClient struct + Client *resourcemanager.Client + func NewTopicsClientWithBaseURI(sdkApi sdkEnv.Api) (*TopicsClient, error) + func (c TopicsClient) CreateOrUpdate(ctx context.Context, id TopicId, input Topic) (result CreateOrUpdateOperationResponse, err error) + func (c TopicsClient) CreateOrUpdateThenPoll(ctx context.Context, id TopicId, input Topic) error + func (c TopicsClient) Delete(ctx context.Context, id TopicId) (result DeleteOperationResponse, err error) + func (c TopicsClient) DeleteThenPoll(ctx context.Context, id TopicId) error + func (c TopicsClient) ExtensionTopicsGet(ctx context.Context, id commonids.ScopeId) (result ExtensionTopicsGetOperationResponse, err error) + func (c TopicsClient) Get(ctx context.Context, id TopicId) (result GetOperationResponse, err error) + func (c TopicsClient) ListByResourceGroup(ctx context.Context, id commonids.ResourceGroupId, ...) (result ListByResourceGroupOperationResponse, err error) + func (c TopicsClient) ListByResourceGroupComplete(ctx context.Context, id commonids.ResourceGroupId, ...) (ListByResourceGroupCompleteResult, error) + func (c TopicsClient) ListByResourceGroupCompleteMatchingPredicate(ctx context.Context, id commonids.ResourceGroupId, ...) (result ListByResourceGroupCompleteResult, err error) + func (c TopicsClient) ListBySubscription(ctx context.Context, id commonids.SubscriptionId, ...) (result ListBySubscriptionOperationResponse, err error) + func (c TopicsClient) ListBySubscriptionComplete(ctx context.Context, id commonids.SubscriptionId, ...) (ListBySubscriptionCompleteResult, error) + func (c TopicsClient) ListBySubscriptionCompleteMatchingPredicate(ctx context.Context, id commonids.SubscriptionId, ...) (result ListBySubscriptionCompleteResult, err error) + func (c TopicsClient) ListEventTypes(ctx context.Context, id commonids.ScopeId) (result ListEventTypesOperationResponse, err error) + func (c TopicsClient) ListSharedAccessKeys(ctx context.Context, id TopicId) (result ListSharedAccessKeysOperationResponse, err error) + func (c TopicsClient) RegenerateKey(ctx context.Context, id TopicId, input TopicRegenerateKeyRequest) (result RegenerateKeyOperationResponse, err error) + func (c TopicsClient) RegenerateKeyThenPoll(ctx context.Context, id TopicId, input TopicRegenerateKeyRequest) error + func (c TopicsClient) Update(ctx context.Context, id TopicId, input TopicUpdateParameters) (result UpdateOperationResponse, err error) + func (c TopicsClient) UpdateThenPoll(ctx context.Context, id TopicId, input TopicUpdateParameters) error + type UpdateOperationResponse struct + HttpResponse *http.Response + Model *Topic + OData *odata.OData + Poller pollers.Poller