emetric

Documentation

Overview

Package emetric provides primitives for searching and processing data in Metric files.

Index

• func MetricChecker(loader loaders.Loader, devUUID uuid.UUID, q map[string]string, ...) (err error)
• func MetricItemFind(mm *metrics.ZMetricMsg, query map[string]string) bool
• func MetricItemPrint(mm *metrics.ZMetricMsg, query []string) *types.PrintResult
• func MetricLast(loader loaders.Loader, query map[string]string, handler HandlerFunc) error
• func MetricPrn(le *metrics.ZMetricMsg, format types.OutputFormat)
• func MetricWatch(loader loaders.Loader, query map[string]string, handler HandlerFunc, ...) error
• func ParseMetricsBundle(data []byte) (logBundle *metrics.ZMetricMsg, err error)
• type HandlerFunc
• type MetricCheckerMode
  • func MetricTail(count uint) MetricCheckerMode

Functions

func MetricChecker

func MetricChecker(loader loaders.Loader, devUUID uuid.UUID, q map[string]string, handler HandlerFunc, mode MetricCheckerMode, timeout time.Duration) (err error)

MetricChecker check metrics by pattern from existence files with HandlerFunc with timeout for observe new files

func MetricItemFind

func MetricItemFind(mm *metrics.ZMetricMsg, query map[string]string) bool

MetricItemFind find ZMetricMsg records by reqexps in 'query' corresponded to ZMetricMsg structure.

func MetricItemPrint

func MetricItemPrint(mm *metrics.ZMetricMsg, query []string) *types.PrintResult

MetricItemPrint find ZMetricMsg records by path in 'query'

func MetricLast

func MetricLast(loader loaders.Loader, query map[string]string, handler HandlerFunc) error

MetricLast function process Metric files in the 'filepath' directory according to the 'query' reqexps and return last founded item

func MetricPrn

func MetricPrn(le *metrics.ZMetricMsg, format types.OutputFormat)

MetricPrn print Metric data

func MetricWatch

func MetricWatch(loader loaders.Loader, query map[string]string, handler HandlerFunc, timeoutSeconds time.Duration) error

MetricWatch monitors the change of Metric files in the 'filepath' directory according to the 'query' reqexps and processing using the 'handler' function.

func ParseMetricsBundle

func ParseMetricsBundle(data []byte) (logBundle *metrics.ZMetricMsg, err error)

ParseMetricsBundle unmarshal LogBundle

Types

type HandlerFunc

type HandlerFunc func(msg *metrics.ZMetricMsg) bool

HandlerFunc must process ZMetricMsg and return true to exit or false to continue

type MetricCheckerMode

type MetricCheckerMode int

MetricCheckerMode is MetricExist, MetricNew and MetricAny

const (
	MetricExist MetricCheckerMode = -3 //MetricExist just look to existing files
	MetricNew   MetricCheckerMode = -2 //MetricNew wait for new files
	MetricAny   MetricCheckerMode = -1 //MetricAny use both mechanisms
)

MetricChecker modes MetricExist, MetricNew and MetricAny.

func MetricTail

func MetricTail(count uint) MetricCheckerMode

MetricTail returns MetricCheckerMode for process only defined count of last messages