Module: GRI
- Defined in:
- lib/gri/api.rb,
lib/gri/ldb.rb,
lib/gri/cast.rb,
lib/gri/list.rb,
lib/gri/loop.rb,
lib/gri/main.rb,
lib/gri/page.rb,
lib/gri/trad.rb,
lib/gri/clist.rb,
lib/gri/graph.rb,
lib/gri/spark.rb,
lib/gri/utils.rb,
lib/gri/wmain.rb,
lib/gri/cgraph.rb,
lib/gri/config.rb,
lib/gri/plugin.rb,
lib/gri/sgraph.rb,
lib/gri/vendor.rb,
lib/gri/writer.rb,
lib/gri/ds_list.rb,
lib/gri/gparams.rb,
lib/gri/grapher.rb,
lib/gri/request.rb,
lib/gri/updater.rb,
lib/gri/version.rb,
lib/gri/collector.rb,
lib/gri/fake_snmp.rb,
lib/gri/scheduler.rb,
lib/gri/app_walker.rb,
lib/gri/pcollector.rb,
lib/gri/builtindefs.rb,
lib/gri/polling_unit.rb,
lib/gri/app_collector.rb,
lib/gri/format_helper.rb,
lib/gri/tra_collector.rb,
lib/gri/plugin/bootstrap.rb,
lib/gri/plugin/exec_collector.rb,
lib/gri/plugin/writer_fluentd.rb,
lib/gri/plugin/writer_influxdb.rb
Defined Under Namespace
Modules: Bootstrap, FormatHelper, Plugin, Utils Classes: API, AppCollector, AppWalker, Cast, Cgraph, Clist, Collector, Config, DSList, ExecCollector, FakeSNMP, FakeSock, FluentWriter, GParams, Graph, Grapher, HRSWRunPerfPollingUnit, InfluxdbWriter, List, LocalLDB, Loop, Main, Page, PollingUnit, RRDUpdater, RRDWriter, RemoteLDB, Request, SNMPCollector, STDOUTWriter, Scheduler, Sgraph, Spark, TextWriter, TraCollector, Trad, UScheduler, Updater, Vendor, WMain, Writer
Constant Summary collapse
- VERSION =
"10.1.1"- DEFS =
{ 'num'=>{ :ds=>['num,num,GAUGE,,,,:index'], :rra=>['RRA:AVERAGE:0.5:15:10000', 'RRA:MAX:0.5:1:50000', 'RRA:MAX:0.5:15:10000', 'RRA:MAX:0.5:180:10000'], :prop=>{:name=>'_index', :description=>'description', :lastvalue=>'num'}, :list=>['Num', '%N,%L\r'], :graph=>[['', 0]], :composite=>['', 's', 'v', 't'], }, 'counter'=>{ :ds=>['num,num,DERIVE,,,,:index'], :prop=>{:name=>'_index', :description=>'description'}, :list=>['Counter', '%N'], :graph=>[['', 0, [0, nil]]], :composite=>['', 's', 'v', 't'], }, 'grimetrics'=>{:ds=>['number,number,GAUGE'], :prop=>{:name=>'_index'}, :list_text=>['grimetrics', '%N,%L\r'], :composite=>['s'], :graph=>[['n', 0]], }, 'interfaces'=>{:cat=>'', :oid=>['ifDescr', 'ifSpeed', 'ifAdminStatus', 'ifOperStatus', 'ifType', 'ifInOctets', 'ifOutOctets', 'ifInDiscards', 'ifOutDiscards', 'ifInErrors', 'ifOutErrors', 'ifInUcastPkts', 'ifOutUcastPkts', 'ifInNUcastPkts', 'ifOutNUcastPkts',], :index_key => 'ifDescr', :ignore? => proc {|record| /(^(Loopback|Null|Async)\d+)|cef layer|atm subif/ === record['ifDescr']}, :exclude? => proc {|record| record['ifOperStatus'].to_i != 1 or record['ifSpeed'].to_i == 0 or (Integer(record['ifInOctets']) == 0 and Integer(record['ifOutOctets']) == 0) or /(^(Loopback|Null|Async|lo)\d+)|cef layer|atm subif/ === record['ifDescr'] }, :hidden? => proc {|record| /cef layer|atm subif|unrouted.VLAN/ === record['ifDescr'] }, :tdb=>['', 'ifDescr', 'ifAlias', 'ifSpeed', 'ifInOctets', 'ifOutOctets', 'ifInDiscards', 'ifOutDiscards', 'ifInErrors', 'ifOutErrors', 'ifHCInOctets', 'ifHCOutOctets',], :ds=>['ifInOctets,inoctet,DERIVE,MAX,AREA,#90f090,in,8', 'ifOutOctets,outoctet,DERIVE,MAX,LINE1,#0000ff,out,8', 'ifInDiscards,indiscard,DERIVE,MAX,LINE1,#00ff0f', 'ifOutDiscards,outdiscard,DERIVE,MAX,LINE1,#00afff', 'ifInErrors,inerror,DERIVE,MAX,LINE1,#ff0f0f', 'ifOutErrors,outerror,DERIVE,MAX,LINE1,#ffaf00', 'ifInUcastPkts,inucast,DERIVE,MAX,LINE1,#90f090', 'ifOutUcastPkts,outucast,DERIVE,MAX,LINE1,#0000ef', 'ifInNUcastPkts,innucast,DERIVE,MAX,LINE1,#ff0f0f', 'ifOutNUcastPkts,outnucast,DERIVE,MAX,LINE1,#ffaf00'], :prop=>{:name=>'ifDescr', :description=>'ifAlias', :ostatus=>'ifOperStatus', :astatus=>'ifAdminStatus', :ipaddr=>'ipaddr', :ub=>'ifSpeed',}, :list=>['Status,Interface,Description,IP Address', '%S,%N,%D,%I'], :graph=>[['bps', 1000, [0, nil], /Octets/], ['pps', 1000, [0, nil], /N?UcastPkts/], ['packets/5min', 1000, [0, nil], /Error|Discard/]], #/ :composite=>['s', 'v', 't'], }, 'ifMIB'=>{:cat=>'', :oid=>['ifName', 'ifHCInOctets', 'ifHCOutOctets', 'ifHighSpeed', 'ifAlias'], :fix_workhash=>proc {|wh, | for k, r in wh[''] r['ifInOctets'] = r['ifHCInOctets'] if r['ifHCInOctets'] r['ifOutOctets'] = r['ifHCOutOctets'] if r['ifHCOutOctets'] if ['ifhighspeed'] r['ifHighSpeed'] = ['ifhighspeed'].to_i end if r['ifHighSpeed'] and r['ifHighSpeed'].to_i > 4000 r['ifSpeed'] = r['ifHighSpeed'].to_i * 1_000_000 end if ['ifname'] and r['ifName'] r['ifDescr'] = r['ifName'] end end }, }, 'ipaddr'=>{ :oid=>['ipAdEntIfIndex', 'ipAdEntNetMask'], :feed => lambda {|h, enoid, tag, val| ind = BER.dec_oid(enoid[9..-1]).join('.') h[ind] ||= {} if tag == 2 h[ind]['ifIndex'] = val elsif tag == 0x40 # IPv4 Addr h[ind]['mask'] = val end }, :fix_workhash => lambda {|wh| ifrecord = wh[''] || {} for k, record in wh[:ipaddr] a = k + '/' + (record['mask'] || '?') ind = record['ifIndex'] if (r = ifrecord[ind]) if r['ipaddr'] r['ipaddr'] += ',' + a else r['ipaddr'] = a end end end wh.delete :ipaddr }, }, 'tcp'=>{ :oid=>['tcpCurrEstab', 'tcpActiveOpens', 'tcpPassiveOpens', 'tcpAttemptFails', 'tcpEstabResets', 'tcpInSegs', 'tcpOutSegs', 'tcpRetransSegs', 'tcpInErrs', 'tcpOutRsts',], :tdb=>['tcp', 'tcpCurrEstab', 'tcpActiveOpens', 'tcpPassiveOpens', 'tcpAttemptFails', 'tcpEstabResets', 'tcpInSegs', 'tcpOutSegs', 'tcpRetransSegs', 'tcpInErrs', 'tcpOutRsts',], :ds=>[ 'tcpCurrEstab,tcpCurrEstab,GAUGE,MAX,AREA,#90f090', 'tcpActiveOpens,tcpActiveOpens,DERIVE,MAX,LINE1,#0000ff', 'tcpPassiveOpens,tcpPassiveOpens,DERIVE,MAX,LINE1,#c000ff', 'tcpAttemptFails,tcpAttemptFails,DERIVE,MAX,LINE1,#ff0000', 'tcpEstabResets,tcpEstabResets,DERIVE,MAX,LINE1,#ff9030', 'tcpInSegs,tcpInSegs,DERIVE,MAX,AREA,#99ff99', 'tcpOutSegs,tcpOutSegs,DERIVE,MAX,LINE1,#0000ff', 'tcpRetransSegs,tcpRetransSegs,DERIVE,MAX,LINE1,#00ffff', 'tcpInErrs,tcpInErrs,DERIVE,MAX,LINE1,#ff0000', 'tcpOutRsts,tcpOutRsts,DERIVE,MAX,LINE1,#ff9030', ], :prop=>{:name=>'tcp'}, :list=>['TCP'], :graph=>[ ['connection', 0, [0, nil], /tcp(CurrEstab|ActiveOpens|PassiveOpens|AttemptFails|EstabResets)/], ['packet/sec', 0, [0, nil], /tcp(InSegs|OutSegs|RetransSegs|InErrs|OutRsts)/] ], }, 'udp'=>{ :oid=>['udpInDatagrams', 'udpOutDatagrams', 'udpNoPorts', 'udpInErrors'], :tdb=>['udp', 'udpInDatagrams', 'udpOutDatagrams', 'udpNoPorts', 'udpInErrors'], :ds=>[ 'udpInDatagrams,udpInDatagrams,DERIVE,MAX,AREA,#90f090', 'udpOutDatagrams,udpOutDatagrams,DERIVE,MAX,LINE1,#0000ef', 'udpNoPorts,udpNoPorts,DERIVE,MAX,LINE1,#00afff', 'udpInErrors,udpInErrors,DERIVE,MAX,LINE1,#ff0f0f', ], :prop=>{:name=>'udp'}, :list=>['UDP'], :graph=>[['"datagram/sec"', 0, [0, nil]]], }, 'entityu'=>{:oid=>['entPhysicalDescr', 'entPhysicalName'],}, 'hrSystemNumUsers'=>{ :oid=>['hrSystemNumUsers'], :tdb=>['hrsystemnumusers', 'hrSystemNumUsers'], :ds=>['hrSystemNumUsers,users,GAUGE,MAX,LINE1,#ff4020,users'], :prop=>{:name=>'users', :lastvalue=>'hrSystemNumUsers'}, :graph=>[['"users"', 0]], :list=>['Users', '%N, %L\r'], }, 'hrStorage'=>{ :oid=>['hrStorageEntry'], :exclude? => proc {|record| record['hrStorageDescr'] =~ /devicemapper/}, :hidden? => proc {|record| record['hrStorageDescr'] =~ /devicemapper/}, :tdb=>['hrStorage', 'hrStorageDescr', 'hrStorageSize', 'hrStorageUsed'], :fix_workhash=>lambda {|wh| if (th = wh[:hrStorageTotalHack]) ht = Hash[*(th.map {|k, v| [v['dskPath'], (v['dskTotalHigh'].to_i * 4294967296 + v['dskTotalLow'].to_i) * 1024] }).flatten] hu = Hash[*(th.map {|k, v| [v['dskPath'], (v['dskUsedHigh'].to_i * 4294967296 + v['dskUsedLow'].to_i) * 1024] }).flatten] end if (h = wh[:hrStorage]) h.reject! {|k, v| v['hrStorageType'] != "+\x06\x01\x02\x01\x19\x02\x01\x04"} h.each {|k, v| u = v['hrStorageAllocationUnits'].to_i v.delete 'hrStorageType' if ht and (t = ht[v['hrStorageDescr']]) v['hrStorageSize'] = t else v['hrStorageSize'] = v['hrStorageSize'].to_i * u end if hu and (t = hu[v['hrStorageDescr']]) v['hrStorageUsed'] = t else v['hrStorageUsed'] = v['hrStorageUsed'].to_i * u end } end }, :ds=>['hrStorageUsed,used,GAUGE,MAX,AREA,#40ff40'], :prop=>{:name=>'hrStorageDescr', :lastvalue=>'hrStorageUsed', :ub=>'hrStorageSize'}, :list=>['Storage Used', '%N, %1024L / %1024U\r'], :graph=>[['storage used', 1024]], :composite=>['s', 'v', 't'], }, 'hrStorageTotalHack'=>{ :oid=>['dskPath', 'dskTotalLow', 'dskTotalHigh', 'dskUsedLow', 'dskUsedHigh'], }, 'hrSWRunPerf'=>{ :puclass=>'HRSWRunPerf', :oid=>['hrSWRunPath', 'hrSWRunParameters', 'hrSWRunPerfCPU', 'hrSWRunPerfMem'], :tdb=>['hrSWRunPerf', 'name', 'hrSWRunPerfCPU', 'hrSWRunPerfMem'], :ds=>['hrSWRunPerfMem,mem,GAUGE,MAX,AREA,#40ff40', 'hrSWRunPerfCPU,cputime,DERIVE,MAX,LINE1,#4444ff,,300',], :prop=>{:name=>'hrSWRunPerfMatched', :lastvalue=>'hrSWRunPerfMem', :cputime=>'hrSWRunPerfCPU'}, :list=>['RunPerf', '%N,%1024L\r'], :composite=>['s', 'v', 't'], :graph=>[['mem', 1024, nil, /mem/], ['centisecond', 0, [0, nil], /cputime/] ], }, :term => { :default=>[['Daily', 30*3600], ['Weekly', 8*24*3600], ['Monthly', 31*24*3600], ['Yearly', 365*24*3600]], :short=>[['Last 3 hours', 3*3600], ['Daily', 30*3600], ['Weekly', 8*24*3600], ['Monthly', 31*24*3600]], :long=>[['Weekly', 8*24*3600], ['Monthly', 31*24*3600], ['Yearly', 365*24*3600], ['Last 6 years', 6*365*24*3600]], :verylong=>[['Monthly', 31*24*3600], ['Yearly', 365*24*3600], ['Last 8 years', 8*365*24*3600]], } }