internal

package

Go to main page

Versions in this module

v1

v1.2.1

May 20, 2024

v1.2.0

May 7, 2024

v1.1.0

Apr 2, 2024

v1.0.4

Mar 4, 2024

v1.0.3

Jan 8, 2024

v1.0.2

Nov 7, 2023

v1.0.1

Jun 6, 2023

Changes in this version

+ var RPCLinkClosedErr = errors.New("rpc link closed")

+ type LinkRetrier struct

+ CloseLink func(ctx context.Context, partitionID string, linkName string) error

+ GetLink func(ctx context.Context, partitionID string) (LinkWithID[LinkT], error)

+ NSRecover func(ctx context.Context, connID uint64) error

+ func (l LinkRetrier[LinkT]) RecoverIfNeeded(ctx context.Context, err error) error

+ func (l LinkRetrier[LinkT]) Retry(ctx context.Context, eventName azlog.Event, operation string, ...) error

type LinkWithID

+ Close func(ctx context.Context) error

type Links

+ func (l *Links[LinkT]) RetryManagement(ctx context.Context, eventName log.Event, operation string, ...) error

+ type RetryCallback func(ctx context.Context, lwid LinkWithID[LinkT]) error

v1.0.0

May 8, 2023

v0

v0.6.0

Mar 7, 2023

Changes in this version

+ func IsNotAllowedError(err error) bool

v0.5.0

Feb 8, 2023

v0.4.0

Jan 5, 2023

Changes in this version

type LinkWithID

+ PartitionID string

+ func (lwid *LinkWithID[LinkT]) String() string

v0.3.0

Nov 10, 2022

v0.2.0

Oct 17, 2022

Changes in this version

+ func IsOwnershipLostError(err error) bool

+ type FakeAMQPReceiver struct

+ ActiveCredits uint32

+ CloseCalled int

+ CloseError error

+ CreditsSetFromOptions uint32

+ IssuedCredit []uint32

+ ManualCreditsSetFromOptions bool

+ Messages []*amqp.Message

+ NameForLink string

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

+ func (r *FakeAMQPReceiver) Credits() uint32

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

+ func (r *FakeAMQPReceiver) LinkName() string

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

+ type FakeAMQPSender struct

+ CloseCalled int

+ CloseError error

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

+ type FakeAMQPSession struct

+ CloseCalled int

+ NS *FakeNSForPartClient

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

+ func (sess *FakeAMQPSession) NewReceiver(ctx context.Context, source string, opts *amqp.ReceiverOptions) (amqpwrap.AMQPReceiverCloser, error)

+ func (sess *FakeAMQPSession) NewSender(ctx context.Context, target string, opts *amqp.SenderOptions) (AMQPSenderCloser, error)

+ type FakeNSForPartClient struct

+ NewReceiverCalled int

+ NewReceiverErr error

+ NewSenderCalled int

+ NewSenderErr error

+ Receiver *FakeAMQPReceiver

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

+ Sender *FakeAMQPSender

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

+ func (ns *FakeNSForPartClient) NewAMQPSession(ctx context.Context) (amqpwrap.AMQPSession, uint64, error)

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

v0.1.1

Sep 8, 2022

Changes in this version

+ func IsQuickRecoveryError(err error) bool

+ type LinksForPartitionClient interface

+ Close func(ctx context.Context) error

+ RecoverIfNeeded func(ctx context.Context, partitionID string, lwid *LinkWithID[LinkT], err error) error

+ Retry func(ctx context.Context, eventName log.Event, operation string, partitionID string, ...) error

v0.1.0

Aug 11, 2022

Changes in this version

+ const RPCResponseCodeLockLost

+ const Version

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

+ func IsCancelError(err error) bool

+ func IsDetachError(err error) bool

+ func IsDrainingError(err error) bool

+ func IsErrNotFound(err error) bool

+ func IsFatalEHError(err error) bool

+ func NegotiateClaim(ctx context.Context, audience string, conn amqpwrap.AMQPClient, ...) error

+ func NewErrNonRetriable(message string) error

+ func NewRPCLink(ctx context.Context, args RPCLinkArgs) (*rpcLink, error)

+ func TransformError(err error) error

+ type AMQPLink interface

+ Close func(ctx context.Context) error

+ LinkName func() string

+ type AMQPReceiver = amqpwrap.AMQPReceiver

+ type AMQPReceiverCloser = amqpwrap.AMQPReceiverCloser

+ type AMQPSender = amqpwrap.AMQPSender

+ type AMQPSenderCloser = amqpwrap.AMQPSenderCloser

+ type Closeable interface

+ Close func(ctx context.Context) error

+ type ErrAMQP RPCResponse

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

+ ConnID uint64

+ Link LinkT

+ type Links struct

+ func NewLinks(ns NamespaceForAMQPLinks, managementPath string, ...) *Links[LinkT]

+ func (l *Links[LinkT]) Close(ctx context.Context) error

+ func (l *Links[LinkT]) CloseLink(ctx context.Context, partitionID string) error

+ func (l *Links[LinkT]) GetLink(ctx context.Context, partitionID string) (*LinkWithID[LinkT], error)

+ func (l *Links[LinkT]) GetManagementLink(ctx context.Context) (LinkWithID[RPCLink], error)

+ func (l *Links[LinkT]) RecoverIfNeeded(ctx context.Context, partitionID string, lwid *LinkWithID[LinkT], err error) error

+ func (l *Links[LinkT]) Retry(ctx context.Context, eventName log.Event, operation string, partitionID string, ...) error

+ type Namespace struct

+ FQDN string

+ RetryOptions exported.RetryOptions

+ TokenProvider *sbauth.TokenProvider

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

+ func (ns *Namespace) Check() error

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

+ func (ns *Namespace) GetAMQPClientImpl(ctx context.Context) (amqpwrap.AMQPClient, uint64, error)

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

+ func (ns *Namespace) GetHTTPSHostURI() string

+ func (ns *Namespace) GetTokenForEntity(eventHub string) (*auth.Token, error)

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

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

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

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

+ type NamespaceForAMQPLinks interface

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

+ GetEntityAudience func(entityPath string) string

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

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

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

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

+ type NamespaceForManagementOps interface

+ GetTokenForEntity func(eventHub string) (*auth.Token, error)

+ type NamespaceForProducerOrConsumer = NamespaceForManagementOps

+ type NamespaceOption func(h *Namespace) error

+ func NamespaceWithConnectionString(connStr string) NamespaceOption

+ func NamespaceWithRetryOptions(retryOptions exported.RetryOptions) NamespaceOption

+ func NamespaceWithTLSConfig(tlsConfig *tls.Config) NamespaceOption

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

+ func NamespaceWithUserAgent(userAgent string) NamespaceOption

+ func NamespaceWithWebSocket(...) NamespaceOption

+ type NamespaceWithNewAMQPLinks interface

+ Check func() error

+ type NewLinksFn func(ctx context.Context, session amqpwrap.AMQPSession, entityPath string) (LinkT, error)

+ type RPCError struct

+ Message string

+ Resp *RPCResponse

+ func (e RPCError) Error() string

+ func (e RPCError) RPCCode() int

+ type RPCLink interface

+ Close func(ctx context.Context) error

+ LinkName func() string

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

+ type RPCLinkArgs struct

+ Address string

+ Client amqpwrap.AMQPClient

+ LogEvent azlog.Event

+ type RPCLinkOption func(link *rpcLink) error

+ type RPCResponse struct

+ Code int

+ Description string

+ Message *amqp.Message

+ type RecoveryKind string

+ const RecoveryKindConn

+ const RecoveryKindFatal

+ const RecoveryKindLink

+ const RecoveryKindNone

+ func GetRecoveryKind(err error) RecoveryKind

+ func GetRecoveryKindForSession(err error) RecoveryKind

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