snmp

type DataType int

type Handler interface {
	// NewMessage is called when a trap/inform message has been received.
	// pdu defines the content of the message.
	// isInform defines the message type.
	// sourceAddr is the address which originated the message
	// Note that a NewMessage invocation will block the receipt of other messages.
	// In the case of an inform message, it will also block the transmission of the acknowledgement message.
	// It is the responsibility of the Handler implementation to return in a timely fashion.
	NewMessage(pdu *PDU, isInform bool, sourceAddr net.Addr)
}

type PDU struct {
	RequestID int32
	// Non-zero used to indicate that an exception occurred to prevent the processing of the request
	Error int
	// If Error is non-zero, identifies which variable binding in the list caused the exception
	ErrorIndex  int
	VarbindList []Varbind
}

type Server io.Closer

type ServerFactory interface {
	// NewServer instantiates an SNMP Trap/Inform server.
	NewServer(ctx context.Context, handler Handler, opts ...ServerOption) (Server, error)
}

type ServerHooks struct {
	// StartListening is called when the server is about to start listening for messages.
	StartListening func(addr net.Addr)

	// StopListening is called when the server has stopped listening.
	StopListening func(addr net.Addr, err error)

	// Error is called after an error condition has been detected.
	Error func(config *serverConfig, err error)

	// WriteComplete is called after a packet has been written
	WriteComplete func(config *serverConfig, addr net.Addr, output []byte, err error)

	// ReadComplete is called after a read has completed
	ReadComplete func(config *serverConfig, addr net.Addr, input []byte, err error)
}

type ServerOption func(*serverConfig)

type Session interface {
	// Issues an SNMP GET request for the specified oids.
	// Get request processing is described at https://tools.ietf.org/html/rfc1905#section-4.2.1.
	Get(ctx context.Context, oids []string) (*PDU, error)

	// Issues an SNMP GET NEXT request for the specified oids.
	// Get Bext request processing is described athttps://tools.ietf.org/html/rfc1905#section-4.2.2.
	GetNext(ctx context.Context, oids []string) (*PDU, error)

	// Issues an SNMP GET BULK request for the specified oids.
	// Get Bulk request processing is described at https://tools.ietf.org/html/rfc1905#section-4.2.3
	GetBulk(ctx context.Context, oids []string, nonRepeaters int, maxRepetitions int) (*PDU, error)

	// Issues SNMP GET NEXT requests starting from the specified root oid, invoking the function walker for each
	// variable that is a descendant of the root oid.
	Walk(ctx context.Context, rootOid string, walker Walker) error

	// Issues SNMP GET BULK requests starting from the specified root oid, invoking the function walker for each
	// variable that is a descendant of the root oid.
	BulkWalk(ctx context.Context, rootOid string, maxRepetitions int, walker Walker) error

	// Embed standard Close()
	io.Closer
}

type SessionConfig struct {
	// contains filtered or unexported fields
}

type SessionFactory interface {
	// NewSession instantiates an SNMP session for managing the target device.
	NewSession(ctx context.Context, target string, opts ...SessionOption) (Session, error)
}

type SessionOption func(*SessionConfig)

type SessionTrace struct {
	// ConnectStart is called before establishing a network connection to an agent.
	ConnectStart func(config *SessionConfig)

	// ConnectDone is called when the network connection attempt completes, with err indicating
	// whether it was successful.
	ConnectDone func(config *SessionConfig, err error, d time.Duration)

	// Error is called after an error condition has been detected.
	Error func(location string, config *SessionConfig, err error)

	// WriteDone is called after a packet has been written
	WriteDone func(config *SessionConfig, output []byte, err error, d time.Duration)

	// ReadDone is called after a read has completed
	ReadDone func(config *SessionConfig, input []byte, err error, d time.Duration)
}

type TypedValue struct {
	Type  DataType
	Value interface{}
}

type Varbind struct {
	OID        asn1.ObjectIdentifier
	TypedValue *TypedValue
}

type Version int

type Walker func(vb *Varbind) error