unixserver

Documentation

Index

• func Listen(ctx context.Context, address string, w *bufio.Writer, ...) (err error)
• type CDMetric
• type CDMetricDescription
• type CDMetricDescriptions
  • func NewCDMetricDescriptions() (metricDescriptions *CDMetricDescriptions)
• type CDMetrics
  • func NewCDMetrics() (m *CDMetrics)
  • func (a *CDMetrics) Collect(ch chan<- prometheus.Metric)
  • func (a *CDMetrics) Describe(ch chan<- *prometheus.Desc)
• type PromIntf
  • func NewPromIntf(source string) *PromIntf
  • func (a *PromIntf) AddTotalReceived(num int)
  • func (a *PromIntf) Collect(ch chan<- prometheus.Metric)
  • func (a *PromIntf) Describe(ch chan<- *prometheus.Desc)
  • func (a *PromIntf) GetTotalAmqpReceived() uint64
  • func (a *PromIntf) GetTotalDecodeErrors() uint64
  • func (a *PromIntf) GetTotalMetricsReceived() uint64
  • func (a *PromIntf) IncTotalAmqpReceived()
  • func (a *PromIntf) IncTotalDecodeErrors()
  • func (a *PromIntf) IncTotalMetricsReceived()

Functions

func Listen

func Listen(ctx context.Context, address string, w *bufio.Writer, registry *prometheus.Registry) (err error)

Types

type CDMetric

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

type CDMetricDescription

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

type CDMetricDescriptions

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

func NewCDMetricDescriptions

func NewCDMetricDescriptions() (metricDescriptions *CDMetricDescriptions)

type CDMetrics

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

func NewCDMetrics

func NewCDMetrics() (m *CDMetrics)

func (*CDMetrics) Collect

func (a *CDMetrics) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*CDMetrics) Describe

func (a *CDMetrics) Describe(ch chan<- *prometheus.Desc)

Describe ...

type PromIntf

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

AMQPHandler ...

func NewPromIntf

func NewPromIntf(source string) *PromIntf

NewAMQPHandler ...

func (*PromIntf) AddTotalReceived

func (a *PromIntf) AddTotalReceived(num int)

AddTotalReceived ...

func (*PromIntf) Collect

func (a *PromIntf) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*PromIntf) Describe

func (a *PromIntf) Describe(ch chan<- *prometheus.Desc)

Describe ...

func (*PromIntf) GetTotalAmqpReceived

func (a *PromIntf) GetTotalAmqpReceived() uint64

GetTotalReceived ...

func (*PromIntf) GetTotalDecodeErrors

func (a *PromIntf) GetTotalDecodeErrors() uint64

GetTotalDecodeErrors ...

func (*PromIntf) GetTotalMetricsReceived

func (a *PromIntf) GetTotalMetricsReceived() uint64

GetTotalReceived ...

func (*PromIntf) IncTotalAmqpReceived

func (a *PromIntf) IncTotalAmqpReceived()

IncTtoalAmqpReceived ...

func (*PromIntf) IncTotalDecodeErrors

func (a *PromIntf) IncTotalDecodeErrors()

IncTotalDecodeErrors ...

func (*PromIntf) IncTotalMetricsReceived

func (a *PromIntf) IncTotalMetricsReceived()

IncTotalMetricsReceived ...