statistics

Documentation

Index

• type EngineStatistics
• type EngineStats
  • func NewEngineStats(ctx context.Context, logger *zap.Logger, reportStats bool) *EngineStats
  • func (s *EngineStats) ConnectionsDec()
  • func (s *EngineStats) ConnectionsInc()
  • func (s *EngineStats) GetReport() *UsageReport
  • func (s *EngineStats) Subscribe(ctx context.Context) chan *UsageReport
  • func (s *EngineStats) SubscriptionCountDec(count int)
  • func (s *EngineStats) SubscriptionCountInc(count int)
  • func (s *EngineStats) SubscriptionUpdateSent()
  • func (s *EngineStats) TriggerCountDec(count int)
  • func (s *EngineStats) TriggerCountInc(count int)
• type NoopEngineStats
  • func NewNoopEngineStats() *NoopEngineStats
  • func (s *NoopEngineStats) ConnectionsDec()
  • func (s *NoopEngineStats) ConnectionsInc()
  • func (s *NoopEngineStats) GetReport() *UsageReport
  • func (s *NoopEngineStats) Subscribe(_ context.Context) chan *UsageReport
  • func (s *NoopEngineStats) SubscriptionCountDec(_ int)
  • func (s *NoopEngineStats) SubscriptionCountInc(_ int)
  • func (s *NoopEngineStats) SubscriptionUpdateSent()
  • func (s *NoopEngineStats) SynchronousSubscriptionsDec()
  • func (s *NoopEngineStats) SynchronousSubscriptionsInc()
  • func (s *NoopEngineStats) TriggerCountDec(count int)
  • func (s *NoopEngineStats) TriggerCountInc(count int)
• type UsageReport

Types

type EngineStatistics

type EngineStatistics interface {
	Subscribe(ctx context.Context) chan *UsageReport
	GetReport() *UsageReport
	SubscriptionUpdateSent()
	ConnectionsInc()
	ConnectionsDec()
	SubscriptionCountInc(count int)
	SubscriptionCountDec(count int)
	TriggerCountInc(count int)
	TriggerCountDec(count int)
}

type EngineStats

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

func NewEngineStats

func NewEngineStats(ctx context.Context, logger *zap.Logger, reportStats bool) *EngineStats

func (*EngineStats) ConnectionsDec

func (s *EngineStats) ConnectionsDec()

func (*EngineStats) ConnectionsInc

func (s *EngineStats) ConnectionsInc()

func (*EngineStats) GetReport

func (s *EngineStats) GetReport() *UsageReport

func (*EngineStats) Subscribe

func (s *EngineStats) Subscribe(ctx context.Context) chan *UsageReport

func (*EngineStats) SubscriptionCountDec

func (s *EngineStats) SubscriptionCountDec(count int)

func (*EngineStats) SubscriptionCountInc

func (s *EngineStats) SubscriptionCountInc(count int)

func (*EngineStats) SubscriptionUpdateSent

func (s *EngineStats) SubscriptionUpdateSent()

func (*EngineStats) TriggerCountDec

func (s *EngineStats) TriggerCountDec(count int)

func (*EngineStats) TriggerCountInc

func (s *EngineStats) TriggerCountInc(count int)

type NoopEngineStats

type NoopEngineStats struct{}

func NewNoopEngineStats

func NewNoopEngineStats() *NoopEngineStats

func (*NoopEngineStats) ConnectionsDec

func (s *NoopEngineStats) ConnectionsDec()

func (*NoopEngineStats) ConnectionsInc

func (s *NoopEngineStats) ConnectionsInc()

func (*NoopEngineStats) GetReport

func (s *NoopEngineStats) GetReport() *UsageReport

func (*NoopEngineStats) Subscribe

func (s *NoopEngineStats) Subscribe(_ context.Context) chan *UsageReport

func (*NoopEngineStats) SubscriptionCountDec

func (s *NoopEngineStats) SubscriptionCountDec(_ int)

func (*NoopEngineStats) SubscriptionCountInc

func (s *NoopEngineStats) SubscriptionCountInc(_ int)

func (*NoopEngineStats) SubscriptionUpdateSent

func (s *NoopEngineStats) SubscriptionUpdateSent()

func (*NoopEngineStats) SynchronousSubscriptionsDec

func (s *NoopEngineStats) SynchronousSubscriptionsDec()

func (*NoopEngineStats) SynchronousSubscriptionsInc

func (s *NoopEngineStats) SynchronousSubscriptionsInc()

func (*NoopEngineStats) TriggerCountDec

func (s *NoopEngineStats) TriggerCountDec(count int)

func (*NoopEngineStats) TriggerCountInc

func (s *NoopEngineStats) TriggerCountInc(count int)

type UsageReport

type UsageReport struct {
	Connections   uint64
	Subscriptions uint64
	MessagesSent  uint64
	Triggers      uint64
}