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 PossibleValuesForEntityStatus() []string + func PossibleValuesForFilterType() []string + func ValidateRuleID(input interface{}, key string) (warnings []string, errors []error) + func ValidateSubscriptions2ID(input interface{}, key string) (warnings []string, errors []error) + func ValidateTopicID(input interface{}, key string) (warnings []string, errors []error) + type Action struct + CompatibilityLevel *int64 + RequiresPreprocessing *bool + SqlExpression *string + type CorrelationFilter struct + ContentType *string + CorrelationId *string + Label *string + MessageId *string + Properties *map[string]string + ReplyTo *string + ReplyToSessionId *string + RequiresPreprocessing *bool + SessionId *string + To *string + type CreateOrUpdateOperationResponse struct + HttpResponse *http.Response + Model *SBSubscription + OData *odata.OData + type DeleteOperationResponse struct + HttpResponse *http.Response + OData *odata.OData + type EntityStatus string + const EntityStatusActive + const EntityStatusCreating + const EntityStatusDeleting + const EntityStatusDisabled + const EntityStatusReceiveDisabled + const EntityStatusRenaming + const EntityStatusRestoring + const EntityStatusSendDisabled + const EntityStatusUnknown + func (s *EntityStatus) UnmarshalJSON(bytes []byte) error + type FilterType string + const FilterTypeCorrelationFilter + const FilterTypeSqlFilter + func (s *FilterType) UnmarshalJSON(bytes []byte) error + type GetOperationResponse struct + HttpResponse *http.Response + Model *SBSubscription + OData *odata.OData + type ListByTopicCompleteResult struct + Items []SBSubscription + LatestHttpResponse *http.Response + type ListByTopicCustomPager struct + NextLink *odata.Link + func (p *ListByTopicCustomPager) NextPageLink() *odata.Link + type ListByTopicOperationOptions struct + Skip *int64 + Top *int64 + func DefaultListByTopicOperationOptions() ListByTopicOperationOptions + func (o ListByTopicOperationOptions) ToHeaders() *client.Headers + func (o ListByTopicOperationOptions) ToOData() *odata.Query + func (o ListByTopicOperationOptions) ToQuery() *client.QueryParams + type ListByTopicOperationResponse struct + HttpResponse *http.Response + Model *[]SBSubscription + OData *odata.OData + type MessageCountDetails struct + ActiveMessageCount *int64 + DeadLetterMessageCount *int64 + ScheduledMessageCount *int64 + TransferDeadLetterMessageCount *int64 + TransferMessageCount *int64 + type Rule struct + Id *string + Location *string + Name *string + Properties *Ruleproperties + SystemData *systemdata.SystemData + Type *string + type RuleId struct + NamespaceName string + ResourceGroupName string + RuleName string + SubscriptionId string + SubscriptionName string + TopicName string + func NewRuleID(subscriptionId string, resourceGroupName string, namespaceName string, ...) RuleId + func ParseRuleID(input string) (*RuleId, error) + func ParseRuleIDInsensitively(input string) (*RuleId, error) + func (id *RuleId) FromParseResult(input resourceids.ParseResult) error + func (id RuleId) ID() string + func (id RuleId) Segments() []resourceids.Segment + func (id RuleId) String() string + type Ruleproperties struct + Action *Action + CorrelationFilter *CorrelationFilter + FilterType *FilterType + SqlFilter *SqlFilter + type RulesGetOperationResponse struct + HttpResponse *http.Response + Model *Rule + OData *odata.OData + type SBClientAffineProperties struct + ClientId *string + IsDurable *bool + IsShared *bool + type SBSubscription struct + Id *string + Location *string + Name *string + Properties *SBSubscriptionProperties + SystemData *systemdata.SystemData + Type *string + type SBSubscriptionOperationPredicate struct + Id *string + Location *string + Name *string + Type *string + func (p SBSubscriptionOperationPredicate) Matches(input SBSubscription) bool + type SBSubscriptionProperties struct + AccessedAt *string + AutoDeleteOnIdle *string + ClientAffineProperties *SBClientAffineProperties + CountDetails *MessageCountDetails + CreatedAt *string + DeadLetteringOnFilterEvaluationExceptions *bool + DeadLetteringOnMessageExpiration *bool + DefaultMessageTimeToLive *string + DuplicateDetectionHistoryTimeWindow *string + EnableBatchedOperations *bool + ForwardDeadLetteredMessagesTo *string + ForwardTo *string + IsClientAffine *bool + LockDuration *string + MaxDeliveryCount *int64 + MessageCount *int64 + RequiresSession *bool + Status *EntityStatus + UpdatedAt *string + func (o *SBSubscriptionProperties) GetAccessedAtAsTime() (*time.Time, error) + func (o *SBSubscriptionProperties) GetCreatedAtAsTime() (*time.Time, error) + func (o *SBSubscriptionProperties) GetUpdatedAtAsTime() (*time.Time, error) + func (o *SBSubscriptionProperties) SetAccessedAtAsTime(input time.Time) + func (o *SBSubscriptionProperties) SetCreatedAtAsTime(input time.Time) + func (o *SBSubscriptionProperties) SetUpdatedAtAsTime(input time.Time) + type SqlFilter struct + CompatibilityLevel *int64 + RequiresPreprocessing *bool + SqlExpression *string + type Subscriptions2Id struct + NamespaceName string + ResourceGroupName string + SubscriptionId string + SubscriptionName string + TopicName string + func NewSubscriptions2ID(subscriptionId string, resourceGroupName string, namespaceName string, ...) Subscriptions2Id + func ParseSubscriptions2ID(input string) (*Subscriptions2Id, error) + func ParseSubscriptions2IDInsensitively(input string) (*Subscriptions2Id, error) + func (id *Subscriptions2Id) FromParseResult(input resourceids.ParseResult) error + func (id Subscriptions2Id) ID() string + func (id Subscriptions2Id) Segments() []resourceids.Segment + func (id Subscriptions2Id) String() string + type SubscriptionsClient struct + Client *resourcemanager.Client + func NewSubscriptionsClientWithBaseURI(sdkApi sdkEnv.Api) (*SubscriptionsClient, error) + func (c SubscriptionsClient) CreateOrUpdate(ctx context.Context, id Subscriptions2Id, input SBSubscription) (result CreateOrUpdateOperationResponse, err error) + func (c SubscriptionsClient) Delete(ctx context.Context, id Subscriptions2Id) (result DeleteOperationResponse, err error) + func (c SubscriptionsClient) Get(ctx context.Context, id Subscriptions2Id) (result GetOperationResponse, err error) + func (c SubscriptionsClient) ListByTopic(ctx context.Context, id TopicId, options ListByTopicOperationOptions) (result ListByTopicOperationResponse, err error) + func (c SubscriptionsClient) ListByTopicComplete(ctx context.Context, id TopicId, options ListByTopicOperationOptions) (ListByTopicCompleteResult, error) + func (c SubscriptionsClient) ListByTopicCompleteMatchingPredicate(ctx context.Context, id TopicId, options ListByTopicOperationOptions, ...) (result ListByTopicCompleteResult, err error) + func (c SubscriptionsClient) RulesGet(ctx context.Context, id RuleId) (result RulesGetOperationResponse, err error) + type TopicId struct + NamespaceName string + ResourceGroupName string + SubscriptionId string + TopicName string + func NewTopicID(subscriptionId string, resourceGroupName string, namespaceName 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
Go to main page