vmetrics

package
v0.1.12 Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2023 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MustRegister added in v0.1.10

func MustRegister(metrics ...Metric)

func Register

func Register(metric Metric)

func SetupDefaultRegistry added in v0.1.9

func SetupDefaultRegistry(brokers []string, topic string, logger *log.Logger)

Types

type BrokerList added in v0.1.6

type BrokerList []string

type Counter added in v0.1.10

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

func NewCounter added in v0.1.10

func NewCounter(name string) *Counter

func (*Counter) Aggregated added in v0.1.10

func (c *Counter) Aggregated() []string

func (*Counter) Clear added in v0.1.10

func (c *Counter) Clear()

func (*Counter) Get added in v0.1.10

func (c *Counter) Get() int64

func (*Counter) Inc added in v0.1.10

func (c *Counter) Inc()

type CounterVec added in v0.1.10

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

func NewCounterVec added in v0.1.10

func NewCounterVec(labels []string) *CounterVec

func (*CounterVec) Aggregated added in v0.1.10

func (cv *CounterVec) Aggregated() []string

func (*CounterVec) Clear added in v0.1.10

func (cv *CounterVec) Clear()

func (*CounterVec) GetSize added in v0.1.10

func (cv *CounterVec) GetSize() int

func (*CounterVec) WithLabelValues added in v0.1.10

func (cv *CounterVec) WithLabelValues(lvs ...string) *Counter

type Metric

type Metric interface {
	Aggregated() []string
	Clear()
}

type Registry

type Registry struct {
	Metrics  []Metric
	Config   *RegistryConfig
	Producer sarama.SyncProducer
	Logger   *log.Logger
}
var (
	DefaultRegistry *Registry
)

func NewRegistry

func NewRegistry(config *RegistryConfig, logger *log.Logger) *Registry

func (*Registry) Register

func (r *Registry) Register(metric Metric)

func (*Registry) Start

func (r *Registry) Start()

type RegistryConfig

type RegistryConfig struct {
	BrokerList []string
	Topic      string
	Cycle      time.Duration
}

Jump to

Keyboard shortcuts

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