transport

Documentation

Index

• func AddLoggerToContext(logger log.Logger, otTracer stdopentracing.Tracer) amqptransport.RequestFunc
• func DecodeB64(message string) (string, error)
• func ErrMissingCaName() error
• func ErrMissingConnectorID() error
• func ErrMissingDeviceID() error
• func HTTPToContext(logger log.Logger) httptransport.RequestFunc
• func MakeAmqpHandler(s service.Service, logger log.Logger, otTracer stdopentracing.Tracer, ...)
• func MakeHTTPHandler(s service.Service, logger log.Logger, otTracer stdopentracing.Tracer) http.Handler

Functions

func AddLoggerToContext

func AddLoggerToContext(logger log.Logger, otTracer stdopentracing.Tracer) amqptransport.RequestFunc

func DecodeB64

func DecodeB64(message string) (string, error)

func ErrMissingCaName

func ErrMissingCaName() error

func ErrMissingConnectorID

func ErrMissingConnectorID() error

func ErrMissingDeviceID

func ErrMissingDeviceID() error

func HTTPToContext

func HTTPToContext(logger log.Logger) httptransport.RequestFunc

func MakeAmqpHandler

func MakeAmqpHandler(s service.Service, logger log.Logger, otTracer stdopentracing.Tracer, amqpServerCaCert string, amqpClientCert string, amqpClientKey string, amqpIp string, amqpPort string)

func MakeHTTPHandler

func MakeHTTPHandler(s service.Service, logger log.Logger, otTracer stdopentracing.Tracer) http.Handler