telemetry

package
v0.0.0-...-57c0a64 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	IsPresent    = "1"
	IsNotPresent = "0"

	InputNameApplication    = v1.InputNameApplication
	InputNameAudit          = v1.InputNameAudit
	InputNameInfrastructure = v1.InputNameInfrastructure
	InputNameHttpReceiver   = v1.ReceiverTypeHttp
	InputNameSyslogReceiver = v1.ReceiverTypeSyslog

	OutputTypeDefault            = "default"
	OutputTypeElasticsearch      = v1.OutputTypeElasticsearch
	OutputTypeFluentdForward     = v1.OutputTypeFluentdForward
	OutputTypeSyslog             = v1.OutputTypeSyslog
	OutputTypeKafka              = v1.OutputTypeKafka
	OutputTypeLoki               = v1.OutputTypeLoki
	OutputTypeCloudwatch         = v1.OutputTypeCloudwatch
	OutputTypeHttp               = v1.OutputTypeHttp
	OutputTypeGoogleCloudLogging = v1.OutputTypeGoogleCloudLogging
	OutputTypeSplunk             = v1.OutputTypeSplunk
	OutputTypeAzureMonitor       = v1.OutputTypeAzureMonitor

	ManagedStatus = "managedStatus"
	HealthStatus  = "healthStatus"
	VersionNo     = "version"
	PipelineNo    = "pipelineInfo"
	Deployed      = "deployed"
)

Variables

View Source
var (
	Data = NewTD()

	MetricCLList = []prometheus.Collector{
		mCLInfo,
	}

	MetricCLFList = []prometheus.Collector{
		mCollectorErrorCount,
		mCLFInfo,
		mCLFInputType,
		mCLFOutputType,
	}

	MetricLFMEList = []prometheus.Collector{
		mLFMEInfo,
	}
)

Functions

func CancelMetrics

func CancelMetrics()

CancelMetrics resets previous info metrics

func NewInfoVec

func NewInfoVec(metricname string, metrichelp string, labelNames []string) *prometheus.GaugeVec

func RegisterMetrics

func RegisterMetrics() error

func SetCLFMetrics

func SetCLFMetrics(value float64)

func SetCLMetrics

func SetCLMetrics(value float64)

func SetLFMEMetrics

func SetLFMEMetrics(value float64)

func UpdateInfofromCL

func UpdateInfofromCL(cl logging.ClusterLogging)

func UpdateInfofromCLF

func UpdateInfofromCLF(forwarder logging.ClusterLogForwarder)

func UpdateMetrics

func UpdateMetrics()

Types

type TData

type TData struct {
	CLInfo              *utils.StringMap
	CLLogStoreType      *utils.StringMap
	CollectorErrorCount *utils.Float64Map
	CLFInfo             *utils.StringMap
	CLFInputType        *utils.StringMap
	CLFOutputType       *utils.StringMap
	LFMEInfo            *utils.StringMap
}

placeholder for keeping clo info which will be used for clo metrics update

func NewTD

func NewTD() *TData

IsNotPresent stands for managedStatus and healthStatus true and healthy

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL