vlmonitoring

Documentation

Index

• func LoadStore(src *uint64, dst *uint64) uint64
• type Bytes
• type Clients
• type Counter
  • func (c *Counter) AddU64(n uint64) uint64
  • func (c *Counter) Diff(prev *Counter) Counter
  • func (c *Counter) Get() uint64
  • func (c *Counter) Load() uint64
• type DynamicIFace
• type FlowCounter
  • func (c *FlowCounter) Diff(prev *FlowCounter) FlowCounter
  • func (c *FlowCounter) RecvAddU64(n uint64) uint64
  • func (c *FlowCounter) SentAddU64(n uint64) uint64
• type IFace
• type Max
  • func (c *Max) AddU64(n uint64)
  • func (c *Max) Get() uint64
  • func (c *Max) Load() Max
  • func (c *Max) SubU64(n uint64)
• type Packets
• type State
  • func (c *State) Get() uint64
  • func (c *State) Load() uint64
• type Stats
• type Subscriptions

Functions

func LoadStore

func LoadStore(src *uint64, dst *uint64) uint64

Types

type Bytes

type Bytes struct {
	FlowCounter
}

type Clients

type Clients struct {
	Connected Max
	Persisted Max
	Total     Max
	Expired   Counter
	Rejected  Counter
}

type Counter

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

func (*Counter) AddU64

func (c *Counter) AddU64(n uint64) uint64

func (*Counter) Diff

func (c *Counter) Diff(prev *Counter) Counter

func (*Counter) Get

func (c *Counter) Get() uint64

func (*Counter) Load

func (c *Counter) Load() uint64

type DynamicIFace

type DynamicIFace interface {
	Topic() string
	// Retained used by topics provider to get retained message when there is new subscription to given topic
	Retained() *mqttp.Publish
	// Publish used by systree update routine to publish new value when on periodic basis
	Publish() *mqttp.Publish

	Add(uint64) uint64
	Set(uint64)
	Get() uint64
}

DynamicIFace interface describes states of the dynamic value

type FlowCounter

type FlowCounter struct {
	Sent Counter
	Recv Counter
}

func (*FlowCounter) Diff

func (c *FlowCounter) Diff(prev *FlowCounter) FlowCounter

func (*FlowCounter) RecvAddU64

func (c *FlowCounter) RecvAddU64(n uint64) uint64

func (*FlowCounter) SentAddU64

func (c *FlowCounter) SentAddU64(n uint64) uint64

type IFace

type IFace interface {
	Push(stats Stats)
	Shutdown() error
}

type Max

type Max struct {
	State
	Max uint64
}

func (*Max) AddU64

func (c *Max) AddU64(n uint64)

func (*Max) Get

func (c *Max) Get() uint64

func (*Max) Load

func (c *Max) Load() Max

func (*Max) SubU64

func (c *Max) SubU64(n uint64)

type Packets

type Packets struct {
	Total      FlowCounter
	Connect    Counter
	ConnAck    Counter
	Publish    FlowCounter
	Puback     FlowCounter
	Pubrec     FlowCounter
	Pubrel     FlowCounter
	Pubcomp    FlowCounter
	Sub        Counter
	SubAck     Counter
	UnSub      Counter
	UnSubAck   Counter
	Disconnect FlowCounter
	PingReq    Counter
	PingResp   Counter
	Auth       FlowCounter
	Unknown    Counter
	Rejected   Counter
	UnAckSent  Max
	UnAckRecv  Max
	Retained   Max
	Stored     Max
}

type State

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

func (*State) Get

func (c *State) Get() uint64

func (*State) Load

func (c *State) Load() uint64

type Stats

type Stats struct {
	Bytes   Bytes
	Packets Packets
	Clients Clients
	Subs    Subscriptions
}

type Subscriptions

type Subscriptions struct {
	Total Max
}