toputils

Documentation

Index

• Constants
• func Nsize(displayRawValue bool, s int64) string
• func Psize(displayRawValue bool, s int64) string
• type ConnRates
• type Engine
  • func NewEngine(host string, port int, conns int, delay int) *Engine
  • func (engine *Engine) FetchStatsSnapshot() *Stats
  • func (engine *Engine) MonitorStats() error
  • func (engine *Engine) Request(path string) (interface{}, error)
  • func (engine *Engine) SetupHTTP()
  • func (engine *Engine) SetupHTTPS(caCertOpt, certOpt, keyOpt string, skipVerifyOpt bool) error
• type Rates
• type Stats

Constants

const DisplaySubscriptions = 1

Functions

func Nsize

func Nsize(displayRawValue bool, s int64) string

Nsize takes a float and returns a human readable string.

func Psize

func Psize(displayRawValue bool, s int64) string

Psize takes a float and returns a human readable string (Used for bytes).

Types

type ConnRates

type ConnRates struct {
	InMsgsRate   float64
	OutMsgsRate  float64
	InBytesRate  float64
	OutBytesRate float64
}

type Engine

type Engine struct {
	Host         string
	Port         int
	HttpClient   *http.Client
	Uri          string
	Conns        int
	SortOpt      server.SortOpt
	Delay        int
	DisplaySubs  bool
	StatsCh      chan *Stats
	ShutdownCh   chan struct{}
	LastStats    *Stats
	LastPollTime time.Time
	ShowRates    bool
	LastConnz    map[uint64]*server.ConnInfo
}

func NewEngine

func NewEngine(host string, port int, conns int, delay int) *Engine

func (*Engine) FetchStatsSnapshot

func (engine *Engine) FetchStatsSnapshot() *Stats

func (*Engine) MonitorStats

func (engine *Engine) MonitorStats() error

MonitorStats is ran as a goroutine and takes options which can modify how poll values then sends to channel.

func (*Engine) Request

func (engine *Engine) Request(path string) (interface{}, error)

Request takes a path and options, and returns a Stats struct with with either connz or varz

func (*Engine) SetupHTTP

func (engine *Engine) SetupHTTP()

SetupHTTP sets up the http client and uri to use for polling.

func (*Engine) SetupHTTPS

func (engine *Engine) SetupHTTPS(caCertOpt, certOpt, keyOpt string, skipVerifyOpt bool) error

SetupHTTPS sets up the http client and uri to use for polling.

type Rates

type Rates struct {
	InMsgsRate   float64
	OutMsgsRate  float64
	InBytesRate  float64
	OutBytesRate float64
	Connections  map[uint64]*ConnRates
}

Rates represents the tracked in/out msgs and bytes flow from a NATS server.

type Stats

type Stats struct {
	Varz  *server.Varz
	Connz *server.Connz
	Rates *Rates
	Error error
}

Stats represents the monitored data from a NATS server.