servicebus

package module

Go to main page

Versions in this module

v0

v0.10.13

May 6, 2021

Changes in this version

+ const DeadLetterQueueName

+ const TransferDeadLetterQueueName

+ func IsErrNotFound(err error) bool

+ type ActionDescriber interface

+ ToActionDescription func() ActionDescription

+ type ActionDescription struct

+ CompatibilityLevel int

+ RequiresPreprocessing bool

+ SQLExpression string

+ Type string

+ type BatchDispositionError struct

+ Errors []DispositionError

+ func (bde BatchDispositionError) Error() string

+ type BatchDispositionIterator struct

+ LockTokenIDs []*uuid.UUID

+ Status MessageStatus

+ func (bdi *BatchDispositionIterator) Done() bool

+ func (bdi *BatchDispositionIterator) Next() (uuid *uuid.UUID)

+ type BatchIterator interface

+ Done func() bool

+ Next func(messageID string, opts *BatchOptions) (*MessageBatch, error)

+ type BatchOptions struct

+ SessionID *string

+ type Closer interface

+ Close func(ctx context.Context) error

+ type CorrelationFilter struct

+ ContentType *string

+ CorrelationID *string

+ Label *string

+ MessageID *string

+ Properties map[string]interface{}

+ ReplyTo *string

+ ReplyToSessionID *string

+ SessionID *string

+ To *string

+ func (cf CorrelationFilter) ToFilterDescription() FilterDescription

+ type DeadLetter struct

+ func NewDeadLetter(builder DeadLetterBuilder) *DeadLetter

+ func (dl *DeadLetter) Close(ctx context.Context) error

+ func (dl *DeadLetter) ReceiveOne(ctx context.Context, handler Handler) error

+ type DeadLetterBuilder interface

+ NewDeadLetterReceiver func(ctx context.Context, opts ...ReceiverOption) (ReceiveOner, error)

+ type DefaultRuleDescription struct

+ Filter FilterDescription

+ Name *string

+ XMLName xml.Name

+ type DispositionError struct

+ LockTokenID *uuid.UUID

+ func (de DispositionError) Error() string

+ func (de DispositionError) UnWrap() error

+ type Entity struct

+ ID string

+ Name string

+ func (e Entity) TargetURI() string

+ type EntityManagementAddresser interface

+ ManagementPath func() string

+ type EntityStatus string

+ const Active

+ const Creating

+ const Deleting

+ const Disabled

+ const ReceiveDisabled

+ const Renaming

+ const Restoring

+ const SendDisabled

+ const Unknown

+ type ErrAMQP rpc.Response

+ func (e ErrAMQP) Error() string

+ type ErrConnectionClosed string

+ func (e ErrConnectionClosed) Error() string

+ type ErrIncorrectType struct

+ ActualValue interface{}

+ ExpectedType reflect.Type

+ Key string

+ func (e ErrIncorrectType) Error() string

+ type ErrMalformedMessage string

+ func (e ErrMalformedMessage) Error() string

+ type ErrMissingField string

+ func (e ErrMissingField) Error() string

+ type ErrNoMessages struct

+ func (e ErrNoMessages) Error() string

+ type ErrNotFound struct

+ EntityPath string

+ func (e ErrNotFound) Error() string

+ type FalseFilter struct

+ func (ff FalseFilter) ToFilterDescription() FilterDescription

+ type FilterDescriber interface

+ ToFilterDescription func() FilterDescription

+ type FilterDescription struct

+ CompatibilityLevel int

+ SQLExpression *string

+ Type string

+ XMLName xml.Name

type Handler

+ Handle func(context.Context, *Message) error

+ type HandlerFunc func(context.Context, *Message) error

+ func (hf HandlerFunc) Handle(ctx context.Context, msg *Message) error

+ type MaxMessageSizeInBytes int

+ const PremiumMaxMessageSizeInBytes

+ const StandardMaxMessageSizeInBytes

type Message

+ Format uint32

+ SessionID *string

+ func (m *Message) AbandonAction() DispositionAction

+ func (m *Message) CompleteAction() DispositionAction

+ func (m *Message) DeadLetterAction(err error) DispositionAction

+ func (m *Message) DeadLetterWithInfoAction(err error, condition MessageErrorCondition, additionalData map[string]string) DispositionAction

+ func (m *Message) Defer(ctx context.Context) error

+ func (m *Message) GetKeyValues() map[string]interface{}

+ func (m *Message) ScheduleAt(t time.Time)

+ type MessageBatch struct

+ MaxSize MaxMessageSizeInBytes

+ func NewMessageBatch(maxSize MaxMessageSizeInBytes, messageID string, opts *BatchOptions) *MessageBatch

+ func (mb *MessageBatch) Add(m *Message) (bool, error)

+ func (mb *MessageBatch) Clear()

+ func (mb *MessageBatch) Size() int

+ type MessageBatchIterator struct

+ Cursor int

+ MaxSize MaxMessageSizeInBytes

+ Messages []*Message

+ func NewMessageBatchIterator(maxBatchSize MaxMessageSizeInBytes, msgs ...*Message) *MessageBatchIterator

+ func (mbi *MessageBatchIterator) Done() bool

+ func (mbi *MessageBatchIterator) Next(messageID string, opts *BatchOptions) (*MessageBatch, error)

+ type MessageIterator interface

+ Done func() bool

+ Next func(context.Context) (*Message, error)

+ type MessageSession struct

+ func (ms *MessageSession) Close()

+ func (ms *MessageSession) ListSessions(ctx context.Context) ([]byte, error)

+ func (ms *MessageSession) LockedUntil() time.Time

+ func (ms *MessageSession) RenewLock(ctx context.Context) error

+ func (ms *MessageSession) SessionID() *string

+ func (ms *MessageSession) SetState(ctx context.Context, state []byte) error

+ func (ms *MessageSession) State(ctx context.Context) ([]byte, error)

+ type MessageSliceIterator struct

+ Cursor int

+ Target []*Message

+ func AsMessageSliceIterator(target []*Message) *MessageSliceIterator

+ func (ms *MessageSliceIterator) Next(_ context.Context) (*Message, error)

+ func (ms MessageSliceIterator) Done() bool

+ type MessageStatus dispositionStatus

+ const Abort

+ const Complete

+ type MiddlewareFunc func(next RestHandler) RestHandler

+ func TraceReqAndResponseMiddleware() MiddlewareFunc

type Namespace

+ Suffix string

+ func (ns *Namespace) NewReceiver(ctx context.Context, entityPath string, opts ...ReceiverOption) (*Receiver, error)

+ func (ns *Namespace) NewSender(ctx context.Context, entityPath string, opts ...SenderOption) (*Sender, error)

type NamespaceOption

+ func NamespaceWithAzureEnvironment(namespaceName, environmentName string) NamespaceOption

+ func NamespaceWithEnvironmentBinding(name string) NamespaceOption

+ func NamespaceWithTLSConfig(tlsConfig *tls.Config) NamespaceOption

+ func NamespaceWithTokenProvider(provider auth.TokenProvider) NamespaceOption

+ func NamespaceWithUserAgent(userAgent string) NamespaceOption

+ func NamespaceWithWebSocket() NamespaceOption

+ type PeekOption func(*peekIterator) error

+ func PeekFromSequenceNumber(seq int64) PeekOption

+ func PeekWithPageSize(pageSize int) PeekOption

type Queue

+ func (q *Queue) NewDeadLetter() *DeadLetter

+ func (q *Queue) NewDeadLetterReceiver(ctx context.Context, opts ...ReceiverOption) (ReceiveOner, error)

+ func (q *Queue) NewReceiver(ctx context.Context, opts ...ReceiverOption) (*Receiver, error)

+ func (q *Queue) NewSender(ctx context.Context, opts ...SenderOption) (*Sender, error)

+ func (q *Queue) NewSession(sessionID *string) *QueueSession

+ func (q *Queue) NewTransferDeadLetter() *TransferDeadLetter

+ func (q *Queue) NewTransferDeadLetterReceiver(ctx context.Context, opts ...ReceiverOption) (ReceiveOner, error)

+ func (q *Queue) SendBatch(ctx context.Context, iterator BatchIterator) error

type QueueDescription

+ ForwardDeadLetteredMessagesTo *string

+ ForwardTo *string

type QueueManagementOption

+ func QueueEntityWithAutoForward(target Targetable) QueueManagementOption

+ func QueueEntityWithForwardDeadLetteredMessagesTo(target Targetable) QueueManagementOption

type QueueManager

+ func (em QueueManager) TokenProvider() auth.TokenProvider

+ func (em QueueManager) Use(mw ...MiddlewareFunc)

type QueueOption

+ func QueueWithPrefetchCount(prefetch uint32) QueueOption

+ type QueueSession struct

+ func NewQueueSession(builder SendAndReceiveBuilder, sessionID *string) *QueueSession

+ func (qs *QueueSession) Close(ctx context.Context) error

+ func (qs *QueueSession) ManagementPath() string

+ func (qs *QueueSession) ReceiveDeferred(ctx context.Context, handler Handler, mode ReceiveMode, ...) error

+ func (qs *QueueSession) ReceiveOne(ctx context.Context, handler SessionHandler) error

+ func (qs *QueueSession) Send(ctx context.Context, msg *Message) error

+ func (qs *QueueSession) SessionID() *string

+ type ReceiveBuilder interface

+ type ReceiveOner interface

+ ReceiveOne func(ctx context.Context, handler Handler) error

+ type Receiver struct

+ Closed bool

+ DefaultDisposition DispositionAction

+ Name string

+ func (r *Receiver) Close(ctx context.Context) error

+ func (r *Receiver) Listen(ctx context.Context, handler Handler) *ListenerHandle

+ func (r *Receiver) ReceiveOne(ctx context.Context, handler Handler) error

+ func (r *Receiver) Recover(ctx context.Context) error

+ type ReceiverBuilder interface

+ NewReceiver func(ctx context.Context, opts ...ReceiverOption) (*Receiver, error)

+ type ReceiverOption func(receiver *Receiver) error

+ func ReceiverWithPrefetchCount(prefetch uint32) ReceiverOption

+ func ReceiverWithReceiveMode(mode ReceiveMode) ReceiverOption

+ func ReceiverWithSession(sessionID *string) ReceiverOption

+ type RestHandler func(ctx context.Context, req *http.Request) (*http.Response, error)

+ type RuleDescription struct

+ Action *ActionDescription

+ CreatedAt *date.Time

+ Filter FilterDescription

+ XMLName xml.Name

+ type RuleEntity struct

+ type SQLAction struct

+ Expression string

+ func (sf SQLAction) ToActionDescription() ActionDescription

+ type SQLFilter struct

+ Expression string

+ func (sf SQLFilter) ToFilterDescription() FilterDescription

+ type SendAndReceiveBuilder interface

+ type Sender struct

+ Name string

+ func (s *Sender) Close(ctx context.Context) error

+ func (s *Sender) Recover(ctx context.Context) error

+ func (s *Sender) Send(ctx context.Context, msg *Message, opts ...SendOption) error

+ func (s *Sender) String() string

+ type SenderBuilder interface

+ NewSender func(ctx context.Context, opts ...SenderOption) (*Sender, error)

+ type SenderOption func(*Sender) error

+ func SenderWithSession(sessionID *string) SenderOption

+ type SessionHandler interface

+ End func()

+ Start func(*MessageSession) error

+ func NewSessionHandler(base Handler, start func(*MessageSession) error, end func()) SessionHandler

type Subscription

+ func (re Subscription) Peek(ctx context.Context, options ...PeekOption) (MessageIterator, error)

+ func (re Subscription) PeekOne(ctx context.Context, options ...PeekOption) (*Message, error)

+ func (re Subscription) ReceiveDeferred(ctx context.Context, handler Handler, sequenceNumbers ...int64) error

+ func (re Subscription) ReceiveDeferredWithMode(ctx context.Context, handler Handler, mode ReceiveMode, ...) error

+ func (re Subscription) RenewLocks(ctx context.Context, messages ...*Message) error

+ func (re Subscription) SendBatchDisposition(ctx context.Context, iterator BatchDispositionIterator) error

+ func (s *Subscription) NewDeadLetter() *DeadLetter

+ func (s *Subscription) NewDeadLetterReceiver(ctx context.Context, opts ...ReceiverOption) (ReceiveOner, error)

+ func (s *Subscription) NewReceiver(ctx context.Context, opts ...ReceiverOption) (*Receiver, error)

+ func (s *Subscription) NewSession(sessionID *string) *SubscriptionSession

+ func (s *Subscription) NewTransferDeadLetter() *TransferDeadLetter

+ func (s *Subscription) NewTransferDeadLetterReceiver(ctx context.Context, opts ...ReceiverOption) (ReceiveOner, error)

type SubscriptionDescription

+ CountDetails *CountDetails

+ DefaultRuleDescription *DefaultRuleDescription

+ ForwardDeadLetteredMessagesTo *string

+ ForwardTo *string

type SubscriptionManagementOption

+ func SubscriptionWithAutoForward(target Targetable) SubscriptionManagementOption

+ func SubscriptionWithDefaultRuleDescription(filter FilterDescriber, name string) SubscriptionManagementOption

+ func SubscriptionWithForwardDeadLetteredMessagesTo(target Targetable) SubscriptionManagementOption

type SubscriptionManager

+ func (em SubscriptionManager) TokenProvider() auth.TokenProvider

+ func (em SubscriptionManager) Use(mw ...MiddlewareFunc)

+ func (sm *SubscriptionManager) DeleteRule(ctx context.Context, subscriptionName, ruleName string) error

+ func (sm *SubscriptionManager) ListRules(ctx context.Context, subscriptionName string) ([]*RuleEntity, error)

+ func (sm *SubscriptionManager) PutRule(ctx context.Context, subscriptionName, ruleName string, filter FilterDescriber) (*RuleEntity, error)

+ func (sm *SubscriptionManager) PutRuleWithAction(ctx context.Context, subscriptionName, ruleName string, filter FilterDescriber, ...) (*RuleEntity, error)

type SubscriptionOption

+ func SubscriptionWithPrefetchCount(prefetch uint32) SubscriptionOption

+ type SubscriptionSession struct

+ func NewSubscriptionSession(builder ReceiveBuilder, sessionID *string) *SubscriptionSession

+ func (ss *SubscriptionSession) Close(ctx context.Context) error

+ func (ss *SubscriptionSession) ManagementPath() string

+ func (ss *SubscriptionSession) ReceiveDeferred(ctx context.Context, handler Handler, mode ReceiveMode, ...) error

+ func (ss *SubscriptionSession) ReceiveOne(ctx context.Context, handler SessionHandler) error

+ func (ss *SubscriptionSession) SessionID() *string

type SystemProperties

+ Annotations map[string]interface{}

+ type Targetable interface

+ TargetURI func() string

type Topic

+ func (se Topic) CancelScheduled(ctx context.Context, seq ...int64) error

+ func (se Topic) ScheduleAt(ctx context.Context, enqueueTime time.Time, messages ...*Message) ([]int64, error)

+ func (t *Topic) NewSender(ctx context.Context, opts ...SenderOption) (*Sender, error)

+ func (t *Topic) NewSession(sessionID *string) *TopicSession

+ func (t *Topic) NewTransferDeadLetter() *TransferDeadLetter

+ func (t *Topic) NewTransferDeadLetterReceiver(ctx context.Context, opts ...ReceiverOption) (ReceiveOner, error)

+ func (t *Topic) SendBatch(ctx context.Context, iterator BatchIterator) error

type TopicManager

+ func (em TopicManager) TokenProvider() auth.TokenProvider

+ func (em TopicManager) Use(mw ...MiddlewareFunc)

+ type TopicSession struct

+ func NewTopicSession(builder SenderBuilder, sessionID *string) *TopicSession

+ func (ts *TopicSession) Close(ctx context.Context) error

+ func (ts *TopicSession) Send(ctx context.Context, msg *Message) error

+ func (ts *TopicSession) SessionID() *string

+ type TransferDeadLetter struct

+ func NewTransferDeadLetter(builder TransferDeadLetterBuilder) *TransferDeadLetter

+ func (dl *TransferDeadLetter) Close(ctx context.Context) error

+ func (dl *TransferDeadLetter) ReceiveOne(ctx context.Context, handler Handler) error

+ type TransferDeadLetterBuilder interface

+ NewTransferDeadLetterReceiver func(ctx context.Context, opts ...ReceiverOption) (ReceiveOner, error)

+ type TrueFilter struct

+ func (tf TrueFilter) ToFilterDescription() FilterDescription

v0.1.0

Jul 6, 2018

Changes in this version

+ const Megabytes

+ const Version

+ type BaseEntityDescription struct

+ InstanceMetadataSchema *string

+ ServiceBusSchema *string

+ type CountDetails struct

+ ActiveMessageCount *int32

+ DeadLetterMessageCount *int32

+ ScheduledMessageCount *int32

+ TransferDeadLetterMessageCount *int32

+ TransferMessageCount *int32

+ XMLName xml.Name

+ type DispositionAction func(ctx context.Context)

+ type Handler func(context.Context, *Message) DispositionAction

+ type ListenerHandle struct

+ func (lc *ListenerHandle) Close(ctx context.Context) error

+ func (lc *ListenerHandle) Done() <-chan struct{}

+ func (lc *ListenerHandle) Err() error

+ type Message struct

+ ContentType string

+ CorrelationID string

+ Data []byte

+ DeliveryCount uint32

+ GroupID *string

+ GroupSequence *uint32

+ ID string

+ Label string

+ LockToken *uuid.UUID

+ ReplyTo string

+ ReplyToGroupID string

+ SystemProperties *SystemProperties

+ TTL *time.Duration

+ To string

+ UserProperties map[string]interface{}

+ func NewMessage(data []byte) *Message

+ func NewMessageFromString(message string) *Message

+ func (m *Message) Abandon() DispositionAction

+ func (m *Message) Complete() DispositionAction

+ func (m *Message) DeadLetter(err error) DispositionAction

+ func (m *Message) DeadLetterWithInfo(err error, condition MessageErrorCondition, additionalData map[string]string) DispositionAction

+ func (m *Message) ForeachKey(handler func(key, val string) error) error

+ func (m *Message) Set(key, value string)

+ type MessageErrorCondition string

+ const ErrorDecodeError

+ const ErrorIllegalState

+ const ErrorInternalError

+ const ErrorInvalidField

+ const ErrorNotAllowed

+ const ErrorNotFound

+ const ErrorNotImplemented

+ const ErrorPreconditionFailed

+ const ErrorResourceDeleted

+ const ErrorResourceLimitExceeded

+ const ErrorResourceLocked

+ const ErrorUnauthorizedAccess

+ type MessageWithContext struct

+ Ctx context.Context

+ func (m *MessageWithContext) Abandon()

+ func (m *MessageWithContext) Complete()

+ func (m *MessageWithContext) DeadLetter(err error)

+ func (m *MessageWithContext) DeadLetterWithInfo(err error, condition MessageErrorCondition, additionalData map[string]string)

+ type Namespace struct

+ Environment azure.Environment

+ Name string

+ TokenProvider auth.TokenProvider

+ func NewNamespace(opts ...NamespaceOption) (*Namespace, error)

+ func (ns *Namespace) NewQueue(ctx context.Context, name string, opts ...QueueOption) (*Queue, error)

+ func (ns *Namespace) NewQueueManager() *QueueManager

+ func (ns *Namespace) NewSubscriptionManager(ctx context.Context, topicName string) (*SubscriptionManager, error)

+ func (ns *Namespace) NewTopic(ctx context.Context, name string, opts ...TopicOption) (*Topic, error)

+ func (ns *Namespace) NewTopicManager() *TopicManager

+ type NamespaceOption func(h *Namespace) error

+ func NamespaceWithConnectionString(connStr string) NamespaceOption

+ type Queue struct

+ func (q *Queue) Close(ctx context.Context) error

+ func (q *Queue) Receive(ctx context.Context, handler Handler) (*ListenerHandle, error)

+ func (q *Queue) ReceiveOne(ctx context.Context) (*MessageWithContext, error)

+ func (q *Queue) Send(ctx context.Context, event *Message) error

+ type QueueDescription struct

+ AutoDeleteOnIdle *string

+ CountDetails *CountDetails

+ CreatedAt *date.Time

+ DeadLetteringOnMessageExpiration *bool

+ DefaultMessageTimeToLive *string

+ DuplicateDetectionHistoryTimeWindow *string

+ EnableBatchedOperations *bool

+ EnableExpress *bool

+ EnablePartitioning *bool

+ IsAnonymousAccessible *bool

+ LockDuration *string

+ MaxDeliveryCount *int32

+ MaxSizeInMegabytes *int32

+ MessageCount *int64

+ RequiresDuplicateDetection *bool

+ RequiresSession *bool

+ SizeInBytes *int64

+ Status *servicebus.EntityStatus

+ SupportOrdering *bool

+ UpdatedAt *date.Time

+ XMLName xml.Name

+ type QueueEntity struct

+ Name string

+ type QueueManagementOption func(*QueueDescription) error

+ func QueueEntityWithAutoDeleteOnIdle(window *time.Duration) QueueManagementOption

+ func QueueEntityWithDeadLetteringOnMessageExpiration() QueueManagementOption

+ func QueueEntityWithDuplicateDetection(window *time.Duration) QueueManagementOption

+ func QueueEntityWithLockDuration(window *time.Duration) QueueManagementOption

+ func QueueEntityWithMaxDeliveryCount(count int32) QueueManagementOption

+ func QueueEntityWithMaxSizeInMegabytes(size int) QueueManagementOption

+ func QueueEntityWithMessageTimeToLive(window *time.Duration) QueueManagementOption

+ func QueueEntityWithPartitioning() QueueManagementOption

+ func QueueEntityWithRequiredSessions() QueueManagementOption

+ type QueueManager struct

+ func (em QueueManager) Execute(ctx context.Context, method string, entityPath string, body io.Reader) (*http.Response, error)

+ func (em QueueManager) Post(ctx context.Context, entityPath string, body []byte) (*http.Response, error)

+ func (qm *QueueManager) Delete(ctx context.Context, name string) error

+ func (qm *QueueManager) Get(ctx context.Context, name string) (*QueueEntity, error)

+ func (qm *QueueManager) List(ctx context.Context) ([]*QueueEntity, error)

+ func (qm *QueueManager) Put(ctx context.Context, name string, opts ...QueueManagementOption) (*QueueEntity, error)

+ type QueueOption func(*Queue) error

+ func QueueWithReceiveAndDelete() QueueOption

+ type ReceiveMode int

+ const PeekLockMode

+ const ReceiveAndDeleteMode

+ type SendOption func(event *Message) error

+ type Subscription struct

+ Topic *Topic

+ func (s *Subscription) Close(ctx context.Context) error

+ func (s *Subscription) Receive(ctx context.Context, handler Handler) (*ListenerHandle, error)

+ func (s *Subscription) ReceiveOne(ctx context.Context) (*MessageWithContext, error)

+ type SubscriptionDescription struct

+ AccessedAt *date.Time

+ AutoDeleteOnIdle *string

+ CreatedAt *date.Time

+ DeadLetteringOnFilterEvaluationExceptions *bool

+ DeadLetteringOnMessageExpiration *bool

+ DefaultMessageTimeToLive *string

+ EnableBatchedOperations *bool

+ LockDuration *string

+ MaxDeliveryCount *int32

+ MessageCount *int64

+ RequiresSession *bool

+ Status *servicebus.EntityStatus

+ UpdatedAt *date.Time

+ XMLName xml.Name

+ type SubscriptionEntity struct

+ Name string

+ type SubscriptionManagementOption func(*SubscriptionDescription) error

+ func SubscriptionWithAutoDeleteOnIdle(window *time.Duration) SubscriptionManagementOption

+ func SubscriptionWithBatchedOperations() SubscriptionManagementOption

+ func SubscriptionWithDeadLetteringOnMessageExpiration() SubscriptionManagementOption

+ func SubscriptionWithLockDuration(window *time.Duration) SubscriptionManagementOption

+ func SubscriptionWithMessageTimeToLive(window *time.Duration) SubscriptionManagementOption

+ func SubscriptionWithRequiredSessions() SubscriptionManagementOption

+ type SubscriptionManager struct

+ Topic *Topic

+ func (em SubscriptionManager) Execute(ctx context.Context, method string, entityPath string, body io.Reader) (*http.Response, error)

+ func (em SubscriptionManager) Post(ctx context.Context, entityPath string, body []byte) (*http.Response, error)

+ func (sm *SubscriptionManager) Delete(ctx context.Context, name string) error

+ func (sm *SubscriptionManager) Get(ctx context.Context, name string) (*SubscriptionEntity, error)

+ func (sm *SubscriptionManager) List(ctx context.Context) ([]*SubscriptionEntity, error)

+ func (sm *SubscriptionManager) Put(ctx context.Context, name string, opts ...SubscriptionManagementOption) (*SubscriptionEntity, error)

+ type SubscriptionOption func(*Subscription) error

+ func SubscriptionWithReceiveAndDelete() SubscriptionOption

+ type SystemProperties struct

+ DeadLetterSource *string

+ EnqueuedSequenceNumber *int64

+ EnqueuedTime *time.Time

+ LockedUntil *time.Time

+ PartitionID *int16

+ PartitionKey *string

+ ScheduledEnqueueTime *time.Time

+ SequenceNumber *int64

+ ViaPartitionKey *string

+ type Topic struct

+ func (t *Topic) Close(ctx context.Context) error

+ func (t *Topic) NewSubscription(ctx context.Context, name string, opts ...SubscriptionOption) (*Subscription, error)

+ func (t *Topic) NewSubscriptionManager() *SubscriptionManager

+ func (t *Topic) Send(ctx context.Context, event *Message, opts ...SendOption) error

+ type TopicDescription struct

+ AutoDeleteOnIdle *string

+ CountDetails *CountDetails

+ CreatedAt *date.Time

+ DefaultMessageTimeToLive *string

+ DuplicateDetectionHistoryTimeWindow *string

+ EnableBatchedOperations *bool

+ EnableExpress *bool

+ EnablePartitioning *bool

+ EnableSubscriptionPartitioning *bool

+ FilteringMessagesBeforePublishing *bool

+ IsAnonymousAccessible *bool

+ MaxSizeInMegabytes *int32

+ RequiresDuplicateDetection *bool

+ SizeInBytes *int64

+ Status *servicebus.EntityStatus

+ SupportOrdering *bool

+ UpdatedAt *date.Time

+ XMLName xml.Name

+ type TopicEntity struct

+ Name string

+ type TopicManagementOption func(*TopicDescription) error

+ func TopicWithAutoDeleteOnIdle(window *time.Duration) TopicManagementOption

+ func TopicWithBatchedOperations() TopicManagementOption

+ func TopicWithDuplicateDetection(window *time.Duration) TopicManagementOption

+ func TopicWithExpress() TopicManagementOption

+ func TopicWithMaxSizeInMegabytes(size int) TopicManagementOption

+ func TopicWithMessageTimeToLive(window *time.Duration) TopicManagementOption

+ func TopicWithOrdering() TopicManagementOption

+ func TopicWithPartitioning() TopicManagementOption

+ type TopicManager struct

+ func (em TopicManager) Execute(ctx context.Context, method string, entityPath string, body io.Reader) (*http.Response, error)

+ func (em TopicManager) Post(ctx context.Context, entityPath string, body []byte) (*http.Response, error)

+ func (tm *TopicManager) Delete(ctx context.Context, name string) error

+ func (tm *TopicManager) Get(ctx context.Context, name string) (*TopicEntity, error)

+ func (tm *TopicManager) List(ctx context.Context) ([]*TopicEntity, error)

+ func (tm *TopicManager) Put(ctx context.Context, name string, opts ...TopicManagementOption) (*TopicEntity, error)

+ type TopicOption func(*Topic) error

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