metrics

Documentation

Index

• Constants
• Variables
• func JsonNumToFloat64(num json.Number) (val float64)
• func JsonNumToInt32(num json.Number) (val int32)
• func MetricsHandler(inner http.Handler, sbox string, svc string) http.Handler
• func ObserveNotification(sbox string, svc string, notif string, url string, resp *http.Response, ...)
• func StrToFloat64(str string) (val float64)
• func StrToInt32(str string) (val int32)
• type EventMetric
• type GisMetric
• type HttpMetric
• type Metric
• type MetricStore
  • func NewMetricStore(name string, namespace string, influxAddr string, redisAddr string) (ms *MetricStore, err error)
  • func (ms *MetricStore) Copy(src string, dst string) error
  • func (ms *MetricStore) Flush()
  • func (ms *MetricStore) FormatMetrics(h HttpMetric) (mermaidLogs string, sdorgLogs string)
  • func (ms *MetricStore) GetCachedNetworkMetric(src string, dst string) (metric NetworkMetric, err error)
  • func (ms *MetricStore) GetCachedNetworkMetrics(src string, dst string) (metric []NetworkMetric, err error)
  • func (ms *MetricStore) GetEventMetric(eventType string, duration string, count int) (metrics []EventMetric, err error)
  • func (ms *MetricStore) GetHttpMetric(loggerName string, msgType string, duration string, count int) (metrics []HttpMetric, err error)
  • func (ms *MetricStore) GetInfluxMetric(metric string, tags map[string]string, fields []string, duration string, ...) (values []map[string]interface{}, err error)
  • func (ms *MetricStore) GetNetworkMetric(src string, dst string, duration string, count int) (metrics []NetworkMetric, err error)
  • func (ms *MetricStore) GetRedisMetric(metric string, tagStr string) (values []map[string]interface{}, err error)
  • func (ms *MetricStore) GetSandboxMetric(typ string, duration string, count int) (metrics []SandboxMetric, err error)
  • func (ms *MetricStore) GetSessionMetric(typ string, duration string, count int) (metrics []SessionMetric, err error)
  • func (ms *MetricStore) SetCachedNetworkMetric(metric NetworkMetric) (err error)
  • func (ms *MetricStore) SetEventMetric(eventType string, em EventMetric) error
  • func (ms *MetricStore) SetHttpMetric(h HttpMetric) error
  • func (ms *MetricStore) SetInfluxMetric(metricList []Metric) error
  • func (ms *MetricStore) SetNetworkMetric(nm NetworkMetric) error
  • func (ms *MetricStore) SetRedisMetric(metric string, tagStr string, fields map[string]interface{}) (err error)
  • func (ms *MetricStore) SetSandboxMetric(typ string, sm SandboxMetric) error
  • func (ms *MetricStore) SetSessionMetric(typ string, sm SessionMetric) error
  • func (ms *MetricStore) SetStore(name string, namespace string, createDb bool) error
  • func (ms *MetricStore) StartSnapshotThread() error
  • func (ms *MetricStore) StopSnapshotThread()
  • func (ms *MetricStore) TakeGisMetricSnapshot()
• type MetricsResponseWriter
  • func NewMetricsResponseWriter(w http.ResponseWriter) *MetricsResponseWriter
  • func (mrw *MetricsResponseWriter) WriteHeader(code int)
• type NetworkMetric
• type SandboxMetric
• type SessionMetric

Constants

const (
	SesMetTypeLogin   = "login"
	SesMetTypeLogout  = "logout"
	SesMetTypeTimeout = "timeout"
	SesMetTypeError   = "error"
)

Session metric types

const (
	SesMetErrTypeOauth       = "oauth"
	SesMetErrTypeMaxSessions = "maxsessions"
)

Session metric error types

const EvMetDescription = "description"

const EvMetDest = "dest"

const EvMetEvent = "event"

const EvMetName = "events"

const EvMetSrc = "src"

const EvMetTime = "time"

const EvMetType = "type"

const GisMetDest = "dest"

const GisMetDestType = "destType"

const GisMetDistance = "dist"

const GisMetMeasType = "measType"

const GisMetMeasTypeDistance = "distance"

const GisMetMeasTypeSignal = "signal"

const GisMetName = "meas"

const GisMetNameInflux = "gis"

const GisMetRsrp = "rsrp"

const GisMetRsrq = "rsrq"

const GisMetRssi = "rssi"

const GisMetSrc = "src"

const GisMetSrcType = "srcType"

const GisMetTime = "time"

const HttpBody = "body"

const HttpDst = "dst"

const HttpLogEndpoint = "endpoint"

const HttpLogId = "id"

const HttpLogMetricName = "http"

const HttpLogTime = "time"

const HttpLoggerDirection = "direction"

const HttpLoggerMsgType = "msg_type"

const HttpLoggerName = "logger_name"

const HttpMermaid = "mermaid"

const HttpMethod = "method"

const HttpMsgDirectionRx = "RX"

const HttpMsgDirectionTx = "TX"

const HttpMsgTypeNotification = "notification"

const HttpMsgTypeRequest = "request"

const HttpMsgTypeResponse = "response"

const HttpProcTime = "proc_time"

const HttpRespBody = "resp_body"

const HttpRespCode = "resp_code"

const HttpSdorg = "sdorg"

const HttpSrc = "src"

const HttpUrl = "url"

const MetricsDbDisabled = "disabled"

const NetMetDLPktLoss = "dlos"

const NetMetDLThroughput = "dl"

const NetMetDst = "dest"

const NetMetLatency = "lat"

const NetMetName = "network"

const NetMetSrc = "src"

const NetMetTime = "time"

const NetMetULPktLoss = "ulos"

const NetMetULThroughput = "ul"

const SboxMetCreateTime = "createtime"

const SboxMetName = "sbox"

const SboxMetSboxName = "sboxname"

const SboxMetTime = "time"

const SboxMetType = "type"

const (
	SboxMetTypeCreate = "create"
)

Sandbox metric types

const SesMetDesc = "description"

const SesMetErrType = "errtype"

const SesMetName = "session"

const SesMetProvider = "provider"

const SesMetSbox = "sbox"

const SesMetSid = "sid"

const SesMetTime = "time"

const SesMetType = "type"

const SesMetUser = "userid"

Variables

var MAX_LIMIT = 10000

Functions

func JsonNumToFloat64

func JsonNumToFloat64(num json.Number) (val float64)

func JsonNumToInt32

func JsonNumToInt32(num json.Number) (val int32)

func MetricsHandler

func MetricsHandler(inner http.Handler, sbox string, svc string) http.Handler

MetricsHandler - REST API Metrics Handler

func ObserveNotification

func ObserveNotification(sbox string, svc string, notif string, url string, resp *http.Response, duration float64)

func StrToFloat64

func StrToFloat64(str string) (val float64)

func StrToInt32

func StrToInt32(str string) (val int32)

Types

type EventMetric

type EventMetric struct {
	Time        interface{}
	Event       string
	Description string
	Src         string
	Dest        string
}

type GisMetric

type GisMetric struct {
	Src      string
	SrcType  string
	Dest     string
	DestType string
	Time     interface{}
	Rssi     int32
	Rsrp     int32
	Rsrq     int32
	Distance float64
}

type HttpMetric

type HttpMetric struct {
	LoggerName string
	MsgType    string
	Id         int32
	Url        string
	Endpoint   string
	Method     string
	Src        string
	Dst        string
	Body       string
	RespBody   string
	RespCode   string
	ProcTime   string
	Time       interface{}
	Mermaid    string
	Sdorg      string
}

type Metric

type Metric struct {
	Name   string
	Tags   map[string]string
	Fields map[string]interface{}
}

type MetricStore

type MetricStore struct {
	// contains filtered or unexported fields
}

MetricStore - Implements a metric store

func NewMetricStore

func NewMetricStore(name string, namespace string, influxAddr string, redisAddr string) (ms *MetricStore, err error)

NewMetricStore - Creates and initialize a Metric Store instance

func (*MetricStore) Copy

func (ms *MetricStore) Copy(src string, dst string) error

Copy

func (*MetricStore) Flush

func (ms *MetricStore) Flush()

Flush

func (*MetricStore) FormatMetrics

func (ms *MetricStore) FormatMetrics(h HttpMetric) (mermaidLogs string, sdorgLogs string)

func (*MetricStore) GetCachedNetworkMetric

func (ms *MetricStore) GetCachedNetworkMetric(src string, dst string) (metric NetworkMetric, err error)

GetCachedNetworkMetric

func (*MetricStore) GetCachedNetworkMetrics

func (ms *MetricStore) GetCachedNetworkMetrics(src string, dst string) (metric []NetworkMetric, err error)

GetCachedNetworkMetrics

func (*MetricStore) GetEventMetric

func (ms *MetricStore) GetEventMetric(eventType string, duration string, count int) (metrics []EventMetric, err error)

GetEventMetric

func (*MetricStore) GetHttpMetric

func (ms *MetricStore) GetHttpMetric(loggerName string, msgType string, duration string, count int) (metrics []HttpMetric, err error)

GetHttpMetric

func (*MetricStore) GetInfluxMetric

func (ms *MetricStore) GetInfluxMetric(metric string, tags map[string]string, fields []string, duration string, limit int) (values []map[string]interface{}, err error)

GetInfluxMetric - Generic metric getter

func (*MetricStore) GetNetworkMetric

func (ms *MetricStore) GetNetworkMetric(src string, dst string, duration string, count int) (metrics []NetworkMetric, err error)

GetNetworkMetric

func (*MetricStore) GetRedisMetric

func (ms *MetricStore) GetRedisMetric(metric string, tagStr string) (values []map[string]interface{}, err error)

GetRedisMetric - Generic metric getter

func (*MetricStore) GetSandboxMetric

func (ms *MetricStore) GetSandboxMetric(typ string, duration string, count int) (metrics []SandboxMetric, err error)

GetSandboxMetric

func (*MetricStore) GetSessionMetric

func (ms *MetricStore) GetSessionMetric(typ string, duration string, count int) (metrics []SessionMetric, err error)

GetSessionMetric

func (*MetricStore) SetCachedNetworkMetric

func (ms *MetricStore) SetCachedNetworkMetric(metric NetworkMetric) (err error)

SetCachedNetworkMetric

func (*MetricStore) SetEventMetric

func (ms *MetricStore) SetEventMetric(eventType string, em EventMetric) error

SetEventMetric

func (*MetricStore) SetHttpMetric

func (ms *MetricStore) SetHttpMetric(h HttpMetric) error

SetHttpMetric

func (*MetricStore) SetInfluxMetric

func (ms *MetricStore) SetInfluxMetric(metricList []Metric) error

SetInfluxMetric - Generic metric setter

func (*MetricStore) SetNetworkMetric

func (ms *MetricStore) SetNetworkMetric(nm NetworkMetric) error

SetNetworkMetric

func (*MetricStore) SetRedisMetric

func (ms *MetricStore) SetRedisMetric(metric string, tagStr string, fields map[string]interface{}) (err error)

SetRedisMetric - Generic metric setter

func (*MetricStore) SetSandboxMetric

func (ms *MetricStore) SetSandboxMetric(typ string, sm SandboxMetric) error

SetSandboxMetric

func (*MetricStore) SetSessionMetric

func (ms *MetricStore) SetSessionMetric(typ string, sm SessionMetric) error

SetSessionMetric

func (*MetricStore) SetStore

func (ms *MetricStore) SetStore(name string, namespace string, createDb bool) error

SetStore -

func (*MetricStore) StartSnapshotThread

func (ms *MetricStore) StartSnapshotThread() error

func (*MetricStore) StopSnapshotThread

func (ms *MetricStore) StopSnapshotThread()

func (*MetricStore) TakeGisMetricSnapshot

func (ms *MetricStore) TakeGisMetricSnapshot()

func (gc *GisCache) getMetricsEntryHandler(key string, fields map[string]string, userData interface{}) error {
	// Retrieve field values
	values := make(map[string]interface{})
	for k, v := range fields {
		values[k] = v
	}
	// Append values list to data
	data := userData.(*[]map[string]interface{})
	*data = append(*data, values)

	return nil
}

type MetricsResponseWriter

type MetricsResponseWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

ResponseWriter wrapper to capture status code

func NewMetricsResponseWriter

func NewMetricsResponseWriter(w http.ResponseWriter) *MetricsResponseWriter

func (*MetricsResponseWriter) WriteHeader

func (mrw *MetricsResponseWriter) WriteHeader(code int)

type NetworkMetric

type NetworkMetric struct {
	Src    string
	Dst    string
	Time   interface{}
	Lat    int32
	UlTput float64
	DlTput float64
	UlLoss float64
	DlLoss float64
}

type SandboxMetric

type SandboxMetric struct {
	Time       interface{}
	Name       string
	CreateTime float64
}

type SessionMetric

type SessionMetric struct {
	Time        interface{}
	Provider    string
	User        string
	SessionId   string
	Sandbox     string
	ErrType     string
	Description string
}