stats

package
v0.0.0-...-e9c30ff Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Registry

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

Registry handles statistics

func NewRegistry

func NewRegistry(log *log.Logger, statsClient *statsd.Client) (*Registry, error)

NewRegistry creates a new stats Registry

func (*Registry) CurrentlyWatching

func (s *Registry) CurrentlyWatching() int

func (*Registry) RegisterSpectator

func (s *Registry) RegisterSpectator(ctx context.Context) (func(), error)

func (*Registry) RegisterStreamSubscriber

func (s *Registry) RegisterStreamSubscriber(stream StatStreamConsumersType, authenticated bool) func()

type StatStreamConsumersType

type StatStreamConsumersType string

StatStreamConsumersType is a type of gRPC stream consumer count

const StatStreamConsumersChat StatStreamConsumersType = "chat"

StatStreamConsumersChat is the chat gRPC stream consumer count

const StatStreamConsumersCommunitySkipping StatStreamConsumersType = "community_skipping"

StatStreamConsumersCommunitySkipping is the community skipping gRPC stream consumer count

const StatStreamConsumersQueue StatStreamConsumersType = "queue"

StatStreamConsumersQueue is the queue gRPC stream consumer count

Jump to

Keyboard shortcuts

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