Support equipment responding from different source address (prometheu…

…s#702) Closes prometheus#699. Signed-off-by: Torbjörn Lönnemark <[email protected]>
stephrdev · Mar 21, 2022 · 1bbd025 · 1bbd025
1 parent 0b5fa5a
commit 1bbd025
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 10 deletions.
diff --git a/collector/collector.go b/collector/collector.go
@@ -122,6 +122,7 @@ func ScrapeTarget(ctx context.Context, target string, config *config.Module, log
 	snmp.MaxRepetitions = config.WalkParams.MaxRepetitions
 	snmp.Retries = config.WalkParams.Retries
 	snmp.Timeout = config.WalkParams.Timeout
+	snmp.UseUnconnectedUDPSocket = config.WalkParams.UseUnconnectedUDPSocket
 
 	var sent time.Time
 	snmp.OnSent = func(x *gosnmp.GoSNMP) {

diff --git a/config/config.go b/config/config.go
@@ -44,11 +44,12 @@ var (
 		PrivProtocol:  "DES",
 	}
 	DefaultWalkParams = WalkParams{
-		Version:        2,
-		MaxRepetitions: 25,
-		Retries:        3,
-		Timeout:        time.Second * 5,
-		Auth:           DefaultAuth,
+		Version:                 2,
+		MaxRepetitions:          25,
+		Retries:                 3,
+		Timeout:                 time.Second * 5,
+		Auth:                    DefaultAuth,
+		UseUnconnectedUDPSocket: false,
 	}
 	DefaultModule = Module{
 		WalkParams: DefaultWalkParams,
@@ -62,11 +63,12 @@ var (
 type Config map[string]*Module
 
 type WalkParams struct {
-	Version        int           `yaml:"version,omitempty"`
-	MaxRepetitions uint32        `yaml:"max_repetitions,omitempty"`
-	Retries        int           `yaml:"retries,omitempty"`
-	Timeout        time.Duration `yaml:"timeout,omitempty"`
-	Auth           Auth          `yaml:"auth,omitempty"`
+	Version                 int           `yaml:"version,omitempty"`
+	MaxRepetitions          uint32        `yaml:"max_repetitions,omitempty"`
+	Retries                 int           `yaml:"retries,omitempty"`
+	Timeout                 time.Duration `yaml:"timeout,omitempty"`
+	Auth                    Auth          `yaml:"auth,omitempty"`
+	UseUnconnectedUDPSocket bool          `yaml:"use_unconnected_udp_socket,omitempty"`
 }
 
 type Module struct {