toputils

Aug 22, 2024

Changes in this version

+ func Nsize(displayRawValue bool, s int64) string

Apr 6, 2023

Changes in this version

+ type ConnRates struct

+ InBytesRate float64

+ InMsgsRate float64

+ OutBytesRate float64

+ OutMsgsRate float64

type Engine

+ LastConnz map[uint64]*server.ConnInfo

+ ShowRates bool

type Rates

+ Connections map[uint64]*ConnRates

Apr 25, 2022

Changes in this version

type Engine

+ LastPollTime time.Time

+ LastStats *Stats

Mar 22, 2022

Changes in this version

type Engine

+ func (engine *Engine) FetchStatsSnapshot() *Stats

Aug 23, 2016

Changes in this version

type Stats

+ Error error

Feb 13, 2016

Changes in this version

+ type Engine struct

+ Conns int

+ Delay int

+ DisplaySubs bool

+ Host string

+ HttpClient *http.Client

+ Port int

+ ShutdownCh chan struct{}

+ SortOpt gnatsd.SortOpt

+ StatsCh chan *Stats

+ Uri string

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

+ 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

Aug 20, 2015

Changes in this version

+ const DisplaySubscriptions

+ const SortByCid

+ const SortByInBytes

+ const SortByInMsgs

+ const SortByOutBytes

+ const SortByOutMsgs

+ const SortBySubs

+ func MonitorStats(opts map[string]interface{}, statsCh chan *Stats, shutdownCh chan struct{}) error

+ func Psize(s int64) string

+ func Request(path string, opts map[string]interface{}) (interface{}, error)

+ type ByBytesFrom []*server.ConnInfo

+ func (d ByBytesFrom) Len() int

+ func (d ByBytesFrom) Less(i, j int) bool

+ func (d ByBytesFrom) Swap(i, j int)

+ type ByBytesTo []*server.ConnInfo

+ func (d ByBytesTo) Len() int

+ func (d ByBytesTo) Less(i, j int) bool

+ func (d ByBytesTo) Swap(i, j int)

+ type ByCid []*server.ConnInfo

+ func (d ByCid) Len() int

+ func (d ByCid) Less(i, j int) bool

+ func (d ByCid) Swap(i, j int)

+ type ByMsgsFrom []*server.ConnInfo

+ func (d ByMsgsFrom) Len() int

+ func (d ByMsgsFrom) Less(i, j int) bool

+ func (d ByMsgsFrom) Swap(i, j int)

+ type ByMsgsTo []*server.ConnInfo

+ func (d ByMsgsTo) Len() int

+ func (d ByMsgsTo) Less(i, j int) bool

+ func (d ByMsgsTo) Swap(i, j int)

+ type ByPending []*server.ConnInfo

+ func (d ByPending) Len() int

+ func (d ByPending) Less(i, j int) bool

+ func (d ByPending) Swap(i, j int)

+ type BySubs []*server.ConnInfo

+ func (d BySubs) Len() int

+ func (d BySubs) Less(i, j int) bool

+ func (d BySubs) Swap(i, j int)

+ type Rates struct

+ InBytesRate float64

+ InMsgsRate float64

+ OutBytesRate float64

+ OutMsgsRate float64

+ type Stats struct

+ Connz *server.Connz

+ Rates *Rates

+ Varz *server.Varz