Versions in this module Expand all Collapse all v0 v0.0.1 Apr 19, 2021 Changes in this version + var ErrBrokerURLEmpty = errors.New("invalid empty broker URL") + var ErrCACertLoading = errors.New("unable to read CA certificate") + var ErrClientIDEmpty = errors.New("invalid empty client ID") + var ErrDeviceAuth = errors.New("error authenticating device") + var ErrSendMessage = errors.New("error sending message") + var ErrTLSConfLoading = errors.New("unable to read client TLS configuration") + var ErrTopicEmpty = errors.New("invalid empty topic") + 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 struct + HealthEndpoint endpoint.Endpoint + PostConnect endpoint.Endpoint + PostDisconnect endpoint.Endpoint + PostSendMessage endpoint.Endpoint + func MakeServerEndpoints(s Service, otTracer stdopentracing.Tracer) Endpoints + type Middleware func(Service) Service + func LoggingMidleware(logger log.Logger) Middleware + func NewInstrumentingMiddleware(counter metrics.Counter, latency metrics.Histogram) Middleware + type Service interface + Health func(ctx context.Context) bool + PostConnect func(ctx context.Context, authKey string, authCRT string, brokerURL string, ...) error + PostDisconnect func(ctx context.Context) + PostSendMessage func(ctx context.Context, message string, topic string) error + func NewDeviceService(CAPath string, client client.Client) Service