Versions in this module Expand all Collapse all v0 v0.1.1 May 12, 2022 v0.1.0 Mar 28, 2022 Changes in this version + type Link struct + func NewLink(conn *amqp.Client, address string, opts ...LinkOption) (*Link, error) + func NewLinkWithSession(session *amqp.Session, address string, opts ...LinkOption) (*Link, error) + func (l *Link) Close(ctx context.Context) error + func (l *Link) RPC(ctx context.Context, msg *amqp.Message) (*Response, error) + func (l *Link) RetryableRPC(ctx context.Context, times int, delay time.Duration, msg *amqp.Message) (*Response, error) + type LinkOption func(link *Link) error + func LinkWithSessionFilter(sessionID *string) LinkOption + type Response struct + Code int + Description string + Message *amqp.Message
Go to main page