Add context to GetEndpoints

Fixes gopcua#402
axlev · Mar 26, 2021 · 4ab5e03 · 4ab5e03
1 parent e8807bb
commit 4ab5e03
Show file tree

Hide file tree

Showing 8 changed files with 10 additions and 9 deletions.
diff --git a/client.go b/client.go
@@ -26,9 +26,9 @@ import (
 )
 
 // GetEndpoints returns the available endpoint descriptions for the server.
-func GetEndpoints(endpoint string) ([]*ua.EndpointDescription, error) {
+func GetEndpoints(ctx context.Context, endpoint string) ([]*ua.EndpointDescription, error) {
 	c := NewClient(endpoint, AutoReconnect(false))
-	if err := c.Dial(context.Background()); err != nil {
+	if err := c.Dial(ctx); err != nil {
 		return nil, err
 	}
 	defer c.Close()

diff --git a/examples/crypto/crypto.go b/examples/crypto/crypto.go
@@ -46,7 +46,7 @@ func main() {
 	ctx := context.Background()
 
 	// Get a list of the endpoints for our target server
-	endpoints, err := opcua.GetEndpoints(*endpoint)
+	endpoints, err := opcua.GetEndpoints(ctx, *endpoint)
 	if err != nil {
 		log.Fatal(err)
 	}

diff --git a/examples/datetime/datetime.go b/examples/datetime/datetime.go
@@ -27,7 +27,7 @@ func main() {
 
 	ctx := context.Background()
 
-	endpoints, err := opcua.GetEndpoints(*endpoint)
+	endpoints, err := opcua.GetEndpoints(ctx, *endpoint)
 	if err != nil {
 		log.Fatal(err)
 	}

diff --git a/examples/endpoints/endpoints.go b/examples/endpoints/endpoints.go
@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"flag"
 	"log"
 
@@ -19,7 +20,7 @@ func main() {
 	flag.Parse()
 	log.SetFlags(0)
 
-	eps, err := opcua.GetEndpoints(*endpoint)
+	eps, err := opcua.GetEndpoints(context.Background(), *endpoint)
 	if err != nil {
 		log.Fatal(err)
 	}

diff --git a/examples/monitor/monitor.go b/examples/monitor/monitor.go
@@ -47,7 +47,7 @@ func main() {
 		cancel()
 	}()
 
-	endpoints, err := opcua.GetEndpoints(*endpoint)
+	endpoints, err := opcua.GetEndpoints(ctx, *endpoint)
 	if err != nil {
 		log.Fatal(err)
 	}

diff --git a/examples/subscribe/subscribe.go b/examples/subscribe/subscribe.go
@@ -43,7 +43,7 @@ func main() {
 	ctx, cancel := context.WithTimeout(context.Background(), d)
 	defer cancel()
 
-	endpoints, err := opcua.GetEndpoints(*endpoint)
+	endpoints, err := opcua.GetEndpoints(ctx, *endpoint)
 	if err != nil {
 		log.Fatal(err)
 	}

diff --git a/examples/trigger/trigger.go b/examples/trigger/trigger.go
@@ -44,7 +44,7 @@ func main() {
 	ctx, cancel := context.WithTimeout(context.Background(), d)
 	defer cancel()
 
-	endpoints, err := opcua.GetEndpoints(*endpoint)
+	endpoints, err := opcua.GetEndpoints(ctx, *endpoint)
 	if err != nil {
 		log.Fatal(err)
 	}

diff --git a/examples/udt/udt.go b/examples/udt/udt.go
@@ -35,7 +35,7 @@ func main() {
 
 	ctx := context.Background()
 
-	endpoints, err := opcua.GetEndpoints(*endpoint)
+	endpoints, err := opcua.GetEndpoints(ctx, *endpoint)
 	if err != nil {
 		log.Fatal(err)
 	}