amqprpc

package module

Go to main page

Versions in this module

v1

v1.0.1

Sep 10, 2021

v1.0.0

Sep 1, 2020

v0

v0.13.0

Aug 28, 2020

v0.12.0

Nov 29, 2019

Changes in this version

type Server

+ func (s *Server) WithQoSPrefetchCount(c int) *Server

v0.11.0

Nov 28, 2019

Changes in this version

+ var ErrRequestRejected = errors.New("publishing Nacked")

+ var ErrRequestReturned = errors.New("publishing returned")

+ var ErrRequestTimeout = errors.New("request timed out")

type Client

+ func (c *Client) WithConfirmMode(confirmMode bool) *Client

type PublishSettings

+ ConfirmMode bool

type Request

+ func (r *Request) AfterTimeout() <-chan time.Time

+ type RequestMap struct

+ func (m *RequestMap) Delete(r *Request)

+ func (m *RequestMap) GetByCorrelationID(key string) (*Request, bool)

+ func (m *RequestMap) GetByDeliveryTag(key uint64) (*Request, bool)

+ func (m *RequestMap) Set(r *Request)

v0.10.1

Oct 25, 2019

Changes in this version

+ type AwareAcknowledger struct

+ Acknowledger amqp.Acknowledger

+ Handled bool

+ func NewAwareAcknowledger(acknowledger amqp.Acknowledger) *AwareAcknowledger

+ func (a *AwareAcknowledger) Ack(tag uint64, multiple bool) error

+ func (a *AwareAcknowledger) Nack(tag uint64, multiple bool, requeue bool) error

+ func (a *AwareAcknowledger) Reject(tag uint64, requeue bool) error

type Client

+ func (c *Client) WithMaxRetries(n int) *Client

type ConsumeSettings

+ QoSPrefetchCount int

+ QoSPrefetchSize int

+ type MockAcknowledger struct

+ Acks int

+ Nacks int

+ Rejects int

+ func (ma *MockAcknowledger) Ack(tag uint64, multiple bool) error

+ func (ma *MockAcknowledger) Nack(tag uint64, multiple bool, requeue bool) error

+ func (ma *MockAcknowledger) Reject(tag uint64, requeue bool) error

type Server

+ func (s *Server) WithAutoAck(b bool) *Server

+ func (s *Server) WithConsumeSettings(settings ConsumeSettings) *Server

+ func (s *Server) WithExchangeDeclareSettings(settings ExchangeDeclareSettings) *Server

+ func (s *Server) WithQueueDeclareSettings(settings QueueDeclareSettings) *Server

v0.9.8

Apr 3, 2019

Changes in this version

+ const CtxQueueName

+ const ExchangeDirect

+ const ExchangeFanout

+ const ExchangeHeaders

+ const ExchangeTopic

+ var ErrTimeout = errors.New("request timed out")

+ var ErrUnexpectedConnClosed = errors.New("unexpected connection close without specific error")

+ func DefaultDialer(network, addr string) (net.Conn, error)

+ type Certificates struct

+ CA string

+ Cert string

+ Key string

+ func (c *Certificates) TLSConfig() *tls.Config

+ type Client struct

+ Sender SendFunc

+ func NewClient(url string) *Client

+ func (c *Client) AddMiddleware(m ClientMiddlewareFunc) *Client

+ func (c *Client) OnStarted(f OnStartedFunc)

+ func (c *Client) Send(r *Request) (*amqp.Delivery, error)

+ func (c *Client) Stop()

+ func (c *Client) WithConsumeSettings(s ConsumeSettings) *Client

+ func (c *Client) WithDebugLogger(f LogFunc) *Client

+ func (c *Client) WithDialConfig(dc amqp.Config) *Client

+ func (c *Client) WithErrorLogger(f LogFunc) *Client

+ func (c *Client) WithPublishSettings(s PublishSettings) *Client

+ func (c *Client) WithQueueDeclareSettings(s QueueDeclareSettings) *Client

+ func (c *Client) WithTLS(tls *tls.Config) *Client

+ func (c *Client) WithTimeout(t time.Duration) *Client

+ type ClientMiddlewareFunc func(next SendFunc) SendFunc

+ type ConsumeSettings struct

+ Args amqp.Table

+ AutoAck bool

+ Consumer string

+ Exclusive bool

+ NoLocal bool

+ NoWait bool

+ type Dialer func(string, string) (net.Conn, error)

+ type ExchangeDeclareSettings struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ NoWait bool

+ type HandlerBinding struct

+ BindHeaders amqp.Table

+ ExchangeName string

+ ExchangeType string

+ Handler HandlerFunc

+ QueueName string

+ RoutingKey string

+ func DirectBinding(routingKey string, handler HandlerFunc) HandlerBinding

+ func FanoutBinding(exchangeName string, handler HandlerFunc) HandlerBinding

+ func HeadersBinding(queueName string, headers amqp.Table, handler HandlerFunc) HandlerBinding

+ func TopicBinding(queueName, routingKey string, handler HandlerFunc) HandlerBinding

+ type HandlerFunc func(context.Context, *ResponseWriter, amqp.Delivery)

+ func ServerMiddlewareChain(next HandlerFunc, m ...ServerMiddlewareFunc) HandlerFunc

+ type LogFunc func(format string, args ...interface{})

+ type OnStartedFunc func(inputConn, outputConn *amqp.Connection, ...)

+ type PublishSettings struct

+ Immediate bool

+ Mandatory bool

+ type QueueDeclareSettings struct

+ Args amqp.Table

+ DeleteWhenUnused bool

+ Durable bool

+ Exclusive bool

+ NoWait bool

+ type Request struct

+ Context context.Context

+ Exchange string

+ Publishing amqp.Publishing

+ Reply bool

+ RoutingKey string

+ Timeout time.Duration

+ func NewRequest() *Request

+ func (r *Request) AddMiddleware(m ClientMiddlewareFunc) *Request

+ func (r *Request) WithBody(b string) *Request

+ func (r *Request) WithContentType(ct string) *Request

+ func (r *Request) WithContext(ctx context.Context) *Request

+ func (r *Request) WithCorrelationID(id string) *Request

+ func (r *Request) WithExchange(e string) *Request

+ func (r *Request) WithHeaders(h amqp.Table) *Request

+ func (r *Request) WithResponse(wr bool) *Request

+ func (r *Request) WithRoutingKey(rk string) *Request

+ func (r *Request) WithTimeout(t time.Duration) *Request

+ func (r *Request) Write(p []byte) (int, error)

+ func (r *Request) WriteHeader(header string, value interface{})

+ type ResponseWriter struct

+ func NewResponseWriter(p *amqp.Publishing) *ResponseWriter

+ func (rw *ResponseWriter) Immediate(i bool)

+ func (rw *ResponseWriter) Mandatory(m bool)

+ func (rw *ResponseWriter) Publishing() *amqp.Publishing

+ func (rw *ResponseWriter) Write(p []byte) (int, error)

+ func (rw *ResponseWriter) WriteHeader(header string, value interface{})

+ type SendFunc func(r *Request) (d *amqp.Delivery, e error)

+ func ClientMiddlewareChain(next SendFunc, m ...ClientMiddlewareFunc) SendFunc

+ type Server struct

+ func NewServer(url string) *Server

+ func (s *Server) AddMiddleware(m ServerMiddlewareFunc) *Server

+ func (s *Server) Bind(binding HandlerBinding)

+ func (s *Server) ListenAndServe()

+ func (s *Server) OnStarted(f OnStartedFunc)

+ func (s *Server) Stop()

+ func (s *Server) WithDebugLogger(f LogFunc) *Server

+ func (s *Server) WithDialConfig(c amqp.Config) *Server

+ func (s *Server) WithErrorLogger(f LogFunc) *Server

+ func (s *Server) WithTLS(tls *tls.Config) *Server

+ type ServerMiddlewareFunc func(next HandlerFunc) HandlerFunc

Other modules containing this package

github.com/0x4b53/amqp-rpc/v2

github.com/0x4b53/amqp-rpc/v3

github.com/0x4b53/amqp-rpc/v4

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