monitoring

Dec 4, 2025

Changes in this version

+ func WaitUntilRunning(timeout time.Duration) bool

Sep 4, 2025

Changes in this version

+ func AddEnvAndRunType(ctx context.Context, envId, runType string) context.Context

+ type EnvIDKey struct

+ type RunTypeKey struct

Aug 14, 2025

Changes in this version

+ func SetupStreamClientInterceptor(metricName string, convert NameConvertType) grpc.StreamClientInterceptor

+ func SetupUnaryClientInterceptor(name string, convert NameConvertType) grpc.UnaryClientInterceptor

+ func Timer(metric *Metric, unit TimeResolution) func()

+ func TimerSendHist(metric *Metric, unit TimeResolution) func()

+ func TimerSendSingle(metric *Metric, unit TimeResolution) func()

+ type NameConvertType func(string) string

+ type TimeResolution int

+ const Millisecond

+ const Nanosecond

May 15, 2025

Changes in this version

+ func Format(writer io.Writer, metrics []Metric) error

+ func SendHistogrammable(metric *Metric)

+ func TimerMS(metric *Metric) func()

+ func TimerNS(metric *Metric) func()

+ type FieldsType map[string]any

type Metric

+ func NewDefaultMetric(name string, timestamp time.Time) Metric

+ func NewMetric(name string) Metric

+ func (metric *Metric) MergeFields(other *Metric)

+ func (metric *Metric) SetFieldFloat64(fieldName string, field float64)

+ func (metric *Metric) SetFieldInt64(fieldName string, field int64)

+ func (metric *Metric) SetFieldUInt64(fieldName string, field uint64)

+ type MetricsAggregate struct

+ func NewMetricsAggregate() *MetricsAggregate

+ func (this *MetricsAggregate) AddMetric(metric *Metric)

+ func (this *MetricsAggregate) Clear()

+ func (this *MetricsAggregate) GetMetrics() []Metric

+ type MetricsReservoirSampling struct

+ func NewMetricsReservoirSampling() *MetricsReservoirSampling

+ func (this *MetricsReservoirSampling) AddMetric(metric *Metric)

+ func (this *MetricsReservoirSampling) Clear()

+ func (this *MetricsReservoirSampling) GetMetrics() []Metric

+ type Tag struct

Feb 13, 2025

Changes in this version

+ func IsRunning() bool

+ func Run(port uint16, endpointName string, messageBufferSize int) error

Dec 12, 2024

Changes in this version

+ var Log = logger.New(logrus.StandardLogger(), "metrics")

+ func Send(metric Metric)

+ func Start(port uint16, endpointName string, messageBufferSize int) error

+ func Stop()

+ type Metric struct

+ Name string

+ Tags TagsType

+ Timestamp int64

+ Values ValuesType

+ func (metric *Metric) AddTag(tagName string, value any)

+ func (metric *Metric) AddValue(valueName string, value any)

+ type TagsType map[string]any

+ type ValuesType map[string]any