service

Documentation

Index

• Constants
• type Bonjour
  • func NewBonjour(repo *repository.Probe) *Bonjour
  • func (s *Bonjour) Count() (int64, error)
  • func (s *Bonjour) Record(b *model.Bonjour) error
  • func (s *Bonjour) UIDExists(uid string) bool
• type Prometheus
  • func NewPrometheus() *Prometheus
  • func (p *Prometheus) IncPV(platform, path string)
  • func (p *Prometheus) IncUV(platform, path string)
  • func (p *Prometheus) RecordReconnection(platform string, reconnects int)
  • func (p *Prometheus) RegisterLiveUserFunc(function func() float64)
  • func (p *Prometheus) RegisterUsersFunc(function func() float64)

Constants

const (
	PromNamespace = "probe"
)

Types

type Bonjour

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

Bonjour is the bonjour service

func NewBonjour

func NewBonjour(repo *repository.Probe) *Bonjour

NewBonjour creates a bonjour request-related service with repo

func (*Bonjour) Count

func (s *Bonjour) Count() (int64, error)

Count counts current bonjour requests from db

func (*Bonjour) Record

func (s *Bonjour) Record(b *model.Bonjour) error

Record adds a bonjour request in model.Bonjour to db

func (*Bonjour) UIDExists

func (s *Bonjour) UIDExists(uid string) bool

type Prometheus

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

func NewPrometheus

func NewPrometheus() *Prometheus

func (*Prometheus) IncPV

func (p *Prometheus) IncPV(platform, path string)

func (*Prometheus) IncUV

func (p *Prometheus) IncUV(platform, path string)

func (*Prometheus) RecordReconnection

func (p *Prometheus) RecordReconnection(platform string, reconnects int)

func (*Prometheus) RegisterLiveUserFunc

func (p *Prometheus) RegisterLiveUserFunc(function func() float64)

func (*Prometheus) RegisterUsersFunc

func (p *Prometheus) RegisterUsersFunc(function func() float64)