Versions in this module Expand all Collapse all v1 v1.0.0 Jul 6, 2022 Changes in this version + const KentikAPIToken + type KentikConfig struct + ApiEmail string + ApiPlan int + ApiRoot string + ApiToken string v1.0.0-rc23 Jun 24, 2022 v0 v0.1.2 Sep 15, 2023 v0.1.1 Sep 15, 2023 v0.0.3 Sep 21, 2023 Changes in this version + const AWSErrPrefix + const AdminStatus + const AwsSmPrefix + const AzureErrPrefix + const AzureKVPrefix + const BitString + const CollectorName + const CompressionDeflate + const CompressionGzip + const CompressionNone + const CompressionNull + const CompressionSnappy + const CountMetric + const Counter + const Counter64 + const DefaultProfileMessage + const DeviceProvider + const DeviceTagTable + const DropMetric + const EnableAllMibs + const EventOutput + const FloatMS + const FromGCP + const FromLambda + const GCPErrPrefix + const GCPSmPrefix + const Gauge + const GaugeMetric + const GlobalProvider + const INTEGER + const Index + const IndexVar + const InstProvider + const Integer32 + const InvalidEnum + const IpAddr + const KENTIK_EVENT_EXT + const KENTIK_EVENT_JSON + const KENTIK_EVENT_KTRANS_METRIC + const KENTIK_EVENT_SNMP + const KENTIK_EVENT_SNMP_DEV_METRIC + const KENTIK_EVENT_SNMP_INT_METRIC + const KENTIK_EVENT_SNMP_METADATA + const KENTIK_EVENT_SNMP_TRAP + const KENTIK_EVENT_SYNTH + const KENTIK_EVENT_TRACE + const KENTIK_EVENT_TYPE + const KentikAPITimeout + const LOGICAL_INTERFACE + const MetricOutput + const NetAddr + const ObjID + const PHYSICAL_INTERFACE + const PluginHealth + const PluginSyslog + const PollAdjustTime + const PrivateIP + const ProviderPrefix + const ProviderToken + const RollupOutput + const SIGUSR1 + const SIGUSR2 + const SNMP_BAD_DEVICE_ERR + const SNMP_BAD_FIRST_METRICS_POLL + const SNMP_BAD_INIT_METADATA + const SNMP_BAD_INIT_METRICS + const SNMP_BAD_INTERFACE_ERR + const SNMP_BAD_NO_DATA + const SNMP_BAD_POLL_TIMEOUT + const SNMP_GOOD + const SendBatchDuration + const SnmpCollector + const String + const StringPrefix + const TimeTicks + const UserTagPrefix + var InputTesting = []*JCHF + var InputTestingSnmp = []*JCHF + var InputTestingSynth = []*JCHF + var SNMP_STATUS_MAP = map[int64]string + func FixupName(name string) string + func LookupEnvBool(key string, defaultVal bool) bool + func LookupEnvInt(key string, defaultVal int) int + func LookupEnvString(key string, defaultVal string) string + type Addr struct + Address string + Netmask string + type AgentId IntId + func NewAgentId(id string) AgentId + type Cid IntId + func (id Cid) Itoa() string + type Column struct + ID uint64 + Name string + Type string + type Compression string + type CustomColumn struct + CustomMapValues map[uint32]string + ID uint32 + Name string + Type string + type Device struct + AllInterfaces []Interface + BgpType string + CdnAttr string + CompanyID Cid + CustomStr string + Customs []Column + Description string + DeviceSubtype string + DeviceType string + ID DeviceID + IP net.IP + Interfaces map[IfaceID]Interface + Labels []DeviceLabel + MaxFlowRate int + Name string + Plan Plan + SampleRate uint32 + SendingIps []net.IP + Site DeviceSite + SnmpCommunity string + SnmpIp string + SnmpV3 *V3SNMPConfig + func (d *Device) InitUserTags(serviceName string, tags map[string]string) + func (d *Device) SetMsgUserTags(in sfmt.LogParts) + func (d *Device) SetUserTags(in map[string]string) + type DeviceData struct + DeviceMetricsMetadata *DeviceMetricsMetadata + InterfaceData map[string]*InterfaceData + Manufacturer string + type DeviceID IntId + func (id DeviceID) Itoa() string + type DeviceLabel struct + Desc string + ID int + Name string + type DeviceList struct + Devices []Device + type DeviceMap map[string]*SnmpDeviceConfig + func (a *DeviceMap) UnmarshalYAML(unmarshal func(interface{}) error) error + type DeviceMapper struct + Devices map[DeviceID]map[IfaceID]*InterfaceRow + type DeviceMetricsMetadata struct + CustomInts map[string]int64 + Customs map[string]string + EngineID string + SysContact string + SysDescr string + SysLocation string + SysName string + SysObjectID string + SysServices int + Tables map[string]DeviceTableMetadata + type DeviceSite struct + ID int + SiteName string + type DeviceTableMetadata struct + Customs map[string]MetaValue + func NewDeviceTableMetadata() DeviceTableMetadata + type Devices map[DeviceID]*Device + type EAPIC EAPIConfig + type EAPIConfig struct + Host string + Password string + Port int + Transport string + Username string + func (a *EAPIConfig) MarshalYAML() (interface{}, error) + func (a *EAPIConfig) UnmarshalYAML(unmarshal func(interface{}) error) error + type Enricher interface + EnrichMetric func(string, string, map[string]int64, map[string]string, map[string]MetricInfo) + EnrichMib func(string, string, map[string]interface{}, *LastMetadata) + type ExtensionSet struct + EAPIConfig *EAPIConfig + ExtOnly bool + MerakiConfig *MerakiConfig + type IPAddr struct + Address string + Netmask string + type IfaceID IntId + func (id IfaceID) Itoa() string + type IntId uint64 + type Interface struct + Addrs []Addr + DeviceID DeviceID + DeviceName string + DeviceType string + ID int64 + InterfaceDescription string + InterfaceIP string + Netmask string + Provider string + SiteCountry string + SiteID int + SiteTitle string + SnmpAlias string + SnmpID IfaceID + SnmpSpeedMbps int64 + SnmpType int + VrfID int64 + type InterfaceCapacityBPS = uint64 + type InterfaceData struct + Alias string + AliasAddr []IPAddr + Description string + ExtraInfo map[string]string + Index string + Speed uint64 + Type string + type InterfaceRow struct + DeviceId uint32 + DeviceName string + DeviceType string + InterfaceDescription string + InterfaceIp string + Provider string + SiteCountry string + SiteId uint32 + SiteTitle string + SnmpAlias string + SnmpId string + SnmpSpeed int64 + SnmpType uint32 + VrfId uint32 + type JCHF struct + ApplySample bool + CompanyId Cid + CustomBigInt map[string]int64 + CustomInt map[string]int32 + CustomMetrics map[string]MetricInfo + CustomStr map[string]string + CustomTables map[string]DeviceTableMetadata + DeviceId DeviceID + DeviceName string + DstAddr string + DstAs uint32 + DstBgpAsPath string + DstBgpCommunity string + DstEthMac string + DstFlowTags string + DstGeo string + DstGeoCity string + DstGeoRegion string + DstNextHop string + DstNextHopAs uint32 + DstRoutePrefix string + DstSecondAsn uint32 + DstThirdAsn uint32 + EventType string + HeaderLen uint32 + InBytes uint64 + InPkts uint64 + InputIntAlias string + InputIntDesc string + InputInterfaceCapacity int64 + InputInterfaceIP string + InputPort IfaceID + IpSize uint32 + L4DstPort uint32 + L4SrcPort uint32 + MatchAttr map[string]*regexp.Regexp + MplsType uint32 + NextHop string + OutBytes uint64 + OutPkts uint64 + OutputIntAlias string + OutputIntDesc string + OutputInterfaceCapacity int64 + OutputInterfaceIP string + OutputPort IfaceID + Protocol string + Provider Provider + SampleRate uint32 + SampledPacketSize uint32 + SrcAddr string + SrcAs uint32 + SrcBgpAsPath string + SrcBgpCommunity string + SrcEthMac string + SrcFlowTags string + SrcGeo string + SrcGeoCity string + SrcGeoRegion string + SrcNextHop string + SrcNextHopAs uint32 + SrcRoutePrefix string + SrcSecondAsn uint32 + SrcThirdAsn uint32 + TcpFlags uint32 + TcpRetransmit uint32 + Timestamp int64 + Tos uint32 + VlanIn uint32 + VlanOut uint32 + func NewJCHF() *JCHF + func (j *JCHF) Flatten() map[string]interface{} + func (j *JCHF) Reset() + func (j *JCHF) SetIFPorts(p IfaceID) *JCHF + func (j *JCHF) SetMap() + func (j *JCHF) ToMap() map[string]interface{} + type KentikDisco struct + DeviceMatching KentikMatch + UseDeviceInventory bool + type KentikMatch struct + IPAddress []string + Labels []string + Sites []string + type LastMetadata struct + DeviceInfo map[string]interface{} + InterfaceInfo map[IfaceID]map[string]interface{} + MatchAttr map[string]*regexp.Regexp + Tables map[string]DeviceTableMetadata + XtraInfo map[string]MetricInfo + func (lm *LastMetadata) GetTableName(key string) (string, map[string]bool, bool) + func (lm *LastMetadata) Missing(new *LastMetadata) []string + func (lm *LastMetadata) Size() int + type MerakiConfig struct + ApiKey string + Host string + MonitorDevices bool + MonitorNetworkClients bool + MonitorOrgChanges bool + MonitorUplinks bool + MonitorVpnStatus bool + Networks []string + Orgs []string + Prefs map[string]bool + ProductTypes []string + type MetaValue struct + IntVal int64 + Mib *Mib + StringVal string + TableName string + TableNames map[string]bool + func NewMetaValue(mib *Mib, sv string, iv int64) MetaValue + func (mv *MetaValue) GetScript() Enricher + func (mv *MetaValue) GetValue() interface{} + type MetricInfo struct + Format string + Mib string + Name string + Oid string + PollDur time.Duration + Profile string + Table string + Tables map[string]bool + Type string + func (m *MetricInfo) GetType() string + type Mib struct + AllowDup bool + Condition *MibCondition + Conversion string + Enum map[string]int64 + EnumRev map[int64]string + Extra string + Format string + FromExtended bool + MatchAttr map[string]*regexp.Regexp + Mib string + Name string + Oid string + OtherTables map[string]bool + PollDur time.Duration + Script Enricher + Table string + TableOid string + Tag string + Type Oidtype + VarSet map[string][]int + WalkTable bool + XAttr map[string]string + func (mb *Mib) Extend(nm *Mib) + func (mb *Mib) GetName() string + func (mb *Mib) IsPollReady() bool + func (mb *Mib) String() string + type MibCondition struct + TargetName string + TargetValue int64 + type Oidtype int + type Output struct + Body []byte + CB func(error) + Ctx OutputContext + func NewOutput(body []byte) *Output + func NewOutputWithProvider(body []byte, prov Provider, stype OutputType) *Output + func NewOutputWithProviderAndCompanySender(body []byte, prov Provider, cid Cid, stype OutputType, senderid string) *Output + func (o *Output) BodyLen() int + func (o *Output) GetDataType() string + func (o *Output) IsEvent() bool + func (o *Output) IsMetric() bool + type OutputContext struct + CompanyId Cid + Provider Provider + SenderId string + Type OutputType + type OutputType string + type Plan struct + ID uint64 + Name string + type Provider string + const ProviderAgent + const ProviderAlert + const ProviderDefault + const ProviderFibreChannel + const ProviderFirewall + const ProviderFlowDevice + const ProviderHost + const ProviderHttpDevice + const ProviderIOT + const ProviderMerakiCloud + const ProviderNas + const ProviderPDU + const ProviderRouter + const ProviderSan + const ProviderSwitch + const ProviderSynth + const ProviderTrapUnknown + const ProviderUPS + const ProviderVPC + const ProviderWirelessController + type ProviderMap struct + MatchAttr map[string]string + UserTags map[string]string + func (p *ProviderMap) Init(provider string, cfg *SnmpConfig) + type SNMPTestWalker interface + WalkAll func(string) ([]gosnmp.SnmpPDU, error) + type SnmpConfig struct + DeviceOrig string + Devices DeviceMap + Disco *SnmpDiscoConfig + Global *SnmpGlobalConfig + Trap *SnmpTrapConfig + type SnmpDeviceConfig struct + Checked time.Time + Community string + Debug bool + Description string + DeviceIP string + DeviceName string + DiscoveredMibs []string + EngineID string + Ext *ExtensionSet + FlowOnly bool + InstrumentationName string + MatchAttr map[string]string + MibProfile string + MonitorAdminShut bool + NoCheckIncreasing bool + NoUseBulkWalkAll bool + OID string + PingOnly bool + PingSec int + PollTimeSec int + Port uint16 + Provider Provider + PurgeDevice int + Retries int + RunPing bool + SampleRate int64 + TimeoutMS int + UseV1 bool + UserTags map[string]string + V3 *V3SNMPConfig + func (d *SnmpDeviceConfig) AddUserTag(k string, v string) + func (d *SnmpDeviceConfig) GetTestWalker() SNMPTestWalker + func (d *SnmpDeviceConfig) GetUserTags() map[string]string + func (d *SnmpDeviceConfig) InitUserTags(serviceName string) + func (d *SnmpDeviceConfig) SetTestWalker(w SNMPTestWalker) + func (d *SnmpDeviceConfig) SetUserTags(in map[string]string) + func (d *SnmpDeviceConfig) UpdateFrom(old *SnmpDeviceConfig, conf *SnmpConfig) + type SnmpDeviceMetric struct + DeviceMetrics go_metrics.Meter + Errors go_metrics.Meter + Fail go_metrics.Gauge + InterfaceMetrics go_metrics.Meter + Metadata go_metrics.Meter + Missing go_metrics.Gauge + MissingMeta go_metrics.Gauge + func NewSnmpDeviceMetric(registry go_metrics.Registry, deviceName string) *SnmpDeviceMetric + type SnmpDiscoConfig struct + AddAllMibs bool + AddDevices bool + CheckAll bool + CheckAllVersions bool + CidrOrig string + Cidrs StringArray + Debug bool + DefaultCommunities []string + DefaultV3 *V3SNMPConfig + IgnoreList StringArray + IgnoreOrig string + Kentik *KentikDisco + NoDedup bool + OtherV3s []*V3SNMPConfig + Ports []int + ReplaceDevices bool + Threads int + UseV1 bool + type SnmpGlobalConfig struct + DropIfOutside bool + GlobalV3 *V3SNMPConfig + JitterTimeSec int + MatchAttr map[string]string + MibDB string + MibProfileDir string + MibsEnabled []string + NoDeviceHardcodedOids bool + PingSec int + PollTimeSec int + ProviderMap map[string]ProviderMap + PurgeDevices int + Retries int + RunPing bool + TimeoutMS int + UserTags map[string]string + type SnmpMetricSet struct + Devices map[string]*SnmpDeviceMetric + Mux sync.RWMutex + Traps go_metrics.Meter + func NewSnmpMetricSet(registry go_metrics.Registry) *SnmpMetricSet + type SnmpTrapConfig struct + Community string + Listen string + Transport string + TrapOnly bool + V3 *V3SNMPConfig + Version string + type StringArray []string + func (a *StringArray) UnmarshalYAML(unmarshal func(interface{}) error) error + type TestId IntId + func NewTestId(id string) TestId + type TopValue struct + Asn uint32 + Packets uint64 + type V3SNMP V3SNMPConfig + type V3SNMPConfig struct + AuthenticationPassphrase string + AuthenticationProtocol string + ContextEngineID string + ContextName string + PrivacyPassphrase string + PrivacyProtocol string + UserName string + func (a *V3SNMPConfig) InheritGlobal() bool + func (a *V3SNMPConfig) MarshalYAML() (interface{}, error) + func (a *V3SNMPConfig) UnmarshalYAML(unmarshal func(interface{}) error) error
Go to main page