stats

Documentation

Index

• 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 NearCacheStatsGetter
• type Service
  • func NewService(is *invocation.Service, invFac *cluster.ConnectionInvocationFactory, ...) *Service
  • func (s *Service) SetNCStatsGetter(ncmsFn func(service string) NearCacheStatsGetter)
  • func (s *Service) Start()
  • func (s *Service) Stop()

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 NearCacheStatsGetter

type NearCacheStatsGetter interface {
	GetNearCacheStats() []proto.Pair
}

type Service

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

func NewService

func NewService(is *invocation.Service, invFac *cluster.ConnectionInvocationFactory, ed *event.DispatchService, lg logger.LogAdaptor, interval time.Duration, client string) *Service

func (*Service) SetNCStatsGetter

func (s *Service) SetNCStatsGetter(ncmsFn func(service string) NearCacheStatsGetter)

func (*Service) Start

func (s *Service) Start()

func (*Service) Stop

func (s *Service) Stop()