snmp

Jan 17, 2024

Changes in this version

+ type Correlate struct

+ Duration helper.Duration

+ DurationSeconds float64

+ ID string

+ RaisedTime time.Time

type Message

+ Metadata Metadata

+ Payload *Payload

+ type Metadata struct

+ Compiled bool

+ Eta time.Time

+ MessageJSON []byte

+ Retries int

+ Skip bool

+ TimeAsTimezone string

+ TimeFormat string

+ type Payload struct

+ AgentAddress *string

+ Community *string

+ Context *string

+ Correlate *Correlate

+ Description *string

+ DstAddress string

+ DstPort int

+ EnterpriseMIBName *string

+ EnterpriseOID *string

+ PDUVersion string

+ SNMPVersion string

+ SrcAddress string

+ SrcPort int

+ Time time.Time

+ TrapSubType *int64

+ TrapType *int64

+ UptimeSeconds *float64

+ User *string

+ Values []Value

Dec 12, 2023

Changes in this version

+ const DefaultBufferSize

type Config

+ BufferSize string

+ func (c *Config) GetBufferSize() (int, error)

Jul 31, 2023

Changes in this version

type AuthType

+ const AuthSHA128

+ const AuthSHA224

+ const AuthSHA256

+ const AuthSHA384

+ const AuthSHA512

type PrivacyProtocol

+ const PrivAES128

+ const PrivAES192

+ const PrivAES256

Jul 12, 2023

Changes in this version

+ var Functions = []expr.Option

type Header

+ const HeaderTime

type Message

+ DstAddress string

+ DstPort int

+ Eta time.Time

+ MessageCompiled MessageCompiled

+ MessageJSON []byte

+ Retries int

+ Skip bool

+ SrcAddress string

+ SrcPort int

+ Time TimeLayout

+ func (m *Message) Compare(other queue.Item) int

+ func (m *Message) Compile(conf MessageCompiler)

+ func (m *Message) ComputeEta(minDelay, maxDelay time.Duration) time.Time

+ func (m *Message) Copy() Message

+ type MessageCompiled struct

+ AgentAddress *string

+ Community *string

+ Context *string

+ Description *string

+ DstAddress string

+ DstPort int

+ EnterpriseMIBName *string

+ EnterpriseOID *string

+ PDUVersion string

+ SNMPVersion string

+ SrcAddress string

+ SrcPort int

+ Time any

+ TrapSubType *int64

+ TrapType *int64

+ UptimeSeconds *float64

+ User *string

+ Values []ValueCompiled

+ type MessageCompiler struct

+ Filter *vm.Program

+ JSONFormat *vm.Program

+ Logger zerolog.Logger

+ TimeAsTimezone string

+ TimeFormat string

+ type TimeLayout struct

+ func (t *TimeLayout) MarshalJSON() ([]byte, error)

+ func (t *TimeLayout) MarshalNative() any

+ func (t *TimeLayout) SetLayout(layout string)

+ func (t *TimeLayout) SetTimezone(tz string)

+ func (t *TimeLayout) String() string

type Value

+ func (v Value) Compile(conf MessageCompiler) ValueCompiled

+ type ValueCompiled struct

+ MIBName string

+ NativeType string

+ OID string

+ Type string

+ Value any

+ ValueDetail ValueDetail

Jul 8, 2023

Changes in this version

type ValueType

+ const TypeNull

Jul 7, 2023

Changes in this version

+ const PidFilePath

+ func InitMIBTranslator(mibPath string) error

+ func ParserWorker(i int, wg *sync.WaitGroup, parseChan <-chan []byte, messageChan chan<- Message)

+ type AuthConfig struct

+ Community []Community

+ Enable bool

+ User []User

+ type AuthType int8

+ const AuthMD5

+ const AuthSHA

+ func (a *AuthType) String() string

+ func (a *AuthType) UnmarshalText(text []byte) error

+ type Community struct

+ Name string

+ type Config struct

+ AdditionalConfig string

+ Auth AuthConfig

+ Listening []string

+ MagicBegin string

+ MagicEnd string

+ func (c *Config) Serialize(path string) error

+ type Header int8

+ const HeaderAgentAddress

+ const HeaderConnection

+ const HeaderDescription

+ const HeaderEnterprise

+ const HeaderLocalTime

+ const HeaderSecurity

+ const HeaderTrapSubType

+ const HeaderTrapType

+ const HeaderUptime

+ const HeaderVarBinds

+ type Message struct

+ AgentAddress *string

+ Community *string

+ Context *string

+ Description *string

+ EnterpriseMIBName *string

+ EnterpriseOID *string

+ LocalTime *TimeJson

+ PDUVersion *string

+ SNMPVersion *string

+ SourceAddress *string

+ TrapSubType *int

+ TrapType *int

+ UptimeSeconds *float64

+ User *string

+ Values []Value

+ func (m *Message) UnmarshalText(text []byte) error

+ type PrivacyProtocol int8

+ const PrivAES

+ const PrivDES

+ func (p *PrivacyProtocol) String() string

+ func (p *PrivacyProtocol) UnmarshalText(text []byte) error

+ type TimeJson struct

+ func NewTimeJson(t time.Time) TimeJson

+ func (t *TimeJson) MarshalJSON() ([]byte, error)

+ func (t *TimeJson) SetLayout(layout string)

+ func (t *TimeJson) SetTimezone(tz string)

+ func (t *TimeJson) String() string

+ func (t *TimeJson) Time() time.Time

+ type User struct

+ AuthPassphrase string

+ AuthType AuthType

+ EngineID string

+ NoAuth bool

+ PrivacyPassphrase string

+ PrivacyProtocol PrivacyProtocol

+ RequirePrivacy bool

+ Username string

+ func (u User) SecurityLevel() string

+ type Value struct

+ MIBName string

+ NativeType string

+ OID string

+ Type ValueType

+ Value any

+ ValueDetail ValueDetail

+ func (v Value) HasOIDPrefix(prefix string) bool

+ func (v Value) SnmpCmd() (cmd []string)

+ type ValueDetail struct

+ Hex *string

+ Raw any

+ type ValueType int8

+ const TypeBits

+ const TypeBytes

+ const TypeDateAndTime

+ const TypeDuration

+ const TypeEnum

+ const TypeInteger

+ const TypeIpAddress

+ const TypeOID

+ const TypeString

+ const TypeUnknown

+ func (v *ValueType) FromMIB(text string) error

+ func (v *ValueType) FromSNMP(text string) error

+ func (v *ValueType) MarshalJSON() ([]byte, error)

+ func (v *ValueType) Parse(text string) (any, ValueDetail, error)

+ func (v *ValueType) String() string