api

func BuildJSONPageMetadata ¶ added in v0.30.0

func BuildJSONPageMetadata(r *http.Request) (readers.JSONPageMetadata, error)

func BuildSenMLPageMetadata ¶ added in v0.30.0

func BuildSenMLPageMetadata(r *http.Request) (readers.SenMLPageMetadata, error)

func ConvertCSVToJSONMessages ¶ added in v0.30.1

func ConvertCSVToJSONMessages(csvMessages []byte) ([]mfjson.Message, error)

func ConvertCSVToSenMLMessages ¶ added in v0.30.1

func ConvertCSVToSenMLMessages(data []byte) ([]senml.Message, error)

func ConvertJSONToJSONMessages ¶ added in v0.30.1

func ConvertJSONToJSONMessages(data []byte) ([]mfjson.Message, error)

func ConvertJSONToSenMLMessages ¶ added in v0.30.1

func ConvertJSONToSenMLMessages(data []byte) ([]senml.Message, error)

func GenerateCSVFromJSON ¶ added in v0.30.1

func GenerateCSVFromJSON(page readers.MessagesPage) ([]byte, error)

func GenerateCSVFromSenML ¶ added in v0.30.1

func GenerateCSVFromSenML(page readers.MessagesPage) ([]byte, error)

func GenerateJSON ¶ added in v0.30.1

func GenerateJSON(page readers.MessagesPage) ([]byte, error)

func LoggingMiddleware ¶

func LoggingMiddleware(svc readers.Service, logger logger.Logger) readers.Service

LoggingMiddleware adds logging facilities to the core service.

func MakeHandler ¶

func MakeHandler(svc readers.Service, tracer opentracing.Tracer, svcName string, logger logger.Logger) http.Handler

func MetricsMiddleware ¶

func MetricsMiddleware(svc readers.Service, counter metrics.Counter, latency metrics.Histogram) readers.Service

MetricsMiddleware instruments core service by tracking request count and latency.