admin

package

Go to main page

Versions in this module

v1

v1.8.0-beta.1

May 1, 2024

v1.7.1

May 20, 2024

v1.7.0

Apr 2, 2024

v1.6.1

Mar 4, 2024

v1.6.0

Jan 17, 2024

v1.5.0

Oct 2, 2023

Changes in this version

type CreateQueueResponse

+ QueueName string

type CreateSubscriptionResponse

+ SubscriptionName string

+ TopicName string

type CreateTopicResponse

+ TopicName string

type GetQueueResponse

+ QueueName string

type GetQueueRuntimePropertiesResponse

+ QueueName string

type GetSubscriptionResponse

+ SubscriptionName string

+ TopicName string

type GetSubscriptionRuntimePropertiesResponse

+ SubscriptionName string

+ TopicName string

type GetTopicResponse

+ TopicName string

type GetTopicRuntimePropertiesResponse

+ TopicName string

type UpdateQueueResponse

+ QueueName string

type UpdateSubscriptionResponse

+ SubscriptionName string

+ TopicName string

type UpdateTopicResponse

+ TopicName string

v1.4.1

Sep 6, 2023

v1.4.0

Jun 6, 2023

Changes in this version

type SubscriptionProperties

+ DefaultRule *RuleProperties

v1.3.0

May 8, 2023

v1.2.1

Mar 7, 2023

v1.2.0

Feb 7, 2023

v1.1.4

Jan 4, 2023

v1.1.3

Nov 17, 2022

v1.1.2

Nov 8, 2022

retracted

v1.1.1

Oct 4, 2022

v1.1.0

Aug 9, 2022

v1.0.2

Jul 5, 2022

v1.0.2-beta.0

Jul 7, 2022

v1.0.1

Jun 7, 2022

Changes in this version

type QueueProperties

+ MaxMessageSizeInKilobytes *int64

type TopicProperties

+ MaxMessageSizeInKilobytes *int64

v1.0.0

May 16, 2022

v0

v0.4.1

May 12, 2022

Changes in this version

+ type AccessRight string

+ const AccessRightListen

+ const AccessRightManage

+ const AccessRightSend

+ type AuthorizationRule struct

+ AccessRights []AccessRight

+ CreatedTime *time.Time

+ KeyName *string

+ ModifiedTime *time.Time

+ PrimaryKey *string

+ SecondaryKey *string

type Client

+ func (ac *Client) CreateRule(ctx context.Context, topicName string, subscriptionName string, ...) (CreateRuleResponse, error)

+ func (ac *Client) DeleteRule(ctx context.Context, topicName string, subscriptionName string, ...) (DeleteRuleResponse, error)

+ func (ac *Client) GetRule(ctx context.Context, topicName string, subscriptionName string, ...) (*GetRuleResponse, error)

+ func (ac *Client) NewListQueuesPager(options *ListQueuesOptions) *runtime.Pager[ListQueuesResponse]

+ func (ac *Client) NewListQueuesRuntimePropertiesPager(options *ListQueuesRuntimePropertiesOptions) *runtime.Pager[ListQueuesRuntimePropertiesResponse]

+ func (ac *Client) NewListRulesPager(topicName string, subscriptionName string, options *ListRulesOptions) *runtime.Pager[ListRulesResponse]

+ func (ac *Client) NewListSubscriptionsPager(topicName string, options *ListSubscriptionsOptions) *runtime.Pager[ListSubscriptionsResponse]

+ func (ac *Client) NewListSubscriptionsRuntimePropertiesPager(topicName string, options *ListSubscriptionsRuntimePropertiesOptions) *runtime.Pager[ListSubscriptionsRuntimePropertiesResponse]

+ func (ac *Client) NewListTopicsPager(options *ListTopicsOptions) *runtime.Pager[ListTopicsResponse]

+ func (ac *Client) NewListTopicsRuntimePropertiesPager(options *ListTopicsRuntimePropertiesOptions) *runtime.Pager[ListTopicsRuntimePropertiesResponse]

+ func (ac *Client) UpdateRule(ctx context.Context, topicName string, subscriptionName string, ...) (UpdateRuleResponse, error)

+ type CorrelationFilter struct

+ ApplicationProperties map[string]interface{}

+ ContentType *string

+ CorrelationID *string

+ MessageID *string

+ ReplyTo *string

+ ReplyToSessionID *string

+ SessionID *string

+ Subject *string

+ To *string

+ type CreateRuleOptions struct

+ Action RuleAction

+ Filter RuleFilter

+ Name *string

+ type CreateRuleResponse struct

+ type DeleteRuleOptions struct

+ type DeleteRuleResponse struct

+ type FalseFilter struct

+ type GetRuleOptions struct

+ type GetRuleResponse struct

+ type ListRulesOptions struct

+ MaxPageSize int32

+ type ListRulesResponse struct

+ Rules []RuleProperties

type QueueProperties

+ AuthorizationRules []AuthorizationRule

+ type Rule struct

+ Action RuleAction

+ Filter RuleFilter

+ type RuleAction interface

+ type RuleFilter interface

+ type RuleProperties struct

+ Action RuleAction

+ Filter RuleFilter

+ Name string

+ type SQLAction struct

+ Expression string

+ Parameters map[string]interface{}

+ type SQLFilter struct

+ Expression string

+ Parameters map[string]interface{}

type TopicProperties

+ AuthorizationRules []AuthorizationRule

+ type TrueFilter struct

+ type UnknownRuleAction struct

+ RawXML []byte

+ Type string

+ type UnknownRuleFilter struct

+ RawXML []byte

+ Type string

+ type UpdateRuleOptions struct

+ type UpdateRuleResponse struct

v0.4.0

Apr 6, 2022

Changes in this version

type CreateQueueOptions

+ Properties *QueueProperties

type CreateSubscriptionOptions

+ Properties *SubscriptionProperties

type CreateTopicOptions

+ Properties *TopicProperties

type ListQueuesResponse

+ Queues []QueueItem

type ListQueuesRuntimePropertiesResponse

+ QueueRuntimeProperties []QueueRuntimePropertiesItem

type ListSubscriptionsResponse

+ Subscriptions []SubscriptionPropertiesItem

type ListSubscriptionsRuntimePropertiesResponse

+ SubscriptionRuntimeProperties []SubscriptionRuntimePropertiesItem

type ListTopicsResponse

+ Topics []TopicItem

type ListTopicsRuntimePropertiesResponse

+ TopicRuntimeProperties []TopicRuntimePropertiesItem

v0.3.6

Mar 8, 2022

v0.3.5

Feb 11, 2022

v0.3.4

Feb 8, 2022

Changes in this version

type ClientOptions

+ RetryOptions *RetryOptions

+ type RetryOptions = utils.RetryOptions

v0.3.3

Jan 12, 2022

v0.3.2

Dec 8, 2021

v0.3.1

Nov 16, 2021

v0.3.0

Nov 12, 2021

Changes in this version

+ type Client struct

+ func NewClient(fullyQualifiedNamespace string, tokenCredential azcore.TokenCredential, ...) (*Client, error)

+ func NewClientFromConnectionString(connectionString string, options *ClientOptions) (*Client, error)

+ func (ac *Client) CreateQueue(ctx context.Context, queueName string, properties *QueueProperties, ...) (*CreateQueueResponse, error)

+ func (ac *Client) CreateSubscription(ctx context.Context, topicName string, subscriptionName string, ...) (*CreateSubscriptionResponse, error)

+ func (ac *Client) CreateTopic(ctx context.Context, topicName string, properties *TopicProperties, ...) (*CreateTopicResponse, error)

+ func (ac *Client) DeleteQueue(ctx context.Context, queueName string, options *DeleteQueueOptions) (*DeleteQueueResponse, error)

+ func (ac *Client) DeleteSubscription(ctx context.Context, topicName string, subscriptionName string, ...) (*DeleteSubscriptionResponse, error)

+ func (ac *Client) DeleteTopic(ctx context.Context, topicName string, options *DeleteTopicOptions) (*DeleteTopicResponse, error)

+ func (ac *Client) GetNamespaceProperties(ctx context.Context, options *GetNamespacePropertiesOptions) (*GetNamespacePropertiesResponse, error)

+ func (ac *Client) GetQueue(ctx context.Context, queueName string, options *GetQueueOptions) (*GetQueueResponse, error)

+ func (ac *Client) GetQueueRuntimeProperties(ctx context.Context, queueName string, ...) (*GetQueueRuntimePropertiesResponse, error)

+ func (ac *Client) GetSubscription(ctx context.Context, topicName string, subscriptionName string, ...) (*GetSubscriptionResponse, error)

+ func (ac *Client) GetSubscriptionRuntimeProperties(ctx context.Context, topicName string, subscriptionName string, ...) (*GetSubscriptionRuntimePropertiesResponse, error)

+ func (ac *Client) GetTopic(ctx context.Context, topicName string, options *GetTopicOptions) (*GetTopicResponse, error)

+ func (ac *Client) GetTopicRuntimeProperties(ctx context.Context, topicName string, ...) (*GetTopicRuntimePropertiesResponse, error)

+ func (ac *Client) ListQueues(options *ListQueuesOptions) *QueuePager

+ func (ac *Client) ListQueuesRuntimeProperties(options *ListQueuesRuntimePropertiesOptions) *QueueRuntimePropertiesPager

+ func (ac *Client) ListSubscriptions(topicName string, options *ListSubscriptionsOptions) *SubscriptionPager

+ func (ac *Client) ListSubscriptionsRuntimeProperties(topicName string, options *ListSubscriptionsRuntimePropertiesOptions) *SubscriptionRuntimePropertiesPager

+ func (ac *Client) ListTopics(options *ListTopicsOptions) *TopicsPager

+ func (ac *Client) ListTopicsRuntimeProperties(options *ListTopicsRuntimePropertiesOptions) *TopicRuntimePropertiesPager

+ func (ac *Client) UpdateQueue(ctx context.Context, queueName string, properties QueueProperties, ...) (*UpdateQueueResponse, error)

+ func (ac *Client) UpdateSubscription(ctx context.Context, topicName string, subscriptionName string, ...) (*UpdateSubscriptionResponse, error)

+ func (ac *Client) UpdateTopic(ctx context.Context, topicName string, properties TopicProperties, ...) (*UpdateTopicResponse, error)

+ type ClientOptions struct

+ type CreateQueueOptions struct

+ type CreateQueueResponse struct

+ RawResponse *http.Response

+ type CreateQueueResult struct

+ type CreateSubscriptionOptions struct

+ type CreateSubscriptionResponse struct

+ RawResponse *http.Response

+ type CreateSubscriptionResult struct

+ type CreateTopicOptions struct

+ type CreateTopicResponse struct

+ RawResponse *http.Response

+ type CreateTopicResult struct

+ type DeleteQueueOptions struct

+ type DeleteQueueResponse struct

+ RawResponse *http.Response

+ type DeleteSubscriptionOptions struct

+ type DeleteSubscriptionResponse struct

+ RawResponse *http.Response

+ type DeleteTopicOptions struct

+ type DeleteTopicResponse struct

+ RawResponse *http.Response

+ Value *TopicProperties

+ type EntityStatus string

+ const EntityStatusActive

+ const EntityStatusDisabled

+ const EntityStatusReceiveDisabled

+ const EntityStatusSendDisabled

+ type GetNamespacePropertiesOptions struct

+ type GetNamespacePropertiesResponse struct

+ RawResponse *http.Response

+ type GetNamespacePropertiesResult struct

+ type GetQueueOptions struct

+ type GetQueueResponse struct

+ RawResponse *http.Response

+ type GetQueueResult struct

+ type GetQueueRuntimePropertiesOptions struct

+ type GetQueueRuntimePropertiesResponse struct

+ RawResponse *http.Response

+ type GetQueueRuntimePropertiesResult struct

+ type GetSubscriptionOptions struct

+ type GetSubscriptionResponse struct

+ RawResponse *http.Response

+ type GetSubscriptionResult struct

+ type GetSubscriptionRuntimePropertiesOptions struct

+ type GetSubscriptionRuntimePropertiesResponse struct

+ RawResponse *http.Response

+ type GetSubscriptionRuntimePropertiesResult struct

+ type GetTopicOptions struct

+ type GetTopicResponse struct

+ RawResponse *http.Response

+ type GetTopicResult struct

+ type GetTopicRuntimePropertiesOptions struct

+ type GetTopicRuntimePropertiesResponse struct

+ RawResponse *http.Response

+ type GetTopicRuntimePropertiesResult struct

+ type ListQueuesOptions struct

+ MaxPageSize int32

+ type ListQueuesResponse struct

+ RawResponse *http.Response

+ type ListQueuesResult struct

+ Items []*QueueItem

+ type ListQueuesRuntimePropertiesOptions struct

+ MaxPageSize int32

+ type ListQueuesRuntimePropertiesResponse struct

+ Items []*QueueRuntimePropertiesItem

+ RawResponse *http.Response

+ type ListSubscriptionsOptions struct

+ MaxPageSize int32

+ type ListSubscriptionsResponse struct

+ Items []*SubscriptionPropertiesItem

+ RawResponse *http.Response

+ type ListSubscriptionsRuntimePropertiesOptions struct

+ MaxPageSize int32

+ type ListSubscriptionsRuntimePropertiesResponse struct

+ Items []*SubscriptionRuntimePropertiesItem

+ RawResponse *http.Response

+ type ListTopicsOptions struct

+ MaxPageSize int32

+ type ListTopicsResponse struct

+ Items []*TopicItem

+ RawResponse *http.Response

+ type ListTopicsRuntimePropertiesOptions struct

+ MaxPageSize int32

+ type ListTopicsRuntimePropertiesResponse struct

+ Items []*TopicRuntimePropertiesItem

+ RawResponse *http.Response

+ type NamespaceProperties struct

+ CreatedTime time.Time

+ MessagingUnits *int64

+ ModifiedTime time.Time

+ Name string

+ SKU string

+ type QueueItem struct

+ QueueName string

+ type QueuePager struct

+ func (p *QueuePager) Err() error

+ func (p *QueuePager) NextPage(ctx context.Context) bool

+ func (p *QueuePager) PageResponse() *ListQueuesResponse

+ type QueueProperties struct

+ AutoDeleteOnIdle *time.Duration

+ DeadLetteringOnMessageExpiration *bool

+ DefaultMessageTimeToLive *time.Duration

+ DuplicateDetectionHistoryTimeWindow *time.Duration

+ EnableBatchedOperations *bool

+ EnablePartitioning *bool

+ ForwardDeadLetteredMessagesTo *string

+ ForwardTo *string

+ LockDuration *time.Duration

+ MaxDeliveryCount *int32

+ MaxSizeInMegabytes *int32

+ RequiresDuplicateDetection *bool

+ RequiresSession *bool

+ Status *EntityStatus

+ UserMetadata *string

+ type QueueRuntimeProperties struct

+ AccessedAt time.Time

+ ActiveMessageCount int32

+ CreatedAt time.Time

+ DeadLetterMessageCount int32

+ ScheduledMessageCount int32

+ SizeInBytes int64

+ TotalMessageCount int64

+ TransferDeadLetterMessageCount int32

+ TransferMessageCount int32

+ UpdatedAt time.Time

+ type QueueRuntimePropertiesItem struct

+ QueueName string

+ type QueueRuntimePropertiesPager struct

+ func (p *QueueRuntimePropertiesPager) Err() error

+ func (p *QueueRuntimePropertiesPager) NextPage(ctx context.Context) bool

+ func (p *QueueRuntimePropertiesPager) PageResponse() *ListQueuesRuntimePropertiesResponse

+ type SubscriptionPager struct

+ func (p *SubscriptionPager) Err() error

+ func (p *SubscriptionPager) NextPage(ctx context.Context) bool

+ func (p *SubscriptionPager) PageResponse() *ListSubscriptionsResponse

+ type SubscriptionProperties struct

+ AutoDeleteOnIdle *time.Duration

+ DeadLetteringOnMessageExpiration *bool

+ DefaultMessageTimeToLive *time.Duration

+ EnableBatchedOperations *bool

+ EnableDeadLetteringOnFilterEvaluationExceptions *bool

+ ForwardDeadLetteredMessagesTo *string

+ ForwardTo *string

+ LockDuration *time.Duration

+ MaxDeliveryCount *int32

+ RequiresSession *bool

+ Status *EntityStatus

+ UserMetadata *string

+ type SubscriptionPropertiesItem struct

+ SubscriptionName string

+ TopicName string

+ type SubscriptionRuntimeProperties struct

+ AccessedAt time.Time

+ ActiveMessageCount int32

+ CreatedAt time.Time

+ DeadLetterMessageCount int32

+ TotalMessageCount int64

+ TransferDeadLetterMessageCount int32

+ TransferMessageCount int32

+ UpdatedAt time.Time

+ type SubscriptionRuntimePropertiesItem struct

+ SubscriptionName string

+ TopicName string

+ type SubscriptionRuntimePropertiesPager struct

+ func (p *SubscriptionRuntimePropertiesPager) Err() error

+ func (p *SubscriptionRuntimePropertiesPager) NextPage(ctx context.Context) bool

+ func (p *SubscriptionRuntimePropertiesPager) PageResponse() *ListSubscriptionsRuntimePropertiesResponse

+ type TopicItem struct

+ TopicName string

+ type TopicProperties struct

+ AutoDeleteOnIdle *time.Duration

+ DefaultMessageTimeToLive *time.Duration

+ DuplicateDetectionHistoryTimeWindow *time.Duration

+ EnableBatchedOperations *bool

+ EnablePartitioning *bool

+ MaxSizeInMegabytes *int32

+ RequiresDuplicateDetection *bool

+ Status *EntityStatus

+ SupportOrdering *bool

+ UserMetadata *string

+ type TopicRuntimeProperties struct

+ AccessedAt time.Time

+ CreatedAt time.Time

+ ScheduledMessageCount int32

+ SizeInBytes int64

+ SubscriptionCount int32

+ UpdatedAt time.Time

+ type TopicRuntimePropertiesItem struct

+ TopicName string

+ type TopicRuntimePropertiesPager struct

+ func (p *TopicRuntimePropertiesPager) Err() error

+ func (p *TopicRuntimePropertiesPager) NextPage(ctx context.Context) bool

+ func (p *TopicRuntimePropertiesPager) PageResponse() *ListTopicsRuntimePropertiesResponse

+ type TopicsPager struct

+ func (p *TopicsPager) Err() error

+ func (p *TopicsPager) NextPage(ctx context.Context) bool

+ func (p *TopicsPager) PageResponse() *ListTopicsResponse

+ type UpdateQueueOptions struct

+ type UpdateQueueResponse struct

+ RawResponse *http.Response

+ type UpdateQueueResult struct

+ type UpdateSubscriptionOptions struct

+ type UpdateSubscriptionResponse struct

+ RawResponse *http.Response

+ type UpdateSubscriptionResult struct

+ type UpdateTopicOptions struct

+ type UpdateTopicResponse struct

+ RawResponse *http.Response

+ type UpdateTopicResult struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL