collector

Aug 30, 2019

Changes in this version

+ var CoreSystem = "gnatsd"

+ var ReplicatorSystem = "replicator"

+ var StreamingSystem = "nss"

Jul 15, 2019

Changes in this version

+ func GetServerIDFromVarz(endpoint string, retryInterval time.Duration) string

May 31, 2019

Changes in this version

+ type Connz struct

+ Connections []struct{ ... }

+ Limit int

+ NumConnections int

+ Offset int

+ Total int

Apr 29, 2019

Changes in this version

type StreamingServerz

+ ClusterID string

+ GoVersion string

+ Role string

+ ServerID string

+ StartTime string

+ State string

+ Version string

Mar 22, 2019

Changes in this version

+ type Channelsz struct

+ Channels []*Channelz

+ ClusterID string

+ Count int

+ Limit int

+ Names []string

+ Now time.Time

+ Offset int

+ ServerID string

+ Total int

+ type Channelz struct

+ Bytes uint64

+ FirstSeq uint64

+ LastSeq uint64

+ Msgs int

+ Name string

+ Subscriptions []*Subscriptionz

+ type StreamingServerz struct

+ Channels int

+ Clients int

+ Subscriptions int

+ TotalBytes int

+ TotalMsgs int

+ type Subscriptionz struct

+ AckInbox string

+ AckWait int

+ ClientID string

+ DurableName string

+ Inbox string

+ IsDurable bool

+ IsOffline bool

+ IsStalled bool

+ LastSent uint64

+ MaxInflight int

+ PendingCount int

+ QueueName string

Feb 23, 2018

Changes in this version

+ const ConsoleLogType

+ const FileLogType

+ const RemoteSysLogType

+ const SysLogType

+ func ConfigureLogger(lOpts *LoggerOptions)

+ func Debugf(format string, v ...interface{})

+ func Errorf(format string, v ...interface{})

+ func Fatalf(format string, v ...interface{})

+ func Noticef(format string, v ...interface{})

+ func RemoveLogger()

+ func Tracef(format string, v ...interface{})

+ type CollectedServer struct

+ ID string

+ URL string

+ type Logger interface

+ Debugf func(format string, v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Noticef func(format string, v ...interface{})

+ Tracef func(format string, v ...interface{})

+ type LoggerOptions struct

+ Debug bool

+ LogFile string

+ LogType int

+ Logtime bool

+ RemoteSyslog string

+ Trace bool

+ type NATSCollector struct

+ Stats map[string]interface{}

+ func NewCollector(endpoint string, servers []*CollectedServer) *NATSCollector

+ func (nc *NATSCollector) Collect(ch chan<- prometheus.Metric)

+ func (nc *NATSCollector) Describe(ch chan<- *prometheus.Desc)