Documentation ¶
Index ¶
- func PossibleValuesForDataResidencyBoundary() []string
- func PossibleValuesForIPActionType() []string
- func PossibleValuesForInputSchema() []string
- func PossibleValuesForInputSchemaMappingType() []string
- func PossibleValuesForPersistedConnectionStatus() []string
- func PossibleValuesForPublicNetworkAccess() []string
- func PossibleValuesForResourceProvisioningState() []string
- func PossibleValuesForTopicProvisioningState() []string
- func ValidateTopicID(input interface{}, key string) (warnings []string, errors []error)
- type ConnectionState
- type CreateOrUpdateOperationResponse
- type DataResidencyBoundary
- type DeleteOperationResponse
- type EventType
- type EventTypeProperties
- type EventTypesListResult
- type ExtensionTopic
- type ExtensionTopicProperties
- type ExtensionTopicsGetOperationResponse
- type GetOperationResponse
- type IPActionType
- type InboundIPRule
- type InputSchema
- type InputSchemaMapping
- type InputSchemaMappingType
- type JsonField
- type JsonFieldWithDefault
- type JsonInputSchemaMapping
- type JsonInputSchemaMappingProperties
- type ListByResourceGroupCompleteResult
- type ListByResourceGroupOperationOptions
- type ListByResourceGroupOperationResponse
- type ListBySubscriptionCompleteResult
- type ListBySubscriptionOperationOptions
- type ListBySubscriptionOperationResponse
- type ListEventTypesOperationResponse
- type ListSharedAccessKeysOperationResponse
- type PersistedConnectionStatus
- type PrivateEndpoint
- type PrivateEndpointConnection
- type PrivateEndpointConnectionProperties
- type PublicNetworkAccess
- type RegenerateKeyOperationResponse
- type ResourceProvisioningState
- type Topic
- type TopicId
- type TopicOperationPredicate
- type TopicProperties
- type TopicProvisioningState
- type TopicRegenerateKeyRequest
- type TopicSharedAccessKeys
- type TopicUpdateParameterProperties
- type TopicUpdateParameters
- type TopicsClient
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PossibleValuesForDataResidencyBoundary ¶
func PossibleValuesForDataResidencyBoundary() []string
func PossibleValuesForIPActionType ¶
func PossibleValuesForIPActionType() []string
func PossibleValuesForInputSchema ¶
func PossibleValuesForInputSchema() []string
func PossibleValuesForInputSchemaMappingType ¶
func PossibleValuesForInputSchemaMappingType() []string
func PossibleValuesForPersistedConnectionStatus ¶
func PossibleValuesForPersistedConnectionStatus() []string
func PossibleValuesForPublicNetworkAccess ¶
func PossibleValuesForPublicNetworkAccess() []string
func PossibleValuesForResourceProvisioningState ¶
func PossibleValuesForResourceProvisioningState() []string
func PossibleValuesForTopicProvisioningState ¶
func PossibleValuesForTopicProvisioningState() []string
func ValidateTopicID ¶
ValidateTopicID checks that 'input' can be parsed as a Topic ID
Types ¶
type ConnectionState ¶
type ConnectionState struct { ActionsRequired *string `json:"actionsRequired,omitempty"` Description *string `json:"description,omitempty"` Status *PersistedConnectionStatus `json:"status,omitempty"` }
type DataResidencyBoundary ¶
type DataResidencyBoundary string
const ( DataResidencyBoundaryWithinGeopair DataResidencyBoundary = "WithinGeopair" DataResidencyBoundaryWithinRegion DataResidencyBoundary = "WithinRegion" )
func (*DataResidencyBoundary) UnmarshalJSON ¶
func (s *DataResidencyBoundary) UnmarshalJSON(bytes []byte) error
type DeleteOperationResponse ¶
type EventType ¶
type EventType struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Properties *EventTypeProperties `json:"properties,omitempty"` Type *string `json:"type,omitempty"` }
type EventTypeProperties ¶
type EventTypesListResult ¶
type EventTypesListResult struct {
Value *[]EventType `json:"value,omitempty"`
}
type ExtensionTopic ¶
type ExtensionTopic struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Properties *ExtensionTopicProperties `json:"properties,omitempty"` SystemData *systemdata.SystemData `json:"systemData,omitempty"` Type *string `json:"type,omitempty"` }
type ExtensionTopicsGetOperationResponse ¶
type ExtensionTopicsGetOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *ExtensionTopic }
type GetOperationResponse ¶
type IPActionType ¶
type IPActionType string
const (
IPActionTypeAllow IPActionType = "Allow"
)
func (*IPActionType) UnmarshalJSON ¶
func (s *IPActionType) UnmarshalJSON(bytes []byte) error
type InboundIPRule ¶
type InboundIPRule struct { Action *IPActionType `json:"action,omitempty"` IPMask *string `json:"ipMask,omitempty"` }
type InputSchema ¶
type InputSchema string
const ( InputSchemaCloudEventSchemaVOneZero InputSchema = "CloudEventSchemaV1_0" InputSchemaCustomEventSchema InputSchema = "CustomEventSchema" InputSchemaEventGridSchema InputSchema = "EventGridSchema" )
func (*InputSchema) UnmarshalJSON ¶
func (s *InputSchema) UnmarshalJSON(bytes []byte) error
type InputSchemaMapping ¶
type InputSchemaMapping interface { }
type InputSchemaMappingType ¶
type InputSchemaMappingType string
const (
InputSchemaMappingTypeJson InputSchemaMappingType = "Json"
)
func (*InputSchemaMappingType) UnmarshalJSON ¶
func (s *InputSchemaMappingType) UnmarshalJSON(bytes []byte) error
type JsonFieldWithDefault ¶
type JsonInputSchemaMapping ¶
type JsonInputSchemaMapping struct {
Properties *JsonInputSchemaMappingProperties `json:"properties,omitempty"`
}
func (JsonInputSchemaMapping) MarshalJSON ¶
func (s JsonInputSchemaMapping) MarshalJSON() ([]byte, error)
type JsonInputSchemaMappingProperties ¶
type JsonInputSchemaMappingProperties struct { DataVersion *JsonFieldWithDefault `json:"dataVersion,omitempty"` EventTime *JsonField `json:"eventTime,omitempty"` EventType *JsonFieldWithDefault `json:"eventType,omitempty"` Id *JsonField `json:"id,omitempty"` Subject *JsonFieldWithDefault `json:"subject,omitempty"` Topic *JsonField `json:"topic,omitempty"` }
type ListByResourceGroupCompleteResult ¶
type ListByResourceGroupCompleteResult struct {
Items []Topic
}
type ListByResourceGroupOperationOptions ¶
func DefaultListByResourceGroupOperationOptions ¶
func DefaultListByResourceGroupOperationOptions() ListByResourceGroupOperationOptions
func (ListByResourceGroupOperationOptions) ToHeaders ¶
func (o ListByResourceGroupOperationOptions) ToHeaders() *client.Headers
func (ListByResourceGroupOperationOptions) ToOData ¶
func (o ListByResourceGroupOperationOptions) ToOData() *odata.Query
func (ListByResourceGroupOperationOptions) ToQuery ¶
func (o ListByResourceGroupOperationOptions) ToQuery() *client.QueryParams
type ListBySubscriptionCompleteResult ¶
type ListBySubscriptionCompleteResult struct {
Items []Topic
}
type ListBySubscriptionOperationOptions ¶
func DefaultListBySubscriptionOperationOptions ¶
func DefaultListBySubscriptionOperationOptions() ListBySubscriptionOperationOptions
func (ListBySubscriptionOperationOptions) ToHeaders ¶
func (o ListBySubscriptionOperationOptions) ToHeaders() *client.Headers
func (ListBySubscriptionOperationOptions) ToOData ¶
func (o ListBySubscriptionOperationOptions) ToOData() *odata.Query
func (ListBySubscriptionOperationOptions) ToQuery ¶
func (o ListBySubscriptionOperationOptions) ToQuery() *client.QueryParams
type ListEventTypesOperationResponse ¶
type ListEventTypesOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *EventTypesListResult }
type ListSharedAccessKeysOperationResponse ¶
type ListSharedAccessKeysOperationResponse struct {}
type PersistedConnectionStatus ¶
type PersistedConnectionStatus string
const ( PersistedConnectionStatusApproved PersistedConnectionStatus = "Approved" PersistedConnectionStatusDisconnected PersistedConnectionStatus = "Disconnected" PersistedConnectionStatusPending PersistedConnectionStatus = "Pending" PersistedConnectionStatusRejected PersistedConnectionStatus = "Rejected" )
func (*PersistedConnectionStatus) UnmarshalJSON ¶
func (s *PersistedConnectionStatus) UnmarshalJSON(bytes []byte) error
type PrivateEndpoint ¶
type PrivateEndpoint struct {
Id *string `json:"id,omitempty"`
}
type PrivateEndpointConnection ¶
type PrivateEndpointConnection struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Properties *PrivateEndpointConnectionProperties `json:"properties,omitempty"` Type *string `json:"type,omitempty"` }
type PrivateEndpointConnectionProperties ¶
type PrivateEndpointConnectionProperties struct { GroupIds *[]string `json:"groupIds,omitempty"` PrivateEndpoint *PrivateEndpoint `json:"privateEndpoint,omitempty"` PrivateLinkServiceConnectionState *ConnectionState `json:"privateLinkServiceConnectionState,omitempty"` ProvisioningState *ResourceProvisioningState `json:"provisioningState,omitempty"` }
type PublicNetworkAccess ¶
type PublicNetworkAccess string
const ( PublicNetworkAccessDisabled PublicNetworkAccess = "Disabled" PublicNetworkAccessEnabled PublicNetworkAccess = "Enabled" )
func (*PublicNetworkAccess) UnmarshalJSON ¶
func (s *PublicNetworkAccess) UnmarshalJSON(bytes []byte) error
type ResourceProvisioningState ¶
type ResourceProvisioningState string
const ( ResourceProvisioningStateCanceled ResourceProvisioningState = "Canceled" ResourceProvisioningStateCreating ResourceProvisioningState = "Creating" ResourceProvisioningStateDeleting ResourceProvisioningState = "Deleting" ResourceProvisioningStateFailed ResourceProvisioningState = "Failed" ResourceProvisioningStateSucceeded ResourceProvisioningState = "Succeeded" ResourceProvisioningStateUpdating ResourceProvisioningState = "Updating" )
func (*ResourceProvisioningState) UnmarshalJSON ¶
func (s *ResourceProvisioningState) UnmarshalJSON(bytes []byte) error
type Topic ¶
type Topic struct { Id *string `json:"id,omitempty"` Identity *identity.SystemAndUserAssignedMap `json:"identity,omitempty"` Location string `json:"location"` Name *string `json:"name,omitempty"` Properties *TopicProperties `json:"properties,omitempty"` SystemData *systemdata.SystemData `json:"systemData,omitempty"` Tags *map[string]string `json:"tags,omitempty"` Type *string `json:"type,omitempty"` }
type TopicId ¶
TopicId is a struct representing the Resource ID for a Topic
func NewTopicID ¶
NewTopicID returns a new TopicId struct
func ParseTopicID ¶
ParseTopicID parses 'input' into a TopicId
func ParseTopicIDInsensitively ¶
ParseTopicIDInsensitively parses 'input' case-insensitively into a TopicId note: this method should only be used for API response data and not user input
func (TopicId) Segments ¶
func (id TopicId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Topic ID
type TopicOperationPredicate ¶
func (TopicOperationPredicate) Matches ¶
func (p TopicOperationPredicate) Matches(input Topic) bool
type TopicProperties ¶
type TopicProperties struct { DataResidencyBoundary *DataResidencyBoundary `json:"dataResidencyBoundary,omitempty"` DisableLocalAuth *bool `json:"disableLocalAuth,omitempty"` Endpoint *string `json:"endpoint,omitempty"` InboundIPRules *[]InboundIPRule `json:"inboundIpRules,omitempty"` InputSchema *InputSchema `json:"inputSchema,omitempty"` InputSchemaMapping InputSchemaMapping `json:"inputSchemaMapping"` MetricResourceId *string `json:"metricResourceId,omitempty"` PrivateEndpointConnections *[]PrivateEndpointConnection `json:"privateEndpointConnections,omitempty"` ProvisioningState *TopicProvisioningState `json:"provisioningState,omitempty"` PublicNetworkAccess *PublicNetworkAccess `json:"publicNetworkAccess,omitempty"` }
func (*TopicProperties) UnmarshalJSON ¶
func (s *TopicProperties) UnmarshalJSON(bytes []byte) error
type TopicProvisioningState ¶
type TopicProvisioningState string
const ( TopicProvisioningStateCanceled TopicProvisioningState = "Canceled" TopicProvisioningStateCreating TopicProvisioningState = "Creating" TopicProvisioningStateDeleting TopicProvisioningState = "Deleting" TopicProvisioningStateFailed TopicProvisioningState = "Failed" TopicProvisioningStateSucceeded TopicProvisioningState = "Succeeded" TopicProvisioningStateUpdating TopicProvisioningState = "Updating" )
func (*TopicProvisioningState) UnmarshalJSON ¶
func (s *TopicProvisioningState) UnmarshalJSON(bytes []byte) error
type TopicRegenerateKeyRequest ¶
type TopicRegenerateKeyRequest struct {
KeyName string `json:"keyName"`
}
type TopicSharedAccessKeys ¶
type TopicSharedAccessKeys struct {}
type TopicUpdateParameterProperties ¶
type TopicUpdateParameterProperties struct { DataResidencyBoundary *DataResidencyBoundary `json:"dataResidencyBoundary,omitempty"` DisableLocalAuth *bool `json:"disableLocalAuth,omitempty"` InboundIPRules *[]InboundIPRule `json:"inboundIpRules,omitempty"` PublicNetworkAccess *PublicNetworkAccess `json:"publicNetworkAccess,omitempty"` }
type TopicUpdateParameters ¶
type TopicUpdateParameters struct { Identity *identity.SystemAndUserAssignedMap `json:"identity,omitempty"` Properties *TopicUpdateParameterProperties `json:"properties,omitempty"` Tags *map[string]string `json:"tags,omitempty"` }
type TopicsClient ¶
type TopicsClient struct {
Client *resourcemanager.Client
}
func NewTopicsClientWithBaseURI ¶
func NewTopicsClientWithBaseURI(api environments.Api) (*TopicsClient, error)
func (TopicsClient) CreateOrUpdate ¶
func (c TopicsClient) CreateOrUpdate(ctx context.Context, id TopicId, input Topic) (result CreateOrUpdateOperationResponse, err error)
CreateOrUpdate ...
func (TopicsClient) CreateOrUpdateThenPoll ¶
CreateOrUpdateThenPoll performs CreateOrUpdate then polls until it's completed
func (TopicsClient) Delete ¶
func (c TopicsClient) Delete(ctx context.Context, id TopicId) (result DeleteOperationResponse, err error)
Delete ...
func (TopicsClient) DeleteThenPoll ¶
func (c TopicsClient) DeleteThenPoll(ctx context.Context, id TopicId) error
DeleteThenPoll performs Delete then polls until it's completed
func (TopicsClient) ExtensionTopicsGet ¶
func (c TopicsClient) ExtensionTopicsGet(ctx context.Context, id commonids.ScopeId) (result ExtensionTopicsGetOperationResponse, err error)
ExtensionTopicsGet ...
func (TopicsClient) Get ¶
func (c TopicsClient) Get(ctx context.Context, id TopicId) (result GetOperationResponse, err error)
Get ...
func (TopicsClient) ListByResourceGroup ¶
func (c TopicsClient) ListByResourceGroup(ctx context.Context, id commonids.ResourceGroupId, options ListByResourceGroupOperationOptions) (result ListByResourceGroupOperationResponse, err error)
ListByResourceGroup ...
func (TopicsClient) ListByResourceGroupComplete ¶
func (c TopicsClient) ListByResourceGroupComplete(ctx context.Context, id commonids.ResourceGroupId, options ListByResourceGroupOperationOptions) (ListByResourceGroupCompleteResult, error)
ListByResourceGroupComplete retrieves all the results into a single object
func (TopicsClient) ListByResourceGroupCompleteMatchingPredicate ¶
func (c TopicsClient) ListByResourceGroupCompleteMatchingPredicate(ctx context.Context, id commonids.ResourceGroupId, options ListByResourceGroupOperationOptions, predicate TopicOperationPredicate) (result ListByResourceGroupCompleteResult, err error)
ListByResourceGroupCompleteMatchingPredicate retrieves all the results and then applies the predicate
func (TopicsClient) ListBySubscription ¶
func (c TopicsClient) ListBySubscription(ctx context.Context, id commonids.SubscriptionId, options ListBySubscriptionOperationOptions) (result ListBySubscriptionOperationResponse, err error)
ListBySubscription ...
func (TopicsClient) ListBySubscriptionComplete ¶
func (c TopicsClient) ListBySubscriptionComplete(ctx context.Context, id commonids.SubscriptionId, options ListBySubscriptionOperationOptions) (ListBySubscriptionCompleteResult, error)
ListBySubscriptionComplete retrieves all the results into a single object
func (TopicsClient) ListBySubscriptionCompleteMatchingPredicate ¶
func (c TopicsClient) ListBySubscriptionCompleteMatchingPredicate(ctx context.Context, id commonids.SubscriptionId, options ListBySubscriptionOperationOptions, predicate TopicOperationPredicate) (result ListBySubscriptionCompleteResult, err error)
ListBySubscriptionCompleteMatchingPredicate retrieves all the results and then applies the predicate
func (TopicsClient) ListEventTypes ¶
func (c TopicsClient) ListEventTypes(ctx context.Context, id commonids.ScopeId) (result ListEventTypesOperationResponse, err error)
ListEventTypes ...
func (TopicsClient) ListSharedAccessKeys ¶
func (c TopicsClient) ListSharedAccessKeys(ctx context.Context, id TopicId) (result ListSharedAccessKeysOperationResponse, err error)
ListSharedAccessKeys ...
func (TopicsClient) RegenerateKey ¶
func (c TopicsClient) RegenerateKey(ctx context.Context, id TopicId, input TopicRegenerateKeyRequest) (result RegenerateKeyOperationResponse, err error)
RegenerateKey ...
func (TopicsClient) RegenerateKeyThenPoll ¶
func (c TopicsClient) RegenerateKeyThenPoll(ctx context.Context, id TopicId, input TopicRegenerateKeyRequest) error
RegenerateKeyThenPoll performs RegenerateKey then polls until it's completed
func (TopicsClient) Update ¶
func (c TopicsClient) Update(ctx context.Context, id TopicId, input TopicUpdateParameters) (result UpdateOperationResponse, err error)
Update ...
func (TopicsClient) UpdateThenPoll ¶
func (c TopicsClient) UpdateThenPoll(ctx context.Context, id TopicId, input TopicUpdateParameters) error
UpdateThenPoll performs Update then polls until it's completed
Source Files ¶
- client.go
- constants.go
- id_topic.go
- method_createorupdate.go
- method_delete.go
- method_extensiontopicsget.go
- method_get.go
- method_listbyresourcegroup.go
- method_listbysubscription.go
- method_listeventtypes.go
- method_listsharedaccesskeys.go
- method_regeneratekey.go
- method_update.go
- model_connectionstate.go
- model_eventtype.go
- model_eventtypeproperties.go
- model_eventtypeslistresult.go
- model_extensiontopic.go
- model_extensiontopicproperties.go
- model_inboundiprule.go
- model_inputschemamapping.go
- model_jsonfield.go
- model_jsonfieldwithdefault.go
- model_jsoninputschemamapping.go
- model_jsoninputschemamappingproperties.go
- model_privateendpoint.go
- model_privateendpointconnection.go
- model_privateendpointconnectionproperties.go
- model_topic.go
- model_topicproperties.go
- model_topicregeneratekeyrequest.go
- model_topicsharedaccesskeys.go
- model_topicupdateparameterproperties.go
- model_topicupdateparameters.go
- predicates.go
- version.go