Documentation ¶
Index ¶
- Variables
- func MakeHTTPHandler(s Service, logger log.Logger, otTracer stdopentracing.Tracer) http.Handler
- func MakeHealthEndpoint(s Service) endpoint.Endpoint
- func MakePostConnect(s Service) endpoint.Endpoint
- func MakePostDisconnect(s Service) endpoint.Endpoint
- func MakePostSendMessage(s Service) endpoint.Endpoint
- type Endpoints
- type Middleware
- type Service
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrSendMessage = errors.New("error sending message") ErrDeviceAuth = errors.New("error authenticating device") ErrCACertLoading = errors.New("unable to read CA certificate") ErrTLSConfLoading = errors.New("unable to read client TLS configuration") ErrBrokerURLEmpty = errors.New("invalid empty broker URL") ErrClientIDEmpty = errors.New("invalid empty client ID") ErrTopicEmpty = errors.New("invalid empty topic") )
Functions ¶
func MakeHTTPHandler ¶
func MakeHealthEndpoint ¶
func MakePostConnect ¶
func MakePostDisconnect ¶
func MakePostSendMessage ¶
Types ¶
type Endpoints ¶
type Endpoints struct { HealthEndpoint endpoint.Endpoint PostSendMessage endpoint.Endpoint PostConnect endpoint.Endpoint PostDisconnect endpoint.Endpoint }
func MakeServerEndpoints ¶
func MakeServerEndpoints(s Service, otTracer stdopentracing.Tracer) Endpoints
type Middleware ¶
func LoggingMidleware ¶
func LoggingMidleware(logger log.Logger) Middleware
func NewInstrumentingMiddleware ¶
func NewInstrumentingMiddleware(counter metrics.Counter, latency metrics.Histogram) Middleware
Click to show internal directories.
Click to hide internal directories.