internal

package

Go to main page

Versions in this module

v1

v1.8.0-beta.1

May 1, 2024

v1.7.0

Apr 2, 2024

v1.6.1

Mar 4, 2024

Changes in this version

+ func SettleOnMgmtLink(ctx context.Context, rpcLink amqpwrap.RPCLink, linkName string, ...) error

v1.6.0

Jan 17, 2024

v1.5.0

Oct 2, 2023

v1.4.1

Sep 6, 2023

v1.4.0

Jun 6, 2023

v1.3.0

May 8, 2023

Changes in this version

+ func IsLinkError(err error) bool

type AMQPLinks

+ Prefix func() string

+ Writef func(evt azlog.Event, format string, args ...any)

type FakeAMQPLinks

+ func (l *FakeAMQPLinks) Prefix() string

+ func (l *FakeAMQPLinks) Writef(evt azlog.Event, format string, args ...any)

type FakeAMQPSender

+ func (s *FakeAMQPSender) LinkName() string

v1.2.1

Mar 7, 2023

Changes in this version

+ func IsNotAllowedError(err error) bool

v1.2.0

Feb 7, 2023

Changes in this version

type NamespaceForAMQPLinks

+ Check func() error

type NamespaceOption

+ func NamespaceWithNewClientFn(fn func(ctx context.Context) (amqpwrap.AMQPClient, error)) NamespaceOption

v1.1.4

Jan 4, 2023

v1.1.3

Nov 17, 2022

v1.1.2

Nov 8, 2022

retracted

Changes in this version

+ func IsLocalIdleError(err error) bool

type FakeAMQPLinks

+ CloseIfNeededArgs []error

+ GetFn func(ctx context.Context) (*LinksWithID, error)

+ type LocalIdleTracker struct

+ IdleStart time.Time

+ MaxDuration time.Duration

+ func (idle *LocalIdleTracker) Check(parentCtx context.Context, operationStart time.Time, err error) error

+ func (idle *LocalIdleTracker) NewContextWithDeadline(ctx context.Context) (context.Context, context.CancelFunc)

v1.1.1

Oct 4, 2022

v1.1.0

Aug 9, 2022

Changes in this version

type FakeAMQPReceiver

+ CreditsCalled int

+ CreditsImpl func() uint32

+ PrefetchedResults []*amqp.Message

+ ReleaseMessageCalled int

+ ReleaseMessageFn func(ctx context.Context, msg *amqp.Message) error

+ func (r *FakeAMQPReceiver) Credits() uint32

+ func (r *FakeAMQPReceiver) ReleaseMessage(ctx context.Context, msg *amqp.Message) error

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 FakeAMQPReceiver

+ func (r *FakeAMQPReceiver) LinkName() string

v1.0.0

May 16, 2022

v0

v0.4.1

May 12, 2022

Changes in this version

+ func TransformError(err error) error

type FakeAMQPReceiver

+ CloseFn func(ctx context.Context) error

type FakeAMQPSession

+ NewReceiverFn func(opts ...amqp.LinkOption) (AMQPReceiverCloser, error)

+ func (s *FakeAMQPSession) NewReceiver(opts ...amqp.LinkOption) (AMQPReceiverCloser, error)

+ type FakeRPCLink struct

+ Error error

+ Resp *RPCResponse

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

+ func (r *FakeRPCLink) RPC(ctx context.Context, msg *amqp.Message) (*RPCResponse, error)

type Namespace

+ RetryOptions exported.RetryOptions

+ type RPCError struct

+ Message string

+ Resp *RPCResponse

+ func (e RPCError) Error() string

+ func (e RPCError) RPCCode() int

v0.4.0

Apr 6, 2022

Changes in this version

+ const RPCResponseCodeLockLost

+ var ErrClientClosed = NewErrNonRetriable("client has been closed by user")

+ func NegotiateClaim(ctx context.Context, audience string, conn *amqp.Client, ...) error

type FakeAMQPReceiver

+ ReceiveFn func(ctx context.Context) (*amqp.Message, error)

type FakeNS

+ func (ns *FakeNS) Check() error

type Namespace

+ func (ns *Namespace) Check() error

type NamespaceWithNewAMQPLinks

+ Check func() error

+ type NewAMQPLinksArgs struct

+ CreateLinkFunc CreateLinkFunc

+ EntityPath string

+ GetRecoveryKindFunc func(err error) RecoveryKind

+ NS NamespaceForAMQPLinks

+ type RPCLinkArgs struct

+ Address string

+ Client amqpwrap.AMQPClient

+ LogEvent azlog.Event

+ type RecoveryKind string

+ func GetRecoveryKindForSession(err error) RecoveryKind

v0.3.6

Mar 8, 2022

Changes in this version

+ func IsDetachError(err error) bool

+ func NewErrNonRetriable(message string) error

type AMQPLinks

+ CloseIfNeeded func(ctx context.Context, err error) recoveryKind

type AMQPLinksImpl

+ func (l *AMQPLinksImpl) CloseIfNeeded(ctx context.Context, err error) recoveryKind

type FakeAMQPLinks

+ CloseIfNeededCalled int

+ func (l *FakeAMQPLinks) CloseIfNeeded(ctx context.Context, err error) recoveryKind

type FakeAMQPReceiver

+ DrainCalled int

+ DrainCreditImpl func(ctx context.Context) error

+ IssueCreditErr error

+ PrefetchResults []struct{ ... }

+ PrefetchedCalled int

+ ReceiveCalled int

type FakeNS

+ CloseCalled int

+ func (ns *FakeNS) Close(ctx context.Context) error

type NamespaceForAMQPLinks

+ Close func(ctx context.Context) error

v0.3.5

Feb 11, 2022

v0.3.4

Feb 8, 2022

Changes in this version

+ const EventAuth

+ const EventConn

+ const EventMgmtLink

+ const EventReceiver

+ func CancelScheduledMessages(ctx context.Context, rpcLink RPCLink, seq []int64) error

+ func GetSessionState(ctx context.Context, rpcLink RPCLink, sessionID string) ([]byte, error)

+ func IsFatalSBError(err error) bool

+ func NewRPCLink(conn *amqp.Client, address string, opts ...RPCLinkOption) (*rpcLink, error)

+ func PeekMessages(ctx context.Context, rpcLink RPCLink, fromSequenceNumber int64, ...) ([]*amqp.Message, error)

+ func ReceiveDeferred(ctx context.Context, rpcLink RPCLink, mode ReceiveMode, ...) ([]*amqp.Message, error)

+ func RenewLocks(ctx context.Context, rpcLink RPCLink, linkName string, lockTokens []amqp.UUID) ([]time.Time, error)

+ func RenewSessionLock(ctx context.Context, rpcLink RPCLink, sessionID string) (time.Time, error)

+ func ScheduleMessages(ctx context.Context, rpcLink RPCLink, enqueueTime time.Time, ...) ([]int64, error)

+ func SendDisposition(ctx context.Context, rpcLink RPCLink, lockToken *amqp.UUID, state Disposition, ...) error

+ func SetSessionState(ctx context.Context, rpcLink RPCLink, sessionID string, state []byte) error

type AMQPLinks

+ func NewAMQPLinks(ns NamespaceForAMQPLinks, entityPath string, createLink CreateLinkFunc) AMQPLinks

+ Retry func(ctx context.Context, name string, fn RetryWithLinksFn, o utils.RetryOptions) error

+ type AMQPLinksImpl struct

+ RPCLink RPCLink

+ Receiver AMQPReceiverCloser

+ Sender AMQPSenderCloser

+ func (l *AMQPLinksImpl) Audience() string

+ func (l *AMQPLinksImpl) Close(ctx context.Context, permanent bool) error

+ func (l *AMQPLinksImpl) ClosedPermanently() bool

+ func (l *AMQPLinksImpl) EntityPath() string

+ func (l *AMQPLinksImpl) Get(ctx context.Context) (*LinksWithID, error)

+ func (l *AMQPLinksImpl) Retry(ctx context.Context, name string, fn RetryWithLinksFn, o utils.RetryOptions) error

+ func (links *AMQPLinksImpl) ManagementPath() string

+ func (links *AMQPLinksImpl) RecoverIfNeeded(ctx context.Context, theirID LinkID, origErr error) error

type FakeAMQPLinks

+ RPC RPCLink

+ func (l *FakeAMQPLinks) Retry(ctx context.Context, name string, fn RetryWithLinksFn, o utils.RetryOptions) error

type FakeAMQPReceiver

+ ReceiveResults ...

+ RequestedCredits uint32

+ func (r *FakeAMQPReceiver) IssueCredit(credit uint32) error

+ func (r *FakeAMQPReceiver) Prefetched(ctx context.Context) (*amqp.Message, error)

+ func (r *FakeAMQPReceiver) Receive(ctx context.Context) (*amqp.Message, error)

type FakeNS

+ func (ns *FakeNS) CloseIfNeeded(ctx context.Context, clientRevision uint64) error

+ type LinkID struct

+ Conn uint64

+ Link uint64

+ type LinksWithID struct

+ ID LinkID

+ RPC RPCLink

+ Receiver AMQPReceiver

+ Sender AMQPSender

type Namespace

+ func (ns *Namespace) GetAMQPClientImpl(ctx context.Context) (*amqp.Client, uint64, error)

type NamespaceForAMQPLinks

+ NewRPCLink func(ctx context.Context, managementPath string) (RPCLink, error)

type NamespaceOption

+ func NamespaceWithRetryOptions(retryOptions utils.RetryOptions) NamespaceOption

+ func NamespaceWithTokenCredential(fullyQualifiedNamespace string, tokenCredential azcore.TokenCredential) NamespaceOption

type RPCLink

+ RPC func(ctx context.Context, msg *amqp.Message) (*RPCResponse, error)

+ type RPCLinkOption func(link *rpcLink) error

+ type RPCResponse struct

+ Code int

+ Description string

+ Message *amqp.Message

+ type RetryWithLinksFn func(ctx context.Context, lwid *LinksWithID, args *utils.RetryFnArgs) error

+ type SBErrInfo struct

+ RecoveryKind recoveryKind

+ func GetSBErrInfo(err error) *SBErrInfo

+ func (sbe *SBErrInfo) AsError() error

+ func (sbe *SBErrInfo) String() string

v0.3.3

Jan 12, 2022

Changes in this version

+ const EventRetry

+ const RecoveryKindConn

+ const RecoveryKindFatal

+ const RecoveryKindLink

+ const RecoveryKindNone

+ func GetRecoveryKind(ctxForLogging context.Context, err error) recoveryKind

+ func Retry(ctx context.Context, name string, ...) error

+ type ErrNonRetriable struct

+ Message string

+ func (e ErrNonRetriable) Error() string

+ type RetryFnArgs struct

+ I int32

+ LastErr error

+ func (rf *RetryFnArgs) ResetAttempts()

+ type RetryOptions struct

+ MaxRetries int32

+ MaxRetryDelay time.Duration

+ RetryDelay time.Duration

+ type ServiceBusError struct

+ RecoveryKind recoveryKind

+ func ToSBE(loggingCtx context.Context, err error) *ServiceBusError

+ func (sbe *ServiceBusError) AsError() error

+ func (sbe *ServiceBusError) String() string

v0.3.2

Dec 8, 2021

Changes in this version

type Namespace

+ FQDN string

+ type NewWebSocketConnArgs struct

+ Host string

v0.3.1

Nov 16, 2021

v0.3.0

Nov 12, 2021

Changes in this version

type AMQPReceiver

+ Prefetched func(ctx context.Context) (*amqp.Message, error)

v0.2.0

Nov 3, 2021

Changes in this version

+ func IsSessionLockedError(err error) bool

type AMQPReceiver

+ LinkName func() string

+ LinkSourceFilterValue func(name string) interface{}

type MgmtClient

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

+ GetSessionState func(ctx context.Context, sessionID string) ([]byte, error)

+ RenewLocks func(ctx context.Context, linkName string, lockTokens []amqp.UUID) ([]time.Time, error)

+ RenewSessionLock func(ctx context.Context, sessionID string) (time.Time, error)

+ ScheduleMessages func(ctx context.Context, enqueueTime time.Time, messages ...*amqp.Message) ([]int64, error)

+ SetSessionState func(ctx context.Context, sessionID string, state []byte) error

v0.1.0

Oct 5, 2021

Changes in this version

+ const SpanCompleteMessage

+ const SpanNegotiateClaim

+ const SpanProcessorClose

+ const SpanProcessorLoop

+ const SpanProcessorMessage

+ const SpanRecover

+ const SpanRecoverClient

+ const SpanRecoverLink

+ const SpanSendMessageFmt

+ const Version

+ func ApplyComponentInfo(span tab.Spanner)

+ func ConstructAtomPath(basePath string, skip int, top int) string

+ func IsCancelError(err error) bool

+ func IsDrainingError(err error) bool

+ func IsErrNotFound(err error) bool

+ func IsNonRetriable(err error) bool

+ func ShouldRecover(ctx context.Context, err error) bool

+ type AMQPLinks interface

+ Audience func() string

+ Close func(ctx context.Context, permanent bool) error

+ ClosedPermanently func() bool

+ EntityPath func() string

+ Get func(ctx context.Context) (AMQPSender, AMQPReceiver, MgmtClient, uint64, error)

+ ManagementPath func() string

+ RecoverIfNeeded func(ctx context.Context, linksRevision uint64, err error) error

+ type AMQPReceiver interface

+ AcceptMessage func(ctx context.Context, msg *amqp.Message) error

+ DrainCredit func(ctx context.Context) error

+ IssueCredit func(credit uint32) error

+ ModifyMessage func(ctx context.Context, msg *amqp.Message, deliveryFailed, undeliverableHere bool, ...) error

+ Receive func(ctx context.Context) (*amqp.Message, error)

+ RejectMessage func(ctx context.Context, msg *amqp.Message, e *amqp.Error) error

+ ReleaseMessage func(ctx context.Context, msg *amqp.Message) error

+ type AMQPReceiverCloser interface

+ Close func(ctx context.Context) error

+ type AMQPSender interface

+ MaxMessageSize func() uint64

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

+ type AMQPSenderCloser interface

+ Close func(ctx context.Context) error

+ type AMQPSession interface

+ NewReceiver func(opts ...amqp.LinkOption) (*amqp.Receiver, error)

+ NewSender func(opts ...amqp.LinkOption) (*amqp.Sender, error)

+ type AMQPSessionCloser interface

+ Close func(ctx context.Context) error

+ type ActionDescriber interface

+ ToActionDescription func() ActionDescription

+ type ActionDescription struct

+ CompatibilityLevel int

+ RequiresPreprocessing bool

+ SQLExpression string

+ Type string

+ type BackoffRetrierParams struct

+ Factor float64

+ Jitter bool

+ Max time.Duration

+ MaxRetries int

+ Min time.Duration

+ type BaseEntityDescription struct

+ InstanceMetadataSchema *string

+ ServiceBusSchema *string

+ type Closeable 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 CountDetails struct

+ ActiveMessageCount *int32

+ DeadLetterMessageCount *int32

+ ScheduledMessageCount *int32

+ TransferDeadLetterMessageCount *int32

+ TransferMessageCount *int32

+ XMLName xml.Name

+ type CreateLinkFunc func(ctx context.Context, session AMQPSession) (AMQPSenderCloser, AMQPReceiverCloser, error)

+ type DefaultRuleDescription struct

+ Filter FilterDescription

+ Name *string

+ XMLName xml.Name

+ type Disposition struct

+ DeadLetterDescription *string

+ DeadLetterReason *string

+ LockTokens []*uuid.UUID

+ Status DispositionStatus

+ type DispositionStatus string

+ const AbandonedDisposition

+ const CompletedDisposition

+ const DeferredDisposition

+ const SuspendedDisposition

+ type Entity struct

+ ID string

+ Name string

+ func (e Entity) TargetURI() 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 NewErrIncorrectType(key string, expected, actual interface{}) ErrIncorrectType

+ 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 FakeAMQPLinks struct

+ Closed int

+ Err error

+ Mgmt MgmtClient

+ Receiver AMQPReceiver

+ Revision uint64

+ Sender AMQPSender

+ func (l *FakeAMQPLinks) Close(ctx context.Context, permanently bool) error

+ func (l *FakeAMQPLinks) ClosedPermanently() bool

+ func (l *FakeAMQPLinks) Get(ctx context.Context) (AMQPSender, AMQPReceiver, MgmtClient, uint64, error)

+ type FakeAMQPReceiver struct

+ Closed int

+ Drain int

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

+ func (r *FakeAMQPReceiver) DrainCredit(ctx context.Context) error

+ type FakeAMQPSender struct

+ Closed int

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

+ type FakeAMQPSession struct

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

+ type FakeNS struct

+ AMQPLinks *FakeAMQPLinks

+ MgmtClient MgmtClient

+ RPCLink *rpc.Link

+ Session AMQPSessionCloser

+ func (ns *FakeNS) GetEntityAudience(entityPath string) string

+ func (ns *FakeNS) NegotiateClaim(ctx context.Context, entityPath string) (func() <-chan struct{}, error)

+ func (ns *FakeNS) NewAMQPLinks(entityPath string, createLinkFunc CreateLinkFunc) AMQPLinks

+ func (ns *FakeNS) NewAMQPSession(ctx context.Context) (AMQPSessionCloser, uint64, error)

+ func (ns *FakeNS) NewMgmtClient(ctx context.Context, links AMQPLinks) (MgmtClient, error)

+ func (ns *FakeNS) NewRPCLink(ctx context.Context, managementPath string) (*rpc.Link, error)

+ func (ns *FakeNS) Recover(ctx context.Context, clientRevision uint64) error

+ 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 ListQueuesOption func(*ListQueuesOptions) error

+ func ListQueuesWithSkip(skip int) ListQueuesOption

+ func ListQueuesWithTop(top int) ListQueuesOption

+ type ListQueuesOptions struct

+ type ListSubscriptionsOption func(*ListSubscriptionsOptions) error

+ func ListSubscriptionsWithSkip(skip int) ListSubscriptionsOption

+ func ListSubscriptionsWithTop(top int) ListSubscriptionsOption

+ type ListSubscriptionsOptions struct

+ type ListTopicsOption func(*ListTopicsOptions) error

+ func ListTopicsWithSkip(skip int) ListTopicsOption

+ func ListTopicsWithTop(top int) ListTopicsOption

+ type ListTopicsOptions struct

+ type MgmtClient interface

+ Close func(ctx context.Context) error

+ PeekMessages func(ctx context.Context, fromSequenceNumber int64, messageCount int32) ([]*amqp.Message, error)

+ ReceiveDeferred func(ctx context.Context, mode ReceiveMode, sequenceNumbers []int64) ([]*amqp.Message, error)

+ SendDisposition func(ctx context.Context, lockToken *amqp.UUID, state Disposition) error

+ type MiddlewareFunc func(next RestHandler) RestHandler

+ func TraceReqAndResponseMiddleware() MiddlewareFunc

+ type Namespace struct

+ Environment azure.Environment

+ Name string

+ Suffix string

+ TokenProvider *tokenProvider

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

+ func (ns *Namespace) Close(ctx context.Context) error

+ func (ns *Namespace) GetEntityAudience(entityPath string) string

+ func (ns *Namespace) GetHTTPSHostURI() string

+ func (ns *Namespace) GetHostname() string

+ func (ns *Namespace) NegotiateClaim(ctx context.Context, entityPath string) (func() <-chan struct{}, error)

+ func (ns *Namespace) NewAMQPLinks(entityPath string, createLinkFunc CreateLinkFunc) AMQPLinks

+ func (ns *Namespace) NewAMQPSession(ctx context.Context) (AMQPSessionCloser, uint64, error)

+ func (ns *Namespace) NewMgmtClient(ctx context.Context, l AMQPLinks) (MgmtClient, error)

+ func (ns *Namespace) NewRPCLink(ctx context.Context, managementPath string) (*rpc.Link, error)

+ func (ns *Namespace) NewSubscriptionManager(topicName string) (*SubscriptionManager, error)

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

+ func (ns *Namespace) Recover(ctx context.Context, clientRevision uint64) error

+ type NamespaceForAMQPLinks interface

+ GetEntityAudience func(entityPath string) string

+ NegotiateClaim func(ctx context.Context, entityPath string) (func() <-chan struct{}, error)

+ NewAMQPSession func(ctx context.Context) (AMQPSessionCloser, uint64, error)

+ NewMgmtClient func(ctx context.Context, links AMQPLinks) (MgmtClient, error)

+ Recover func(ctx context.Context, clientRevision uint64) error

+ type NamespaceForMgmtClient interface

+ NewRPCLink func(ctx context.Context, managementPath string) (*rpc.Link, error)

+ type NamespaceOption func(h *Namespace) error

+ func NamespaceWithAzureEnvironment(namespaceName, environmentName string) NamespaceOption

+ func NamespaceWithConnectionString(connStr string) NamespaceOption

+ func NamespaceWithTLSConfig(tlsConfig *tls.Config) NamespaceOption

+ func NamespaceWithUserAgent(userAgent string) NamespaceOption

+ func NamespaceWithWebSocket() NamespaceOption

+ func NamespacesWithTokenCredential(fullyQualifiedNamespace string, tokenCredential azcore.TokenCredential) NamespaceOption

+ type NamespaceWithNewAMQPLinks interface

+ NewAMQPLinks func(entityPath string, createLinkFunc CreateLinkFunc) AMQPLinks

+ type NonRetriable interface

+ NonRetriable func()

+ type QueueDescription struct

+ AutoDeleteOnIdle *string

+ CountDetails *CountDetails

+ CreatedAt *date.Time

+ DeadLetteringOnMessageExpiration *bool

+ DefaultMessageTimeToLive *string

+ DuplicateDetectionHistoryTimeWindow *string

+ EnableBatchedOperations *bool

+ EnableExpress *bool

+ EnablePartitioning *bool

+ ForwardDeadLetteredMessagesTo *string

+ ForwardTo *string

+ IsAnonymousAccessible *bool

+ LockDuration *string

+ MaxDeliveryCount *int32

+ MaxSizeInMegabytes *int32

+ MessageCount *int64

+ RequiresDuplicateDetection *bool

+ RequiresSession *bool

+ SizeInBytes *int64

+ Status *EntityStatus

+ SupportOrdering *bool

+ UpdatedAt *date.Time

+ XMLName xml.Name

+ type QueueEntity struct

+ type QueueManagementOption func(*QueueDescription) error

+ func QueueEntityWithAutoDeleteOnIdle(window *time.Duration) QueueManagementOption

+ func QueueEntityWithAutoForward(target Targetable) QueueManagementOption

+ func QueueEntityWithDeadLetteringOnMessageExpiration() QueueManagementOption

+ func QueueEntityWithDuplicateDetection(window *time.Duration) QueueManagementOption

+ func QueueEntityWithForwardDeadLetteredMessagesTo(target Targetable) 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 NewQueueManager(httpsHostURI string, tokenProvider auth.TokenProvider) *QueueManager

+ 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, mw ...MiddlewareFunc) (*http.Response, error)

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

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

+ 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, options ...ListQueuesOption) ([]*QueueEntity, error)

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

+ type RPCLink interface

+ Close func(ctx context.Context) error

+ RetryableRPC func(ctx context.Context, times int, delay time.Duration, msg *amqp.Message) (*rpc.Response, error)

+ type ReceiveMode int

+ const PeekLock

+ const ReceiveAndDelete

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

+ type Retrier interface

+ Copy func() Retrier

+ CurrentTry func() int

+ Exhausted func() bool

+ Try func(ctx context.Context) bool

+ func NewBackoffRetrier(params BackoffRetrierParams) Retrier

+ 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 SubscriptionDescription struct

+ AccessedAt *date.Time

+ AutoDeleteOnIdle *string

+ CountDetails *CountDetails

+ CreatedAt *date.Time

+ DeadLetteringOnFilterEvaluationExceptions *bool

+ DeadLetteringOnMessageExpiration *bool

+ DefaultMessageTimeToLive *string

+ DefaultRuleDescription *DefaultRuleDescription

+ EnableBatchedOperations *bool

+ ForwardDeadLetteredMessagesTo *string

+ ForwardTo *string

+ LockDuration *string

+ MaxDeliveryCount *int32

+ MessageCount *int64

+ RequiresSession *bool

+ Status *EntityStatus

+ UpdatedAt *date.Time

+ XMLName xml.Name

+ type SubscriptionEntity struct

+ type SubscriptionManagementOption func(*SubscriptionDescription) error

+ func SubscriptionWithAutoDeleteOnIdle(window *time.Duration) SubscriptionManagementOption

+ func SubscriptionWithAutoForward(target Targetable) SubscriptionManagementOption

+ func SubscriptionWithBatchedOperations() SubscriptionManagementOption

+ func SubscriptionWithDeadLetteringOnMessageExpiration() SubscriptionManagementOption

+ func SubscriptionWithDefaultRuleDescription(filter FilterDescriber, name string) SubscriptionManagementOption

+ func SubscriptionWithForwardDeadLetteredMessagesTo(target Targetable) SubscriptionManagementOption

+ func SubscriptionWithLockDuration(window *time.Duration) SubscriptionManagementOption

+ func SubscriptionWithMessageTimeToLive(window *time.Duration) SubscriptionManagementOption

+ func SubscriptionWithRequiredSessions() SubscriptionManagementOption

+ type SubscriptionManager struct

+ 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, mw ...MiddlewareFunc) (*http.Response, error)

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

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

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

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

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

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

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

+ func (sm *SubscriptionManager) Put(ctx context.Context, name string, opts ...SubscriptionManagementOption) (*SubscriptionEntity, 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 Targetable interface

+ TargetURI func() string

+ 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 *EntityStatus

+ SupportOrdering *bool

+ UpdatedAt *date.Time

+ XMLName xml.Name

+ type TopicEntity struct

+ 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, mw ...MiddlewareFunc) (*http.Response, error)

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

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

+ 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, options ...ListTopicsOption) ([]*TopicEntity, error)

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

+ type TrueFilter struct

+ func (tf TrueFilter) ToFilterDescription() FilterDescription

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