metrics

Documentation

Index

• type Bytes
• type Clients
• type IFace
  • func New() IFace
• type Informer
• type Packets
• type Provider
• type Subscriptions

Types

type Bytes

type Bytes interface {
	OnSent(int)
	OnRecv(int)
}

type Clients

type Clients interface {
	OnConnected()
	OnDisconnected(p bool)
	OnPersisted(n uint64)
	OnRemoved(n int)
	OnExpired(n int)
	OnRejected()
}

type IFace

type IFace interface {
	Informer
	Provider
}

func New

func New() IFace

type Informer

type Informer interface {
	Bytes() Bytes
	Packets() Packets
	Subs() Subscriptions
	Clients() Clients
}

type Packets

type Packets interface {
	OnSent(p mqttp.Type)
	OnRecv(p mqttp.Type)
	OnAddRetain()
	OnSubRetain()
	OnAddUnAckSent(n int)
	OnSubUnAckSent(n int)
	OnAddUnAckRecv(n int)
	OnSubUnAckRecv(n int)
	OnAddStore(n int)
	OnSubStore(n int)
	OnRejected(n int)
}

type Provider

type Provider interface {
	Register(name string, face vlmonitoring.IFace) error
	Shutdown() error
}

type Subscriptions

type Subscriptions interface {
	OnSubscribe()
	OnUnsubscribe()
}