Documentation
¶
Index ¶
- Constants
- Variables
- func DefaultMarshalMessageFunc(url string, msg *message.Message) (*http.Request, error)
- func DefaultUnmarshalMessageFunc(topic string, req *http.Request) (*message.Message, error)
- type MarshalMessageFunc
- type Publisher
- type PublisherConfig
- type Subscriber
- type SubscriberConfig
- type UnmarshalMessageFunc
Constants ¶
const ( HeaderUUID = "Message-Uuid" HeaderMetadata = "Message-Metadata" ProviderName = "http" )
Variables ¶
var ( // ErrPublisherClosed happens when trying to publish to a topic while the publisher is closed or closing. ErrPublisherClosed = errors.New("publisher is closed") ErrNoMarshalFunc = errors.New("marshal function is missing") ErrErrorResponse = errors.New("server responded with error status") )
Functions ¶
func DefaultMarshalMessageFunc ¶ added in v0.3.0
DefaultMarshalMessageFunc transforms the message into a HTTP POST request. It encodes the UUID and Metadata in request headers.
Types ¶
type MarshalMessageFunc ¶ added in v0.3.0
MarshalMessageFunc transforms the message into a HTTP request to be sent to the specified url.
type Publisher ¶ added in v0.3.0
type Publisher struct {
// contains filtered or unexported fields
}
func NewPublisher ¶ added in v0.3.0
func NewPublisher(config PublisherConfig, logger watermill.LoggerAdapter) (*Publisher, error)
NewPublisher creates a new Publisher. It publishes the received messages as HTTP requests. The URL, method and payload of the request are determined by the configured MarshalMessageFunc.
type PublisherConfig ¶ added in v0.3.0
type PublisherConfig struct {
MarshalMessageFunc MarshalMessageFunc
Client *http.Client
// if false (default), when server responds with error (>=400) to the webhook request, the response body is logged.
DoNotLogResponseBodyOnServerError bool
}
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
Subscriber can subscribe to HTTP requests and create Watermill's messages based on them.
func NewSubscriber ¶
func NewSubscriber(addr string, config SubscriberConfig, logger watermill.LoggerAdapter) (*Subscriber, error)
NewSubscriber creates new Subscriber.
addr is TCP address to listen on
logger is Watermill's logger.
func (Subscriber) Addr ¶ added in v0.3.0
func (s Subscriber) Addr() net.Addr
Addr returns the server address or nil if the server isn't running.
func (*Subscriber) Close ¶
func (s *Subscriber) Close() error
func (*Subscriber) StartHTTPServer ¶
func (s *Subscriber) StartHTTPServer() error
StartHTTPServer starts http server. It must be called after all Subscribe calls have completed. Just like http.Server.Serve(), it returns http.ErrServerClosed after the server's been closed. https://golang.org/pkg/net/http/#Server.Serve
func (*Subscriber) Subscribe ¶
Subscribe adds HTTP handler which will listen in provided url for messages.
Subscribe needs to be called before `StartHTTPServer`.
When request is sent, it will wait for the `Ack`. When Ack is received 200 HTTP status wil be sent. When Nack is sent, 500 HTTP status will be sent.
type SubscriberConfig ¶ added in v0.3.0
type SubscriberConfig struct {
Router chi.Router
UnmarshalMessageFunc UnmarshalMessageFunc
}
Source Files