vlmonitoring

package
v0.6.1 Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2020 License: Apache-2.0 Imports: 2 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v0.5.2

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
}

Jump to

Keyboard shortcuts

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