Documentation
¶
Overview ¶
Package http provides an HTTP transport for protoflow.
Index ¶
Constants ¶
View Source
const TransportName = "http"
TransportName is the name used to register this transport.
Variables ¶
View Source
var PublisherFactory = func(config http.PublisherConfig, logger watermill.LoggerAdapter) (message.Publisher, error) { return http.NewPublisher(config, logger) }
PublisherFactory allows overriding the publisher creation for testing.
View Source
var SubscriberFactory = func(addr string, config http.SubscriberConfig, logger watermill.LoggerAdapter) (message.Subscriber, error) { return http.NewSubscriber(addr, config, logger) }
SubscriberFactory allows overriding the subscriber creation for testing.
Functions ¶
func Build ¶
func Build(ctx context.Context, cfg transport.Config, logger watermill.LoggerAdapter) (transport.Transport, error)
Build creates a new HTTP transport.
func Capabilities ¶
func Capabilities() transport.Capabilities
Capabilities returns the capabilities of this transport.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.