stats

Documentation

Index

• func MakeBasicStats(lastTS time.Time, connTS time.Time, addr pubcluster.Address, clientName string) []stat
• type MetricsCompressor
  • func NewMetricCompressor() *MetricsCompressor
  • func (mc *MetricsCompressor) AddDouble(d metricDescriptor, value float64)
  • func (mc *MetricsCompressor) AddLong(d metricDescriptor, value int64)
  • func (mc *MetricsCompressor) GenerateBlob() []byte
  • func (mc *MetricsCompressor) Reset()
• type Service
  • func NewService(requestCh chan<- invocation.Invocation, ...) *Service
  • func (s *Service) Start()
  • func (s *Service) Stop()

Functions

func MakeBasicStats

func MakeBasicStats(lastTS time.Time, connTS time.Time, addr pubcluster.Address, clientName string) []stat

Types

type MetricsCompressor

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

func NewMetricCompressor

func NewMetricCompressor() *MetricsCompressor

func (*MetricsCompressor) AddDouble

func (mc *MetricsCompressor) AddDouble(d metricDescriptor, value float64)

func (*MetricsCompressor) AddLong

func (mc *MetricsCompressor) AddLong(d metricDescriptor, value int64)

func (*MetricsCompressor) GenerateBlob

func (mc *MetricsCompressor) GenerateBlob() []byte

func (*MetricsCompressor) Reset

func (mc *MetricsCompressor) Reset()

type Service

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

func NewService

func NewService(
	requestCh chan<- invocation.Invocation,
	invFactory *cluster.ConnectionInvocationFactory,
	ed *event.DispatchService,
	logger logger.Logger,
	interval time.Duration,
	clientName string) *Service

func (*Service) Start

func (s *Service) Start()

func (*Service) Stop

func (s *Service) Stop()