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 ConvertJSONToCSVFile ¶ added in v0.33.0

func ConvertJSONToCSVFile(page readers.JSONMessagesPage, timeFormat string) ([]byte, error)

func ConvertJSONToJSONFile ¶ added in v0.33.0

func ConvertJSONToJSONFile(page readers.JSONMessagesPage, timeFormat string) ([]byte, 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 ConvertSenMLToCSVFile ¶ added in v0.33.0

func ConvertSenMLToCSVFile(page readers.SenMLMessagesPage, timeFormat string) ([]byte, error)

func ConvertSenMLToJSONFile ¶ added in v0.33.0

func ConvertSenMLToJSONFile(page readers.SenMLMessagesPage, timeFormat string) ([]byte, error)

func Flatten ¶ added in v0.33.0

func Flatten(m map[string]any, prefix string) map[string]any

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.