http

Jul 22, 2021

Changes in this version

type SSERouter

+ func (r SSERouter) Close() error

Jan 10, 2020

Changes in this version

+ func DefaultErrorHandler(w http.ResponseWriter, r *http.Request, err error)

+ type HandleErrorFunc func(w http.ResponseWriter, r *http.Request, err error)

+ type SSERouter struct

+ func NewSSERouter(config SSERouterConfig, logger watermill.LoggerAdapter) (SSERouter, error)

+ func (r SSERouter) AddHandler(topic string, streamAdapter StreamAdapter) http.HandlerFunc

+ func (r SSERouter) Run(ctx context.Context) error

+ func (r SSERouter) Running() chan struct{}

+ type SSERouterConfig struct

+ ErrorHandler HandleErrorFunc

+ UpstreamSubscriber message.Subscriber

+ type StreamAdapter interface

+ GetResponse func(w http.ResponseWriter, r *http.Request) (response interface{}, ok bool)

+ Validate func(r *http.Request, msg *message.Message) (ok bool)

Aug 7, 2019

Changes in this version

+ const HeaderMetadata

+ const HeaderUUID

+ const ProviderName

+ var ErrErrorResponse = errors.New("server responded with error status")

+ var ErrNoMarshalFunc = errors.New("marshal function is missing")

+ var ErrPublisherClosed = errors.New("publisher is closed")

+ func DefaultMarshalMessageFunc(url string, msg *message.Message) (*http.Request, error)

+ func DefaultUnmarshalMessageFunc(topic string, req *http.Request) (*message.Message, error)

+ type MarshalMessageFunc func(url string, msg *message.Message) (*http.Request, error)

+ type Publisher struct

+ func NewPublisher(config PublisherConfig, logger watermill.LoggerAdapter) (*Publisher, error)

+ func (p *Publisher) Close() error

+ func (p *Publisher) Publish(topic string, messages ...*message.Message) error

+ type PublisherConfig struct

+ Client *http.Client

+ DoNotLogResponseBodyOnServerError bool

+ MarshalMessageFunc MarshalMessageFunc

+ type Subscriber struct

+ func NewSubscriber(addr string, config SubscriberConfig, logger watermill.LoggerAdapter) (*Subscriber, error)

+ func (s *Subscriber) Addr() net.Addr

+ func (s *Subscriber) Close() error

+ func (s *Subscriber) StartHTTPServer() error

+ func (s *Subscriber) Subscribe(ctx context.Context, url string) (<-chan *message.Message, error)

+ type SubscriberConfig struct

+ Router chi.Router

+ UnmarshalMessageFunc UnmarshalMessageFunc

+ type UnmarshalMessageFunc func(topic string, request *http.Request) (*message.Message, error)